From 8d619605166f3ebad6947f32d3f7fdcb0c8d3867 Mon Sep 17 00:00:00 2001
From: Skillz4Killz <23035000+Skillz4Killz@users.noreply.github.com>
Date: Fri, 17 Dec 2021 18:26:29 +0000
Subject: [PATCH] fix: compression issue

---
 src/ws/handleOnMessage.ts | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git a/src/ws/handleOnMessage.ts b/src/ws/handleOnMessage.ts
index 9e0f13227..f99454104 100644
--- a/src/ws/handleOnMessage.ts
+++ b/src/ws/handleOnMessage.ts
@@ -14,9 +14,10 @@ import { decompressWith } from "./deps.ts";
 /** Handler for handling every message event from websocket. */
 // deno-lint-ignore no-explicit-any
 export async function handleOnMessage(gateway: GatewayManager, message: any, shardId: number) {
-
-  if (gateway.compress && message instanceof Uint8Array) {
-    message = decompressWith(message, 0, (slice: Uint8Array) => gateway.utf8decoder.decode(slice));
+  if (gateway.compress && message instanceof Blob) {
+    message = decompressWith(new Uint8Array(await message.arrayBuffer()), 0, (slice: Uint8Array) =>
+      gateway.utf8decoder.decode(slice)
+    );
   }
 
   if (typeof message !== "string") return;