diff --git a/libs/common/src/config/tuya.config.ts b/libs/common/src/config/tuya.config.ts index 4745c2e..ca4dd73 100644 --- a/libs/common/src/config/tuya.config.ts +++ b/libs/common/src/config/tuya.config.ts @@ -5,5 +5,7 @@ export default registerAs( (): Record => ({ TUYA_ACCESS_ID: process.env.TUYA_ACCESS_ID, TUYA_ACCESS_KEY: process.env.TUYA_ACCESS_KEY, + TRUN_ON_TUYA_SOCKET: + process.env.TRUN_ON_TUYA_SOCKET === 'true' ? true : false, }), ); diff --git a/libs/common/src/helper/services/tuya.web.socket.service.ts b/libs/common/src/helper/services/tuya.web.socket.service.ts index a0358c7..cca7fc6 100644 --- a/libs/common/src/helper/services/tuya.web.socket.service.ts +++ b/libs/common/src/helper/services/tuya.web.socket.service.ts @@ -22,11 +22,13 @@ export class TuyaWebSocketService { maxRetryTimes: 100, }); - // Set up event handlers - this.setupEventHandlers(); + if (this.configService.get('tuya-config.TRUN_ON_TUYA_SOCKET')) { + // Set up event handlers + this.setupEventHandlers(); - // Start receiving messages - this.client.start(); + // Start receiving messages + this.client.start(); + } } private setupEventHandlers() {