convenience function

dist/fastify.d.ts

@@ -17,6 +17,6 @@ export declare abstract class BaseService<T> {
     constructor(client: T);
     getClient(): T;
     getSuccessfulResult<R = unknown>(result: R): ServiceResult<R>;
-    getErrorResult(error: string): ServiceResult<string>;
+    getErrorResult(errorMessage: string, error?: unknown): ServiceResult<string>;
 }
 //# sourceMappingURL=fastify.d.ts.map

dist/fastify.d.ts.map

@@ -1 +1 @@
-{"version":3,"file":"fastify.d.ts","sourceRoot":"","sources":["../src/fastify.ts"],"names":[],"mappings":"AAAA,OAAO,KAAK,EAAE,aAAa,EAAE,MAAM,OAAO,CAAC;AAG3C,MAAM,MAAM,aAAa,CAAC,CAAC,GAAG,OAAO,IAAI;IACxC,MAAM,EAAE,CAAC,CAAC;IACV,UAAU,EAAE,OAAO,CAAC;CACpB,CAAC;AAEF,qBAAa,SAAS;IACF,KAAK,EAAE,MAAM;gBAAb,KAAK,EAAE,MAAM;CAChC;AAED,8BAAsB,UAAU;IAC/B,OAAO,CAAC,aAAa,CAAgB;gBAEzB,aAAa,EAAE,aAAa;IAIxC,QAAQ,IAAI,aAAa;CAGzB;AAED,8BAAsB,WAAW,CAAC,CAAC;IAClC,OAAO,CAAC,MAAM,CAAI;gBAEN,MAAM,EAAE,CAAC;IAIrB,SAAS,IAAI,CAAC;IAId,mBAAmB,CAAC,CAAC,GAAG,OAAO,EAAE,MAAM,EAAE,CAAC,GAAG,aAAa,CAAC,CAAC,CAAC;IAO7D,cAAc,CAAC,KAAK,EAAE,MAAM,GAAG,aAAa,CAAC,MAAM,CAAC;CAOpD"}
+{"version":3,"file":"fastify.d.ts","sourceRoot":"","sources":["../src/fastify.ts"],"names":[],"mappings":"AAAA,OAAO,KAAK,EAAE,aAAa,EAAE,MAAM,OAAO,CAAC;AAG3C,MAAM,MAAM,aAAa,CAAC,CAAC,GAAG,OAAO,IAAI;IACxC,MAAM,EAAE,CAAC,CAAC;IACV,UAAU,EAAE,OAAO,CAAC;CACpB,CAAC;AAEF,qBAAa,SAAS;IACF,KAAK,EAAE,MAAM;gBAAb,KAAK,EAAE,MAAM;CAChC;AAED,8BAAsB,UAAU;IAC/B,OAAO,CAAC,aAAa,CAAgB;gBAEzB,aAAa,EAAE,aAAa;IAIxC,QAAQ,IAAI,aAAa;CAGzB;AAED,8BAAsB,WAAW,CAAC,CAAC;IAClC,OAAO,CAAC,MAAM,CAAI;gBAEN,MAAM,EAAE,CAAC;IAIrB,SAAS,IAAI,CAAC;IAId,mBAAmB,CAAC,CAAC,GAAG,OAAO,EAAE,MAAM,EAAE,CAAC,GAAG,aAAa,CAAC,CAAC,CAAC;IAO7D,cAAc,CAAC,YAAY,EAAE,MAAM,EAAE,KAAK,CAAC,EAAE,OAAO,GAAG,aAAa,CAAC,MAAM,CAAC;CAO5E"}

dist/fastify.js

@@ -28,10 +28,10 @@ export class BaseService {
             successful: true,
         };
     }
-    getErrorResult(error) {
-        logWarning(error);
+    getErrorResult(errorMessage, error) {
+        logWarning(errorMessage, error);
         return {
-            result: error,
+            result: errorMessage,
             successful: false,
         };
     }

dist/homeassistant.d.ts

@@ -10,9 +10,9 @@ export type HomeAssistantEntity = {
         [key: string]: unknown;
     };
     last_changed: string;
-    last_reported: string;
-    last_updated: string;
-    context: {
+    last_reported?: string;
+    last_updated?: string;
+    context?: {
         id: string;
         parent_id: string | null;
         user_id: string | null;
@@ -28,4 +28,16 @@ export type API_HA_DeskPosition = {
     last_changed: string;
     last_changed_seconds: number;
 };
+export type HA_Update = {
+    entity_id: string;
+    state: string;
+    attributes: {
+        state_class?: string;
+        unit_of_measurement?: string;
+        icon?: string;
+        friendly_name?: string;
+        [key: string]: unknown;
+    };
+    timestamp: string;
+};
 //# sourceMappingURL=homeassistant.d.ts.map

dist/homeassistant.d.ts.map

@@ -1 +1 @@
-{"version":3,"file":"homeassistant.d.ts","sourceRoot":"","sources":["../src/homeassistant.ts"],"names":[],"mappings":"AAAA,OAAO,KAAK,EAAE,WAAW,EAAE,MAAM,cAAc,CAAC;AAEhD,MAAM,MAAM,mBAAmB,GAAG;IACjC,SAAS,EAAE,MAAM,CAAC;IAClB,KAAK,EAAE,MAAM,CAAC;IACd,UAAU,EAAE;QACX,WAAW,CAAC,EAAE,MAAM,CAAC;QACrB,mBAAmB,CAAC,EAAE,MAAM,CAAC;QAC7B,IAAI,CAAC,EAAE,MAAM,CAAC;QACd,aAAa,CAAC,EAAE,MAAM,CAAC;QACvB,CAAC,GAAG,EAAE,MAAM,GAAG,OAAO,CAAC;KACvB,CAAC;IACF,YAAY,EAAE,MAAM,CAAC;IACrB,aAAa,EAAE,MAAM,CAAC;IACtB,YAAY,EAAE,MAAM,CAAC;IACrB,OAAO,EAAE;QACR,EAAE,EAAE,MAAM,CAAC;QACX,SAAS,EAAE,MAAM,GAAG,IAAI,CAAC;QACzB,OAAO,EAAE,MAAM,GAAG,IAAI,CAAC;KACvB,CAAC;CACF,CAAC;AAEF,MAAM,WAAW,+BAA+B;IAC/C,GAAG,EAAE,mBAAmB,CAAC;IACzB,UAAU,EAAE,OAAO,CAAC;IACpB,YAAY,EAAE,WAAW,CAAC;CAC1B;AAED,MAAM,MAAM,mBAAmB,GAAG;IACjC,WAAW,EAAE,OAAO,CAAC;IACrB,YAAY,EAAE,MAAM,CAAC;IACrB,oBAAoB,EAAE,MAAM,CAAC;CAC7B,CAAC"}
+{"version":3,"file":"homeassistant.d.ts","sourceRoot":"","sources":["../src/homeassistant.ts"],"names":[],"mappings":"AAAA,OAAO,KAAK,EAAE,WAAW,EAAE,MAAM,cAAc,CAAC;AAEhD,MAAM,MAAM,mBAAmB,GAAG;IACjC,SAAS,EAAE,MAAM,CAAC;IAClB,KAAK,EAAE,MAAM,CAAC;IACd,UAAU,EAAE;QACX,WAAW,CAAC,EAAE,MAAM,CAAC;QACrB,mBAAmB,CAAC,EAAE,MAAM,CAAC;QAC7B,IAAI,CAAC,EAAE,MAAM,CAAC;QACd,aAAa,CAAC,EAAE,MAAM,CAAC;QACvB,CAAC,GAAG,EAAE,MAAM,GAAG,OAAO,CAAC;KACvB,CAAC;IACF,YAAY,EAAE,MAAM,CAAC;IACrB,aAAa,CAAC,EAAE,MAAM,CAAC;IACvB,YAAY,CAAC,EAAE,MAAM,CAAC;IACtB,OAAO,CAAC,EAAE;QACT,EAAE,EAAE,MAAM,CAAC;QACX,SAAS,EAAE,MAAM,GAAG,IAAI,CAAC;QACzB,OAAO,EAAE,MAAM,GAAG,IAAI,CAAC;KACvB,CAAC;CACF,CAAC;AAEF,MAAM,WAAW,+BAA+B;IAC/C,GAAG,EAAE,mBAAmB,CAAC;IACzB,UAAU,EAAE,OAAO,CAAC;IACpB,YAAY,EAAE,WAAW,CAAC;CAC1B;AAED,MAAM,MAAM,mBAAmB,GAAG;IACjC,WAAW,EAAE,OAAO,CAAC;IACrB,YAAY,EAAE,MAAM,CAAC;IACrB,oBAAoB,EAAE,MAAM,CAAC;CAC7B,CAAC;AAEF,MAAM,MAAM,SAAS,GAAG;IACvB,SAAS,EAAE,MAAM,CAAC;IAClB,KAAK,EAAE,MAAM,CAAC;IACd,UAAU,EAAE;QACX,WAAW,CAAC,EAAE,MAAM,CAAC;QACrB,mBAAmB,CAAC,EAAE,MAAM,CAAC;QAC7B,IAAI,CAAC,EAAE,MAAM,CAAC;QACd,aAAa,CAAC,EAAE,MAAM,CAAC;QACvB,CAAC,GAAG,EAAE,MAAM,GAAG,OAAO,CAAC;KACvB,CAAC;IACF,SAAS,EAAE,MAAM,CAAC;CAClB,CAAC"}

dist/homepage.d.ts

@@ -11,4 +11,8 @@ export type ComponentUpdate = {
     component: string;
     data: unknown;
 };
+export declare function createComponentUpdate(component: string, data: unknown): {
+    component: string;
+    data: unknown;
+};
 //# sourceMappingURL=homepage.d.ts.map

dist/homepage.d.ts.map

@@ -1 +1 @@
-{"version":3,"file":"homepage.d.ts","sourceRoot":"","sources":["../src/homepage.ts"],"names":[],"mappings":"AAAA,OAAO,KAAK,EAAE,yBAAyB,EAAE,MAAM,SAAS,CAAC;AACzD,OAAO,KAAK,EAAE,mBAAmB,EAAE,MAAM,iBAAiB,CAAC;AAC3D,OAAO,KAAK,EAAE,eAAe,EAAE,MAAM,SAAS,CAAC;AAE/C,MAAM,MAAM,eAAe,GAAG;IAC7B,gBAAgB,EAAE,mBAAmB,GAAG,IAAI,CAAC;IAC7C,OAAO,EAAE,MAAM,GAAG,IAAI,CAAC;IACvB,aAAa,EAAE,eAAe,GAAG,IAAI,CAAC;IACtC,oBAAoB,EAAE,yBAAyB,GAAG,IAAI,CAAC;CACvD,CAAC;AAEF,MAAM,MAAM,eAAe,GAAG;IAC7B,SAAS,EAAE,MAAM,CAAC;IAClB,IAAI,EAAE,OAAO,CAAC;CACd,CAAC"}
+{"version":3,"file":"homepage.d.ts","sourceRoot":"","sources":["../src/homepage.ts"],"names":[],"mappings":"AAAA,OAAO,KAAK,EAAE,yBAAyB,EAAE,MAAM,SAAS,CAAC;AACzD,OAAO,KAAK,EAAE,mBAAmB,EAAE,MAAM,iBAAiB,CAAC;AAC3D,OAAO,KAAK,EAAE,eAAe,EAAE,MAAM,SAAS,CAAC;AAE/C,MAAM,MAAM,eAAe,GAAG;IAC7B,gBAAgB,EAAE,mBAAmB,GAAG,IAAI,CAAC;IAC7C,OAAO,EAAE,MAAM,GAAG,IAAI,CAAC;IACvB,aAAa,EAAE,eAAe,GAAG,IAAI,CAAC;IACtC,oBAAoB,EAAE,yBAAyB,GAAG,IAAI,CAAC;CACvD,CAAC;AAEF,MAAM,MAAM,eAAe,GAAG;IAC7B,SAAS,EAAE,MAAM,CAAC;IAClB,IAAI,EAAE,OAAO,CAAC;CACd,CAAC;AAEF,wBAAgB,qBAAqB,CAAC,SAAS,EAAE,MAAM,EAAE,IAAI,EAAE,OAAO;;;EAKrE"}

dist/homepage.js

@@ -1 +1,6 @@
-export {};
+export function createComponentUpdate(component, data) {
+    return {
+        component: component,
+        data: data
+    };
+}

dist/ws.d.ts

@@ -6,9 +6,6 @@ export type WsEvent = {
 export type WsClientChangeCallback = (clients: number) => void;
 export declare class WsService {
     private clients;
-    private listeners;
-    onClientChange(callback: WsClientChangeCallback): () => void;
-    private emitClientChange;
     addClient(ws: WebSocket): void;
     removeClient(ws: WebSocket): void;
     broadcast(message: WsEvent): void;

dist/ws.d.ts.map

@@ -1 +1 @@
-{"version":3,"file":"ws.d.ts","sourceRoot":"","sources":["../src/ws.ts"],"names":[],"mappings":"AAAA,OAAO,KAAK,EAAE,SAAS,EAAE,MAAM,IAAI,CAAC;AAGpC,MAAM,MAAM,OAAO,GAAG;IACrB,IAAI,EAAE,MAAM,CAAC;IACb,IAAI,CAAC,EAAE,OAAO,CAAC;CACf,CAAC;AAEF,MAAM,MAAM,sBAAsB,GAAG,CAAC,OAAO,EAAE,MAAM,KAAK,IAAI,CAAC;AAE/D,qBAAa,SAAS;IACrB,OAAO,CAAC,OAAO,CAA6B;IAC5C,OAAO,CAAC,SAAS,CAAgC;IAEjD,cAAc,CAAC,QAAQ,EAAE,sBAAsB,GAAG,MAAM,IAAI;IAO5D,OAAO,CAAC,gBAAgB;IAMxB,SAAS,CAAC,EAAE,EAAE,SAAS,GAAG,IAAI;IAM9B,YAAY,CAAC,EAAE,EAAE,SAAS,GAAG,IAAI;IAMjC,SAAS,CAAC,OAAO,EAAE,OAAO,GAAG,IAAI;IAMjC,cAAc,IAAI,MAAM;CAGxB"}
+{"version":3,"file":"ws.d.ts","sourceRoot":"","sources":["../src/ws.ts"],"names":[],"mappings":"AAAA,OAAO,KAAK,EAAE,SAAS,EAAE,MAAM,IAAI,CAAC;AAGpC,MAAM,MAAM,OAAO,GAAG;IACrB,IAAI,EAAE,MAAM,CAAC;IACb,IAAI,CAAC,EAAE,OAAO,CAAC;CACf,CAAC;AAEF,MAAM,MAAM,sBAAsB,GAAG,CAAC,OAAO,EAAE,MAAM,KAAK,IAAI,CAAC;AAE/D,qBAAa,SAAS;IACrB,OAAO,CAAC,OAAO,CAA6B;IAE5C,SAAS,CAAC,EAAE,EAAE,SAAS,GAAG,IAAI;IAK9B,YAAY,CAAC,EAAE,EAAE,SAAS,GAAG,IAAI;IAKjC,SAAS,CAAC,OAAO,EAAE,OAAO,GAAG,IAAI;IAMjC,cAAc,IAAI,MAAM;CAGxB"}

dist/ws.js

@@ -1,27 +1,13 @@
 import { logInfo } from "./logger.js";
 export class WsService {
     clients = new Set();
-    listeners = [];
-    onClientChange(callback) {
-        this.listeners.push(callback);
-        return () => {
-            this.listeners = this.listeners.filter((cb) => cb !== callback);
-        };
-    }
-    emitClientChange() {
-        for (const callback of this.listeners) {
-            callback(this.clients.size);
-        }
-    }
     addClient(ws) {
         this.clients.add(ws);
         logInfo(`Socket connected. Total clients: ${this.clients.size}`);
-        this.emitClientChange();
     }
     removeClient(ws) {
         this.clients.delete(ws);
         logInfo(`Socket disconnected. Total clients: ${this.clients.size}`);
-        this.emitClientChange();
     }
     broadcast(message) {
         this.clients.forEach((socket) => {

package-lock.json

@@ -1,12 +1,12 @@
 {
   "name": "@dpu/shared",
-  "version": "1.9.2",
+  "version": "1.9.7",
   "lockfileVersion": 3,
   "requires": true,
   "packages": {
     "": {
       "name": "@dpu/shared",
-      "version": "1.9.2",
+      "version": "1.9.7",
       "dependencies": {
         "@types/ws": "^8.18.1",
         "axios": "^1.7.9",

package.json

@@ -1,6 +1,6 @@
 {
   "name": "@dpu/shared",
-  "version": "1.9.2",
+  "version": "1.9.7",
   "description": "",
   "main": "dist/index.js",
   "types": "dist/index.d.ts",

src/fastify.ts

@@ -40,10 +40,10 @@ export abstract class BaseService<T> {
 		};
 	}
 
-	getErrorResult(error: string): ServiceResult<string> {
-		logWarning(error);
+	getErrorResult(errorMessage: string, error?: unknown): ServiceResult<string> {
+		logWarning(errorMessage, error);
 		return {
-			result: error,
+			result: errorMessage,
 			successful: false,
 		};
 	}

src/homeassistant.ts

@@ -11,9 +11,9 @@ export type HomeAssistantEntity = {
 		[key: string]: unknown;
 	};
 	last_changed: string; // datetime string
-	last_reported: string; // datetime string
-	last_updated: string; // datetime string
-	context: {
+	last_reported?: string; // datetime string
+	last_updated?: string; // datetime string
+	context?: {
 		id: string;
 		parent_id: string | null;
 		user_id: string | null;
@@ -31,3 +31,16 @@ export type API_HA_DeskPosition = {
 	last_changed: string;
 	last_changed_seconds: number;
 };
+
+export type HA_Update = {
+	entity_id: string;
+	state: string;
+	attributes: {
+		state_class?: string;
+		unit_of_measurement?: string;
+		icon?: string;
+		friendly_name?: string;
+		[key: string]: unknown;
+	};
+	timestamp: string; // datetime string
+};

src/homepage.ts

@@ -13,3 +13,10 @@ export type ComponentUpdate = {
 	component: string;
 	data: unknown;
 };
+
+export function createComponentUpdate(component: string, data: unknown) {
+	return {
+		component: component,
+		data: data
+	}
+}

src/ws.ts

@@ -10,31 +10,15 @@ export type WsClientChangeCallback = (clients: number) => void;
 
 export class WsService {
 	private clients: Set<WebSocket> = new Set();
-	private listeners: WsClientChangeCallback[] = [];
-
-	onClientChange(callback: WsClientChangeCallback): () => void {
-		this.listeners.push(callback);
-		return () => {
-			this.listeners = this.listeners.filter((cb) => cb !== callback);
-		};
-	}
-
-	private emitClientChange(): void {
-		for (const callback of this.listeners) {
-			callback(this.clients.size);
-		}
-	}
 
 	addClient(ws: WebSocket): void {
 		this.clients.add(ws);
 		logInfo(`Socket connected. Total clients: ${this.clients.size}`);
-		this.emitClientChange();
 	}
 
 	removeClient(ws: WebSocket): void {
 		this.clients.delete(ws);
 		logInfo(`Socket disconnected. Total clients: ${this.clients.size}`);
-		this.emitClientChange();
 	}
 
 	broadcast(message: WsEvent): void {