mocker.patch("charm.KubernetesServicePatch", lambda x, y: None)
harness = Harness(OsmNbiCharm)
harness.begin()
+ harness.container_pebble_ready(container_name)
yield harness
harness.cleanup()
assert type(harness.charm.unit.status) == BlockedStatus
assert all(
relation in harness.charm.unit.status.message
- for relation in ["mongodb", "kafka", "prometheus", "keystone"]
+ for relation in ["mongodb", "kafka", "prometheus", "keystone", "temporal"]
)
check_service_active(container, service_name)
+def test_nbi_relation_joined(harness: Harness):
+ harness.set_leader(True)
+ _add_relations(harness)
+ relation_id = harness.add_relation("nbi", "ng-ui")
+ harness.add_relation_unit(relation_id, "ng-ui/0")
+ relation_data = harness.get_relation_data(relation_id, harness.charm.app.name)
+ assert harness.charm.unit.status == ActiveStatus()
+ assert relation_data == {"host": harness.charm.app.name, "port": "9999"}
+
+
def _add_relations(harness: Harness):
relation_ids = []
# Add mongo relation
relation_id = harness.add_relation("mongodb", "mongodb")
harness.add_relation_unit(relation_id, "mongodb/0")
harness.update_relation_data(
- relation_id, "mongodb/0", {"connection_string": "mongodb://:1234"}
+ relation_id,
+ "mongodb",
+ {"uris": "mongodb://:1234", "username": "user", "password": "password"},
)
relation_ids.append(relation_id)
# Add kafka relation
relation_id = harness.add_relation("kafka", "kafka")
harness.add_relation_unit(relation_id, "kafka/0")
- harness.update_relation_data(relation_id, "kafka", {"host": "kafka", "port": 9092})
+ harness.update_relation_data(relation_id, "kafka", {"host": "kafka", "port": "9092"})
relation_ids.append(relation_id)
# Add prometheus relation
relation_id = harness.add_relation("prometheus", "prometheus")
harness.add_relation_unit(relation_id, "prometheus/0")
harness.update_relation_data(
- relation_id, "prometheus", {"hostname": "prometheus", "port": 9090}
+ relation_id, "prometheus", {"hostname": "prometheus", "port": "9090"}
)
relation_ids.append(relation_id)
# Add keystone relation
},
)
relation_ids.append(relation_id)
+ # Add temporal relation
+ relation_id = harness.add_relation("temporal", "temporal")
+ harness.add_relation_unit(relation_id, "temporal/0")
+ harness.update_relation_data(relation_id, "temporal", {"host": "temporal", "port": "7233"})
+ relation_ids.append(relation_id)
return relation_ids