feat(client): add watcher

Author: Exeloo

apps/client/src/env.ts

@@ -13,3 +13,11 @@ export const getGameDir = () => {
   if (process.env.GAME_DIR) return process.env.GAME_DIR;
   throw new Error("GAME_DIR env variable not found");
 };
+
+export const getWatch = () => {
+  return process.env.WATCH;
+};
+
+export const getWatchPort = () => {
+  return process.env.WATCH_PORT;
+};

apps/client/src/server.ts

@@ -1,11 +1,23 @@
 import { join } from "node:path";
 
-import { getGameDir, getPort, getPublicEnv } from "./env";
+import { getGameDir, getPort, getPublicEnv, getWatch, getWatchPort } from "./env";
 import { updateManifest } from "./manifest";
+import { startWatch } from "./watch";
 
-export const MANIFEST: { version: string; files: { path: string }[] } = {
+type IManifest = {
+  version: string;
+  files: { path: string }[];
+  watch: { enable: false } | { enable: true; url: string };
+};
+
+const watch = getWatch() === "true";
+
+export const MANIFEST: IManifest = {
   version: "",
   files: [],
+  watch: {
+    enable: false,
+  },
 };
 
 const resolveWebDir = (str: string) => {
@@ -68,4 +80,6 @@ const server = Bun.serve({
   },
 });
 
-console.log(`Client started on port ${server.port}`);
+console.log(`Client started on url ${server.url.toString()}`);
+
+if (watch) startWatch(gameDir, getWatchPort());

apps/client/src/watch.ts

@@ -0,0 +1,38 @@
+import { watch } from "fs";
+
+import { MANIFEST } from "./server";
+
+export const startWatch = (gameDir: string, port?: string) => {
+  const server = Bun.serve({
+    port: port ?? 0,
+    fetch(req, server) {
+      if (server.upgrade(req)) {
+        return;
+      }
+      return new Response("Upgrade failed", { status: 500 });
+    },
+    websocket: {
+      message(ws) {
+        ws.send("not allowed");
+      },
+      open(ws) {
+        ws.subscribe("watch");
+      },
+      close(ws) {
+        ws.unsubscribe("watch");
+      },
+    },
+  });
+
+  MANIFEST.watch = {
+    enable: true,
+    url: server.url.toString(),
+  };
+
+  watch(gameDir, { recursive: true }, () => {
+    server.publish("watch", "update");
+    console.log(`Game updated`);
+  });
+
+  console.log(`Watcher started on url ${server.url.toString()}`);
+};

tsconfig.json

@@ -5,7 +5,6 @@
     // Type Checking
     "allowUnreachableCode": false,
     "allowUnusedLabels": false,
-    "exactOptionalPropertyTypes": true,
     "noFallthroughCasesInSwitch": true,
     "noImplicitOverride": true,
     "noImplicitReturns": true,