From 6708160cec15ccd4a79979ed8ba79310fbd9285f Mon Sep 17 00:00:00 2001 From: Elizabeth Hunt Date: Tue, 5 Sep 2023 22:28:11 -0600 Subject: add compression to engine messages --- client/src/network/MessagePublisher.ts | 4 ++-- client/src/network/MessageQueueReceiver.ts | 6 ++++-- 2 files changed, 6 insertions(+), 4 deletions(-) (limited to 'client/src/network') diff --git a/client/src/network/MessagePublisher.ts b/client/src/network/MessagePublisher.ts index de105c5..c0aec28 100644 --- a/client/src/network/MessagePublisher.ts +++ b/client/src/network/MessagePublisher.ts @@ -1,5 +1,5 @@ import type { Message, MessagePublisher } from '@engine/network'; -import { stringify } from '@engine/utils'; +import { serialize } from '@engine/utils'; export class ClientSocketMessagePublisher implements MessagePublisher { private socket: WebSocket; @@ -17,7 +17,7 @@ export class ClientSocketMessagePublisher implements MessagePublisher { public publish() { if (this.socket.readyState == WebSocket.OPEN) { this.messages.forEach((message: Message) => - this.socket.send(stringify(message)) + this.socket.send(serialize(message)) ); this.messages = []; } diff --git a/client/src/network/MessageQueueReceiver.ts b/client/src/network/MessageQueueReceiver.ts index 46ca5cc..cb74cf7 100644 --- a/client/src/network/MessageQueueReceiver.ts +++ b/client/src/network/MessageQueueReceiver.ts @@ -10,8 +10,10 @@ export class ClientSocketMessageQueueProvider implements MessageQueueProvider { this.messages = []; this.socket.addEventListener('message', (e) => { - const messages = parse(e.data); - this.messages = this.messages.concat(messages); + e.data.arrayBuffer().then((buffer) => { + const messages = parse(new Uint8Array(buffer)); + this.messages = this.messages.concat(messages); + }); }); } -- cgit v1.2.3-70-g09d2