Nemcio/NodeBB
1
0
Fork 0
mirror of https://github.com/NodeBB/NodeBB.git synced 2025-11-06 22:15:48 +01:00
Code Issues Packages Projects Releases Wiki Activity

adding cls back in socketio index

Browse Source
This commit is contained in:
Aziz Khoury
2016-04-15 16:45:04 -04:00
parent 4f3a962f7f
commit 807e3a9d7e
1 changed files with 12 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
src/socket.io/index.js
View File

@@ -10,6 +10,7 @@ var winston = require('winston');
var db = require('../database'); var db = require('../database');
var logger = require('../logger'); var logger = require('../logger');
var ratelimit = require('../middleware/ratelimit'); var ratelimit = require('../middleware/ratelimit');
var cls = require('../middleware/cls');
var Sockets = {}; var Sockets = {};
var Namespaces = {}; var Namespaces = {};
@@ -29,6 +30,7 @@ Sockets.init = function(server) {
io.use(authorize); io.use(authorize);
io.on('connection', onConnection); io.on('connection', onConnection);
io.on('disconnect', onDisconnect);
io.listen(server, { io.listen(server, {
transports: nconf.get('socket.io:transports') transports: nconf.get('socket.io:transports')
@@ -42,11 +44,15 @@ function onConnection(socket) {
logger.io_one(socket, socket.uid); logger.io_one(socket, socket.uid);
cls.socket(socket, null, 'connection', function() {
onConnect(socket); onConnect(socket);
});
socket.on('*', function(payload) { socket.on('*', function(payload) {
cls.socket(socket, payload, null, function() {
onMessage(socket, payload); onMessage(socket, payload);
}); });
});
} }
function onConnect(socket) { function onConnect(socket) {
@@ -58,6 +64,10 @@ function onConnect(socket) {
} }
} }
function onDisconnect(socket) {
cls.socket(socket, null, 'disconnect', function() {});
}
function onMessage(socket, payload) { function onMessage(socket, payload) {
if (!payload.data.length) { if (!payload.data.length) {