diff options
Diffstat (limited to 'server/src')
-rw-r--r-- | server/src/network/MessagePublisher.ts | 4 | ||||
-rw-r--r-- | server/src/server.ts | 10 |
2 files changed, 7 insertions, 7 deletions
diff --git a/server/src/network/MessagePublisher.ts b/server/src/network/MessagePublisher.ts index 9c6011f..0b8340e 100644 --- a/server/src/network/MessagePublisher.ts +++ b/server/src/network/MessagePublisher.ts @@ -1,7 +1,7 @@ import { Message, MessagePublisher } from '@engine/network'; import { Server } from 'bun'; import { Constants } from '../constants'; -import { stringify } from '@engine/utils'; +import { serialize } from '@engine/utils'; export class ServerSocketMessagePublisher implements MessagePublisher { private server?: Server; @@ -23,7 +23,7 @@ export class ServerSocketMessagePublisher implements MessagePublisher { public publish() { if (this.messages.length) { - this.server?.publish(Constants.GAME_TOPIC, stringify(this.messages)); + this.server?.publish(Constants.GAME_TOPIC, serialize(this.messages)); this.messages = []; } diff --git a/server/src/server.ts b/server/src/server.ts index 251fd89..b99380b 100644 --- a/server/src/server.ts +++ b/server/src/server.ts @@ -10,11 +10,10 @@ import { Session, SessionManager } from './network'; -import { parse } from '@engine/utils'; +import { parse, serialize } from '@engine/utils'; import { Server, ServerWebSocket } from 'bun'; import { Input } from '@engine/systems'; import { Control, NetworkUpdateable } from '@engine/components'; -import { stringify } from '@engine/utils'; export class GameServer { private server?: Server; @@ -44,7 +43,8 @@ export class GameServer { websocket: { open: (ws) => this.openWebsocket(ws), message: (ws, msg) => { - if (typeof msg === 'string') this.websocketMessage(ws, msg); + if (typeof msg !== 'string') + this.websocketMessage(ws, new Uint8Array(msg)); }, close: (ws) => this.closeWebsocket(ws) } @@ -57,7 +57,7 @@ export class GameServer { private websocketMessage( websocket: ServerWebSocket<SessionData>, - message: string + message: Uint8Array ) { const receivedMessage = parse<ServerMessage>(message); receivedMessage.sessionData = websocket.data; @@ -117,7 +117,7 @@ export class GameServer { }) } ]; - websocket.sendText(stringify(addCurrentEntities)); + websocket.sendBinary(serialize(addCurrentEntities)); const addNewPlayer: Message = { type: MessageType.NEW_ENTITIES, |