Merge pull request #9 from Archish27/error_message

🎨 Added error message in logs

Author: francisf

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();
     });
 

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);
   }
 
   /**

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);
   }
 
   /**

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));
     });

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);
     });
   });