From d24348ef0f53c80ad618056c45eda6c147525133 Mon Sep 17 00:00:00 2001 From: Flam3rboy <34555296+Flam3rboy@users.noreply.github.com> Date: Thu, 12 Aug 2021 20:18:05 +0200 Subject: :sparkles: gateway --- gateway/src/util/Send.ts | 28 ++++++++++++++++++++++++++++ 1 file changed, 28 insertions(+) create mode 100644 gateway/src/util/Send.ts (limited to 'gateway/src/util/Send.ts') diff --git a/gateway/src/util/Send.ts b/gateway/src/util/Send.ts new file mode 100644 index 00000000..be25ac4f --- /dev/null +++ b/gateway/src/util/Send.ts @@ -0,0 +1,28 @@ +var erlpack: any; +try { + erlpack = require("erlpack"); +} catch (error) {} +import { Payload } from "../util/Constants"; + +import WebSocket from "./WebSocket"; + +export async 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) { + socket.deflate.write(buffer); + socket.deflate.flush(); + return; + } + + return new Promise((res, rej) => { + socket.send(buffer, (err) => { + if (err) return rej(err); + return res(null); + }); + }); +} -- cgit 1.5.1