fix: ZBOSS: fixed port reconnection processing during RESET (#1289)

Koenkk · Jan 10, 2025 · 801212f · 801212f
1 parent eb5b89c
commit 801212f
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 3 deletions.
diff --git a/src/adapter/zboss/uart.ts b/src/adapter/zboss/uart.ts
@@ -38,6 +38,7 @@ export class ZBOSSUart extends EventEmitter {
         this.socketPort = undefined;
         this.writer = new ZBOSSWriter();
         this.reader = new ZBOSSReader();
+        this.reader.on('data', this.onPackage.bind(this));
         this.queue = new Queue(1);
         this.waitress = new Waitress<number, number>(this.waitressValidator, this.waitressTimeoutFormatter);
     }
@@ -123,7 +124,6 @@ export class ZBOSSUart extends EventEmitter {
             this.writer.pipe(this.serialPort);
 
             this.serialPort.pipe(this.reader);
-            this.reader.on('data', this.onPackage.bind(this));
 
             try {
                 await this.serialPort.asyncOpen();
@@ -147,7 +147,6 @@ export class ZBOSSUart extends EventEmitter {
             this.writer.pipe(this.socketPort);
 
             this.socketPort.pipe(this.reader);
-            this.reader.on('data', this.onPackage.bind(this));
 
             return await new Promise((resolve, reject): void => {
                 const openError = async (err: Error): Promise<void> => {
@@ -311,7 +310,9 @@ export class ZBOSSUart extends EventEmitter {
                     const waiter = this.waitFor(nextSeq);
                     this.writeBuffer(data);
                     logger.debug(`-?- waiting (${nextSeq})`, NS);
-                    await waiter.start().promise;
+                    if (!this.inReset) {
+                        await waiter.start().promise;
+                    }
                     logger.debug(`-+- waiting (${nextSeq}) success`, NS);
                 } else {
                     this.writeBuffer(data);

diff --git a/src/controller/controller.ts b/src/controller/controller.ts
@@ -179,6 +179,7 @@ export class Controller extends events.EventEmitter<ControllerEventMap> {
             for (const device of Device.allIterator()) {
                 device.removeFromDatabase();
             }
+            Device.resetCache();
         }
 
         if (startResult === 'reset' || (this.options.backupPath && !fs.existsSync(this.options.backupPath))) {