fix(mqtt): Only migrate HAss topics if enabled (#912)

Hypfer · May 10, 2021 · eb2edaf · eb2edaf
1 parent a05dcfe
commit eb2edaf
Showing 1 changed file with 8 additions and 5 deletions.
diff --git a/lib/mqtt/MqttController.js b/lib/mqtt/MqttController.js
@@ -302,7 +302,9 @@ class MqttController {
                     await HassAnchor.getTopicReference(HassAnchor.REFERENCE.AVAILABILITY).post(this.stateTopic);
 
                     // TODO: temporary, remove!
-                    await this.asyncClient.subscribe(this.getHassMigrationTopics());
+                    if (this.hassEnabled) {
+                        await this.asyncClient.subscribe(this.getHassMigrationTopics());
+                    }
 
                     await this.robotHandle.configure();
                     if (this.hassEnabled) {
@@ -319,11 +321,12 @@ class MqttController {
 
             this.client.on("message", (topic, message) => {
                 // TODO: temporary, remove!
-                if (topic.startsWith(this.hassController.autoconfPrefix + "/") && message.toString().length > 0) {
-                    this.migrateHass(topic).then();
-                    return;
+                if (this.hassEnabled) {
+                    if (topic.startsWith(this.hassController.autoconfPrefix + "/") && message.toString().length > 0) {
+                        this.migrateHass(topic).then();
+                        return;
+                    }
                 }
-
                 if (!Object.prototype.hasOwnProperty.call(this.subscriptions, topic)) {
                     return;
                 }