From 90c5d8ae338e2479ee874ce6ef81baf8bf125c78 Mon Sep 17 00:00:00 2001
From: Florin Duban <dubanflorin@yahoo.com>
Date: Thu, 9 Feb 2017 10:58:19 +0200
Subject: [PATCH 1/3] fix auto-restart option when server has arguments

---
 lib/master/starter.js | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/lib/master/starter.js b/lib/master/starter.js
index f23bc3647..177b15168 100644
--- a/lib/master/starter.js
+++ b/lib/master/starter.js
@@ -73,7 +73,7 @@ starter.run = function(app, server, cb) {
     cmd = util.format('cd "%s" && "%s"', app.getBase(), process.execPath);
     var arg = server.args;
     if (arg !== undefined) {
-      cmd += arg;
+      cmd += ' ' + arg;
     }
     cmd += util.format(' "%s" env=%s ', app.get(Constants.RESERVED.MAIN), env);
     for(key in server) {

From 320911050c4c3791853021afab6e8fcfeaf6fb86 Mon Sep 17 00:00:00 2001
From: Florin Duban <florin.duban@erepubliklabs.com>
Date: Thu, 27 Feb 2020 09:35:42 +0100
Subject: [PATCH 2/3] * attach a listener for error until data is received

---
 lib/connectors/hybrid/switcher.js | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git a/lib/connectors/hybrid/switcher.js b/lib/connectors/hybrid/switcher.js
index ac6584eb5..86c6e6bde 100644
--- a/lib/connectors/hybrid/switcher.js
+++ b/lib/connectors/hybrid/switcher.js
@@ -51,6 +51,13 @@ Switcher.prototype.newSocket = function(socket) {
     return;
   }
 
+  function onError(error) {
+    logger.error('socket with remote ip: %s && port: %s has error: %s',
+      socket.remoteAddress, socket.remotePort, error.stack);
+    socket.destroy();
+  }
+  socket.on('error', onError);
+
   socket.setTimeout(this.timeout, function() {
      logger.warn('connection is timeout without communication, the remote ip is %s && port is %s',
        socket.remoteAddress, socket.remotePort);
@@ -60,6 +67,7 @@ Switcher.prototype.newSocket = function(socket) {
   var self = this;
 
   socket.once('data', function(data) {
+    socket.removeListener('error', onError);
     // FIXME: handle incomplete HTTP method
     if(isHttp(data)) {
       processHttp(self, self.wsprocessor, socket, data);

From 20910f390c86551ae7a5b010fb5edf1b316feeb7 Mon Sep 17 00:00:00 2001
From: Georgian Onel <georgian.onel@erepubliklabs.com>
Date: Thu, 18 Nov 2021 01:04:29 +0200
Subject: [PATCH 3/3] tcp socket encode fix

---
 lib/connectors/hybrid/tcpsocket.js | 1 +
 1 file changed, 1 insertion(+)

diff --git a/lib/connectors/hybrid/tcpsocket.js b/lib/connectors/hybrid/tcpsocket.js
index bfcc9eb73..1b8b4f41f 100644
--- a/lib/connectors/hybrid/tcpsocket.js
+++ b/lib/connectors/hybrid/tcpsocket.js
@@ -65,6 +65,7 @@ util.inherits(Socket, Stream);
 module.exports = Socket;
 
 Socket.prototype.send = function(msg, encode, cb) {
+  if (encode && encode.binary) { encode = 'utf8'; }
   this._socket.write(msg, encode, cb);
 };