From 60c8f3e6b2e7fc3b802d51222b4b0f5ae61ddd8c Mon Sep 17 00:00:00 2001 From: Madeline <46743919+MaddyUnderStars@users.noreply.github.com> Date: Sun, 21 Aug 2022 17:35:04 +1000 Subject: fosscord-server/pulls/858 --- gateway/src/util/Send.ts | 4 +--- gateway/src/util/WebSocket.ts | 3 ++- 2 files changed, 3 insertions(+), 4 deletions(-) (limited to 'gateway/src/util') diff --git a/gateway/src/util/Send.ts b/gateway/src/util/Send.ts index c4202b21..2a4aa5ef 100644 --- a/gateway/src/util/Send.ts +++ b/gateway/src/util/Send.ts @@ -14,9 +14,7 @@ export function Send(socket: WebSocket, data: Payload) { else return; // TODO: compression if (socket.deflate) { - socket.deflate.write(buffer); - socket.deflate.flush(); - return; + buffer = socket.deflate.process(buffer) as Buffer; } return new Promise((res, rej) => { diff --git a/gateway/src/util/WebSocket.ts b/gateway/src/util/WebSocket.ts index e3313f40..1ca90340 100644 --- a/gateway/src/util/WebSocket.ts +++ b/gateway/src/util/WebSocket.ts @@ -1,6 +1,6 @@ import { Intents, Permissions } from "@fosscord/util"; import WS from "ws"; -import { Deflate } from "zlib"; +import { Deflate, Inflate } from "fast-zlib"; export interface WebSocket extends WS { version: number; @@ -11,6 +11,7 @@ export interface WebSocket extends WS { shard_count?: bigint; shard_id?: bigint; deflate?: Deflate; + inflate?: Inflate; heartbeatTimeout: NodeJS.Timeout; readyTimeout: NodeJS.Timeout; intents: Intents; -- cgit 1.5.1