From f44f5d7ac2d24ff836c2e1d4b2fa58da04b13052 Mon Sep 17 00:00:00 2001 From: Madeline <46743919+MaddyUnderStars@users.noreply.github.com> Date: Sun, 25 Sep 2022 18:24:21 +1000 Subject: Refactor to mono-repo + upgrade packages --- src/gateway/util/Send.ts | 32 ++++++++++++++++++++++++++++++++ 1 file changed, 32 insertions(+) create mode 100644 src/gateway/util/Send.ts (limited to 'src/gateway/util/Send.ts') diff --git a/src/gateway/util/Send.ts b/src/gateway/util/Send.ts new file mode 100644 index 00000000..e1460846 --- /dev/null +++ b/src/gateway/util/Send.ts @@ -0,0 +1,32 @@ +var 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 function Send(socket: WebSocket, data: Payload) { + 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) { + buffer = socket.deflate.process(buffer) as Buffer; + } + + return new Promise((res, rej) => { + if (socket.readyState !== 1) { + // return rej("socket not open"); + socket.close(); + return; + } + + socket.send(buffer, (err: any) => { + if (err) return rej(err); + return res(null); + }); + }); +} -- cgit 1.5.1