Use socket.io for Temporal -> Svelte updates.

game/package.json

@@ -24,7 +24,7 @@
     "@temporalio/client": "^1.10.2",
     "@temporalio/worker": "^1.10.2",
     "@temporalio/workflow": "^1.10.2",
-    "undici": "^6.19.8",
+    "socket.io-client": "^4.7.5",
     "yargs": "^17.7.2"
   },
   "devDependencies": {

game/src/activities.ts

@@ -1,40 +1,17 @@
 import { Snake, Round } from './workflows';
-import { request, Agent } from 'undici';
+import { io } from 'socket.io-client';
 
-const agent = new Agent({
-    keepAliveTimeout: 10,
-    keepAliveMaxTimeout: 10
-});
+const socket = io('http://localhost:5173');
 
 export async function snakeWork(durationMs: number) {
     // sleep for duration
     await new Promise((resolve) => setTimeout(resolve, durationMs));
 }
 
 export async function snakeMovedNotification(snake: Snake) {
-    await request(`http://localhost:5173/api/signal`, {
-        dispatcher: agent,
-        method: 'POST',
-        headers: {
-            'Content-Type': 'application/json',
-        },
-        body: JSON.stringify({
-            action: 'snakeMoved',
-            snake: snake,
-        })
-    });
+    socket.emit('snakeMoved', snake);
 }
 
 export async function roundUpdateNotification(round: Round) {
-    await request(`http://localhost:5173/api/game`, {
-        dispatcher: agent,
-        method: 'POST',
-        headers: {
-            'Content-Type': 'application/json',
-        },
-        body: JSON.stringify({
-            action: 'roundUpdate',
-            round: { ...round, stale: undefined },
-        })
-    });
+    socket.emit('roundUpdate', { ...round, stale: undefined });
 }

snakes/src/routes/[id]/round/+page.svelte

@@ -32,8 +32,7 @@
 	function connectSocket() {
 		socket = io();
 
-		socket.on('snakeMoved', (newData) => {
-			const newSnake = newData.snake;
+		socket.on('snakeMoved', (newSnake) => {
 			if (newSnake.id === 'red-0') {
 				SnakeRed1.redraw(newSnake);
 			} else if (newSnake.id === 'red-1') {

snakes/vite.config.ts

@@ -9,8 +9,13 @@ const webSocketServer = {
 
 		const io = new Server(server.httpServer);
 		globalThis.io = io;
-		io.on('connection', (connection) => {
-			connection.emit('eventFromServer', '✅ Connected');
+		io.on('connection', (socket) => {
+			socket.on('snakeMoved', (snake) => {
+				io.emit('snakeMoved', snake);
+			});
+			socket.on('roundUpdate', (round) => {
+				io.emit('roundUpdate', round);
+			});
 		});
 	}
 };