From 8a1f99b049f0ff7b38e72e10e0a9ae2587c88df8 Mon Sep 17 00:00:00 2001 From: hydrabolt Date: Sat, 29 Aug 2015 16:19:53 +0100 Subject: [PATCH] Added queue as a setup option --- lib/Client.js | 7 ++++++- src/Client.js | 9 +++++++-- 2 files changed, 13 insertions(+), 3 deletions(-) diff --git a/lib/Client.js b/lib/Client.js index 6f9ffb851..fa15db196 100644 --- a/lib/Client.js +++ b/lib/Client.js @@ -19,7 +19,7 @@ var WebSocket = require("ws"); var fs = require("fs"); var defaultOptions = { - cache_tokens: false + queue: false }; var Client = (function () { @@ -35,6 +35,7 @@ var Client = (function () { further efforts will be made to connect. */ this.options = options; + this.options.queue = this.options.queue || false; this.token = token; this.state = 0; this.websocket = null; @@ -60,6 +61,7 @@ var Client = (function () { this.serverCache = []; this.pmChannelCache = []; this.readyTime = null; + this.optionsQueue = {}; } _createClass(Client, [{ @@ -603,6 +605,9 @@ var Client = (function () { function send(destination) { + if (self.options.queue) { + //we're QUEUEING messages, so sending them sequentially based on servers. + } request.post(Endpoints.CHANNELS + "/" + destination + "/messages").set("authorization", self.token).send({ content: message, mentions: mentions diff --git a/src/Client.js b/src/Client.js index 21f5caa60..ff8057340 100644 --- a/src/Client.js +++ b/src/Client.js @@ -13,7 +13,7 @@ var WebSocket = require("ws"); var fs = require("fs"); var defaultOptions = { - cache_tokens: false + queue: false } class Client { @@ -25,6 +25,7 @@ class Client { further efforts will be made to connect. */ this.options = options; + this.options.queue = this.options.queue || false; this.token = token; this.state = 0; this.websocket = null; @@ -50,6 +51,7 @@ class Client { this.serverCache = []; this.pmChannelCache = []; this.readyTime = null; + this.optionsQueue = {}; } get uptime() { @@ -620,7 +622,10 @@ class Client { } function send(destination) { - + + if(self.options.queue){ + //we're QUEUEING messages, so sending them sequentially based on servers. + } request .post(`${Endpoints.CHANNELS}/${destination}/messages`) .set("authorization", self.token)