fix: send mqtt message to cerebrum where edge site id changed (#203)

Co-authored-by: 99cloud <qiao.lei@99cloud.net>
open-v2x · Apr 23, 2023 · a35eafc · a35eafc
1 parent a56fea1
commit a35eafc
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/dandelion/api/api_v1/endpoints/system_configs.py b/dandelion/api/api_v1/endpoints/system_configs.py
@@ -23,7 +23,7 @@
 from dandelion import crud, models, schemas
 from dandelion.api import deps
 from dandelion.api.deps import OpenV2XHTTPException as HTTPException
-from dandelion.mqtt import cloud_server as mqtt_cloud_server
+from dandelion.mqtt import cloud_server as mqtt_cloud_server, topic
 
 router = APIRouter()
 CONF: cfg = cfg.CONF
@@ -67,6 +67,7 @@ def create(
             raise HTTPException(
                 status_code=status.HTTP_400_BAD_REQUEST, detail="Cloud MQTT Connection failed"
             )
+    mqtt_cloud_server.MQTT_CLIENT.publish(topic=topic.V2X_EDGE_SITE_CHANGE)
 
     return system_config.to_dict()
 

diff --git a/dandelion/mqtt/topic.py b/dandelion/mqtt/topic.py
@@ -45,6 +45,8 @@
 V2X_RSU_PLUS_SSW_DOWN = "V2X/RSU/+/SSW/DOWN"
 V2X_RSU_PIP_CFG = "V2X/RSU/PIP/CFG"
 
+V2X_EDGE_SITE_CHANGE = "V2X/EDGE/SITE/CHANGE"
+
 
 def v2x_rsu_map_down(rsu_id):
     return f"V2X/RSU/{rsu_id}/MAP/DOWN"