feat: wss + DEBUG all over

Author: coolaj86

dashsight-server.js

@@ -70,6 +70,7 @@ DashSightServer.create = function ({ rpc, wss, authenticate }) {
 
   dss.sockets = {};
   dss.sockets.onconnection = async function (ws, request) {
+    console.error("[DEBUG] dss.sockets.onconnection");
     ws.on("error", console.error);
 
     // TODO session should establish which hostname and port
@@ -96,9 +97,9 @@ DashSightServer.create = function ({ rpc, wss, authenticate }) {
       return;
     }
 
-    console.log(`DEBUG ws query:`);
+    console.log(`[DEBUG] ws query:`);
     console.log(query);
-    let stream = WebSocket.createWebSocketStream(ws);
+    let stream = WebSocket.createWebSocketStream(ws, { encoding: null });
     let conn = Net.createConnection({
       host: query.hostname,
       port: query.port,
@@ -108,14 +109,29 @@ DashSightServer.create = function ({ rpc, wss, authenticate }) {
     });
     stream.pipe(conn);
     conn.pipe(stream);
+    ws.on("open", function (chunk) {
+      console.log("[DEBUG] ws.on open");
+    });
+    ws.on("message", function (chunk) {
+      let hex = chunk.toString("hex");
+      console.log("[DEBUG] ws.on data hex", hex);
+    });
+    conn.on("data", function (chunk) {
+      let hex = chunk.toString("hex");
+      console.log("[DEBUG] conn.on data hex", hex);
+      // ws.send(chunk);
+    });
 
     stream.once("error", disconnect);
     stream.once("end", disconnect);
     stream.once("close", disconnect);
     function disconnect() {
+      console.log("[DEBUG] ws stream pipe disconnected");
       conn.end();
       conn.destroy();
     }
+
+    console.log("[DEBUG] piped each end and added handlers");
   };
 
   dss.router = new AsyncRouter.Router();

server.js

@@ -88,6 +88,7 @@ server.on("upgrade", function upgrade(request, socket, head) {
   }
 
   wss.handleUpgrade(request, socket, head, function (ws) {
+    console.error('[DEBUG] wss.handleUpgrade: emit connection');
     wss.emit("connection", ws, request);
   });
 });