Merge branch 'master' of https://github.com/stakwork/sphinx-relay

api/utils/socket.ts

@@ -1,7 +1,9 @@
 import * as WebSocket from 'ws'
 
-let connections = new Map()
-let connectionCounter = 0
+// let connections = new Map()
+// let connectionCounter = 0
+
+let lastConn: any
 
 const connect = (server) => {
   server = new WebSocket.Server({ server })
@@ -10,16 +12,18 @@ const connect = (server) => {
 
   server.on('connection', socket => {
     console.log('=> [socket] connection received')
-    var id = connectionCounter++;
-    connections.set(id, socket)
+    // var id = connectionCounter++;
+    // connections.set(id, socket)
+    lastConn = socket
   })
 
 }
 
 const send = (body) => {
-  connections.forEach((socket, index) => {
-    socket.send(body)
-  })
+  // connections.forEach((socket, index) => {
+  //   socket.send(body)
+  // })
+  lastConn.send(body)
 }
 
 const sendJson = (object) => {

dist/api/utils/socket.js

@@ -1,22 +1,25 @@
 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 const WebSocket = require("ws");
-let connections = new Map();
-let connectionCounter = 0;
+// let connections = new Map()
+// let connectionCounter = 0
+let lastConn;
 const connect = (server) => {
     server = new WebSocket.Server({ server });
     console.log('=> [socket] connected to server');
     server.on('connection', socket => {
         console.log('=> [socket] connection received');
-        var id = connectionCounter++;
-        connections.set(id, socket);
+        // var id = connectionCounter++;
+        // connections.set(id, socket)
+        lastConn = socket;
     });
 };
 exports.connect = connect;
 const send = (body) => {
-    connections.forEach((socket, index) => {
-        socket.send(body);
-    });
+    // connections.forEach((socket, index) => {
+    //   socket.send(body)
+    // })
+    lastConn.send(body);
 };
 exports.send = send;
 const sendJson = (object) => {

dist/api/utils/socket.js.map

@@ -1 +1 @@
-{"version":3,"file":"socket.js","sourceRoot":"","sources":["../../../api/utils/socket.ts"],"names":[],"mappings":";;AAAA,gCAA+B;AAE/B,IAAI,WAAW,GAAG,IAAI,GAAG,EAAE,CAAA;AAC3B,IAAI,iBAAiB,GAAG,CAAC,CAAA;AAEzB,MAAM,OAAO,GAAG,CAAC,MAAM,EAAE,EAAE;IACzB,MAAM,GAAG,IAAI,SAAS,CAAC,MAAM,CAAC,EAAE,MAAM,EAAE,CAAC,CAAA;IAEzC,OAAO,CAAC,GAAG,CAAC,iCAAiC,CAAC,CAAA;IAE9C,MAAM,CAAC,EAAE,CAAC,YAAY,EAAE,MAAM,CAAC,EAAE;QAC/B,OAAO,CAAC,GAAG,CAAC,iCAAiC,CAAC,CAAA;QAC9C,IAAI,EAAE,GAAG,iBAAiB,EAAE,CAAC;QAC7B,WAAW,CAAC,GAAG,CAAC,EAAE,EAAE,MAAM,CAAC,CAAA;IAC7B,CAAC,CAAC,CAAA;AAEJ,CAAC,CAAA;AAaC,0BAAO;AAXT,MAAM,IAAI,GAAG,CAAC,IAAI,EAAE,EAAE;IACpB,WAAW,CAAC,OAAO,CAAC,CAAC,MAAM,EAAE,KAAK,EAAE,EAAE;QACpC,MAAM,CAAC,IAAI,CAAC,IAAI,CAAC,CAAA;IACnB,CAAC,CAAC,CAAA;AACJ,CAAC,CAAA;AAQC,oBAAI;AANN,MAAM,QAAQ,GAAG,CAAC,MAAM,EAAE,EAAE;IAC1B,IAAI,CAAC,IAAI,CAAC,SAAS,CAAC,MAAM,CAAC,CAAC,CAAA;AAC9B,CAAC,CAAA;AAKC,4BAAQ"}
+{"version":3,"file":"socket.js","sourceRoot":"","sources":["../../../api/utils/socket.ts"],"names":[],"mappings":";;AAAA,gCAA+B;AAE/B,8BAA8B;AAC9B,4BAA4B;AAE5B,IAAI,QAAa,CAAA;AAEjB,MAAM,OAAO,GAAG,CAAC,MAAM,EAAE,EAAE;IACzB,MAAM,GAAG,IAAI,SAAS,CAAC,MAAM,CAAC,EAAE,MAAM,EAAE,CAAC,CAAA;IAEzC,OAAO,CAAC,GAAG,CAAC,iCAAiC,CAAC,CAAA;IAE9C,MAAM,CAAC,EAAE,CAAC,YAAY,EAAE,MAAM,CAAC,EAAE;QAC/B,OAAO,CAAC,GAAG,CAAC,iCAAiC,CAAC,CAAA;QAC9C,gCAAgC;QAChC,8BAA8B;QAC9B,QAAQ,GAAG,MAAM,CAAA;IACnB,CAAC,CAAC,CAAA;AAEJ,CAAC,CAAA;AAcC,0BAAO;AAZT,MAAM,IAAI,GAAG,CAAC,IAAI,EAAE,EAAE;IACpB,2CAA2C;IAC3C,sBAAsB;IACtB,KAAK;IACL,QAAQ,CAAC,IAAI,CAAC,IAAI,CAAC,CAAA;AACrB,CAAC,CAAA;AAQC,oBAAI;AANN,MAAM,QAAQ,GAAG,CAAC,MAAM,EAAE,EAAE;IAC1B,IAAI,CAAC,IAAI,CAAC,SAAS,CAAC,MAAM,CAAC,CAAC,CAAA;AAC9B,CAAC,CAAA;AAKC,4BAAQ"}