mirror of
https://github.com/discordjs/discord.js.git
synced 2026-03-09 16:13:31 +01:00
5519d6fbaa
* src: Step 1 of who knows how many * src: Remove accidentally committed test file * src: Remove useless added property in package.json * docs: Trailing spaces, come back >.> * src: Buhbye uws, we will miss you..not! * src: Move 'auto' shard selection from totalShardCount to shards * src: tweak * src: Filter out floats from shard IDs You want half of a shard or what? * src: Misc cleanup and bugfix for GUILD_BAN_ADD * src: Rewrite checkReady * src: Misse this while merging master into my branch * typings: Bring these up to date * typings: Forgot allReady event * src: Don't checkReady if the shard isn't waiting for guilds * src: Fix a possible bug for when the ws dies and the session becomes -1 * src: Hopefully fix last edge case that could case a shard to infinitely boot loop * src: Rename totalShardCount to shardCount * src: Small bugfix * src: Correct error message for shardCount being imvalid Co-Authored-By: bdistin <bdistin@gmail.com> * src: Small tweaks * src: If this doesn't fix the issues I'm gonna throw a brick at my PC * src: I swear, STOP BREAKING * src: *groans at a certain snake* * src: Use undefined instead of null on destroy in close event Setting it to null sets the close code to null, which causes a WebSocket error to be thrown. The error is thrown from WebSocket, although there is no connection alive. Fun times! * src: @SpaceEEC's requested changes * src: Remove zucc from discord.js Discord is removing support for it, sooo... Bye bye * src: Missed this * src: Apply @kyranet's suggestions Co-Authored-By: Antonio Román <kyradiscord@gmail.com> * src: @kyranet's suggestions * src: Remove pako, update debug messages - Pako is officially gone from both enviroments Install zlib-sync on node.js if you want it - Improve a few debug messages some more - Discover that internal sharding works in browsers but please don't do that
50 lines
1.3 KiB
JavaScript
50 lines
1.3 KiB
JavaScript
'use strict';
|
|
|
|
const { browser } = require('./util/Constants');
|
|
|
|
let erlpack;
|
|
|
|
try {
|
|
erlpack = require('erlpack');
|
|
if (!erlpack.pack) erlpack = null;
|
|
} catch {} // eslint-disable-line no-empty
|
|
|
|
let TextDecoder;
|
|
|
|
if (browser) {
|
|
TextDecoder = window.TextDecoder; // eslint-disable-line no-undef
|
|
exports.WebSocket = window.WebSocket; // eslint-disable-line no-undef
|
|
} else {
|
|
TextDecoder = require('util').TextDecoder;
|
|
exports.WebSocket = require('ws');
|
|
}
|
|
|
|
const ab = new TextDecoder();
|
|
|
|
exports.encoding = erlpack ? 'etf' : 'json';
|
|
|
|
exports.pack = erlpack ? erlpack.pack : JSON.stringify;
|
|
|
|
exports.unpack = (data, type) => {
|
|
if (exports.encoding === 'json' || type === 'json') {
|
|
if (typeof data !== 'string') {
|
|
data = ab.decode(data);
|
|
}
|
|
return JSON.parse(data);
|
|
}
|
|
if (!Buffer.isBuffer(data)) data = Buffer.from(new Uint8Array(data));
|
|
return erlpack.unpack(data);
|
|
};
|
|
|
|
exports.create = (gateway, query = {}, ...args) => {
|
|
const [g, q] = gateway.split('?');
|
|
query.encoding = exports.encoding;
|
|
query = new URLSearchParams(query);
|
|
if (q) new URLSearchParams(q).forEach((v, k) => query.set(k, v));
|
|
const ws = new exports.WebSocket(`${g}?${query}`, ...args);
|
|
if (browser) ws.binaryType = 'arraybuffer';
|
|
return ws;
|
|
};
|
|
|
|
for (const state of ['CONNECTING', 'OPEN', 'CLOSING', 'CLOSED']) exports[state] = exports.WebSocket[state];
|