added support for refreshing (ping) devices

README.md

@@ -84,7 +84,8 @@ Basic example of the configuration (config.json) file.
 {
   "server": {
     "port": 3000,
-    "deviceReconnectWait": 5000
+    "deviceReconnectWait": 5000,
+    "refreshTime": 60000
   },
   "webhooks": ["http://localhost:4321/webhook"],
   "devices": [

config.example.json

@@ -1,7 +1,8 @@
 {
   "server": {
     "port": 3000,
-    "deviceReconnectWait": 5000
+    "deviceReconnectWait": 5000,
+    "refreshTime": 60000
   },
   "webhooks": ["http://localhost:4321/webhook"],
   "devices": [

src/active-device.ts

@@ -64,6 +64,14 @@ export default class ActiveDevice {
     await this.tuya.disconnect();
   }
 
+  async refresh(): Promise<void> {
+    if(this.device.disabled || !this.tuya.isConnected()){
+      return;
+    }
+
+    await this.tuya.refresh({schema: true});
+  }
+
   async set(
     data: ITuyaMultipleProperties | ITuyaSingleProperty
   ): Promise<{ [dps: string]: any }> {

src/app.ts

@@ -8,12 +8,16 @@ import {
 import Logger from "./logger";
 import processDevices from "./process-devices";
 import PublicDevice from "./public-device.model";
+import refreshDevices from "./refresh-devices";
 
 Logger.Info(`Starting`);
 
 let devices: { [id: string]: ActiveDevice } = {};
 
-const config = new Configuration(async () => processDevices(devices));
+const config = new Configuration(async () => {
+  processDevices(devices);
+  refreshDevices(devices);
+});
 config.initialize();
 
 const app = express();
@@ -22,6 +26,7 @@ app.use(express.json());
 const port = config.server().port ?? 3000;
 
 processDevices(devices);
+refreshDevices(devices);
 
 app.get("/", (req, res) => {
   res.json([

src/interfaces/config/server.ts

@@ -1,4 +1,5 @@
 export default interface IConfigServer {
   port: number;
   deviceReconnectWait: number;
+  refreshTime?: number;
 }

src/refresh-devices.ts

@@ -0,0 +1,30 @@
+import ActiveDevice from "./active-device";
+import Configuration from "./configuration";
+import Logger from "./logger";
+
+let refreshDevicesInterval = undefined;
+const refreshDevices = (activeDevices: { [id: string]: ActiveDevice }) => {
+  if (refreshDevicesInterval) {
+    clearInterval(refreshDevicesInterval);
+    refreshDevicesInterval = undefined;
+  }
+
+  const refreshTime = Configuration.instance.server().refreshTime;
+  if (refreshTime && refreshTime > 0) {
+    refreshDevicesInterval = setInterval(() => {
+      for (const key in activeDevices) {
+        try {
+          activeDevices[key].refresh();
+        } catch (ex: unknown) {
+          Logger.Error(
+            `${activeDevices[key].tuya.device.id} - Error refreshing device: ${
+              (<Error>ex).message
+            }`
+          );
+        }
+      }
+    }, refreshTime);
+  }
+};
+
+export default refreshDevices;