|
|
|
@ -76,13 +76,14 @@ const fanoutMsg = (channel, data) => {
|
|
|
|
|
data,
|
|
|
|
|
}
|
|
|
|
|
connections[k].connection.send(JSON.stringify(d))
|
|
|
|
|
} else if (connections[k].events.indexOf('streams:full') !== -1) {
|
|
|
|
|
const m = await crud['streams'].getAllPop()
|
|
|
|
|
const d = {
|
|
|
|
|
event: 'streams:full',
|
|
|
|
|
data: m,
|
|
|
|
|
if (connections[k].events.indexOf('streams:full') !== -1) {
|
|
|
|
|
const m = await crud['streams'].getAllPop()
|
|
|
|
|
const d = {
|
|
|
|
|
event: 'streams:full',
|
|
|
|
|
data: m,
|
|
|
|
|
}
|
|
|
|
|
connections[k].connection.send(JSON.stringify(d))
|
|
|
|
|
}
|
|
|
|
|
connections[k].connection.send(JSON.stringify(d))
|
|
|
|
|
}
|
|
|
|
|
})
|
|
|
|
|
}
|
|
|
|
|