DarDarBinks/dpu-shared
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

set => map

Browse Source
This commit is contained in:
Darius
2026-02-05 04:31:54 +01:00
parent 8daeed6b5f
commit cdd2fcb59e
4 changed files with 22 additions and 26 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
dist/sse.d.ts vendored
View File

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

2
dist/sse.d.ts.map vendored
View File

@@ -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"}

15
dist/sse.js vendored
View File

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

26
src/sse.ts
View File

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