+ self._apply_spec()
+
+ def on_kafka_relation_changed(self, event):
+ kafka_host = event.relation.data[event.unit].get("host")
+ kafka_port = event.relation.data[event.unit].get("port")
+ if kafka_host and self.state.kafka_host != kafka_host:
+ self.state.kafka_host = kafka_host
+ if kafka_port and self.state.kafka_port != kafka_port:
+ self.state.kafka_port = kafka_port
+ self._apply_spec()
+
+ def on_mongo_relation_changed(self, event):
+ mongodb_uri = event.relation.data[event.unit].get("connection_string")
+ if mongodb_uri and self.state.mongodb_uri != mongodb_uri:
+ self.state.mongodb_uri = mongodb_uri
+ self._apply_spec()