highperfocused/nostream
1
0
Fork 0
mirror of https://github.com/Cameri/nostream.git synced 2025-10-09 16:12:36 +02:00
Code Issues Packages Projects Releases Wiki Activity

chore: remove debug logs

Browse Source
This commit is contained in:
Ricardo Arturo Cabral Mejia
2022-08-27 15:33:11 +00:00
parent 64ba4bb118
commit aee0b20979
1 changed files with 0 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/adapters/web-socket-adapter.ts
View File

@@ -32,16 +32,11 @@ export class WebSocketAdapter extends EventEmitter implements IWebSocketAdapter
this.id = Buffer.from(request.headers['sec-websocket-key'], 'base64').toString('hex') this.id = Buffer.from(request.headers['sec-websocket-key'], 'base64').toString('hex')
this.clientAddress = request.headers['x-forwarded-for'] as string this.clientAddress = request.headers['x-forwarded-for'] as string
console.log('id', this.id, 'clientAddress', this.clientAddress)
console.log('listener count:', this.client.listenerCount('close'))
this.client this.client
.on('message', this.onClientMessage.bind(this)) .on('message', this.onClientMessage.bind(this))
.on('close', this.onClientClose.bind(this)) .on('close', this.onClientClose.bind(this))
.on('pong', this.onClientPong.bind(this)) .on('pong', this.onClientPong.bind(this))
console.log('+listener count:', this.client.listenerCount('close'))
this this
.on('heartbeat', this.onHeartbeat.bind(this)) .on('heartbeat', this.onHeartbeat.bind(this))
.on('subscribe', this.onSubscribed.bind(this)) .on('subscribe', this.onSubscribed.bind(this))
@@ -72,7 +67,6 @@ export class WebSocketAdapter extends EventEmitter implements IWebSocketAdapter
} }
public sendMessage(message: OutgoingMessage): void { public sendMessage(message: OutgoingMessage): void {
console.log('sending message', message)
this.client.send(JSON.stringify(message)) this.client.send(JSON.stringify(message))
} }
@@ -103,7 +97,6 @@ export class WebSocketAdapter extends EventEmitter implements IWebSocketAdapter
if (typeof messageHandler.abort === 'function') { if (typeof messageHandler.abort === 'function') {
abort = messageHandler.abort.bind(messageHandler) abort = messageHandler.abort.bind(messageHandler)
this.client.prependOnceListener('close', abort) this.client.prependOnceListener('close', abort)
console.log('+listener count:', this.client.listenerCount('close'))
} }
await messageHandler?.handleMessage(message) await messageHandler?.handleMessage(message)
@@ -119,7 +112,6 @@ export class WebSocketAdapter extends EventEmitter implements IWebSocketAdapter
if (abort) { if (abort) {
this.client.removeListener('close', abort) this.client.removeListener('close', abort)
} }
console.log('-listener count:', this.client.listenerCount('close'))
} }
} }
@@ -134,6 +126,5 @@ export class WebSocketAdapter extends EventEmitter implements IWebSocketAdapter
this.removeAllListeners() this.removeAllListeners()
this.client.removeAllListeners() this.client.removeAllListeners()
console.log('-listener count:', this.client.listenerCount('close'))
} }
} }