working

api/utils/socket.ts

@@ -1,9 +1,5 @@
 import * as WebSocket from 'ws'
 
-// let connections = new Map()
-// let connectionCounter = 0
-
-// let lastConn: any
 let srvr: any
 
 const connect = (server) => {
@@ -12,20 +8,11 @@ const connect = (server) => {
 
   srvr.on('connection', socket => {
     console.log('=> [socket] connection received')
-    // var id = connectionCounter++;
-    // connections.set(id, socket)
-    // lastConn = socket
   })
-
 }
 
 const send = (body) => {
-  // connections.forEach((socket, index) => {
-  //   socket.send(body)
-  // })
-  // if(lastConn) lastConn.send(body)
   srvr.clients.forEach(c=>{
-    console.log(c)
     if(c) c.send(body)
   })
 }

dist/api/utils/socket.js

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

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,8BAA8B;AAC9B,4BAA4B;AAE5B,oBAAoB;AACpB,IAAI,IAAS,CAAA;AAEb,MAAM,OAAO,GAAG,CAAC,MAAM,EAAE,EAAE;IACzB,IAAI,GAAG,IAAI,SAAS,CAAC,MAAM,CAAC,EAAE,MAAM,EAAE,cAAc,EAAC,IAAI,EAAE,CAAC,CAAA;IAC5D,OAAO,CAAC,GAAG,CAAC,iCAAiC,CAAC,CAAA;IAE9C,IAAI,CAAC,EAAE,CAAC,YAAY,EAAE,MAAM,CAAC,EAAE;QAC7B,OAAO,CAAC,GAAG,CAAC,iCAAiC,CAAC,CAAA;QAC9C,gCAAgC;QAChC,8BAA8B;QAC9B,oBAAoB;IACtB,CAAC,CAAC,CAAA;AAEJ,CAAC,CAAA;AAkBC,0BAAO;AAhBT,MAAM,IAAI,GAAG,CAAC,IAAI,EAAE,EAAE;IACpB,2CAA2C;IAC3C,sBAAsB;IACtB,KAAK;IACL,mCAAmC;IACnC,IAAI,CAAC,OAAO,CAAC,OAAO,CAAC,CAAC,CAAA,EAAE;QACtB,OAAO,CAAC,GAAG,CAAC,CAAC,CAAC,CAAA;QACd,IAAG,CAAC;YAAE,CAAC,CAAC,IAAI,CAAC,IAAI,CAAC,CAAA;IACpB,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,IAAI,IAAS,CAAA;AAEb,MAAM,OAAO,GAAG,CAAC,MAAM,EAAE,EAAE;IACzB,IAAI,GAAG,IAAI,SAAS,CAAC,MAAM,CAAC,EAAE,MAAM,EAAE,cAAc,EAAC,IAAI,EAAE,CAAC,CAAA;IAC5D,OAAO,CAAC,GAAG,CAAC,iCAAiC,CAAC,CAAA;IAE9C,IAAI,CAAC,EAAE,CAAC,YAAY,EAAE,MAAM,CAAC,EAAE;QAC7B,OAAO,CAAC,GAAG,CAAC,iCAAiC,CAAC,CAAA;IAChD,CAAC,CAAC,CAAA;AACJ,CAAC,CAAA;AAaC,0BAAO;AAXT,MAAM,IAAI,GAAG,CAAC,IAAI,EAAE,EAAE;IACpB,IAAI,CAAC,OAAO,CAAC,OAAO,CAAC,CAAC,CAAA,EAAE;QACtB,IAAG,CAAC;YAAE,CAAC,CAAC,IAAI,CAAC,IAAI,CAAC,CAAA;IACpB,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"}