|
|
@ -27,6 +27,7 @@ const handleMsg = async (msg, id) => {
|
|
|
|
try {
|
|
|
|
try {
|
|
|
|
const d = JSON.parse(msg)
|
|
|
|
const d = JSON.parse(msg)
|
|
|
|
if (d.hasOwnProperty('subscribe') && channelEvents.indexOf(d.subscribe) !== -1) {
|
|
|
|
if (d.hasOwnProperty('subscribe') && channelEvents.indexOf(d.subscribe) !== -1) {
|
|
|
|
|
|
|
|
console.log('received sub for ', d.subscribe)
|
|
|
|
const channel = d.subscribe.split(':')[0]
|
|
|
|
const channel = d.subscribe.split(':')[0]
|
|
|
|
connections[id].events.push(d.subscribe)
|
|
|
|
connections[id].events.push(d.subscribe)
|
|
|
|
const dm = {
|
|
|
|
const dm = {
|
|
|
|