diff --git a/src/client/websocket/WebSocketConnection.js b/src/client/websocket/WebSocketConnection.js index 493e4b3c4..436988a4d 100644 --- a/src/client/websocket/WebSocketConnection.js +++ b/src/client/websocket/WebSocketConnection.js @@ -82,6 +82,7 @@ class WebSocketConnection extends EventEmitter { this.ratelimit = { queue: [], remaining: 60, + total: 60, resetTimer: null, }; this.connect(gateway); @@ -190,9 +191,9 @@ class WebSocketConnection extends EventEmitter { processQueue() { if (this.ratelimit.remaining === 0) return; if (this.ratelimit.queue.length === 0) return; - if (this.ratelimit.remaining === 120) { + if (this.ratelimit.remaining === this.ratelimit.total) { this.ratelimit.resetTimer = this.client.setTimeout(() => { - this.ratelimit.remaining = 60; + this.ratelimit.remaining = this.ratelimit.total; this.processQueue(); }, 120e3); } @@ -276,6 +277,7 @@ class WebSocketConnection extends EventEmitter { this.packetManager.handleQueue(); this.ws = null; this.status = Constants.Status.DISCONNECTED; + this.ratelimit.remaining = this.ratelimit.total; return true; }