Support for Drupal 7 is ending on 5 January 2025—it’s time to migrate to Drupal 10! Learn about the many benefits of Drupal 10 and find migration tools in our resource center.
Hi,
Is this module working correctly with NodeJS? My NodeJS looks to be setup correctly, i am receiving broadcast messages fine and not getting any errors. Is looks like
.on('message-published', function (message, i)
is never called?
Here are some logs from terminal
engine intercepting request for path "/socket.io/" +8s
engine handling "GET" http request "/socket.io/?EIO=3&transport=polling&t=1419191270767-27" +0ms
engine handshaking client "Le5qQhQgFYEb0saoAAAC" +1ms
engine:socket sending packet "open" ({"sid":"Le5qQhQgFYEb0saoAAAC","upgrades":["websocket"],"pingInterval":25000,"pingTimeout":60000}) +0ms
engine:polling setting request +0ms
engine:socket flushing buffer to transport +0ms
engine:polling writing " �0{"sid":"Le5qQhQgFYEb0saoAAAC","upgrades":["websocket"],"pingInterval":25000,"pingTimeout":60000}" +0ms
engine:socket executing batch send callback +1ms
socket.io:server incoming connection with id Le5qQhQgFYEb0saoAAAC +1.8m
socket.io:client connecting to namespace / +1s
socket.io:namespace adding socket to nsp / +1.8m
socket.io:socket socket connected - writing packet +1s
socket.io:socket joining room Le5qQhQgFYEb0saoAAAC +0ms
socket.io:client writing packet {"type":0,"nsp":"/"} +0ms
socket.io-parser encoding packet {"type":0,"nsp":"/"} +1.7m
socket.io-parser encoded {"type":0,"nsp":"/"} as 0 +0ms
engine:socket sending packet "message" (0) +1ms
socket.io:socket joined room Le5qQhQgFYEb0saoAAAC +1ms
engine intercepting request for path "/socket.io/" +4ms
engine handling "GET" http request "/socket.io/?EIO=3&transport=polling&t=1419191270773-28&sid=Le5qQhQgFYEb0saoAAAC" +0ms
engine setting new request for existing client +2ms
engine:polling setting request +1ms
engine:socket flushing buffer to transport +0ms
engine:polling writing "�40" +0ms
engine:socket executing batch send callback +1ms
engine intercepting request for path "/socket.io/" +9ms
engine handling "GET" http request "/socket.io/?EIO=3&transport=polling&t=1419191270783-30&sid=Le5qQhQgFYEb0saoAAAC" +1ms
engine setting new request for existing client +0ms
engine:polling setting request +0ms
engine intercepting request for path "/socket.io/" +2ms
engine handling "OPTIONS" http request "/socket.io/?EIO=3&transport=polling&t=1419191270782-29&sid=Le5qQhQgFYEb0saoAAAC" +1ms
engine setting new request for existing client +0ms
engine intercepting request for path "/socket.io/" +5ms
engine handling "POST" http request "/socket.io/?EIO=3&transport=polling&t=1419191270782-29&sid=Le5qQhQgFYEb0saoAAAC" +0ms
engine setting new request for existing client +0ms
engine:polling received "�42["authenticate",{"authToken":"5449114a002aa956cc51ade10c1a8f1a"}]" +1ms
engine:socket packet +0ms
socket.io-parser decoded 2["authenticate",{"authToken":"5449114a002aa956cc51ade10c1a8f1a"}] as {"type":2,"nsp":"/","data":["authenticate",{"authToken":"5449114a002aa956cc51ade10c1a8f1a"}]} +27ms
socket.io:socket got packet {"type":2,"nsp":"/","data":["authenticate",{"authToken":"5449114a002aa956cc51ade10c1a8f1a"}]} +28ms
socket.io:socket emitting event ["authenticate",{"authToken":"5449114a002aa956cc51ade10c1a8f1a"}] +0ms
Authenticating client with key "5449114a002aa956cc51ade10c1a8f1a"
Reusing existing authentication data for key: 5449114a002aa956cc51ade10c1a8f1a , client id: Le5qQhQgFYEb0saoAAAC
{ SJHuQncovQQBEDe8AAAA:
{ nsp:
{ name: '/',
server: [Object],
sockets: [Object],
connected: [Object],
fns: [],
ids: 0,
acks: {},
adapter: [Object],
_events: [Object] },
server:
{ nsps: [Object],
_path: '/socket.io',
_serveClient: true,
_adapter: [Function: Adapter],
_origins: '*:*',
sockets: [Object],
eio: [Object],
httpServer: [Object],
engine: [Object] },
adapter: { nsp: [Object], rooms: [Object], sids: [Object], encoder: {} },
id: 'SJHuQncovQQBEDe8AAAA',
client:
{ server: [Object],
conn: [Object],
encoder: {},
decoder: [Object],
id: 'SJHuQncovQQBEDe8AAAA',
request: [Object],
onclose: [Function],
ondata: [Function],
onerror: [Function],
ondecoded: [Function],
sockets: [Object],
nsps: [Object],
connectBuffer: [] },
conn:
{ id: 'SJHuQncovQQBEDe8AAAA',
server: [Object],
upgraded: true,
readyState: 'open',
writeBuffer: [],
packetsFn: [],
sentCallbackFn: [],
request: [Object],
remoteAddress: '127.0.0.1',
checkIntervalTimer: null,
upgradeTimeoutTimer: [Object],
pingTimeoutTimer: [Object],
transport: [Object],
_events: [Object] },
rooms: [ 'SJHuQncovQQBEDe8AAAA' ],
acks: {},
connected: true,
disconnected: false,
handshake:
{ headers: [Object],
time: 'Sun Dec 21 2014 19:46:05 GMT+0000 (GMT)',
address: '127.0.0.1',
xdomain: true,
secure: false,
issued: 1419191165408,
url: '/socket.io/?EIO=3&transport=polling&t=1419191165380-17',
query: [Object] },
_events:
{ authenticate: [Function],
message: [Function],
disconnect: [Function] },
authToken: '76308cf591efe0fc229de6588fa1ec94',
uid: 0 },
Le5qQhQgFYEb0saoAAAC:
{ nsp:
{ name: '/',
server: [Object],
sockets: [Object],
connected: [Object],
fns: [],
ids: 0,
acks: {},
adapter: [Object],
_events: [Object] },
server:
{ nsps: [Object],
_path: '/socket.io',
_serveClient: true,
_adapter: [Function: Adapter],
_origins: '*:*',
sockets: [Object],
eio: [Object],
httpServer: [Object],
engine: [Object] },
adapter: { nsp: [Object], rooms: [Object], sids: [Object], encoder: {} },
id: 'Le5qQhQgFYEb0saoAAAC',
client:
{ server: [Object],
conn: [Object],
encoder: {},
decoder: [Object],
id: 'Le5qQhQgFYEb0saoAAAC',
request: [Object],
onclose: [Function],
ondata: [Function],
onerror: [Function],
ondecoded: [Function],
sockets: [Object],
nsps: [Object],
connectBuffer: [] },
conn:
{ id: 'Le5qQhQgFYEb0saoAAAC',
server: [Object],
upgraded: false,
readyState: 'open',
writeBuffer: [],
packetsFn: [],
sentCallbackFn: [],
request: [Object],
remoteAddress: '127.0.0.1',
checkIntervalTimer: null,
upgradeTimeoutTimer: null,
pingTimeoutTimer: [Object],
transport: [Object],
_events: [Object] },
rooms: [ 'Le5qQhQgFYEb0saoAAAC' ],
acks: {},
connected: true,
disconnected: false,
handshake:
{ headers: [Object],
time: 'Sun Dec 21 2014 19:47:50 GMT+0000 (GMT)',
address: '127.0.0.1',
xdomain: true,
secure: false,
issued: 1419191270771,
url: '/socket.io/?EIO=3&transport=polling&t=1419191270767-27',
query: [Object] },
_events:
{ authenticate: [Function],
message: [Function],
disconnect: [Function] } } }
Still there Le5qQhQgFYEb0saoAAAC
Auth - 4
socket.io:client writing packet {"type":2,"data":["message",{"type":"createChannel","data":"create","callback":"drupalchatNodejsMessageHandler"}],"nsp":"/"} +35ms
socket.io-parser encoding packet {"type":2,"data":["message",{"type":"createChannel","data":"create","callback":"drupalchatNodejsMessageHandler"}],"nsp":"/"} +7ms
socket.io-parser encoded {"type":2,"data":["message",{"type":"createChannel","data":"create","callback":"drupalchatNodejsMessageHandler"}],"nsp":"/"} as 2["message",{"type":"createChannel","data":"create","callback":"drupalchatNodejsMessageHandler"}] +0ms
engine:socket sending packet "message" (2["message",{"type":"createChannel","data":"create","callback":"drupalchatNodejsMessageHandler"}]) +7ms
engine:socket flushing buffer to transport +0ms
engine:polling writing " �42["message",{"type":"createChannel","data":"create","callback":"drupalchatNodejsMessageHandler"}]" +0ms
Sent message to client Le5qQhQgFYEb0saoAAAC
Added - 4
Added channels for uid 4: nodejs_user_4
setupClientConnection { '4': [] }
engine upgrading existing transport +3ms
engine:socket might upgrade socket transport from "polling" to "websocket" +0ms
engine intercepting request for path "/socket.io/" +4ms
engine handling "GET" http request "/socket.io/?EIO=3&transport=polling&t=1419191270809-31&sid=Le5qQhQgFYEb0saoAAAC" +1ms
engine setting new request for existing client +0ms
engine:polling setting request +0ms
engine:socket executing batch send callback +0ms
engine:ws received "2probe" +1ms
engine:ws writing "3probe" +0ms
engine:socket writing a noop packet to polling for fast upgrade +103ms
engine:polling writing "�6" +0ms
engine:ws received "5" +3ms
engine:socket got upgrade packet - upgrading +0ms
socket.io:client client close with reason transport close +145ms
socket.io:socket closing socket - reason transport close +151ms
socket.io:client ignoring remove for Le5qQhQgFYEb0saoAAAC +0ms
Out - 4
Cleaning up after socket id Le5qQhQgFYEb0saoAAAC uid 4
socket.io:server serve client 304 +362ms
engine intercepting request for path "/socket.io/" +701ms
engine handling "GET" http request "/socket.io/?EIO=3&transport=polling&t=1419191271357-0" +0ms
engine handshaking client "9ftb7jOE4yqNvsdVAAAD" +0ms
engine:socket sending packet "open" ({"sid":"9ftb7jOE4yqNvsdVAAAD","upgrades":["websocket"],"pingInterval":25000,"pingTimeout":60000}) +0ms
engine:polling setting request +0ms
engine:socket flushing buffer to transport +1ms
engine:polling writing " �0{"sid":"9ftb7jOE4yqNvsdVAAAD","upgrades":["websocket"],"pingInterval":25000,"pingTimeout":60000}" +0ms
engine:socket executing batch send callback +1ms
socket.io:server incoming connection with id 9ftb7jOE4yqNvsdVAAAD +491ms
socket.io:client connecting to namespace / +673ms
socket.io:namespace adding socket to nsp / +853ms
socket.io:socket socket connected - writing packet +674ms
socket.io:socket joining room 9ftb7jOE4yqNvsdVAAAD +0ms
socket.io:client writing packet {"type":0,"nsp":"/"} +1ms
socket.io-parser encoding packet {"type":0,"nsp":"/"} +819ms
socket.io-parser encoded {"type":0,"nsp":"/"} as 0 +0ms
engine:socket sending packet "message" (0) +1ms
socket.io:socket joined room 9ftb7jOE4yqNvsdVAAAD +0ms
engine intercepting request for path "/socket.io/" +108ms
engine handling "GET" http request "/socket.io/?EIO=3&transport=polling&t=1419191271658-1&sid=9ftb7jOE4yqNvsdVAAAD" +1ms
engine setting new request for existing client +1ms
engine:polling setting request +0ms
engine:socket flushing buffer to transport +0ms
engine:polling writing "�40" +0ms
engine:socket executing batch send callback +4ms
engine intercepting request for path "/socket.io/" +48ms
engine handling "OPTIONS" http request "/socket.io/?EIO=3&transport=polling&t=1419191271780-2&sid=9ftb7jOE4yqNvsdVAAAD" +1ms
engine setting new request for existing client +0ms
engine intercepting request for path "/socket.io/" +3ms
engine handling "GET" http request "/socket.io/?EIO=3&transport=polling&t=1419191271781-3&sid=9ftb7jOE4yqNvsdVAAAD" +1ms
engine setting new request for existing client +0ms
engine:polling setting request +0ms
engine intercepting request for path "/socket.io/" +0ms
engine handling "POST" http request "/socket.io/?EIO=3&transport=polling&t=1419191271780-2&sid=9ftb7jOE4yqNvsdVAAAD" +0ms
engine setting new request for existing client +0ms
engine:polling received "�42["authenticate",{"authToken":"5449114a002aa956cc51ade10c1a8f1a"}]" +1ms
engine:socket packet +0ms
socket.io-parser decoded 2["authenticate",{"authToken":"5449114a002aa956cc51ade10c1a8f1a"}] as {"type":2,"nsp":"/","data":["authenticate",{"authToken":"5449114a002aa956cc51ade10c1a8f1a"}]} +168ms
socket.io:socket got packet {"type":2,"nsp":"/","data":["authenticate",{"authToken":"5449114a002aa956cc51ade10c1a8f1a"}]} +168ms
socket.io:socket emitting event ["authenticate",{"authToken":"5449114a002aa956cc51ade10c1a8f1a"}] +0ms
Authenticating client with key "5449114a002aa956cc51ade10c1a8f1a"
Reusing existing authentication data for key: 5449114a002aa956cc51ade10c1a8f1a , client id: 9ftb7jOE4yqNvsdVAAAD
{ SJHuQncovQQBEDe8AAAA:
{ nsp:
{ name: '/',
server: [Object],
sockets: [Object],
connected: [Object],
fns: [],
ids: 0,
acks: {},
adapter: [Object],
_events: [Object] },
server:
{ nsps: [Object],
_path: '/socket.io',
_serveClient: true,
_adapter: [Function: Adapter],
_origins: '*:*',
sockets: [Object],
eio: [Object],
httpServer: [Object],
engine: [Object] },
adapter: { nsp: [Object], rooms: [Object], sids: [Object], encoder: {} },
id: 'SJHuQncovQQBEDe8AAAA',
client:
{ server: [Object],
conn: [Object],
encoder: {},
decoder: [Object],
id: 'SJHuQncovQQBEDe8AAAA',
request: [Object],
onclose: [Function],
ondata: [Function],
onerror: [Function],
ondecoded: [Function],
sockets: [Object],
nsps: [Object],
connectBuffer: [] },
conn:
{ id: 'SJHuQncovQQBEDe8AAAA',
server: [Object],
upgraded: true,
readyState: 'open',
writeBuffer: [],
packetsFn: [],
sentCallbackFn: [],
request: [Object],
remoteAddress: '127.0.0.1',
checkIntervalTimer: null,
upgradeTimeoutTimer: [Object],
pingTimeoutTimer: [Object],
transport: [Object],
_events: [Object] },
rooms: [ 'SJHuQncovQQBEDe8AAAA' ],
acks: {},
connected: true,
disconnected: false,
handshake:
{ headers: [Object],
time: 'Sun Dec 21 2014 19:46:05 GMT+0000 (GMT)',
address: '127.0.0.1',
xdomain: true,
secure: false,
issued: 1419191165408,
url: '/socket.io/?EIO=3&transport=polling&t=1419191165380-17',
query: [Object] },
_events:
{ authenticate: [Function],
message: [Function],
disconnect: [Function] },
authToken: '76308cf591efe0fc229de6588fa1ec94',
uid: 0 },
'9ftb7jOE4yqNvsdVAAAD':
{ nsp:
{ name: '/',
server: [Object],
sockets: [Object],
connected: [Object],
fns: [],
ids: 0,
acks: {},
adapter: [Object],
_events: [Object] },
server:
{ nsps: [Object],
_path: '/socket.io',
_serveClient: true,
_adapter: [Function: Adapter],
_origins: '*:*',
sockets: [Object],
eio: [Object],
httpServer: [Object],
engine: [Object] },
adapter: { nsp: [Object], rooms: [Object], sids: [Object], encoder: {} },
id: '9ftb7jOE4yqNvsdVAAAD',
client:
{ server: [Object],
conn: [Object],
encoder: {},
decoder: [Object],
id: '9ftb7jOE4yqNvsdVAAAD',
request: [Object],
onclose: [Function],
ondata: [Function],
onerror: [Function],
ondecoded: [Function],
sockets: [Object],
nsps: [Object],
connectBuffer: [] },
conn:
{ id: '9ftb7jOE4yqNvsdVAAAD',
server: [Object],
upgraded: false,
readyState: 'open',
writeBuffer: [],
packetsFn: [],
sentCallbackFn: [],
request: [Object],
remoteAddress: '127.0.0.1',
checkIntervalTimer: null,
upgradeTimeoutTimer: null,
pingTimeoutTimer: [Object],
transport: [Object],
_events: [Object] },
rooms: [ '9ftb7jOE4yqNvsdVAAAD' ],
acks: {},
connected: true,
disconnected: false,
handshake:
{ headers: [Object],
time: 'Sun Dec 21 2014 19:47:51 GMT+0000 (GMT)',
address: '127.0.0.1',
xdomain: true,
secure: false,
issued: 1419191271624,
url: '/socket.io/?EIO=3&transport=polling&t=1419191271357-0',
query: [Object] },
_events:
{ authenticate: [Function],
message: [Function],
disconnect: [Function] } } }
Still there 9ftb7jOE4yqNvsdVAAAD
Auth - 4
socket.io:client writing packet {"type":2,"data":["message",{"type":"createChannel","data":"create","callback":"drupalchatNodejsMessageHandler"}],"nsp":"/"} +176ms
socket.io-parser encoding packet {"type":2,"data":["message",{"type":"createChannel","data":"create","callback":"drupalchatNodejsMessageHandler"}],"nsp":"/"} +8ms
socket.io-parser encoded {"type":2,"data":["message",{"type":"createChannel","data":"create","callback":"drupalchatNodejsMessageHandler"}],"nsp":"/"} as 2["message",{"type":"createChannel","data":"create","callback":"drupalchatNodejsMessageHandler"}] +0ms
engine:socket sending packet "message" (2["message",{"type":"createChannel","data":"create","callback":"drupalchatNodejsMessageHandler"}]) +8ms
engine:socket flushing buffer to transport +0ms
engine:polling writing " �42["message",{"type":"createChannel","data":"create","callback":"drupalchatNodejsMessageHandler"}]" +0ms
Sent message to client 9ftb7jOE4yqNvsdVAAAD
Added - 4
Added channels for uid 4: nodejs_user_4
setupClientConnection { '4': [] }