Add PartyKit

apps/web/package.json

@@ -95,9 +95,11 @@
     "use-debounce": "^10.0.1",
     "usehooks-ts": "^3.1.0",
     "vaul": "^0.9.1",
-    "zod": "^3.23.8"
+    "zod": "^3.23.8",
+    "partysocket": "1.0.2"
   },
   "devDependencies": {
-    "esbuild-register": "^3.5.0"
+    "esbuild-register": "^3.5.0",
+    "partykit": "0.0.111"
   }
 }

apps/web/party/index.ts

@@ -0,0 +1,31 @@
+import type * as Party from "partykit/server";
+
+export default class Server implements Party.Server {
+  constructor(readonly room: Party.Room) {}
+
+  onConnect(conn: Party.Connection, ctx: Party.ConnectionContext) {
+    // A websocket just connected!
+    console.log(
+      `Connected:
+  id: ${conn.id}
+  room: ${this.room.id}
+  url: ${new URL(ctx.request.url).pathname}`
+    );
+
+    // let's send a message to the connection
+    conn.send("hello from server");
+  }
+
+  onMessage(message: string, sender: Party.Connection) {
+    // let's log the message
+    console.log(`connection ${sender.id} sent message: ${message}`);
+    // as well as broadcast it to all the other connections in the room...
+    this.room.broadcast(
+      `${sender.id}: ${message}`,
+      // ...except for the connection it came from
+      [sender.id]
+    );
+  }
+}
+
+Server satisfies Party.Worker;

apps/web/partykit.json

@@ -0,0 +1,6 @@
+{
+  "$schema": "https://www.partykit.io/schema.json",
+  "name": "web-party",
+  "main": "party/index.ts",
+  "compatibilityDate": "2024-10-17"
+}