Delete "theengs/internal/" condition

theengs · Jul 3, 2024 · b4dfc94 · b4dfc94
1 parent f352339
commit b4dfc94
Showing 1 changed file with 19 additions and 21 deletions.
diff --git a/TheengsGateway/ble_gateway.py b/TheengsGateway/ble_gateway.py
@@ -227,28 +227,26 @@ def subscribe(self, sub_topic: str) -> None:
         """Subscribe to MQTT topic <sub_topic>."""
 
         def on_message(client, userdata, msg) -> None:  # noqa: ANN001,ARG001
-            # Theengs internal
-            if "theengs/internal/" in msg.topic:
-                # Evaluate trackersync messages
-                if msg.topic == "theengs/internal/trackersync":
-                    msg_json = json.loads(msg.payload)
-                    logger.debug("trackersync message: %s", msg_json)
-
-                    if (
-                        msg_json["gatewayid"] != self.configuration["gateway_id"]
-                        and msg_json["tracker"] in self.discovered_trackers
-                        and self.discovered_trackers[msg_json["tracker"]].time != 0
-                    ):
-                        self.discovered_trackers[msg_json["tracker"]].time = 0
-                        logger.debug(
-                            "Tracker %s disassociated by gateway %s",
-                            msg_json["tracker"],
-                            msg_json["gatewayid"],
-                        )
+            # Evaluate trackersync messages
+            if msg.topic == "theengs/internal/trackersync":
+                msg_json = json.loads(msg.payload)
+                logger.debug("trackersync message: %s", msg_json)
 
-                        logger.debug(
-                            "[DIS] Discovered Trackers: %s", self.discovered_trackers
-                        )
+                if (
+                    msg_json["gatewayid"] != self.configuration["gateway_id"]
+                    and msg_json["tracker"] in self.discovered_trackers
+                    and self.discovered_trackers[msg_json["tracker"]].time != 0
+                ):
+                    self.discovered_trackers[msg_json["tracker"]].time = 0
+                    logger.debug(
+                        "Tracker %s disassociated by gateway %s",
+                        msg_json["tracker"],
+                        msg_json["gatewayid"],
+                    )
+
+                    logger.debug(
+                        "[DIS] Discovered Trackers: %s", self.discovered_trackers
+                    )
             else:
                 logger.info(
                     "Received `%s` from `%s` topic",