1 files changed, 49 insertions, 26 deletions
diff --git a/server/src/server.ts b/server/src/server.ts
index 74d901b..9a73f11 100644
--- a/server/src/server.ts
+++ b/server/src/server.ts
@@ -1,37 +1,60 @@
 import { Game } from "../../engine/Game";
 import { Floor, Player } from "../../engine/entities";
-import { WallBounds, Physics, Collision } from "../../engine/systems";
+import {
+  WallBounds,
+  Physics,
+  Collision,
+  MessageQueueProvider,
+  MessagePublisher,
+} from "../../engine/systems";
 import { Miscellaneous } from "../../engine/config";
 
 const TICK_RATE = 60 / 1000;
 
-const game = new Game();
+class Server {
+  private server: any;
+  private game: Game;
 
-[
-  new Physics(),
-  new Collision({ width: Miscellaneous.WIDTH, height: Miscellaneous.HEIGHT }),
-  new WallBounds(Miscellaneous.WIDTH),
-].forEach((system) => game.addSystem(system));
+  constructor() {
+    this.game = new Game();
 
-[new Floor(160), new Player()].forEach((entity) => game.addEntity(entity));
+    [
+      new Physics(),
+      new Collision({
+        width: Miscellaneous.WIDTH,
+        height: Miscellaneous.HEIGHT,
+      }),
+      new WallBounds(Miscellaneous.WIDTH),
+    ].forEach((system) => this.game.addSystem(system));
 
-game.start();
-setInterval(() => {
-  game.doGameLoop(performance.now());
-}, TICK_RATE);
+    [new Floor(160), new Player()].forEach((entity) =>
+      this.game.addEntity(entity),
+    );
 
-const server = Bun.serve<>({
-  port: 8080,
-  fetch(req, server) {
-    server.upgrade(req, {
-      data: {},
+    this.game.start();
+    setInterval(() => {
+      this.game.doGameLoop(performance.now());
+    }, TICK_RATE);
+
+    this.server = Bun.serve<any>({
+      websocket: {
+        open(ws) {
+          ws.subscribe("the-group-chat");
+          ws.publish("the-group-chat", msg);
+        },
+        message(ws, message) {
+          // this is a group chat
+          // so the server re-broadcasts incoming message to everyone
+          ws.publish("the-group-chat", `${ws.data.username}: ${message}`);
+        },
+        close(ws) {
+          const msg = `${ws.data.username} has left the chat`;
+          ws.unsubscribe("the-group-chat");
+          ws.publish("the-group-chat", msg);
+        },
+      },
     });
-  },
-  websocket: {
-    // handler called when a message is received
-    async message(ws, message) {
-      console.log(`Received ${message}`);
-    },
-  },
-});
-console.log(`Listening on localhost:${server.port}`);
+  }
+}
+
+new Server();