|
|
@ -38,7 +38,11 @@ const handleMsg = async (msg, id) => {
|
|
|
|
dm.event = 'streams:full'
|
|
|
|
dm.event = 'streams:full'
|
|
|
|
dm.data = await crud[channel].getAllPop()
|
|
|
|
dm.data = await crud[channel].getAllPop()
|
|
|
|
}
|
|
|
|
}
|
|
|
|
connections[id]?.connection?.send(JSON.stringify(dm))
|
|
|
|
try {
|
|
|
|
|
|
|
|
connections[id].connection.send(JSON.stringify(dm))
|
|
|
|
|
|
|
|
} catch (e) {
|
|
|
|
|
|
|
|
console.warn(e)
|
|
|
|
|
|
|
|
}
|
|
|
|
} else if (d.hasOwnProperty('event') && channelEvents.indexOf(d.event) !== -1) {
|
|
|
|
} else if (d.hasOwnProperty('event') && channelEvents.indexOf(d.event) !== -1) {
|
|
|
|
const ev = d.event.split(':')
|
|
|
|
const ev = d.event.split(':')
|
|
|
|
const channel = ev[0]
|
|
|
|
const channel = ev[0]
|
|
|
|