diff options
Diffstat (limited to 'src/gateway/util/Send.ts')
-rw-r--r-- | src/gateway/util/Send.ts | 32 |
1 files changed, 32 insertions, 0 deletions
diff --git a/src/gateway/util/Send.ts b/src/gateway/util/Send.ts new file mode 100644 index 00000000..7826dd40 --- /dev/null +++ b/src/gateway/util/Send.ts @@ -0,0 +1,32 @@ +let erlpack: any; +try { + erlpack = require("@yukikaze-bot/erlpack"); +} catch (error) { + console.log("Missing @yukikaze-bot/erlpack, electron-based desktop clients designed for discord.com will not be able to connect!"); +} +import { Payload, WebSocket } from "@fosscord/gateway"; + +export async function Send(socket: WebSocket, data: Payload) { + if (process.env.WS_VERBOSE) console.log(`[Websocket] Outgoing message: ${JSON.stringify(data)}`); + let buffer: Buffer | string; + if (socket.encoding === "etf") buffer = erlpack.pack(data); + // TODO: encode circular object + else if (socket.encoding === "json") buffer = JSON.stringify(data); + else return; + // TODO: compression + if (socket.deflate) { + socket.deflate.write(buffer); + socket.deflate.flush(); + return; + } + + return new Promise((res, rej) => { + if (socket.readyState !== 1) { + return rej("socket not open"); + } + socket.send(buffer, (err: any) => { + if (err) return rej(err); + return res(null); + }); + }); +} |