From 53fbf42f0049d7afb7bf2aaaaef90ec434adcf99 Mon Sep 17 00:00:00 2001
From: Koushik Dutta <koush@Koushik-MacBook.local>
Date: Wed, 7 Sep 2022 11:00:43 -0500
Subject: [PATCH] mqtt: fix invalid url busting settings

---
 plugins/mqtt/package-lock.json | 6 +++---
 plugins/mqtt/package.json      | 2 +-
 plugins/mqtt/src/main.ts       | 8 ++++++--
 3 files changed, 10 insertions(+), 6 deletions(-)

diff --git a/plugins/mqtt/package-lock.json b/plugins/mqtt/package-lock.json
index 036247cb9..3150d3e68 100644
--- a/plugins/mqtt/package-lock.json
+++ b/plugins/mqtt/package-lock.json
@@ -1,12 +1,12 @@
 {
    "name": "@scrypted/mqtt",
-   "version": "0.0.54",
+   "version": "0.0.55",
    "lockfileVersion": 2,
    "requires": true,
    "packages": {
       "": {
          "name": "@scrypted/mqtt",
-         "version": "0.0.54",
+         "version": "0.0.55",
          "dependencies": {
             "@types/node": "^16.6.1",
             "aedes": "^0.46.1",
@@ -39,7 +39,7 @@
       },
       "../../sdk": {
          "name": "@scrypted/sdk",
-         "version": "0.0.202",
+         "version": "0.0.206",
          "dev": true,
          "license": "ISC",
          "dependencies": {
diff --git a/plugins/mqtt/package.json b/plugins/mqtt/package.json
index 6c6634481..627c7062f 100644
--- a/plugins/mqtt/package.json
+++ b/plugins/mqtt/package.json
@@ -41,5 +41,5 @@
       "@scrypted/common": "file:../../common",
       "@types/nunjucks": "^3.2.0"
    },
-   "version": "0.0.54"
+   "version": "0.0.55"
 }
diff --git a/plugins/mqtt/src/main.ts b/plugins/mqtt/src/main.ts
index 7d2e1a2f4..e1405aa05 100644
--- a/plugins/mqtt/src/main.ts
+++ b/plugins/mqtt/src/main.ts
@@ -171,7 +171,12 @@ class MqttPublisherMixin extends SettingsMixinDeviceBase<any> {
         super(options);
 
         this.device = systemManager.getDeviceById(this.id);
-        this.connectClient();
+        try {
+            this.connectClient();
+        }
+        catch (e) {
+            this.console.error('error while connecting client.', e);
+        }
 
         this.listener = this.device.listen(undefined, (eventSource, eventDetails, eventData) => {
             const { property } = eventDetails;
@@ -224,7 +229,6 @@ class MqttPublisherMixin extends SettingsMixinDeviceBase<any> {
         else {
             this.storage.setItem(key, value.toString());
         }
-        this.client.end();
         this.connectClient();
     }