trackersync_topic

TheengsGateway/ble_gateway.py

@@ -153,7 +153,7 @@ def on_connect(
                 )
                 self.subscribe(self.configuration["subscribe_topic"])
                 if self.configuration["enable_multi_gtw_sync"]:
-                    self.subscribe("home/internal/trackersync")
+                    self.subscribe(self.configuration["trackersync_topic"])
             else:
                 logger.error(
                     "Failed to connect to MQTT broker %s:%d reason code: %s",
@@ -231,7 +231,7 @@ def subscribe(self, sub_topic: str) -> None:
         def on_message(client, userdata, msg) -> None:  # noqa: ANN001,ARG001
             # Evaluate trackersync messages
             if (
-                msg.topic == "home/internal/trackersync"
+                msg.topic == self.configuration["trackersync_topic"]
                 and self.configuration["enable_multi_gtw_sync"]
             ):
                 msg_json = json.loads(msg.payload)
@@ -657,7 +657,7 @@ def publish_json(
                 )
                 self.publish(
                     message,
-                    "home/internal/trackersync",
+                    self.configuration["trackersync_topic"],
                 )
 
                 logger.debug("[GP]  Discovered Trackers: %s", self.discovered_trackers)

TheengsGateway/config.py

@@ -52,6 +52,7 @@
     "whitelist": [],
     "blacklist": [],
     "enable_multi_gtw_sync": 1,
+    "trackersync_topic": "home/internal/trackersync",
 }
 
 
@@ -275,6 +276,12 @@ def parse_args() -> argparse.Namespace:
         type=int,
         help="Disable (0) or enable (1) to use tracker and closest control devices sync across Theengs Gateway gateways and OpenMQTTGateway (default: 1)",  # noqa: E501
     )
+    parser.add_argument(
+        "-tt",
+        "--trackersync_topic",
+        type=str,
+        help="Internal trackersync publish topic",
+    )
     return parser.parse_args()
 
 

TheengsGateway/discovery.py

@@ -284,7 +284,7 @@ def copy_pub_device(self, device: dict) -> dict:
                 )
                 self.publish(
                     message,
-                    "home/internal/trackersync",
+                    self.configuration["trackersync_topic"],
                 )
 
                 logger.debug("      Discovered Trackers: %s", self.discovered_trackers)