2014-11-19 15:55:01 -05:00
|
|
|
'use strict';
|
2017-02-18 02:28:54 -07:00
|
|
|
|
2019-12-16 08:44:55 -05:00
|
|
|
const winston = require('winston');
|
2014-11-19 15:55:01 -05:00
|
|
|
|
2019-12-16 08:44:55 -05:00
|
|
|
const ratelimit = module.exports;
|
2014-11-19 15:55:01 -05:00
|
|
|
|
2019-12-16 08:44:55 -05:00
|
|
|
const allowedCalls = 100;
|
|
|
|
|
const timeframe = 10000;
|
2014-11-19 15:55:01 -05:00
|
|
|
|
2016-10-13 11:43:39 +02:00
|
|
|
ratelimit.isFlooding = function (socket) {
|
2014-11-19 15:55:01 -05:00
|
|
|
socket.callsPerSecond = socket.callsPerSecond || 0;
|
|
|
|
|
socket.elapsedTime = socket.elapsedTime || 0;
|
|
|
|
|
socket.lastCallTime = socket.lastCallTime || Date.now();
|
|
|
|
|
|
2017-02-18 01:12:18 -07:00
|
|
|
socket.callsPerSecond += 1;
|
2014-11-19 15:55:01 -05:00
|
|
|
|
2019-12-16 08:44:55 -05:00
|
|
|
const now = Date.now();
|
2014-11-19 15:55:01 -05:00
|
|
|
socket.elapsedTime += now - socket.lastCallTime;
|
|
|
|
|
|
2015-01-28 19:07:44 -05:00
|
|
|
if (socket.callsPerSecond > allowedCalls && socket.elapsedTime < timeframe) {
|
2021-02-03 23:59:08 -07:00
|
|
|
winston.warn(`Flooding detected! Calls : ${socket.callsPerSecond}, Duration : ${socket.elapsedTime}`);
|
2014-11-19 15:55:01 -05:00
|
|
|
return true;
|
|
|
|
|
}
|
|
|
|
|
|
2015-01-28 19:07:44 -05:00
|
|
|
if (socket.elapsedTime >= timeframe) {
|
2014-11-19 15:55:01 -05:00
|
|
|
socket.elapsedTime = 0;
|
|
|
|
|
socket.callsPerSecond = 0;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
socket.lastCallTime = now;
|
|
|
|
|
return false;
|
|
|
|
|
};
|