Merge pull request #63 from morgsmccauley/feat/websocket-updates

refactor: Replace polled updates with WebSocket subscription

package.json

@@ -1,7 +1,7 @@
 {
   "displayName": "Technotherm",
   "name": "homebridge-technotherm",
-  "version": "1.1.2-beta.0",
+  "version": "1.2.0",
   "description": "Controls for Technotherm electric radiators.",
   "license": "Apache-2.0",
   "repository": {
@@ -33,7 +33,8 @@
   ],
   "dependencies": {
     "axios": "^1.6.7",
-    "axios-retry": "^4.0.0"
+    "axios-retry": "^4.0.0",
+    "socket.io-client": "^2.5.0"
   },
   "devDependencies": {
     "@types/node": "^20.11.17",

src/helki_client.ts

@@ -1,6 +1,7 @@
 import axios, { AxiosInstance } from 'axios';
 import axiosRetry from 'axios-retry';
 import { Logger } from 'homebridge';
+import io from 'socket.io-client';
 
 interface TokenResponse {
   access_token: string;
@@ -56,7 +57,7 @@ interface SetStatus {
 
 interface Status {
   // Common fields for getStatus response and setStatus request
-  mode: 'auto' | 'manual' | 'off';
+  mode: 'auto' | 'manual' | 'off' | 'modified_auto';
   units: 'C' | 'F'; // Temperature units
 
   // Temperature settings
@@ -155,6 +156,8 @@ class HelkiClient {
   private expiresAt: Date;
   private log: Logger;
 
+  private socketNamespace = '/api/v2/socket_io';
+
   constructor(
     apiName: string,
     clientId: string,
@@ -208,6 +211,23 @@ class HelkiClient {
     });
   }
 
+  async subscribeToDeviceUpdates(deviceId: string, callback: (status: Status) => void): Promise<void> {
+    await this.checkRefresh();
+
+    const socket = io(this.apiHost + this.socketNamespace, {
+      query: {
+        token: this.accessToken,
+        dev_id: deviceId,
+      },
+    });
+
+    socket.on('update', (data) => {
+      this.log.debug(`Device ${deviceId} updated:`, data);
+
+      callback(data.body);
+    });
+  }
+
   private async auth(): Promise<void> {
     this.log.info(`Authenticating via ${this.apiHost}`);
     const tokenUrl = `${this.apiHost}/client/token`;