rename mqtt module

linomp · Mar 28, 2024 · d5a6a4c · d5a6a4c
1 parent f131004
commit d5a6a4c
Show file tree

Hide file tree

Showing 4 changed files with 9 additions and 6 deletions.
diff --git a/mvp/server/mqtt/__init__.py → mvp/server/messaging/__init__.py b/mvp/server/mqtt/__init__.py → mvp/server/messaging/__init__.py
diff --git a/mvp/server/mqtt/example.py → mvp/server/messaging/example.py b/mvp/server/mqtt/example.py → mvp/server/messaging/example.py
diff --git a/mvp/server/mqtt/client.py → mvp/server/messaging/mqtt_client.py b/mvp/server/mqtt/client.py → mvp/server/messaging/mqtt_client.py
@@ -26,11 +26,9 @@ class MqttClient:
     __client__: paho.Client = None
 
     def __init__(self):
-
-        # TODO refactor this dirty hack!!
         if MQTT_USER is None:
-            return 
-            
+            return
+
         client = paho.Client(client_id="pdmgame_server", userdata=None, protocol=paho.MQTTv5,
                              callback_api_version=CallbackAPIVersion.VERSION2)
         client.on_connect = on_connect
@@ -48,4 +46,9 @@ def __init__(self):
         self.__client__ = client
 
     def publish_parameter(self, client_uid: str, parameter_name: str, payload: float):
-        self.__client__.publish(f"{MQTT_TOPIC_PREFIX}/{client_uid}/{parameter_name}", payload=payload, qos=1)
+        if self.__client__ is None:
+            return
+
+        self.__client__.publish(
+            f"{MQTT_TOPIC_PREFIX}/{client_uid}/{parameter_name}", payload=payload, qos=1
+        )
diff --git a/mvp/server/routers/sessions.py b/mvp/server/routers/sessions.py
@@ -8,7 +8,7 @@
 from mvp.server.core.game.GameMetrics import GameMetrics
 from mvp.server.core.game.GameSession import GameSession
 from mvp.server.core.game.GameSessionDTO import GameSessionDTO
-from mvp.server.mqtt.client import MqttClient
+from mvp.server.messaging.mqtt_client import MqttClient
 
 sessions: dict[str, GameSession] = {}
 game_metrics = GameMetrics()