Tweak rate limiting on the playlist

channel.js

@@ -1227,11 +1227,20 @@ Channel.prototype.tryQueue = function(user, data) {
         return;
     }
 
-    if(user.rank < Rank.Moderator
+    var limit = {
-            && this.leader != user
+        burst: 3,
-            && user.noflood("queue", 3)) {
+        sustained: 1
-        return;
+    };
-    } else if (user.rank < Rank.Siteadmin && user.noflood("queue", 0.5)) {
+
+    if (user.rank >= Rank.Moderator || this.leader == user) {
+        limit = {
+            burst: 10,
+            sustained: 2
+        };
+    }
+
+    if (user.queueLimiter.throttle(limit)) {
+        user.socket.emit("queueFail", "You are adding videos too quickly");
         return;
     }
 

user.js

@@ -31,6 +31,7 @@ var User = function(socket, Server) {
     this.muted = false;
     this.throttle = {};
     this.flooded = {};
+    this.queueLimiter = $util.newRateLimiter();
     this.profile = {
         image: "",
         text: ""

utilities.js

@@ -48,10 +48,55 @@ module.exports = {
         s = "" + (sec % 60);
         if(s.length < 2)
             s = "0" + s;
-        
+
         if(h === "")
             return [m, s].join(":");
 
         return [h, m, s].join(":");
+    },
+
+    newRateLimiter: function () {
+        return {
+            count: 0,
+            lastTime: 0,
+            throttle: function (opts) {
+                if (typeof opts === "undefined")
+                    opts = {};
+
+                var burst = +opts.burst,
+                    sustained = +opts.sustained,
+                    cooldown = +opts.cooldown;
+
+                if (isNaN(burst))
+                    burst = 10;
+
+                if (isNaN(sustained))
+                    sustained = 2;
+
+                if (isNaN(cooldown))
+                    cooldown = burst / sustained;
+
+                // Haven't reached burst cap yet, allow
+                if (this.count < burst) {
+                    this.count++;
+                    this.lastTime = Date.now();
+                    return false;
+                }
+
+                // Cooled down, allow and clear buffer
+                if (this.lastTime < Date.now() - cooldown*1000) {
+                    this.count = 0;
+                    this.lastTime = Date.now();
+                    return false;
+                }
+
+                var diff = Date.now() - this.lastTime;
+                if (diff < 1000/sustained)
+                    return true;
+
+                this.lastTime = Date.now();
+                return false;
+            }
+        };
     }
 };