create singleplayer game record rest endpoints

src/core/Schemas.ts

@@ -176,7 +176,7 @@ const IntentSchema = z.union([
     BuildUnitIntentSchema,
 ]);
 
-const TurnSchema = z.object({
+export const TurnSchema = z.object({
     turnNumber: z.number(),
     gameID: z.string(),
     intents: z.array(IntentSchema)

src/server/Server.ts

@@ -4,12 +4,14 @@ import { WebSocketServer } from 'ws';
 import path from 'path';
 import { fileURLToPath } from 'url';
 import { GameManager } from './GameManager';
-import { ClientMessage, ClientMessageSchema } from '../core/Schemas';
+import { ClientMessage, ClientMessageSchema, GameRecord, GameRecordSchema, Turn, TurnSchema } from '../core/Schemas';
 import { getConfig } from '../core/configuration/Config';
 import { LogSeverity, slog } from './StructuredLog';
 import { Client } from './Client';
 import { GamePhase, GameServer } from './GameServer';
 import { v4 as uuidv4 } from 'uuid';
+import { z } from 'zod';
+import { ProcessGameRecord } from '../core/Util';
 
 const __filename = fileURLToPath(import.meta.url);
 const __dirname = path.dirname(__filename);
@@ -21,7 +23,9 @@ const wss = new WebSocketServer({ server });
 // Serve static files from the 'out' directory
 app.use(express.static(path.join(__dirname, '../../out')));
 app.use(express.json())
+
 const gm = new GameManager(getConfig())
+const privateGames = new Map<string, GameRecord>()
 
 // New GET endpoint to list lobbies
 app.get('/lobbies', (req, res) => {
@@ -42,6 +46,70 @@ app.post('/private_lobby', (req, res) => {
     });
 });
 
+app.post('/new_private_game_record', (req, res) => {
+    try {
+        // Validate the complete game record sent by client
+        const gameRecord = GameRecordSchema.parse(req.body);
+        privateGames.set(gameRecord.id, gameRecord);
+
+        slog('new_private_game_record', 'Created new private game record', { id: gameRecord.id }, LogSeverity.DEBUG);
+        res.json({ id: gameRecord.id });
+    } catch (error) {
+        slog('new_private_game_record', 'Failed to create new private game record', { error }, LogSeverity.ERROR);
+        res.status(400).json({ error: 'Invalid game record format' });
+    }
+});
+
+app.put('/add_single_player_game_turn', (req, res) => {
+    const { gameId, turns } = req.body;
+
+    try {
+        const gameRecord = privateGames.get(gameId);
+        if (!gameRecord) {
+            res.status(404).json({ error: 'Game record not found' });
+            return;
+        }
+
+        // Validate the array of turns
+        const validatedTurns = z.array(TurnSchema).parse(turns);
+
+        // Add the turns to the game record's turns
+        gameRecord.turns.push(...validatedTurns);
+        privateGames.set(gameId, gameRecord);
+
+        res.json({ success: true, numTurns: validatedTurns.length });
+    } catch (error) {
+        slog('add_single_player_game_turn', 'Failed to add turns', { error, gameId }, LogSeverity.ERROR);
+        res.status(400).json({ error: 'Invalid turns format' });
+    }
+});
+
+app.put('/complete_single_player_game_record/:id', (req, res) => {
+    const gameId = req.params.id;
+    try {
+        let gameRecord = privateGames.get(gameId);
+        if (!gameRecord) {
+            res.status(404).json({ error: 'Game record not found' });
+            return;
+        }
+
+        gameRecord.endTimestampMS = Date.now();
+
+        gameRecord = ProcessGameRecord(gameRecord)
+        // TODO: send to gcs
+
+        GameRecordSchema.parse(gameRecord);
+
+        res.json({
+            success: true,
+            durationSeconds: gameRecord.durationSeconds
+        });
+    } catch (error) {
+        slog('complete_single_player_game_record', 'Failed to complete game record', { error, gameId }, LogSeverity.ERROR);
+        res.status(400).json({ error: 'Invalid game record format' });
+    }
+})
+
 app.post('/start_private_lobby/:id', (req, res) => {
     console.log(`starting private lobby with id ${req.params.id}`)
     gm.startPrivateGame(req.params.id)