🎮 Playing Game

\n \n

\n Player: | \n Game ID: \n

\n\n

\n \n

🎭 My Pieces

\n \n

\n\n

\n \n

\n\n \n

Add New Piece

\n \n

\n\n \n

📸 Take Turn

\n \n \n\n

\n Processing turn...\n

\n\n \n

🤖 Latest Moves

\n \n

\n\n

📋

No moves yet. Take a photo to start!

\n\n \n

\n Connecting...\n

\n\n \n

Edit Instructions

\n \n

\n\n \n\n",[],[149,216],"40daa11e-8e95-11f0-8c91-0224a6c84d84","manage.html","40daa1be-8e95-11f0-8c91-0224a6c84d84",13,["D",1757543213773],"\n\n\n \n \n Manage Game - LLM Board Game Server\n \n \n\n\n

🎮 Game Manager

\n \n

\n Game ID: \n

\n\n \n

⚙️ Game Settings

\n \n

\n Include Previous Move Context\n

When enabled, pieces remember their last move

\n \n \n

\n \n

\n\n \n

📋 Game Rules

\n\n \n

🎭 Piece Types

\n \n

\n\n

\n \n

\n\n \n

Add New Piece Type

\n \n

\n\n \n

👥 Players

\n \n

\n\n \n

🔗 Quick Links

\n Join Game URL\n

\n \n \n

\n Clone Game\n \n

\n\n \n\n",[],[149,224],"224f28d2-8e95-11f0-815f-0224a6c84d84","join.html","224f2990-8e95-11f0-815f-0224a6c84d84",12,["D",1757543162530],"\n\n\n \n \n Join Game - LLM Board Game Server\n \n \n\n\n

Join Game

\n Game: \n

\n ID: \n

\n\n

Game Rules:

\n\n \n\n

🎉 Successfully Joined!

You can now play the game at:

\n \n

\n\n

\n ← Back to Home\n

\n\n

Current Players

Loading players...

\n\n \n\n",[],[149,232],"b56f26d4-8e96-11f0-8a3b-0224a6c84d84","index.html","144540d2-8e95-11f0-a049-0224a6c84d84",43,["D",1757543838843],"\n\n\n \n \n LLM Board Game Server\n \n \n\n\n

🎲 LLM Board Game Server

Let AI pieces play your physical board games

\n\n

How It Works

📋

1. Create Game

Set up rules and define piece types with unique personalities

📸

2. Take Photos

Upload board state photos to trigger AI moves

🤖

3. AI Plays

Each piece thinks independently and suggests moves

\n\n

Create New Game

\n \n \n\n

🎉 Game Created!

\n Game ID: \n

\n Join URL: \n \n

\n Manage URL: \n \n

\n \n \n \n

\n Redirecting to Game Manager in 3 seconds...\n

\n\n

Join Existing Game

\n \n

\n\n \n\n",[],[149,240],["D",1757543138975],[180,181,182,183],[149],"8f1c278a-8e95-11f0-bea3-0224a6c84d84","index.ts",21,["D",1757543345056],"// Main backend server using Hono\n\nimport { Hono } from \"https://esm.sh/hono@3.11.7\";\nimport { readFile, serveFile } from \"https://esm.town/v/std/utils@85-main/index.ts\";\nimport { runMigrations } from \"./database/migrations.ts\";\nimport { gameRoutes } from \"./routes/game.ts\";\nimport { apiRoutes } from \"./routes/api.ts\";\n\nconst app = new Hono();\n\n// Unwrap Hono errors to see original error details\napp.onError((err) => Promise.reject(err));\n\n// Initialize database\nawait runMigrations();\n\n// API routes\napp.route(\"/api\", apiRoutes);\n\n// Game routes\napp.route(\"/game\", gameRoutes);\n\n// Serve static files\napp.get(\"/frontend/*\", c => serveFile(c.req.path, import.meta.url));\napp.get(\"/shared/*\", c => serveFile(c.req.path, import.meta.url));\n\n// Homepage\napp.get(\"/\", async c => {\n let html = await readFile(\"/frontend/index.html\", import.meta.url);\n return c.html(html);\n});\n\n// 404 handler\napp.notFound(c => {\n return c.text(\"Not Found\", 404);\n});\n\nexport default app.fetch; // This is the entry point for HTTP vals",[],[155,251],"b4021544-8e97-11f0-b354-0224a6c84d84","websocket.ts","01a17f9a-8e95-11f0-8806-0224a6c84d84","76fcd33f-1c2f-46c2-b40d-80ecd71d4993",["D",1757544265960],"// Server-Sent Events handling for real-time updates\n\nimport type { SSEMessage } from \"../../shared/types.ts\";\nimport { normalizeGameId } from \"../../shared/utils.ts\";\n\n// Store active SSE connections by game ID\nconst gameConnections = new Map>();\n\n// Create SSE stream for a game\nexport function createSSEStream(gameId: string): ReadableStream {\n const normalizedGameId = normalizeGameId(gameId);\n \n return new ReadableStream({\n start(controller) {\n // Add connection to game\n if (!gameConnections.has(normalizedGameId)) {\n gameConnections.set(normalizedGameId, new Set());\n }\n gameConnections.get(normalizedGameId)!.add(controller);\n \n console.log(`SSE connected to game ${normalizedGameId}`);\n \n // Send initial connection message\n const connectMessage = `data: ${JSON.stringify({\n type: 'connected',\n data: { gameId: normalizedGameId }\n })}\\n\\n`;\n \n try {\n controller.enqueue(new TextEncoder().encode(connectMessage));\n } catch (error) {\n console.error(\"Error sending initial SSE message:\", error);\n }\n },\n \n cancel() {\n // Remove connection from game\n const connections = gameConnections.get(normalizedGameId);\n if (connections) {\n connections.delete(controller);\n console.log(`SSE disconnected from game ${normalizedGameId}`);\n \n // Clean up empty game connection sets\n if (connections.size === 0) {\n gameConnections.delete(normalizedGameId);\n }\n }\n }\n });\n}\n\n// Broadcast message to all connections in a game\nexport function broadcastToGame(gameId: string, message: SSEMessage) {\n const normalizedGameId = normalizeGameId(gameId);\n const connections = gameConnections.get(normalizedGameId);\n \n if (!connections || connections.size === 0) {\n return;\n }\n\n const messageStr = `data: ${JSON.stringify(message)}\\n\\n`;\n const messageBytes = new TextEncoder().encode(messageStr);\n const deadConnections = new Set();\n\n for (const controller of connections) {\n try {\n controller.enqueue(messageBytes);\n } catch (error) {\n console.error(\"Error sending SSE message:\", error);\n deadConnections.add(controller);\n }\n }\n\n // Clean up dead connections\n for (const deadController of deadConnections) {\n connections.delete(deadController);\n }\n\n // Clean up empty game connection sets\n if (connections.size === 0) {\n gameConnections.delete(normalizedGameId);\n }\n}\n\n// Get connection count for a game\nexport function getGameConnectionCount(gameId: string): number {\n const normalizedGameId = normalizeGameId(gameId);\n return gameConnections.get(normalizedGameId)?.size || 0;\n}",[],[155,265,258],"routes","faacff48-8e94-11f0-970e-0224a6c84d84","game.ts","faad0010-8e94-11f0-970e-0224a6c84d84",9,["D",1757543096036],"// Game page routes\n\nimport { Hono } from \"https://esm.sh/hono@3.11.7\";\nimport { readFile } from \"https://esm.town/v/std/utils@85-main/index.ts\";\nimport * as db from \"../database/queries.ts\";\nimport { normalizeGameId } from \"../../shared/utils.ts\";\n\nconst app = new Hono();\n\n// Join game page\napp.get(\"/:gameId\", async c => {\n try {\n const gameId = normalizeGameId(c.req.param(\"gameId\"));\n const game = await db.getGame(gameId);\n \n if (!game) {\n return c.html(`\n \n Game Not Found\n \n

Game Not Found

The game \"${gameId}\" does not exist.

\n ← Back to Home\n \n \n `, 404);\n }\n\n let html = await readFile(\"/frontend/join.html\", import.meta.url);\n \n // Inject game data\n const gameData = {\n id: gameId,\n name: game.name,\n rules: game.rules\n };\n \n const dataScript = ``;\n\n html = html.replace(\"\", `${dataScript}`);\n return c.html(html);\n } catch (error) {\n console.error(\"Error loading join page:\", error);\n return c.text(\"Internal Server Error\", 500);\n }\n});\n\n// Game management page\napp.get(\"/:gameId/manage/:managerId\", async c => {\n try {\n const gameId = normalizeGameId(c.req.param(\"gameId\"));\n const managerId = c.req.param(\"managerId\");\n \n const game = await db.getGame(gameId);\n \n if (!game) {\n return c.html(`\n \n Game Not Found\n \n

Game Not Found

The game \"${gameId}\" does not exist.

\n ← Back to Home\n \n \n `, 404);\n }\n\n if (game.manager_id !== managerId) {\n return c.html(`\n \n Unauthorized\n \n

Unauthorized

Invalid manager ID for this game.

\n ← Join Game Instead\n \n \n `, 403);\n }\n\n let html = await readFile(\"/frontend/manage.html\", import.meta.url);\n \n // Get full game data\n const pieceTypes = await db.getPieceTypes(gameId);\n const players = await db.getPlayers(gameId);\n \n const gameData = {\n game,\n pieceTypes,\n players,\n managerId\n };\n \n const dataScript = ``;\n\n html = html.replace(\"\", `${dataScript}`);\n return c.html(html);\n } catch (error) {\n console.error(\"Error loading manage page:\", error);\n return c.text(\"Internal Server Error\", 500);\n }\n});\n\n// Player game page\napp.get(\"/:gameId/play/:username\", async c => {\n try {\n const gameId = normalizeGameId(c.req.param(\"gameId\"));\n const username = c.req.param(\"username\");\n \n const game = await db.getGame(gameId);\n \n if (!game) {\n return c.html(`\n \n Game Not Found\n \n

Game Not Found

The game \"${gameId}\" does not exist.

\n ← Back to Home\n \n \n `, 404);\n }\n\n if (!await db.playerExists(gameId, username)) {\n return c.html(`\n \n Player Not Found\n \n

Player Not Found

Player \"${username}\" is not registered for this game.

\n ← Join Game\n \n \n `, 404);\n }\n\n let html = await readFile(\"/frontend/play.html\", import.meta.url);\n \n // Get game data\n const pieceTypes = await db.getPieceTypes(gameId);\n const pieces = await db.getPlayerPieces(gameId, username);\n const latestTurn = await db.getLatestTurn(gameId);\n \n let latestMoves = [];\n if (latestTurn) {\n const moves = await db.getTurnMoves(latestTurn.id);\n latestMoves = await Promise.all(moves.map(async move => {\n const pieceInfo = await db.getPieceWithTypeInfo(move.piece_id);\n return {\n ...move,\n piece_name: pieceInfo?.piece_type_name || \"Unknown\",\n player_username: pieceInfo?.player_username || \"Unknown\"\n };\n }));\n }\n \n const gameData = {\n game,\n pieceTypes,\n pieces,\n username,\n latestTurn,\n latestMoves\n };\n \n const dataScript = ``;\n\n html = html.replace(\"\", `${dataScript}`);\n return c.html(html);\n } catch (error) {\n console.error(\"Error loading play page:\", error);\n return c.text(\"Internal Server Error\", 500);\n }\n});\n\n// Clone game redirect\napp.get(\"/:gameId/clone\", async c => {\n const gameId = normalizeGameId(c.req.param(\"gameId\"));\n return c.redirect(`/api/games/${gameId}/clone`, 302);\n});\n\nexport { app as gameRoutes };",[],[155,265,267],"c1e36f02-8e95-11f0-b0da-0224a6c84d84","api.ts","ee6df8f4-8e94-11f0-ab07-0224a6c84d84",28,["D",1757543430239],7,"// API routes for game management\n\nimport { Hono } from \"https://esm.sh/hono@3.11.7\";\nimport { OpenAI } from \"https://esm.town/v/std/openai\";\nimport { blob } from \"https://esm.town/v/std/blob\";\nimport * as db from \"../database/queries.ts\";\nimport { generateGameId, isValidUsername, normalizeGameId, extractMoveFromResponse, createLLMPrompt } from \"../../shared/utils.ts\";\nimport type { CreateGameRequest, CreateGameResponse, CreatePieceTypeRequest, JoinGameRequest, CreatePieceRequest, UpdateInstructionsRequest } from \"../../shared/types.ts\";\n\nconst app = new Hono();\nconst openai = new OpenAI();\n\n// Create new game\napp.post(\"/games\", async c => {\n try {\n const { game_name, game_rules }: CreateGameRequest = await c.req.json();\n \n if (!game_name || !game_rules) {\n return c.json({ error: \"Game name and rules are required\" }, 400);\n }\n\n // Generate unique game ID\n let gameId: string;\n do {\n gameId = generateGameId();\n } while (await db.gameExists(gameId));\n\n const managerId = generateGameId();\n\n await db.createGame({\n id: gameId,\n name: game_name,\n rules: game_rules,\n manager_id: managerId,\n include_previous_move: false\n });\n\n const response: CreateGameResponse = {\n game_id: gameId,\n manager_id: managerId,\n game_url: `/game/${gameId}`,\n manage_url: `/game/${gameId}/manage/${managerId}`\n };\n\n return c.json(response);\n } catch (error) {\n console.error(\"Error creating game:\", error);\n return c.json({ error: \"Failed to create game\" }, 500);\n }\n});\n\n// Clone existing game\napp.post(\"/games/:gameId/clone\", async c => {\n try {\n const gameId = normalizeGameId(c.req.param(\"gameId\"));\n const existingGame = await db.getGame(gameId);\n \n if (!existingGame) {\n return c.json({ error: \"Game not found\" }, 404);\n }\n\n // Generate new IDs\n let newGameId: string;\n do {\n newGameId = generateGameId();\n } while (await db.gameExists(newGameId));\n\n const newManagerId = generateGameId();\n\n // Create new game with same rules\n await db.createGame({\n id: newGameId,\n name: `${existingGame.name} (Clone)`,\n rules: existingGame.rules,\n manager_id: newManagerId,\n include_previous_move: existingGame.include_previous_move\n });\n\n // Copy piece types\n const pieceTypes = await db.getPieceTypes(gameId);\n for (const pieceType of pieceTypes) {\n await db.createPieceType({\n game_id: newGameId,\n name: pieceType.name,\n description: pieceType.description\n });\n }\n\n const response: CreateGameResponse = {\n game_id: newGameId,\n manager_id: newManagerId,\n game_url: `/game/${newGameId}`,\n manage_url: `/game/${newGameId}/manage/${newManagerId}`\n };\n\n return c.json(response);\n } catch (error) {\n console.error(\"Error cloning game:\", error);\n return c.json({ error: \"Failed to clone game\" }, 500);\n }\n});\n\n// Get game info\napp.get(\"/games/:gameId\", async c => {\n try {\n const gameId = normalizeGameId(c.req.param(\"gameId\"));\n console.log(\"Looking for game:\", gameId);\n \n const game = await db.getGame(gameId);\n console.log(\"Found game:\", game);\n \n if (!game) {\n return c.json({ error: \"Game not found\" }, 404);\n }\n\n const pieceTypes = await db.getPieceTypes(gameId);\n const players = await db.getPlayers(gameId);\n\n return c.json({\n game,\n pieceTypes,\n players\n });\n } catch (error) {\n console.error(\"Error getting game:\", error);\n return c.json({ error: \"Failed to get game\" }, 500);\n }\n});\n\n// Create piece type\napp.post(\"/games/:gameId/piece-types\", async c => {\n try {\n const gameId = normalizeGameId(c.req.param(\"gameId\"));\n const { piece_name, piece_description }: CreatePieceTypeRequest = await c.req.json();\n \n if (!piece_name || !piece_description) {\n return c.json({ error: \"Piece name and description are required\" }, 400);\n }\n\n const game = await db.getGame(gameId);\n if (!game) {\n return c.json({ error: \"Game not found\" }, 404);\n }\n\n const pieceTypeId = await db.createPieceType({\n game_id: gameId,\n name: piece_name,\n description: piece_description\n });\n\n return c.json({ id: pieceTypeId });\n } catch (error) {\n console.error(\"Error creating piece type:\", error);\n return c.json({ error: \"Failed to create piece type\" }, 500);\n }\n});\n\n// Join game\napp.post(\"/games/:gameId/join\", async c => {\n try {\n const gameId = normalizeGameId(c.req.param(\"gameId\"));\n const { username }: JoinGameRequest = await c.req.json();\n \n if (!isValidUsername(username)) {\n return c.json({ error: \"Invalid username. Use alphanumeric characters only, no spaces.\" }, 400);\n }\n\n const game = await db.getGame(gameId);\n if (!game) {\n return c.json({ error: \"Game not found\" }, 404);\n }\n\n if (await db.playerExists(gameId, username)) {\n return c.json({ error: \"Username already taken in this game\" }, 409);\n }\n\n await db.createPlayer({\n game_id: gameId,\n username: username\n });\n\n return c.json({ success: true, play_url: `/game/${gameId}/play/${username}` });\n } catch (error) {\n console.error(\"Error joining game:\", error);\n return c.json({ error: \"Failed to join game\" }, 500);\n }\n});\n\n// Get player's pieces\napp.get(\"/games/:gameId/players/:username/pieces\", async c => {\n try {\n const gameId = normalizeGameId(c.req.param(\"gameId\"));\n const username = c.req.param(\"username\");\n \n if (!await db.playerExists(gameId, username)) {\n return c.json({ error: \"Player not found\" }, 404);\n }\n\n const pieces = await db.getPlayerPieces(gameId, username);\n const pieceTypes = await db.getPieceTypes(gameId);\n \n // Enrich pieces with type information\n const enrichedPieces = pieces.map(piece => {\n const pieceType = pieceTypes.find(pt => pt.id === piece.piece_type_id);\n return {\n ...piece,\n piece_type_name: pieceType?.name || \"Unknown\",\n piece_type_description: pieceType?.description || \"\"\n };\n });\n\n return c.json(enrichedPieces);\n } catch (error) {\n console.error(\"Error getting player pieces:\", error);\n return c.json({ error: \"Failed to get pieces\" }, 500);\n }\n});\n\n// Create piece\napp.post(\"/games/:gameId/players/:username/pieces\", async c => {\n try {\n const gameId = normalizeGameId(c.req.param(\"gameId\"));\n const username = c.req.param(\"username\");\n const { piece_type_id, instructions }: CreatePieceRequest = await c.req.json();\n \n if (!await db.playerExists(gameId, username)) {\n return c.json({ error: \"Player not found\" }, 404);\n }\n\n const pieceType = await db.getPieceType(piece_type_id);\n if (!pieceType || pieceType.game_id !== gameId) {\n return c.json({ error: \"Invalid piece type\" }, 400);\n }\n\n const pieceId = await db.createPiece({\n game_id: gameId,\n player_username: username,\n piece_type_id: piece_type_id,\n instructions: instructions || \"\",\n last_move: null\n });\n\n return c.json({ id: pieceId });\n } catch (error) {\n console.error(\"Error creating piece:\", error);\n return c.json({ error: \"Failed to create piece\" }, 500);\n }\n});\n\n// Update piece instructions\napp.put(\"/games/:gameId/pieces/:pieceId/instructions\", async c => {\n try {\n const gameId = normalizeGameId(c.req.param(\"gameId\"));\n const pieceId = parseInt(c.req.param(\"pieceId\"));\n const { instructions }: UpdateInstructionsRequest = await c.req.json();\n \n await db.updatePieceInstructions(pieceId, instructions || \"\");\n \n return c.json({ success: true });\n } catch (error) {\n console.error(\"Error updating instructions:\", error);\n return c.json({ error: \"Failed to update instructions\" }, 500);\n }\n});\n\n// Start turn (photo upload and LLM processing)\napp.post(\"/games/:gameId/turns\", async c => {\n try {\n const gameId = normalizeGameId(c.req.param(\"gameId\"));\n const initiatedBy = c.req.header(\"X-Username\") || \"unknown\";\n \n const formData = await c.req.formData();\n const photoFile = formData.get(\"photo\") as File;\n \n if (!photoFile) {\n return c.json({ error: \"Photo is required\" }, 400);\n }\n\n // Store photo in blob storage\n const photoKey = `game_${gameId}_turn_${Date.now()}`;\n const photoBuffer = await photoFile.arrayBuffer();\n const photoBase64 = btoa(String.fromCharCode(...new Uint8Array(photoBuffer)));\n await blob.setJSON(photoKey, { \n data: photoBase64, \n type: photoFile.type,\n name: photoFile.name \n });\n\n // Create snapshot of current game state\n const snapshot = await db.getGameSnapshot(gameId);\n \n // Create turn record\n const turnId = await db.createTurn({\n game_id: gameId,\n initiated_by: initiatedBy,\n photo_url: photoKey,\n snapshot_data: JSON.stringify(snapshot),\n status: 'processing'\n });\n\n // Broadcast turn started (placeholder for now)\n console.log(`Turn ${turnId} started by ${initiatedBy}`);\n\n // Process all pieces in parallel\n processTurnAsync(turnId, gameId, photoKey, snapshot);\n\n return c.json({ turn_id: turnId });\n } catch (error) {\n console.error(\"Error starting turn:\", error);\n return c.json({ error: \"Failed to start turn\" }, 500);\n }\n});\n\n// Get latest turn moves\napp.get(\"/games/:gameId/latest-moves\", async c => {\n try {\n const gameId = normalizeGameId(c.req.param(\"gameId\"));\n const latestTurn = await db.getLatestTurn(gameId);\n \n if (!latestTurn) {\n return c.json({ moves: [] });\n }\n\n const moves = await db.getTurnMoves(latestTurn.id);\n \n // Enrich moves with piece information\n const enrichedMoves = await Promise.all(moves.map(async move => {\n const pieceInfo = await db.getPieceWithTypeInfo(move.piece_id);\n return {\n ...move,\n piece_name: pieceInfo?.piece_type_name || \"Unknown\",\n player_username: pieceInfo?.player_username || \"Unknown\"\n };\n }));\n\n return c.json({ \n turn: latestTurn,\n moves: enrichedMoves \n });\n } catch (error) {\n console.error(\"Error getting latest moves:\", error);\n return c.json({ error: \"Failed to get moves\" }, 500);\n }\n});\n\n// Update game settings (manager only)\napp.put(\"/games/:gameId/settings\", async c => {\n try {\n const gameId = normalizeGameId(c.req.param(\"gameId\"));\n const managerId = c.req.header(\"X-Manager-Id\");\n const { include_previous_move } = await c.req.json();\n \n const game = await db.getGame(gameId);\n if (!game) {\n return c.json({ error: \"Game not found\" }, 404);\n }\n\n if (game.manager_id !== managerId) {\n return c.json({ error: \"Unauthorized\" }, 403);\n }\n\n await db.updateGameSettings(gameId, include_previous_move);\n \n return c.json({ success: true });\n } catch (error) {\n console.error(\"Error updating settings:\", error);\n return c.json({ error: \"Failed to update settings\" }, 500);\n }\n});\n\n// Async function to process turn\nasync function processTurnAsync(turnId: number, gameId: string, photoKey: string, snapshot: any) {\n try {\n const pieces = snapshot.pieces;\n const game = snapshot.game;\n \n // Get photo data\n const photoData = await blob.getJSON(photoKey);\n const photoBase64 = `data:${photoData.type};base64,${photoData.data}`;\n\n // Create moves for all pieces\n const movePromises = pieces.map(async (piece: any) => {\n const moveId = await db.createMove({\n turn_id: turnId,\n piece_id: piece.id,\n thinking_process: \"\",\n final_move: \"\",\n status: 'pending',\n error_message: null\n });\n\n return processPieceMove(moveId, piece, game, photoBase64, snapshot);\n });\n\n // Wait for all moves to complete\n await Promise.all(movePromises);\n\n // Update turn status\n await db.updateTurnStatus(turnId, 'completed');\n \n // Log completion\n console.log(`Turn ${turnId} completed`);\n\n } catch (error) {\n console.error(\"Error processing turn:\", error);\n await db.updateTurnStatus(turnId, 'error');\n }\n}\n\n// Process individual piece move\nasync function processPieceMove(moveId: number, piece: any, game: any, photoBase64: string, snapshot: any) {\n try {\n // Find piece type info\n const pieceType = snapshot.pieceTypes.find((pt: any) => pt.id === piece.piece_type_id);\n \n // Create LLM prompt context\n const context = {\n game_rules: game.rules,\n piece_name: pieceType?.name || \"Unknown Piece\",\n piece_description: pieceType?.description || \"\",\n player_instructions: piece.instructions || \"\",\n photo_url: photoBase64\n };\n\n // Add previous move if setting is enabled\n if (game.include_previous_move && piece.last_move) {\n context.previous_move = piece.last_move;\n }\n\n const prompt = createLLMPrompt(context);\n\n // Call OpenAI Vision API\n const completion = await openai.chat.completions.create({\n model: \"gpt-4o\",\n messages: [\n {\n role: \"user\",\n content: [\n { type: \"text\", text: prompt },\n { \n type: \"image_url\", \n image_url: { url: photoBase64 }\n }\n ]\n }\n ],\n max_tokens: 500\n });\n\n const response = completion.choices[0]?.message?.content || \"No response generated\";\n const { thinking, move } = extractMoveFromResponse(response);\n\n // Update move in database\n await db.updateMove(moveId, thinking, move, 'completed');\n\n // Update piece's last move if setting is enabled\n if (game.include_previous_move) {\n await db.updatePieceLastMove(piece.id, move);\n }\n\n // Log move update\n console.log(`Move completed for piece ${piece.id}: ${move}`);\n\n } catch (error) {\n console.error(`Error processing piece ${piece.id}:`, error);\n \n await db.updateMove(moveId, \"\", \"\", 'error', error.message);\n }\n}\n\nexport { app as apiRoutes };",[],[155,265,275],"ee6e1564-8e94-11f0-ab07-0224a6c84d84",8,["D",1757543075489],[175,176,177],[155,265],"8e878200-8e96-11f0-96da-0224a6c84d84","queries.ts","c82af890-8e94-11f0-8b25-0224a6c84d84","f9e21dfc-0457-4939-8ae2-29354305b557",40,["D",1757543773588],"// Database query functions\n\nimport { sqlite } from \"https://esm.town/v/stevekrouse/sqlite/main.tsx\";\nimport type { Game, PieceType, Player, Piece, Turn, Move } from \"../../shared/types.ts\";\n\n// Game queries\nexport async function createGame(game: Omit): Promise {\n await sqlite.execute(\n `INSERT INTO games (id, name, rules, manager_id, include_previous_move) \n VALUES (?, ?, ?, ?, ?)`,\n [game.id, game.name, game.rules, game.manager_id, game.include_previous_move]\n );\n}\n\nexport async function getGame(gameId: string): Promise {\n console.log(\"Querying for game ID:\", gameId);\n const result = await sqlite.execute(\n `SELECT * FROM games WHERE id = ?`,\n [gameId]\n );\n console.log(\"Query result:\", result);\n return result.rows && result.rows.length > 0 ? result.rows[0] as Game : null;\n}\n\nexport async function updateGameSettings(gameId: string, includePreviousMove: boolean): Promise {\n await sqlite.execute(\n `UPDATE games SET include_previous_move = ?, updated_at = CURRENT_TIMESTAMP WHERE id = ?`,\n [includePreviousMove, gameId]\n );\n}\n\nexport async function gameExists(gameId: string): Promise {\n const result = await sqlite.execute(\n `SELECT 1 FROM games WHERE id = ? LIMIT 1`,\n [gameId]\n );\n return result.rows && result.rows.length > 0;\n}\n\n// Piece type queries\nexport async function createPieceType(pieceType: Omit): Promise {\n const result = await sqlite.execute(\n `INSERT INTO piece_types (game_id, name, description) VALUES (?, ?, ?) RETURNING id`,\n [pieceType.game_id, pieceType.name, pieceType.description]\n );\n return result.rows[0].id as number;\n}\n\nexport async function getPieceTypes(gameId: string): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM piece_types WHERE game_id = ? ORDER BY created_at`,\n [gameId]\n );\n return result.rows as PieceType[];\n}\n\nexport async function getPieceType(id: number): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM piece_types WHERE id = ?`,\n [id]\n );\n return result.rows && result.rows.length > 0 ? result.rows[0] as PieceType : null;\n}\n\n// Player queries\nexport async function createPlayer(player: Omit): Promise {\n await sqlite.execute(\n `INSERT INTO players (game_id, username) VALUES (?, ?)`,\n [player.game_id, player.username]\n );\n}\n\nexport async function getPlayers(gameId: string): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM players WHERE game_id = ? ORDER BY joined_at`,\n [gameId]\n );\n return result.rows as Player[];\n}\n\nexport async function playerExists(gameId: string, username: string): Promise {\n const result = await sqlite.execute(\n `SELECT 1 FROM players WHERE game_id = ? AND username = ? LIMIT 1`,\n [gameId, username]\n );\n return result.rows && result.rows.length > 0;\n}\n\n// Piece queries\nexport async function createPiece(piece: Omit): Promise {\n const result = await sqlite.execute(\n `INSERT INTO pieces (game_id, player_username, piece_type_id, instructions, last_move) \n VALUES (?, ?, ?, ?, ?) RETURNING id`,\n [piece.game_id, piece.player_username, piece.piece_type_id, piece.instructions, piece.last_move]\n );\n return result.rows[0].id as number;\n}\n\nexport async function getPieces(gameId: string): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM pieces WHERE game_id = ? ORDER BY created_at`,\n [gameId]\n );\n return result.rows as Piece[];\n}\n\nexport async function getPlayerPieces(gameId: string, username: string): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM pieces WHERE game_id = ? AND player_username = ? ORDER BY created_at`,\n [gameId, username]\n );\n return result.rows as Piece[];\n}\n\nexport async function updatePieceInstructions(pieceId: number, instructions: string): Promise {\n await sqlite.execute(\n `UPDATE pieces SET instructions = ?, updated_at = CURRENT_TIMESTAMP WHERE id = ?`,\n [instructions, pieceId]\n );\n}\n\nexport async function updatePieceLastMove(pieceId: number, lastMove: string): Promise {\n await sqlite.execute(\n `UPDATE pieces SET last_move = ?, updated_at = CURRENT_TIMESTAMP WHERE id = ?`,\n [lastMove, pieceId]\n );\n}\n\n// Turn queries\nexport async function createTurn(turn: Omit): Promise {\n const result = await sqlite.execute(\n `INSERT INTO turns (game_id, initiated_by, photo_url, snapshot_data, status) \n VALUES (?, ?, ?, ?, ?) RETURNING id`,\n [turn.game_id, turn.initiated_by, turn.photo_url, turn.snapshot_data, turn.status]\n );\n return result.rows[0].id as number;\n}\n\nexport async function updateTurnStatus(turnId: number, status: string): Promise {\n const completedAt = status === 'completed' ? 'CURRENT_TIMESTAMP' : 'NULL';\n await sqlite.execute(\n `UPDATE turns SET status = ?, completed_at = ${completedAt} WHERE id = ?`,\n [status, turnId]\n );\n}\n\nexport async function getLatestTurn(gameId: string): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM turns WHERE game_id = ? ORDER BY created_at DESC LIMIT 1`,\n [gameId]\n );\n return result.rows && result.rows.length > 0 ? result.rows[0] as Turn : null;\n}\n\n// Move queries\nexport async function createMove(move: Omit): Promise {\n const result = await sqlite.execute(\n `INSERT INTO moves (turn_id, piece_id, thinking_process, final_move, status, error_message) \n VALUES (?, ?, ?, ?, ?, ?) RETURNING id`,\n [move.turn_id, move.piece_id, move.thinking_process, move.final_move, move.status, move.error_message]\n );\n return result.rows[0].id as number;\n}\n\nexport async function updateMove(moveId: number, thinkingProcess: string, finalMove: string, status: string, errorMessage?: string): Promise {\n await sqlite.execute(\n `UPDATE moves SET thinking_process = ?, final_move = ?, status = ?, error_message = ?, completed_at = CURRENT_TIMESTAMP WHERE id = ?`,\n [thinkingProcess, finalMove, status, errorMessage || null, moveId]\n );\n}\n\nexport async function getTurnMoves(turnId: number): Promise {\n const result = await sqlite.execute(\n `SELECT * FROM moves WHERE turn_id = ? ORDER BY created_at`,\n [turnId]\n );\n return result.rows as Move[];\n}\n\n// Complex queries for game state\nexport async function getGameSnapshot(gameId: string): Promise {\n const game = await getGame(gameId);\n const pieceTypes = await getPieceTypes(gameId);\n const pieces = await getPieces(gameId);\n \n return {\n game,\n pieceTypes,\n pieces\n };\n}\n\nexport async function getPieceWithTypeInfo(pieceId: number): Promise {\n const result = await sqlite.execute(`\n SELECT \n p.*,\n pt.name as piece_type_name,\n pt.description as piece_type_description\n FROM pieces p\n JOIN piece_types pt ON p.piece_type_id = pt.id\n WHERE p.id = ?\n `, [pieceId]);\n \n return result.rows && result.rows.length > 0 ? result.rows[0] : null;\n}",[],[155,297,289],"database","b601d526-8e94-11f0-9139-0224a6c84d84","migrations.ts","b601d5da-8e94-11f0-9139-0224a6c84d84",["D",1757542980823],"// Database schema migrations for LLM Board Game Server\n\nimport { sqlite } from \"https://esm.town/v/stevekrouse/sqlite/main.tsx\";\n\nexport async function runMigrations() {\n // Games table\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS games (\n id TEXT PRIMARY KEY,\n name TEXT NOT NULL,\n rules TEXT NOT NULL,\n manager_id TEXT NOT NULL,\n include_previous_move BOOLEAN DEFAULT FALSE,\n created_at DATETIME DEFAULT CURRENT_TIMESTAMP,\n updated_at DATETIME DEFAULT CURRENT_TIMESTAMP\n )\n `);\n\n // Piece types table\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS piece_types (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n game_id TEXT NOT NULL,\n name TEXT NOT NULL,\n description TEXT NOT NULL,\n created_at DATETIME DEFAULT CURRENT_TIMESTAMP,\n FOREIGN KEY (game_id) REFERENCES games (id) ON DELETE CASCADE\n )\n `);\n\n // Players table\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS players (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n game_id TEXT NOT NULL,\n username TEXT NOT NULL,\n joined_at DATETIME DEFAULT CURRENT_TIMESTAMP,\n FOREIGN KEY (game_id) REFERENCES games (id) ON DELETE CASCADE,\n UNIQUE (game_id, username)\n )\n `);\n\n // Pieces table\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS pieces (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n game_id TEXT NOT NULL,\n player_username TEXT NOT NULL,\n piece_type_id INTEGER NOT NULL,\n instructions TEXT DEFAULT '',\n last_move TEXT,\n created_at DATETIME DEFAULT CURRENT_TIMESTAMP,\n updated_at DATETIME DEFAULT CURRENT_TIMESTAMP,\n FOREIGN KEY (game_id) REFERENCES games (id) ON DELETE CASCADE,\n FOREIGN KEY (piece_type_id) REFERENCES piece_types (id) ON DELETE CASCADE,\n FOREIGN KEY (game_id, player_username) REFERENCES players (game_id, username) ON DELETE CASCADE\n )\n `);\n\n // Turns table\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS turns (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n game_id TEXT NOT NULL,\n initiated_by TEXT NOT NULL,\n photo_url TEXT NOT NULL,\n snapshot_data TEXT NOT NULL,\n status TEXT DEFAULT 'processing',\n created_at DATETIME DEFAULT CURRENT_TIMESTAMP,\n completed_at DATETIME,\n FOREIGN KEY (game_id) REFERENCES games (id) ON DELETE CASCADE\n )\n `);\n\n // Moves table\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS moves (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n turn_id INTEGER NOT NULL,\n piece_id INTEGER NOT NULL,\n thinking_process TEXT DEFAULT '',\n final_move TEXT DEFAULT '',\n status TEXT DEFAULT 'pending',\n error_message TEXT,\n created_at DATETIME DEFAULT CURRENT_TIMESTAMP,\n completed_at DATETIME,\n FOREIGN KEY (turn_id) REFERENCES turns (id) ON DELETE CASCADE,\n FOREIGN KEY (piece_id) REFERENCES pieces (id) ON DELETE CASCADE\n )\n `);\n\n // Create indexes for better performance\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_games_id ON games (id)`);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_piece_types_game_id ON piece_types (game_id)`);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_players_game_id ON players (game_id)`);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_pieces_game_id ON pieces (game_id)`);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_pieces_player ON pieces (game_id, player_username)`);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_turns_game_id ON turns (game_id)`);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_moves_turn_id ON moves (turn_id)`);\n\n console.log(\"Database migrations completed successfully\");\n}",[],[155,297,299],"b601e264-8e94-11f0-9139-0224a6c84d84",["D",1757542980823],[172,173],[155,297],["D",1757542980823],[171,174,178],[155],["D",1757539062598],{"_11":12,"_87":83},{"_11":12,"_81":-5,"_82":83,"_44":45,"_84":85,"_86":38},{"_29":30,"_13":26,"_20":21,"_27":28,"_31":-5,"_32":-5,"_76":-5,"_77":-5,"_78":-5,"_79":14,"_80":12},"ctx",{"_69":-5,"_109":349,"_350":351,"_352":353,"_354":38,"_355":38,"_356":38,"_357":49,"_358":-5,"_359":-7,"_360":-7,"_361":53,"_362":38,"_363":38,"_364":-5,"_365":38,"_366":38,"_367":38,"_368":-5},"ENV",{"_320":321,"_322":323,"_324":26,"_325":326,"_327":328,"_329":330,"_331":332,"_333":334,"_335":336,"_337":338,"_339":340,"_341":342,"_343":344,"_345":346,"_347":348},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","71c1b20804b3232a7e513be260cfffc1932a9e97","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Branches1

Branches
1