Fixed MQTT connection issue (error: 5)

README.md

@@ -77,6 +77,10 @@ Please use GitHub issues for this.
 
 ## Changelog
 
+### 1.6.2 (2022-02-05)
+
+* (bropat) Fixed MQTT connection issue (error: 5)
+
 ### 1.6.1 (2022-02-05)
 
 * (bropat) Fixed small issue on driver upgrade of persistence data (has no impact; error entry in log on first startup)

package.json

@@ -1,6 +1,6 @@
 {
   "name": "eufy-security-client",
-  "version": "1.6.1",
+  "version": "1.6.2",
   "description": "Client to comunicate with Eufy-Security devices",
   "author": {
     "name": "bropat",

src/eufysecurity.ts

@@ -622,7 +622,7 @@ export class EufySecurity extends TypedEmitter<EufySecurityEvents> {
 
         const loginData = this.api.getPersistentData();
         if (loginData) {
-            this.mqttService.connect(loginData.user_id, this.persistentData.openudid, this.persistentData.api_base);
+            this.mqttService.connect(loginData.user_id, this.persistentData.openudid, this.persistentData.api_base, loginData.email);
         } else {
             this.log.warn("No login data recevied to initialize MQTT connection...");
         }
@@ -761,6 +761,10 @@ export class EufySecurity extends TypedEmitter<EufySecurityEvents> {
         return this.pushService.isConnected();
     }
 
+    public isMQTTConnected(): boolean {
+        return this.mqttService.isConnected();
+    }
+
     public isConnected(): boolean {
         return this.connected;
     }

src/mqtt/service.ts

@@ -67,7 +67,7 @@ export class MQTTService extends TypedEmitter<MQTTServiceEvents> {
         }
     }
 
-    public connect(clientID: string, androidID: string, apiBase: string): void {
+    public connect(clientID: string, androidID: string, apiBase: string, email: string): void {
         if (!this.connected && !this.connecting) {
             this.connecting = true;
             this.client = mqtt.connect(this.getMQTTBrokerUrl(apiBase), {
@@ -77,7 +77,7 @@ export class MQTTService extends TypedEmitter<MQTTServiceEvents> {
                 resubscribe: true,
                 port: 8789,
                 username: this.USERNAME_FORMAT.replace("<user_id>", clientID),
-                password: "[email protected]",
+                password: email,
                 ca: fse.readFileSync(path.join(__dirname, "./mqtt-eufy.crt")),
                 clientId: this.CLIENT_ID_FORMAT.replace("<user_id>", clientID).replace("<android_id>", androidID)
             });
@@ -101,6 +101,8 @@ export class MQTTService extends TypedEmitter<MQTTServiceEvents> {
             this.client.on("error", (error) => {
                 this.connecting = false;
                 this.log.error("MQTT Error", error);
+                if ((error as any).code === 5)
+                    this.client?.end();
             });
             this.client.on("message", (topic, message, _packet) => {
                 if (topic.includes("smart_lock")) {
@@ -143,6 +145,7 @@ export class MQTTService extends TypedEmitter<MQTTServiceEvents> {
         if (this.connected) {
             this.client?.end(true);
             this.connected = false;
+            this.connecting = false;
         }
     }