summaryrefslogtreecommitdiff
path: root/server/src
diff options
context:
space:
mode:
Diffstat (limited to 'server/src')
-rw-r--r--server/src/network/MessagePublisher.ts4
-rw-r--r--server/src/server.ts10
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,