diff --git a/dist/fastify.js b/dist/fastify.js index 8b83c02..bba4928 100644 --- a/dist/fastify.js +++ b/dist/fastify.js @@ -29,7 +29,7 @@ export class BaseService { }; } getErrorResult(errorMessage, error) { - logWarning(errorMessage); + logWarning(errorMessage, error); return { result: errorMessage, successful: false, diff --git a/dist/ws.d.ts b/dist/ws.d.ts index eb609a9..dc9bacb 100644 --- a/dist/ws.d.ts +++ b/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; diff --git a/dist/ws.d.ts.map b/dist/ws.d.ts.map index a04fcbf..3e64807 100644 --- a/dist/ws.d.ts.map +++ b/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"} \ No newline at end of file +{"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"} \ No newline at end of file diff --git a/dist/ws.js b/dist/ws.js index a687fe1..7e45621 100644 --- a/dist/ws.js +++ b/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) => { diff --git a/src/fastify.ts b/src/fastify.ts index 38e968c..13dacb0 100644 --- a/src/fastify.ts +++ b/src/fastify.ts @@ -41,7 +41,7 @@ export abstract class BaseService { } getErrorResult(errorMessage: string, error?: unknown): ServiceResult { - logWarning(errorMessage); + logWarning(errorMessage, error); return { result: errorMessage, successful: false, diff --git a/src/ws.ts b/src/ws.ts index 3d9f226..86da2ba 100644 --- a/src/ws.ts +++ b/src/ws.ts @@ -10,31 +10,15 @@ export type WsClientChangeCallback = (clients: number) => void; export class WsService { private clients: Set = 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 {