Adding socket hangup logs

Author: karanshah-browserstack

lib/config/constants.js

@@ -48,6 +48,7 @@ const RECONNECT_ID_HEADER = 'x-reconnect-id';
 
 const OUTGOING = '[OUTGOING]';
 const INCOMING = '[INCOMING]';
+const HTTPLOG = '[HTTP]';
 
 class ConfigParser {
   setRetries() {
@@ -253,4 +254,5 @@ module.exports = {
   kUpstreamRestart,
   PROXY_LOCKED,
   PROXY_RESTART,
+  HTTPLOG
 };

lib/core/Proxy.js

@@ -1,7 +1,7 @@
 'use strict';
 
 const WebSocket = require('ws');
-const { config, kCleanup, kAddNewContext } = require('../config/constants');
+const { config, kCleanup, kAddNewContext, HTTPLOG } = require('../config/constants');
 const logger = require('../util/loggerFactory');
 const Context = require('./Context');
 const {
@@ -63,13 +63,22 @@ class Proxy {
       method: request.method,
       headers: request.headers,
     };
+    logger.info(`${HTTPLOG} Received http request ${options}`);
     const proxyReq = http.request(options, (proxyResponse) => {
       response.writeHead(proxyResponse.statusCode, proxyResponse.headers);
       proxyResponse.pipe(response, {
         end: true,
       });
     });
-
+    proxyReq.on('error', (error)=>{
+      logger.error(`${request.url} received error ${error}`);
+    });
+    proxyReq.on('timeout', ()=>{
+      logger.info(`${request.url} timed out`);
+    });
+    proxyReq.on('drain', ()=>{
+      logger.info(`${request.url} drained out`);
+    });
     request.pipe(proxyReq, {
       end: true,
     });