diff --git a/src/ws/streams.js b/src/ws/streams.js index a65464c..9ceef28 100644 --- a/src/ws/streams.js +++ b/src/ws/streams.js @@ -37,11 +37,13 @@ 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 (c.streamid !== null) { + const stream = await crud['streams'].getById(c.streamid) + c.connection.send(JSON.stringify({ + event: 'streams:read', + data: stream, + })) + } } module.exports = {