diff --git a/lib/core/Context.js b/lib/core/Context.js index c7a0c31..f02a4ad 100644 --- a/lib/core/Context.js +++ b/lib/core/Context.js @@ -94,8 +94,8 @@ class Context extends EventEmitter { } else this.outgoingSocket.emit(kSendMessage, msg); }); - this.incomingSocket.on(kError, () => { - logger.error(`${INCOMING} [${this.connectionId}] [ERROR]`); + this.incomingSocket.on(kError, (error) => { + logger.error(`${INCOMING} [${this.connectionId}] [ERROR] ${error}`); incrErrorConnectionCount(); }); @@ -182,8 +182,8 @@ class Context extends EventEmitter { } else this.incomingSocket.emit(kSendMessage, msg); }); - this.outgoingSocket.on(kError, () => { - logger.error(`${OUTGOING} [${this.connectionId}] [ERROR]`); + this.outgoingSocket.on(kError, (error) => { + logger.error(`${OUTGOING} [${this.connectionId}] [ERROR] ${error}`); incrErrorConnectionCount(); }); diff --git a/lib/core/IncomingWebSocket.js b/lib/core/IncomingWebSocket.js index 3c3dddb..7ea2efb 100644 --- a/lib/core/IncomingWebSocket.js +++ b/lib/core/IncomingWebSocket.js @@ -77,8 +77,8 @@ class IncomingWebSocket extends EventEmitter { /** * Triggers when error occured on socket. */ - errorHandler() { - this.emit(kError); + errorHandler(error) { + this.emit(kError, error); } /** diff --git a/lib/core/OutgoingWebSocket.js b/lib/core/OutgoingWebSocket.js index 61f2d00..fedc2e1 100644 --- a/lib/core/OutgoingWebSocket.js +++ b/lib/core/OutgoingWebSocket.js @@ -135,8 +135,8 @@ class OutgoingWebSocket extends EventEmitter { /** * Triggers when error occured on socket. */ - errorHandler() { - this.emit(kError); + errorHandler(error) { + this.emit(kError, error); } /** diff --git a/test/core/incomingWebSocket.test.js b/test/core/incomingWebSocket.test.js index cda1f71..6dc11af 100644 --- a/test/core/incomingWebSocket.test.js +++ b/test/core/incomingWebSocket.test.js @@ -156,7 +156,7 @@ describe('IncomingWebSocket', () => { it('should emit kError once', () => { const emitSpy = spy(); incomingWs.emit = emitSpy; - incomingWs.errorHandler(); + incomingWs.errorHandler('SOME ERROR'); assert(emitSpy.calledOnce); assert(emitSpy.calledWith(kError)); }); diff --git a/test/core/outgoingWebSocket.test.js b/test/core/outgoingWebSocket.test.js index 26e8d31..b621a61 100644 --- a/test/core/outgoingWebSocket.test.js +++ b/test/core/outgoingWebSocket.test.js @@ -224,7 +224,7 @@ describe('OutgoingWebSocket', () => { it('should emit kError', () => { const errSpy = spy(); outgoingWs.emit = errSpy; - outgoingWs.errorHandler(); + outgoingWs.errorHandler('SOME ERROR'); assert(errSpy.calledOnce); }); });