refactor fix

src/index.js

@@ -45,12 +45,14 @@ server.on('upgrade', (req, socket, head) => {
     if (pathname[1] === 'ws' && get(token)) {
         wss1.handleUpgrade(req, socket, head, (socket) => {
             req.id = token
-            wss1.emit('connection', socket, req);
+            wss1.emit('connection', socket, req)
         })
     } else if (pathname[1] === 'stream') {
         wss2.handleUpgrade(req, socket, head, (socket) => {
-            req.id = token
+            if (req.id != null || req.id != '') {
-            wss2.emit('connection', socket, req);
+                req.id = token
+                wss2.emit('connection', socket, req)
+            }
         })
     }
 })

src/ws/streams.js

@@ -37,13 +37,11 @@ const recvUpdate = async (channel, data) => {
 
 const sendInitial = async (id) => {
   const c = connections[id]
-  if (c.streamid !== null) {
+  const stream = await crud['streams'].getById(c.streamid)
-    const stream = await crud['streams'].getById(c.streamid)
+  c.connection.send(JSON.stringify({
-    c.connection.send(JSON.stringify({
+    event: 'streams:read',
-      event: 'streams:read',
+    data: stream,
-      data: stream,
+  }))
-    }))
-  }
 }
 
 module.exports = {