1.5.5

dist/homepage.d.ts

@@ -0,0 +1,8 @@
+import { API_HA_DeskPosition } from "./homeassistant";
+import { TidalGetCurrent } from "./tidal";
+export type FullInformation = {
+    ha_desk_position: API_HA_DeskPosition | null;
+    ha_temp: string | null;
+    tidal_current: TidalGetCurrent | null;
+};
+//# sourceMappingURL=homepage.d.ts.map

dist/homepage.d.ts.map

@@ -0,0 +1 @@
+{"version":3,"file":"homepage.d.ts","sourceRoot":"","sources":["../src/homepage.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,mBAAmB,EAAE,MAAM,iBAAiB,CAAC;AACtD,OAAO,EAAE,eAAe,EAAE,MAAM,SAAS,CAAC;AAE1C,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;CACtC,CAAA"}

dist/homepage.js

@@ -0,0 +1 @@
+export {};

dist/index.d.ts

@@ -1,6 +1,8 @@
 export * from "./fastify.js";
 export * from "./homeassistant.js";
+export * from "./homepage.js";
 export * from "./logger.js";
+export * from "./sse.js";
 export * from "./tidal.js";
 export * from "./timehelper.js";
 //# sourceMappingURL=index.d.ts.map

dist/index.d.ts.map

@@ -1 +1 @@
-{"version":3,"file":"index.d.ts","sourceRoot":"","sources":["../src/index.ts"],"names":[],"mappings":"AAAA,cAAc,cAAc,CAAC;AAC7B,cAAc,oBAAoB,CAAC;AACnC,cAAc,aAAa,CAAC;AAC5B,cAAc,YAAY,CAAC;AAC3B,cAAc,iBAAiB,CAAC"}
+{"version":3,"file":"index.d.ts","sourceRoot":"","sources":["../src/index.ts"],"names":[],"mappings":"AAAA,cAAc,cAAc,CAAC;AAC7B,cAAc,oBAAoB,CAAC;AACnC,cAAc,eAAe,CAAC;AAC9B,cAAc,aAAa,CAAC;AAC5B,cAAc,UAAU,CAAC;AACzB,cAAc,YAAY,CAAC;AAC3B,cAAc,iBAAiB,CAAC"}

dist/index.js

@@ -1,5 +1,7 @@
 export * from "./fastify.js";
 export * from "./homeassistant.js";
+export * from "./homepage.js";
 export * from "./logger.js";
+export * from "./sse.js";
 export * from "./tidal.js";
 export * from "./timehelper.js";

dist/sse.d.ts

@@ -0,0 +1,18 @@
+import { UUID } from "crypto";
+export type SseClient = {
+    id: UUID;
+    send: (data: SseEvent) => void;
+};
+export type SseEvent = {
+    type: string;
+    data?: unknown;
+    message?: string;
+};
+export declare class SseService {
+    private clients;
+    addClient(client: SseClient): void;
+    removeClient(clientId: string): void;
+    notifyClients(event: SseEvent): void;
+    getClientCount(): number;
+}
+//# sourceMappingURL=sse.d.ts.map

dist/sse.d.ts.map

@@ -0,0 +1 @@
+{"version":3,"file":"sse.d.ts","sourceRoot":"","sources":["../src/sse.ts"],"names":[],"mappings":"AAAA,OAAO,EAAE,IAAI,EAAE,MAAM,QAAQ,CAAC;AAG9B,MAAM,MAAM,SAAS,GAAG;IACvB,EAAE,EAAE,IAAI,CAAC;IACT,IAAI,EAAE,CAAC,IAAI,EAAE,QAAQ,KAAK,IAAI,CAAC;CAC/B,CAAA;AAED,MAAM,MAAM,QAAQ,GAAG;IACtB,IAAI,EAAE,MAAM,CAAC;IACb,IAAI,CAAC,EAAE,OAAO,CAAC;IACf,OAAO,CAAC,EAAE,MAAM,CAAC;CACjB,CAAA;AAED,qBAAa,UAAU;IACtB,OAAO,CAAC,OAAO,CAAqC;IAEpD,SAAS,CAAC,MAAM,EAAE,SAAS,GAAG,IAAI;IAOlC,YAAY,CAAC,QAAQ,EAAE,MAAM,GAAG,IAAI;IAOpC,aAAa,CAAC,KAAK,EAAE,QAAQ,GAAG,IAAI;IAMpC,cAAc,IAAI,MAAM;CAGxB"}

dist/sse.js

@@ -0,0 +1,20 @@
+import { logInfo } from "./logger.js";
+export class SseService {
+    clients = new Map();
+    addClient(client) {
+        this.clients.set(client.id, client);
+        logInfo(`SSE client connected: ${client.id}. Total clients: ${this.clients.size}`);
+    }
+    removeClient(clientId) {
+        this.clients.delete(clientId);
+        logInfo(`SSE client disconnected: ${clientId}. Total clients: ${this.clients.size}`);
+    }
+    notifyClients(event) {
+        for (const client of this.clients.values()) {
+            client.send(event);
+        }
+    }
+    getClientCount() {
+        return this.clients.size;
+    }
+}

dist/tidal.d.ts

@@ -1,14 +1,26 @@
-export type TidalSong = {
+export type TidalGetCurrent = {
     title: string;
     artists: string;
+    artistsArray: string[];
     album: string;
     playingFrom: string;
     status: "playing" | "paused";
     url: string;
     current: string;
+    currentInSeconds: number;
     duration: string;
-};
+    durationInSeconds: number;
-export type TidalVolume = {
+    image: string;
+    icon: string;
+    localAlbumArt: string;
+    favorite: boolean;
+    trackId: string;
     volume: number;
+    player: {
+        status: "playing" | "paused";
+        shuffle: boolean;
+        repeat: "all" | "single" | "none";
+    };
+    artist: string;
 };
 //# sourceMappingURL=tidal.d.ts.map

dist/tidal.d.ts.map

@@ -1 +1 @@
-{"version":3,"file":"tidal.d.ts","sourceRoot":"","sources":["../src/tidal.ts"],"names":[],"mappings":"AAAA,MAAM,MAAM,SAAS,GAAG;IACtB,KAAK,EAAE,MAAM,CAAC;IACd,OAAO,EAAE,MAAM,CAAC;IAChB,KAAK,EAAE,MAAM,CAAC;IACd,WAAW,EAAE,MAAM,CAAC;IACpB,MAAM,EAAE,SAAS,GAAG,QAAQ,CAAC;IAC7B,GAAG,EAAE,MAAM,CAAC;IACZ,OAAO,EAAE,MAAM,CAAC;IAChB,QAAQ,EAAE,MAAM,CAAC;CAClB,CAAC;AAEF,MAAM,MAAM,WAAW,GAAG;IACxB,MAAM,EAAE,MAAM,CAAC;CAChB,CAAC"}
+{"version":3,"file":"tidal.d.ts","sourceRoot":"","sources":["../src/tidal.ts"],"names":[],"mappings":"AAAA,MAAM,MAAM,eAAe,GAAG;IAC7B,KAAK,EAAE,MAAM,CAAC;IACd,OAAO,EAAE,MAAM,CAAC;IAChB,YAAY,EAAE,MAAM,EAAE,CAAC;IACvB,KAAK,EAAE,MAAM,CAAC;IACd,WAAW,EAAE,MAAM,CAAC;IACpB,MAAM,EAAE,SAAS,GAAG,QAAQ,CAAC;IAC7B,GAAG,EAAE,MAAM,CAAC;IACZ,OAAO,EAAE,MAAM,CAAC;IAChB,gBAAgB,EAAE,MAAM,CAAC;IACzB,QAAQ,EAAE,MAAM,CAAC;IACjB,iBAAiB,EAAE,MAAM,CAAC;IAC1B,KAAK,EAAE,MAAM,CAAC;IACd,IAAI,EAAE,MAAM,CAAC;IACb,aAAa,EAAE,MAAM,CAAC;IACtB,QAAQ,EAAE,OAAO,CAAC;IAClB,OAAO,EAAE,MAAM,CAAC;IAChB,MAAM,EAAE,MAAM,CAAC;IACf,MAAM,EAAE;QACP,MAAM,EAAE,SAAS,GAAG,QAAQ,CAAC;QAC7B,OAAO,EAAE,OAAO,CAAC;QACjB,MAAM,EAAE,KAAK,GAAG,QAAQ,GAAG,MAAM,CAAC;KAClC,CAAC;IACF,MAAM,EAAE,MAAM,CAAC;CACf,CAAC"}

package-lock.json

@@ -1,12 +1,12 @@
 {
   "name": "@dpu/shared",
-  "version": "1.4.0",
+  "version": "1.5.5",
   "lockfileVersion": 3,
   "requires": true,
   "packages": {
     "": {
       "name": "@dpu/shared",
-      "version": "1.4.0",
+      "version": "1.5.5",
       "dependencies": {
         "axios": "^1.7.9",
         "chalk": "^5.6.2",

package.json

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

src/homepage.ts

@@ -0,0 +1,8 @@
+import { API_HA_DeskPosition } from "./homeassistant";
+import { TidalGetCurrent } from "./tidal";
+
+export type FullInformation = {
+	ha_desk_position: API_HA_DeskPosition | null;
+	ha_temp: string | null;
+	tidal_current: TidalGetCurrent | null;
+}

src/index.ts

@@ -1,5 +1,8 @@
 export * from "./fastify.js";
 export * from "./homeassistant.js";
+export * from "./homepage.js";
 export * from "./logger.js";
+export * from "./sse.js";
 export * from "./tidal.js";
 export * from "./timehelper.js";
+

src/sse.ts

@@ -0,0 +1,41 @@
+import { UUID } from "crypto";
+import { logInfo } from "./logger.js";
+
+export type SseClient = {
+	id: UUID;
+	send: (data: SseEvent) => void;
+}
+
+export type SseEvent = {
+	type: string;
+	data?: unknown;
+	message?: string;
+}
+
+export class SseService {
+	private clients: Map<string, SseClient> = new Map();
+
+	addClient(client: SseClient): void {
+		this.clients.set(client.id, client);
+		logInfo(
+			`SSE client connected: ${client.id}. Total clients: ${this.clients.size}`,
+		);
+	}
+
+	removeClient(clientId: string): void {
+		this.clients.delete(clientId);
+		logInfo(
+			`SSE client disconnected: ${clientId}. Total clients: ${this.clients.size}`,
+		);
+	}
+
+	notifyClients(event: SseEvent): void {
+		for (const client of this.clients.values()) {
+	    client.send(event);
+	  }
+	}
+
+	getClientCount(): number {
+		return this.clients.size;
+	}
+}

src/tidal.ts

@@ -23,7 +23,3 @@ export type TidalGetCurrent = {
 	};
 	artist: string;
 };
-
-export type TidalPutVolume = {
-	volume: number;
-};