Notify UI of snake movements.

game/package.json

@@ -24,6 +24,7 @@
     "@temporalio/client": "^1.10.2",
     "@temporalio/worker": "^1.10.2",
     "@temporalio/workflow": "^1.10.2",
+    "node-fetch": "^3.3.2",
     "yargs": "^17.7.2"
   },
   "devDependencies": {

game/src/activities.ts

@@ -1,4 +1,17 @@
+import { Snake } from './workflows';
+import fetch from 'node-fetch';
+
 export async function snakeWork(durationMs: number) {
     // sleep for duration
     await new Promise((resolve) => setTimeout(resolve, durationMs));
+}
+
+export async function snakeMovedNotification(snake: Snake) {
+    await fetch(`http://localhost:1234/snake/${snake.id}/moved`, {
+        method: 'POST',
+        headers: {
+            'Content-Type': 'application/json',
+        },
+        body: JSON.stringify(snake.segments),
+    });
 }

game/src/starter.ts

@@ -1,11 +1,12 @@
 import { Client } from '@temporalio/client';
+import { WorkflowIdReusePolicy } from '@temporalio/workflow';
 import { GameWorkflow, PlayerWorkflow, roundStartUpdate, snakeChangeDirectionSignal, playerWaitForRoundUpdate, playerJoinTeamUpdate } from './workflows';
 
 export async function runWorkflows(client: Client, taskQueue: string, numWorkflows: number): Promise<void> {
   // Players can be created at any time. They will wait for a game to start if one is not active.
   const playerHandles = await Promise.all(
     Array.from({ length: 4 }).map(
-      (_, i) => client.workflow.start(PlayerWorkflow, { taskQueue, workflowId: `player-${i}`})
+      (_, i) => client.workflow.start(PlayerWorkflow, { taskQueue, workflowId: `player-${i}` })
     )
   );
 

game/src/workflows.ts

@@ -1,5 +1,5 @@
 import {
-  proxyActivities, defineSignal, setHandler, condition, defineUpdate,
+  proxyActivities, proxyLocalActivities, defineSignal, setHandler, condition, defineUpdate,
   log, startChild, workflowInfo, sleep, getExternalWorkflowHandle
 } from '@temporalio/workflow';
 
@@ -13,6 +13,10 @@ const { snakeWork } = proxyActivities<typeof activities>({
   startToCloseTimeout: '1 seconds',
 });
 
+const { snakeMovedNotification } = proxyLocalActivities<typeof activities>({
+  startToCloseTimeout: '1 seconds',
+});
+
 type GameConfig = {
   width: number;
   height: number;
@@ -56,7 +60,7 @@ type Segment = {
   length: number;
 }
 
-type Snake = {
+export type Snake = {
   team: Team;
   id: string;
   segments: Segment[];
@@ -271,6 +275,8 @@ export async function GameWorkflow(config: GameConfig): Promise<void> {
     const snake = moveSnake(game, id, direction);
 
     log.info('Snake moved', { snake: id, direction: direction });
+
+    await snakeMovedNotification(snake);
   });
 
   let gameFinished = false;