mqtt: fix erroneous error

.gitmodules

@@ -19,3 +19,6 @@
 [submodule "external/sort"]
 	path = external/sort
 	url = git@github.com:koush/sort.git
+[submodule "external/scrypted-ffmpeg"]
+	path = external/scrypted-ffmpeg
+	url = git@github.com:koush/scrypted-ffmpeg

plugins/mqtt/package-lock.json

@@ -1,12 +1,12 @@
 {
    "name": "@scrypted/mqtt",
-   "version": "0.0.32",
+   "version": "0.0.34",
    "lockfileVersion": 2,
    "requires": true,
    "packages": {
       "": {
          "name": "@scrypted/mqtt",
-         "version": "0.0.32",
+         "version": "0.0.34",
          "dependencies": {
             "@types/node": "^16.6.1",
             "aedes": "^0.46.1",

plugins/mqtt/package.json

@@ -38,5 +38,5 @@
       "@scrypted/sdk": "file:../../sdk",
       "@types/nunjucks": "^3.2.0"
    },
-   "version": "0.0.32"
+   "version": "0.0.34"
 }

plugins/mqtt/src/api/mqtt-device-base.ts

@@ -61,11 +61,8 @@ export class MqttDeviceBase extends ScryptedDeviceBase implements Settings {
         });
         client.setMaxListeners(Infinity);
 
-        client.on('connect', err => {
-            if (err) {
-                this.console.error('error subscribing to mqtt', err);
-                return;
-            }
+        client.on('connect', packet => {
+            this.console.log('connected to mqtt', packet);
         })
         
         return this.client;

plugins/mqtt/src/main.ts

@@ -295,6 +295,8 @@ class MqttPublisherMixin extends SettingsMixinDeviceBase<any> {
     release() {
         this.client?.end();
         this.client = undefined;
+        this.listener?.removeListener();
+        this.listener = undefined;
     }
 }