From 8cf8a2da902a7dc1fabaf1e878006f00632cc9b6 Mon Sep 17 00:00:00 2001 From: faris Aljohari <83524184+farisaljohari@users.noreply.github.com> Date: Sun, 2 Jun 2024 19:30:51 +0300 Subject: [PATCH] Add conditional check for Tuya web socket service --- libs/common/src/config/tuya.config.ts | 2 ++ .../src/helper/services/tuya.web.socket.service.ts | 10 ++++++---- 2 files changed, 8 insertions(+), 4 deletions(-) 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() {