|
|
@ -36,13 +36,15 @@ const recvUpdate = async (channel, data) => {
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
const sendInitial = async (id) => {
|
|
|
|
const sendInitial = async (id) => {
|
|
|
|
if (id != null || id != '') {
|
|
|
|
try {
|
|
|
|
const c = connections[id]
|
|
|
|
const c = connections[id]
|
|
|
|
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,
|
|
|
|
}))
|
|
|
|
}))
|
|
|
|
|
|
|
|
} catch (e) {
|
|
|
|
|
|
|
|
console.warn(e)
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|