mirror of
https://github.com/discordjs/discord.js.git
synced 2026-03-10 00:23:30 +01:00
0baa59b679
* start rewrite * converted guilds * more changes * convert GuildMember * convert User and remove friend methods which kill people * convert more stuff * even more stuff * make things nicer * speed and fixes and stuff * almost finished * fix * Update Client.js * uwu * Update RESTMethods.js * message editing * fix router * fix issue with references * message delete reason * move message sending * fix dm * message splitting * NO MORE REST METHODS * Update Client.js * Update WebhookClient.js * remove all those endpoints from the constants * Update ClientUser.js * Update ClientUser.js * fixes * Update ClientUser.js * complaiancy * all sort of fixes * merge master (#1) * Fix Permissions now that member is deprecated (#1491) * removing more deprecation leftovers (#1492) * Fix MessageCollectors * Fix awaitMessages (#1493) * Fix MessageCollector#cleanup * Fix MessageCollector#postCheck * Add max option back for safety * Update Invite.js (#1496) * guild setPosition missing docs (#1498) * missing docs * update return docs * indent * switched .invites for the apirouter and invite.js * make multiple options an object * Update ClientUser.js * fix nicks * Update WebhookClient.js
74 lines
2.3 KiB
JavaScript
74 lines
2.3 KiB
JavaScript
const Constants = require('../util/Constants');
|
|
const WebSocketConnection = require('./websocket/WebSocketConnection');
|
|
|
|
/**
|
|
* Manages the state and background tasks of the client.
|
|
* @private
|
|
*/
|
|
class ClientManager {
|
|
constructor(client) {
|
|
/**
|
|
* The client that instantiated this Manager
|
|
* @type {Client}
|
|
*/
|
|
this.client = client;
|
|
|
|
/**
|
|
* The heartbeat interval
|
|
* @type {?number}
|
|
*/
|
|
this.heartbeatInterval = null;
|
|
}
|
|
|
|
/**
|
|
* The status of the client
|
|
* @type {number}
|
|
*/
|
|
get status() {
|
|
return this.connection ? this.connection.status : Constants.Status.IDLE;
|
|
}
|
|
|
|
/**
|
|
* Connects the client to the WebSocket.
|
|
* @param {string} token The authorization token
|
|
* @param {Function} resolve Function to run when connection is successful
|
|
* @param {Function} reject Function to run when connection fails
|
|
*/
|
|
connectToWebSocket(token, resolve, reject) {
|
|
this.client.emit(Constants.Events.DEBUG, `Authenticated using token ${token}`);
|
|
this.client.token = token;
|
|
const timeout = this.client.setTimeout(() => reject(new Error(Constants.Errors.TOOK_TOO_LONG)), 1000 * 300);
|
|
this.client.api.gateway.get().then(res => {
|
|
const protocolVersion = Constants.DefaultOptions.ws.version;
|
|
const gateway = `${res.url}/?v=${protocolVersion}&encoding=${WebSocketConnection.ENCODING}`;
|
|
this.client.emit(Constants.Events.DEBUG, `Using gateway ${gateway}`);
|
|
this.client.ws.connect(gateway);
|
|
this.client.ws.connection.once('close', event => {
|
|
if (event.code === 4004) reject(new Error(Constants.Errors.BAD_LOGIN));
|
|
if (event.code === 4010) reject(new Error(Constants.Errors.INVALID_SHARD));
|
|
if (event.code === 4011) reject(new Error(Constants.Errors.SHARDING_REQUIRED));
|
|
});
|
|
this.client.once(Constants.Events.READY, () => {
|
|
resolve(token);
|
|
this.client.clearTimeout(timeout);
|
|
});
|
|
}, reject);
|
|
}
|
|
|
|
destroy() {
|
|
this.client.ws.destroy();
|
|
this.client.rest.destroy();
|
|
if (!this.client.user) return Promise.resolve();
|
|
if (this.client.user.bot) {
|
|
this.client.token = null;
|
|
return Promise.resolve();
|
|
} else {
|
|
return this.client.api.logout.post().then(() => {
|
|
this.client.token = null;
|
|
});
|
|
}
|
|
}
|
|
}
|
|
|
|
module.exports = ClientManager;
|