Skip to content

Commit

Permalink
Merge pull request #4787 from akhoury/rm-cls
Browse files Browse the repository at this point in the history
rm cls because it's not ready yet
  • Loading branch information
barisusakli committed Jun 27, 2016
2 parents 899ffa9 + 46a57f5 commit 4854f78
Show file tree
Hide file tree
Showing 6 changed files with 4 additions and 87 deletions.
1 change: 0 additions & 1 deletion app.js
Expand Up @@ -22,7 +22,6 @@

var nconf = require('nconf');
nconf.argv().env('__');
require('continuation-local-storage');

var url = require('url'),
async = require('async'),
Expand Down
1 change: 0 additions & 1 deletion package.json
Expand Up @@ -26,7 +26,6 @@
"connect-mongo": "~1.1.0",
"connect-multiparty": "^2.0.0",
"connect-redis": "~3.0.2",
"continuation-local-storage": "^3.1.6",
"cookie-parser": "^1.3.3",
"cron": "^1.0.5",
"csurf": "^1.6.1",
Expand Down
38 changes: 0 additions & 38 deletions src/middleware/cls.js

This file was deleted.

4 changes: 1 addition & 3 deletions src/middleware/index.js
Expand Up @@ -14,7 +14,6 @@ var meta = require('../meta'),
compression = require('compression'),
favicon = require('serve-favicon'),
session = require('express-session'),
cls = require('./cls'),
useragent = require('express-useragent');


Expand Down Expand Up @@ -62,7 +61,7 @@ module.exports = function(app) {
if (nconf.get('secure')) {
cookie.secure = true;
}

if (relativePath !== '') {
cookie.path = relativePath;
}
Expand All @@ -78,7 +77,6 @@ module.exports = function(app) {

app.use(middleware.addHeaders);
app.use(middleware.processRender);
app.use(cls.http);
auth.initialize(app, middleware);

return middleware;
Expand Down
29 changes: 0 additions & 29 deletions src/plugins/hooks.js
Expand Up @@ -7,29 +7,6 @@ module.exports = function(Plugins) {
Plugins.deprecatedHooks = {
'filter:user.custom_fields': null // remove in v1.1.0
};

Plugins.deprecatedHooksParams = {
'action:homepage.get': '{req, res}',
'filter:register.check': '{req, res}',
'action:user.loggedOut': '{req, res}',
'static:user.loggedOut': '{req, res}',
'filter:categories.build': '{req, res}',
'filter:category.build': '{req, res}',
'filter:group.build': '{req, res}',
'filter:register.build': '{req, res}',
'filter:composer.build': '{req, res}',
'filter:popular.build': '{req, res}',
'filter:recent.build': '{req, res}',
'filter:topic.build': '{req, res}',
'filter:users.build': '{req, res}',
'filter:admin.category.get': '{req, res}',
'filter:middleware.renderHeader': '{req, res}',
'filter:widget.render': '{req, res}',
'filter:middleware.buildHeader': '{req, locals}',
'action:middleware.pageView': '{req}',
'action:meta.override404': '{req}'
};

/*
`data` is an object consisting of (* is required):
`data.hook`*, the name of the NodeBB hook
Expand Down Expand Up @@ -62,12 +39,6 @@ module.exports = function(Plugins) {
parts.pop();
}
var hook = parts.join(':');
if (Plugins.deprecatedHooksParams[hook]) {
winston.warn('[plugins/' + id + '] Hook `' + hook + '` parameters: `' + Plugins.deprecatedHooksParams[hook] + '`, are being deprecated, '
+ 'all plugins should now use the `middleware/cls` module instead of hook\'s arguments to get a reference to the `http-request` or the `socket-request` object(s) (from which you can get the current `uid` if you need to.) '
+ '- for more info, visit https://docs.nodebb.org/en/latest/plugins/create.html#getting-a-reference-to-each-request-from-within-any-plugin-hook\n');
delete Plugins.deprecatedHooksParams[hook];
}
}

if (data.hook && data.method) {
Expand Down
18 changes: 3 additions & 15 deletions src/socket.io/index.js
Expand Up @@ -11,7 +11,6 @@ var url = require('url');
var db = require('../database');
var logger = require('../logger');
var ratelimit = require('../middleware/ratelimit');
var cls = require('../middleware/cls');

(function(Sockets) {
var Namespaces = {};
Expand All @@ -30,7 +29,6 @@ var cls = require('../middleware/cls');
io.use(authorize);

io.on('connection', onConnection);
io.on('disconnect', onDisconnect);

io.listen(server, {
transports: nconf.get('socket.io:transports')
Expand All @@ -44,14 +42,10 @@ var cls = require('../middleware/cls');

logger.io_one(socket, socket.uid);

cls.socket(socket, null, 'connection', function () {
onConnect(socket);
});
onConnect(socket);

socket.on('*', function (payload) {
cls.socket(socket, payload, null, function () {
onMessage(socket, payload);
});
onMessage(socket, payload);
});
}

Expand All @@ -64,12 +58,6 @@ var cls = require('../middleware/cls');
}
}

function onDisconnect(socket) {
cls.socket(socket, null, 'disconnect', function () {
});
}


function onMessage(socket, payload) {
if (!payload.data.length) {
return winston.warn('[socket.io] Empty payload');
Expand Down Expand Up @@ -235,4 +223,4 @@ var cls = require('../middleware/cls');
};
};

})(exports);
})(exports);

0 comments on commit 4854f78

Please sign in to comment.