RanchiMall/flosight-api
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

making rate limiter work 3

Browse Source
This commit is contained in:
Manuel Araoz 2014-08-20 18:04:58 -04:00
parent 6e9edca86d
commit 5465f32111
3 changed files with 9 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
app/controllers/socket.js
View File

@ -10,13 +10,18 @@ module.exports.init = function(io_ext) {
if (ios) { if (ios) {
// when a new socket connects // when a new socket connects
ios.sockets.on('connection', function(socket) { ios.sockets.on('connection', function(socket) {
logger.debug('New connection from ' + socket.id); logger.verbose('New connection from ' + socket.id);
// when it subscribes, make it join the according room // when it subscribes, make it join the according room
socket.on('subscribe', function(topic) { socket.on('subscribe', function(topic) {
logger.debug('subscribe to ' + topic); logger.debug('subscribe to ' + topic);
socket.join(topic); socket.join(topic);
}); });
// disconnect handler
socket.on('disconnect', function() {
logger.verbose('disconnected ' + socket.id);
});
}); });
} }
return ios; return ios;
@ -65,4 +70,3 @@ module.exports.broadcastSyncInfo = function(historicSync) {
if (ios) if (ios)
ios.sockets.in('sync').emit('status', historicSync); ios.sockets.in('sync').emit('status', historicSync);
}; };

8
plugins/mailbox.js
View File

@ -11,7 +11,7 @@ module.exports.init = function(ext_io, config) {
io.sockets.on('connection', function(socket) { io.sockets.on('connection', function(socket) {
// when it requests sync, send him all pending messages // when it requests sync, send him all pending messages
socket.on('sync', function(ts) { socket.on('sync', function(ts) {
logger.debug('Sync requested by ' + socket.id); logger.verbose('Sync requested by ' + socket.id);
logger.debug(' from timestamp ' + ts); logger.debug(' from timestamp ' + ts);
var rooms = socket.rooms; var rooms = socket.rooms;
if (rooms.length !== 2) { if (rooms.length !== 2) {
@ -25,7 +25,7 @@ module.exports.init = function(ext_io, config) {
if (err) { if (err) {
throw new Error('Couldn\'t get messages on sync request: ' + err); throw new Error('Couldn\'t get messages on sync request: ' + err);
} }
logger.debug('\tFound ' + messages.length + ' message' + (messages.length !== 1 ? 's' : '')); logger.verbose('\tFound ' + messages.length + ' message' + (messages.length !== 1 ? 's' : ''));
for (var i = 0; i < messages.length; i++) { for (var i = 0; i < messages.length; i++) {
broadcastMessage(messages[i], socket); broadcastMessage(messages[i], socket);
} }
@ -42,10 +42,6 @@ module.exports.init = function(ext_io, config) {
}); });
}); });
// disconnect handler
socket.on('disconnect', function() {
logger.debug('disconnected ' + socket.id);
});
}); });
mdb.on('message', broadcastMessage); mdb.on('message', broadcastMessage);

3
plugins/ratelimiter.js
View File

@ -10,9 +10,8 @@ module.exports.init = function(app, config) {
config = config || {}; config = config || {};
config.whitelistRPH = config.whitelistRPH || 5000; config.whitelistRPH = config.whitelistRPH || 5000;
config.normalRPH = config.normalRPH || 2; config.normalRPH = config.normalRPH || 500;
config.blacklistRPH = config.blacklistRPH || 0; config.blacklistRPH = config.blacklistRPH || 0;
console.log(config);
app.use(limiter({ app.use(limiter({
whitelist: [], whitelist: [],