[ skip ci ] use mosquitto broker for sub topic functionality but for …

…crucial system control pub message directly to the venusOS device.

lib/clients/mqtt_client_factory.py

@@ -4,7 +4,7 @@
 import random
 import paho.mqtt.client as mqtt
 
-from lib.constants import retrieve_mqtt_subcribed_topics, logging, DzEndpoints, cerboGxEndpoint, systemId0
+from lib.constants import retrieve_mqtt_subcribed_topics, logging, DzEndpoints, mosquittoEndpoint, systemId0
 from lib.domoticz_updater import domoticz_update
 
 class VictronClient:
@@ -18,7 +18,7 @@ def __new__(cls, *args, **kwargs):
             cls._instance = super(VictronClient, cls).__new__(cls)
         return cls._instance
 
-    def __init__(self, client_id=f"victron_client-{random.randint(100000, 999999)}", host=cerboGxEndpoint, keepalive=45, port=1883):
+    def __init__(self, client_id=f"victron_client-{random.randint(100000, 999999)}", host=mosquittoEndpoint, keepalive=45, port=1883):
         # To prevent re-initialization if __init__ is called again
         if hasattr(self, '_initialized') and self._initialized:
             return

lib/constants.py

@@ -15,6 +15,7 @@ def dotenv_config(env_variable):
 Basig Configuration
 """
 cerboGxEndpoint = dotenv_config('CERBOGX_IP')
+mosquittoEndpoint = dotenv_config('MOSQUITTO_IP')
 systemId0 = dotenv_config('VRM_PORTAL_ID')
 dzEndpoint = dotenv_config('DZ_URL_PREFIX')
 PushOverConfig = {"id": dotenv_config('PO_USER_ID'), "key": dotenv_config('PO_API_KEY')}

lib/helpers/__init__.py

@@ -6,7 +6,7 @@
 from math import floor, ceil
 
 from lib.helpers.base7_math import *
-from lib.constants import Topics, logging, cerboGxEndpoint
+from lib.constants import Topics, logging, mosquittoEndpoint
 
 
 def publish_message(topic, message=None, qos=0, retain=False, payload=None) -> None:
@@ -53,12 +53,12 @@ def on_message(client, _userdata, msg):
         completed = True
 
     # Initialize a new temporary MQTT client
-    temp_client = mqtt.Client()
+    temp_client = mqtt.Client(client_id="helper-message-retrieval-client")
     temp_client.on_connect = on_connect
     temp_client.on_message = on_message
 
     # Connect to the broker
-    temp_client.connect(cerboGxEndpoint, 1883, 60)
+    temp_client.connect(mosquittoEndpoint, 1883, 60)
     temp_client.loop_start()
 
     # Wait for the message to arrive or for the timeout