diff --git a/src/ws/streams.js b/src/ws/streams.js index a65464c..856685b 100644 --- a/src/ws/streams.js +++ b/src/ws/streams.js @@ -36,12 +36,14 @@ const recvUpdate = async (channel, data) => { } const sendInitial = async (id) => { - const c = connections[id] - const stream = await crud['streams'].getById(c.streamid) - c.connection.send(JSON.stringify({ - event: 'streams:read', - data: stream, - })) + if (id != null || id != '') { + const c = connections[id] + const stream = await crud['streams'].getById(c.streamid) + c.connection.send(JSON.stringify({ + event: 'streams:read', + data: stream, + })) + } } module.exports = {