Nomchy/discord.js
1
0
Fork 0
mirror of https://github.com/discordjs/discord.js.git synced 2026-03-20 21:43:33 +01:00
Code Issues Packages Projects Releases Wiki Activity

Preparing for major API change, added authorisation param to request

Browse Source
This commit is contained in:
hydrabolt
2015-09-12 16:00:38 +01:00
parent 8b88fd1ea5
commit c4d9405f64
2 changed files with 129 additions and 132 deletions
Download Patch File Download Diff File Expand all files Collapse all files

31
lib/Client.js
View File

@@ -148,7 +148,7 @@ var Client = (function () {
self.state = 2; //set state to logged in (not yet ready)
self.token = res.body.token; //set our token
getGateway().then(function (url) {
self.getGateway().then(function (url) {
self.createws(url);
callback(null, self.token);
resolve(self.token);
@@ -1600,6 +1600,20 @@ var Client = (function () {
})();
}
}
}, {
key: "getGateway",
value: function getGateway() {
var self = this;
return new Promise(function (resolve, reject) {
request.get(Endpoints.API + "/gateway").set("authorization", self.token).end(function (err, res) {
if (err) {
reject(err);
} else {
resolve(res.body.url);
}
});
});
}
}, {
key: "uptime",
get: function get() {
@@ -1668,19 +1682,4 @@ var Client = (function () {
return Client;
})();
function getGateway() {
var self = this;
return new Promise(function (resolve, reject) {
request.get(Endpoints.API + "/gateway").end(function (err, res) {
if (err) {
reject(err);
} else {
resolve(res.body.url);
}
});
});
}
module.exports = Client;

68
src/Client.js
View File

@@ -153,7 +153,7 @@ class Client {
if (err) {
self.state = 4; //set state to disconnected
self.trigger("disconnected");
if(self.websocket){
if (self.websocket) {
self.websocket.close();
}
callback(err);
@@ -162,7 +162,7 @@ class Client {
self.state = 2; //set state to logged in (not yet ready)
self.token = res.body.token; //set our token
getGateway().then(function (url) {
self.getGateway().then(function (url) {
self.createws(url);
callback(null, self.token);
resolve(self.token);
@@ -367,7 +367,7 @@ class Client {
return new Promise(function (response, reject) {
if(typeof tts === "function"){
if (typeof tts === "function") {
// tts is a function, which means the developer wants this to be the callback
callback = tts;
tts = false;
@@ -392,7 +392,7 @@ class Client {
}
function remove() {
if(self.options.queue){
if (self.options.queue) {
if (!self.queue[message.channel.id]) {
self.queue[message.channel.id] = [];
}
@@ -404,18 +404,18 @@ class Client {
});
self.checkQueue(message.channel.id);
}else{
} else {
self._deleteMessage(message).then(good).catch(bad);
}
}
function good(){
function good() {
prom.success = true;
callback(null);
resolve();
}
function bad(err){
function bad(err) {
prom.error = err;
callback(err);
reject(err);
@@ -433,7 +433,7 @@ class Client {
content = (content instanceof Array ? content.join("\n") : content);
if(self.options.queue){
if (self.options.queue) {
if (!self.queue[message.channel.id]) {
self.queue[message.channel.id] = [];
}
@@ -446,17 +446,17 @@ class Client {
});
self.checkQueue(message.channel.id);
}else{
} else {
self._updateMessage(message, content).then(good).catch(bad);
}
function good(msg){
function good(msg) {
prom.message = msg;
callback(null, msg);
resolve(msg);
}
function bad(error){
function bad(error) {
prom.error = error;
callback(error);
reject(error);
@@ -611,7 +611,7 @@ class Client {
self.resolveDestination(destination).then(send).catch(bad);
function send(destination) {
if(self.options.queue){
if (self.options.queue) {
//queue send file too
if (!self.queue[destination]) {
self.queue[destination] = [];
@@ -619,14 +619,14 @@ class Client {
self.queue[destination].push({
action: "sendFile",
attachment : fstream,
attachmentName : fileName,
attachment: fstream,
attachmentName: fileName,
then: good,
error: bad
});
self.checkQueue(destination);
}else{
} else {
//not queue
self._sendFile(destination, fstream, fileName).then(good).catch(bad);
}
@@ -656,7 +656,7 @@ class Client {
var prom = new Promise(function (resolve, reject) {
if(typeof tts === "function"){
if (typeof tts === "function") {
// tts is a function, which means the developer wants this to be the callback
callback = tts;
tts = false;
@@ -682,7 +682,7 @@ class Client {
action: "sendMessage",
content: message,
mentions: mentions,
tts : !!tts, //incase it's not a boolean
tts: !!tts, //incase it's not a boolean
then: mgood,
error: mbad
});
@@ -1179,7 +1179,7 @@ class Client {
.send({
content: content,
mentions: mentions,
tts : tts
tts: tts
})
.end(function (err, res) {
@@ -1208,11 +1208,11 @@ class Client {
}
_sendFile(destination, attachment, attachmentName = "DEFAULT BECAUSE YOU DIDN'T SPECIFY WHY.png"){
_sendFile(destination, attachment, attachmentName = "DEFAULT BECAUSE YOU DIDN'T SPECIFY WHY.png") {
var self = this;
return new Promise(function(resolve, reject){
return new Promise(function (resolve, reject) {
request
.post(`${Endpoints.CHANNELS}/${destination}/messages`)
.set("authorization", self.token)
@@ -1237,9 +1237,9 @@ class Client {
}
_updateMessage(message, content){
_updateMessage(message, content) {
var self = this;
return new Promise(function(resolve, reject){
return new Promise(function (resolve, reject) {
request
.patch(`${Endpoints.CHANNELS}/${message.channel.id}/messages/${message.id}`)
.set("authorization", self.token)
@@ -1259,9 +1259,9 @@ class Client {
});
}
_deleteMessage(message){
_deleteMessage(message) {
var self = this;
return new Promise(function(resolve, reject){
return new Promise(function (resolve, reject) {
request
.del(`${Endpoints.CHANNELS}/${message.channel.id}/messages/${message.id}`)
@@ -1309,12 +1309,12 @@ class Client {
case "sendFile":
var fileToSend = queuedEvent;
self._sendFile(channelID, fileToSend.attachment, fileToSend.attachmentName)
.then(function (msg){
.then(function (msg) {
fileToSend.then(msg);
self.queue[channelID].shift();
doNext();
})
.catch(function(err){
.catch(function (err) {
fileToSend.error(err);
self.queue[channelID].shift();
doNext();
@@ -1323,12 +1323,12 @@ class Client {
case "updateMessage":
var msgToUpd = queuedEvent;
self._updateMessage(msgToUpd.message, msgToUpd.content)
.then(function(msg){
.then(function (msg) {
msgToUpd.then(msg);
self.queue[channelID].shift();
doNext();
})
.catch(function(err){
.catch(function (err) {
msgToUpd.error(err);
self.queue[channelID].shift();
doNext();
@@ -1337,12 +1337,12 @@ class Client {
case "deleteMessage":
var msgToDel = queuedEvent;
self._deleteMessage(msgToDel.message)
.then(function(msg){
.then(function (msg) {
msgToDel.then(msg);
self.queue[channelID].shift();
doNext();
})
.catch(function(err){
.catch(function (err) {
msgToDel.error(err);
self.queue[channelID].shift();
doNext();
@@ -1360,15 +1360,13 @@ class Client {
}
}
}
}
function getGateway() {
getGateway() {
var self = this;
return new Promise(function (resolve, reject) {
request
.get(`${Endpoints.API}/gateway`)
.set("authorization", self.token)
.end(function (err, res) {
if (err) {
reject(err);
@@ -1377,7 +1375,7 @@ function getGateway() {
}
});
});
}
}
module.exports = Client;