1.5.5

dist/sse.d.ts

@@ -1,5 +1,6 @@
+import { UUID } from "crypto";
 export type SseClient = {
-    id: number;
+    id: UUID;
     send: (data: SseEvent) => void;
 };
 export type SseEvent = {
@@ -10,7 +11,7 @@ export type SseEvent = {
 export declare class SseService {
     private clients;
     addClient(client: SseClient): void;
-    removeClient(clientId: number): void;
+    removeClient(clientId: string): void;
     notifyClients(event: SseEvent): void;
     getClientCount(): number;
 }

dist/sse.d.ts.map

@@ -1 +1 @@
-{"version":3,"file":"sse.d.ts","sourceRoot":"","sources":["../src/sse.ts"],"names":[],"mappings":"AAEA,MAAM,MAAM,SAAS,GAAG;IACvB,EAAE,EAAE,MAAM,CAAC;IACX,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,CAAwB;IAEvC,SAAS,CAAC,MAAM,EAAE,SAAS,GAAG,IAAI;IAOlC,YAAY,CAAC,QAAQ,EAAE,MAAM,GAAG,IAAI;IAUpC,aAAa,CAAC,KAAK,EAAE,QAAQ,GAAG,IAAI;IAMpC,cAAc,IAAI,MAAM;CAGxB"}
+{"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

@@ -1,21 +1,18 @@
 import { logInfo } from "./logger.js";
 export class SseService {
-    clients = new Set();
+    clients = new Map();
     addClient(client) {
-        this.clients.add(client);
+        this.clients.set(client.id, client);
         logInfo(`SSE client connected: ${client.id}. Total clients: ${this.clients.size}`);
     }
     removeClient(clientId) {
-        const client = [...this.clients].find((c) => c.id === clientId);
+        this.clients.delete(clientId);
-        if (client) {
+        logInfo(`SSE client disconnected: ${clientId}. Total clients: ${this.clients.size}`);
-            this.clients.delete(client);
-            logInfo(`SSE client disconnected: ${clientId}. Total clients: ${this.clients.size}`);
-        }
     }
     notifyClients(event) {
-        this.clients.forEach((client) => {
+        for (const client of this.clients.values()) {
             client.send(event);
-        });
+        }
     }
     getClientCount() {
         return this.clients.size;

package-lock.json

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

package.json

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

src/sse.ts

@@ -1,7 +1,8 @@
+import { UUID } from "crypto";
 import { logInfo } from "./logger.js";
 
 export type SseClient = {
-	id: number;
+	id: UUID;
 	send: (data: SseEvent) => void;
 }
 
@@ -12,29 +13,26 @@ export type SseEvent = {
 }
 
 export class SseService {
-	private clients = new Set<SseClient>();
+	private clients: Map<string, SseClient> = new Map();
 
 	addClient(client: SseClient): void {
-		this.clients.add(client);
+		this.clients.set(client.id, client);
 		logInfo(
 			`SSE client connected: ${client.id}. Total clients: ${this.clients.size}`,
 		);
 	}
 
-	removeClient(clientId: number): void {
+	removeClient(clientId: string): void {
-		const client = [...this.clients].find((c) => c.id === clientId);
+		this.clients.delete(clientId);
-		if (client) {
+		logInfo(
-			this.clients.delete(client);
+			`SSE client disconnected: ${clientId}. Total clients: ${this.clients.size}`,
-			logInfo(
+		);
-				`SSE client disconnected: ${clientId}. Total clients: ${this.clients.size}`,
-			);
-		}
 	}
 
 	notifyClients(event: SseEvent): void {
-		this.clients.forEach((client) => {
+		for (const client of this.clients.values()) {
-			client.send(event);
+	    client.send(event);
-		});
+	  }
 	}
 
 	getClientCount(): number {