diff --git a/src/adapters/web-socket-adapter.ts b/src/adapters/web-socket-adapter.ts index 7ac2673..673c524 100644 --- a/src/adapters/web-socket-adapter.ts +++ b/src/adapters/web-socket-adapter.ts @@ -138,9 +138,8 @@ export class WebSocketAdapter extends EventEmitter implements IWebSocketAdapter this.alive = true } - private onClientClose(code: number) { + private onClientClose() { this.alive = false - console.debug(`worker ${process.pid} - client disconnected with code ${code}`) this.removeAllListeners() this.client.removeAllListeners() diff --git a/src/adapters/web-socket-server-adapter.ts b/src/adapters/web-socket-server-adapter.ts index 33d036b..fd8bf26 100644 --- a/src/adapters/web-socket-server-adapter.ts +++ b/src/adapters/web-socket-server-adapter.ts @@ -64,7 +64,6 @@ export class WebSocketServerAdapter extends WebServerAdapter implements IWebSock } private onConnection(client: WebSocket, req: IncomingMessage) { - console.debug(`worker ${process.pid} - new client - ${this.webSocketServer.clients.size} clients`) this.webSocketsAdapters.set(client, this.createWebSocketAdapter([client, req, this])) } diff --git a/src/handlers/event-message-handler.ts b/src/handlers/event-message-handler.ts index 4c7bae9..bada685 100644 --- a/src/handlers/event-message-handler.ts +++ b/src/handlers/event-message-handler.ts @@ -19,8 +19,6 @@ export class EventMessageHandler implements IMessageHandler { public async handleMessage(message: IncomingEventMessage): Promise { const [, event] = message - console.debug('Received event', event) - let reason = await this.isEventValid(event) if (reason) { console.warn(`Event ${event.id} rejected. Reason: ${reason}`)