[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_158":159,"_160":161},"routes/_app.x.$handle.$name",{"_98":97,"_32":45,"_106":88,"_27":107,"_13":14,"_108":-5,"_11":109,"_110":111,"_112":113,"_114":115,"_116":117,"_20":-5,"_118":-5,"_119":-5,"_120":25,"_121":122,"_123":124,"_125":-5,"_126":-5,"_127":128},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":-5,"_57":25,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":69,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":81,"_82":83,"_84":85,"_86":25},"version",15,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","main.js","latestPath","fileId","4280c750-1b26-11f1-9a62-42dde27851f2","name","fileType","http","content","// Top-down multiplayer shooter prototype for Val Town without WebSockets.\n// Transport model: POST for client input, SSE for server->client state stream.\n\nconst TICK_MS = 50; // 20Hz\nconst WORLD_W = 1400;\nconst WORLD_H = 900;\nconst PLAYER_SPEED = 220;\nconst PLAYER_RADIUS = 14;\nconst BULLET_SPEED = 620;\nconst BULLET_RADIUS = 4;\nconst BULLET_TTL_MS = 1200;\nconst FIRE_COOLDOWN_MS = 140;\nconst HIT_DAMAGE = 34;\nconst MAX_HP = 100;\nconst ROOM_IDLE_MS = 1000 * 60 * 20;\nconst PLAYER_IDLE_MS = 1000 * 30;\nconst EVENT_BUFFER_SIZE = 200;\n\nconst rooms = new Map();\nlet loopStarted = false;\n\nfunction now() {\n return Date.now();\n}\n\nfunction clamp(n, min, max) {\n return Math.min(max, Math.max(min, n));\n}\n\nfunction round(n, digits = 1) {\n const factor = 10 ** digits;\n return Math.round(n * factor) / factor;\n}\n\nfunction randomId() {\n return crypto.randomUUID().slice(0, 12);\n}\n\nfunction randomSpawn() {\n return {\n x: 80 + Math.random() * (WORLD_W - 160),\n y: 80 + Math.random() * (WORLD_H - 160),\n };\n}\n\nfunction randomColor() {\n const palette = [\"#ef4444\", \"#22c55e\", \"#3b82f6\", \"#eab308\", \"#f97316\", \"#a855f7\", \"#14b8a6\"];\n return palette[Math.floor(Math.random() * palette.length)];\n}\n\nfunction withCors(headers = {}) {\n return {\n \"access-control-allow-origin\": \"*\",\n \"access-control-allow-methods\": \"GET,HEAD,POST,OPTIONS\",\n \"access-control-allow-headers\": \"content-type,authorization\",\n ...headers,\n };\n}\n\nfunction json(data, status = 200) {\n return new Response(JSON.stringify(data), {\n status,\n headers: withCors({ \"content-type\": \"application/json; charset=utf-8\" }),\n });\n}\n\nfunction parseBody(req) {\n return req.json().catch(() => null);\n}\n\nfunction getRoom(roomId) {\n let room = rooms.get(roomId);\n if (!room) {\n room = {\n id: roomId,\n players: new Map(),\n inputs: new Map(),\n bullets: [],\n sseClients: new Map(),\n eventId: 0,\n events: [],\n lastActiveAt: now(),\n metrics: {\n tickCount: 0,\n lastTickDurationMs: 0,\n peakTickDurationMs: 0,\n lastStateAt: 0,\n },\n };\n rooms.set(roomId, room);\n }\n room.lastActiveAt = now();\n return room;\n}\n\nfunction emitEvent(room, event, payload) {\n room.eventId += 1;\n const frame = `id: ${room.eventId}\\nevent: ${event}\\ndata: ${JSON.stringify(payload)}\\n\\n`;\n room.events.push({ id: room.eventId, frame });\n if (room.events.length > EVENT_BUFFER_SIZE) room.events.shift();\n\n for (const [playerId, client] of room.sseClients) {\n try {\n client.controller.enqueue(client.encoder.encode(frame));\n client.lastSentAt = now();\n } catch {\n room.sseClients.delete(playerId);\n }\n }\n}\n\nfunction startLoop() {\n if (loopStarted) return;\n loopStarted = true;\n\n setInterval(() => {\n const t = now();\n\n for (const [roomId, room] of rooms) {\n const tickStartedAt = performance.now();\n\n // Cleanup stale players.\n for (const [playerId, p] of room.players) {\n if (t - p.lastInputAt > PLAYER_IDLE_MS) {\n room.players.delete(playerId);\n room.inputs.delete(playerId);\n room.sseClients.delete(playerId);\n emitEvent(room, \"leave\", { playerId });\n }\n }\n\n // Advance players from latest inputs.\n for (const [playerId, p] of room.players) {\n const input = room.inputs.get(playerId) || { mx: 0, my: 0, aim: 0, shoot: false };\n const len = Math.hypot(input.mx, input.my) || 1;\n const mx = len > 1 ? input.mx / len : input.mx;\n const my = len > 1 ? input.my / len : input.my;\n\n p.aim = Number.isFinite(input.aim) ? input.aim : p.aim;\n\n p.x = clamp(p.x + mx * PLAYER_SPEED * (TICK_MS / 1000), PLAYER_RADIUS, WORLD_W - PLAYER_RADIUS);\n p.y = clamp(p.y + my * PLAYER_SPEED * (TICK_MS / 1000), PLAYER_RADIUS, WORLD_H - PLAYER_RADIUS);\n\n if (input.shoot && p.hp > 0 && t - p.lastShotAt >= FIRE_COOLDOWN_MS) {\n const r = (p.aim * Math.PI) / 180;\n const dx = Math.cos(r);\n const dy = Math.sin(r);\n room.bullets.push({\n id: randomId(),\n ownerId: playerId,\n x: p.x + dx * (PLAYER_RADIUS + 8),\n y: p.y + dy * (PLAYER_RADIUS + 8),\n vx: dx * BULLET_SPEED,\n vy: dy * BULLET_SPEED,\n expiresAt: t + BULLET_TTL_MS,\n });\n p.lastShotAt = t;\n }\n }\n\n // Advance bullets and resolve hits.\n const nextBullets = [];\n for (const b of room.bullets) {\n if (t >= b.expiresAt) continue;\n\n b.x += b.vx * (TICK_MS / 1000);\n b.y += b.vy * (TICK_MS / 1000);\n\n if (b.x < 0 || b.x > WORLD_W || b.y < 0 || b.y > WORLD_H) continue;\n\n let hit = false;\n for (const [targetId, p] of room.players) {\n if (targetId === b.ownerId || p.hp <= 0) continue;\n const d = Math.hypot(p.x - b.x, p.y - b.y);\n if (d <= PLAYER_RADIUS + BULLET_RADIUS) {\n p.hp = Math.max(0, p.hp - HIT_DAMAGE);\n hit = true;\n if (p.hp === 0) {\n const killer = room.players.get(b.ownerId);\n if (killer) killer.score += 1;\n const spawn = randomSpawn();\n p.x = spawn.x;\n p.y = spawn.y;\n p.hp = MAX_HP;\n emitEvent(room, \"frag\", { killerId: b.ownerId, victimId: targetId });\n }\n break;\n }\n }\n\n if (!hit) nextBullets.push(b);\n }\n room.bullets = nextBullets;\n\n const tickDurationMs = round(performance.now() - tickStartedAt, 2);\n room.metrics.tickCount += 1;\n room.metrics.lastTickDurationMs = tickDurationMs;\n room.metrics.peakTickDurationMs = Math.max(room.metrics.peakTickDurationMs, tickDurationMs);\n room.metrics.lastStateAt = t;\n\n // Broadcast current state at tick rate.\n const players = [];\n for (const [id, p] of room.players) {\n players.push({\n id,\n name: p.name,\n x: round(p.x, 1),\n y: round(p.y, 1),\n aim: round(p.aim, 1),\n hp: p.hp,\n score: p.score,\n color: p.color,\n });\n }\n\n const bullets = room.bullets.map((b) => ({\n id: b.id,\n x: round(b.x, 1),\n y: round(b.y, 1),\n }));\n\n emitEvent(room, \"state\", {\n roomId,\n ts: t,\n world: { w: WORLD_W, h: WORLD_H },\n players,\n bullets,\n metrics: {\n tickMs: TICK_MS,\n tickCount: room.metrics.tickCount,\n tickDurationMs: room.metrics.lastTickDurationMs,\n peakTickDurationMs: room.metrics.peakTickDurationMs,\n players: room.players.size,\n bullets: room.bullets.length,\n streamClients: room.sseClients.size,\n bufferedEvents: room.events.length,\n totalRooms: rooms.size,\n },\n });\n\n // Remove truly idle empty rooms.\n if (room.players.size === 0 && t - room.lastActiveAt > ROOM_IDLE_MS) {\n rooms.delete(roomId);\n }\n }\n }, TICK_MS);\n}\n\nfunction validateAuth(room, playerId, token) {\n const p = room.players.get(playerId);\n if (!p) return false;\n return p.token === token;\n}\n\nasync function handleJoin(req) {\n const body = await parseBody(req);\n if (!body || !body.roomId) {\n return json({ ok: false, error: \"Missing roomId\" }, 400);\n }\n\n const roomId = String(body.roomId).slice(0, 64);\n const name = String(body.name || \"player\").slice(0, 20);\n const room = getRoom(roomId);\n\n const playerId = randomId();\n const token = randomId() + randomId();\n const spawn = randomSpawn();\n\n room.players.set(playerId, {\n id: playerId,\n token,\n name,\n x: spawn.x,\n y: spawn.y,\n aim: 0,\n hp: MAX_HP,\n score: 0,\n color: randomColor(),\n lastShotAt: 0,\n lastInputAt: now(),\n });\n room.inputs.set(playerId, { mx: 0, my: 0, aim: 0, shoot: false, seq: 0 });\n\n emitEvent(room, \"join\", { playerId, name, spawn });\n\n return json({\n ok: true,\n roomId,\n playerId,\n token,\n tickMs: TICK_MS,\n world: { w: WORLD_W, h: WORLD_H },\n });\n}\n\nasync function handleInput(req) {\n const body = await parseBody(req);\n if (!body || !body.roomId || !body.playerId || !body.token) {\n return json({ ok: false, error: \"Missing roomId/playerId/token\" }, 400);\n }\n\n const room = rooms.get(String(body.roomId));\n if (!room) return json({ ok: false, error: \"Room not found\" }, 404);\n\n const playerId = String(body.playerId);\n const token = String(body.token);\n if (!validateAuth(room, playerId, token)) return json({ ok: false, error: \"Unauthorized\" }, 401);\n\n const mx = clamp(Number(body.mx) || 0, -1, 1);\n const my = clamp(Number(body.my) || 0, -1, 1);\n const aim = Number(body.aim) || 0;\n const shoot = Boolean(body.shoot);\n const seq = Number(body.seq) || 0;\n\n const prev = room.inputs.get(playerId);\n if (prev && seq < prev.seq) {\n return json({ ok: true, dropped: true });\n }\n\n room.inputs.set(playerId, { mx, my, aim, shoot, seq });\n\n const p = room.players.get(playerId);\n if (p) p.lastInputAt = now();\n\n return json({ ok: true });\n}\n\nfunction handleStream(req) {\n const url = new URL(req.url);\n const roomId = url.searchParams.get(\"roomId\") || \"\";\n const playerId = url.searchParams.get(\"playerId\") || \"\";\n const token = url.searchParams.get(\"token\") || \"\";\n\n if (!roomId || !playerId || !token) {\n return json({ ok: false, error: \"Missing roomId/playerId/token\" }, 400);\n }\n\n const room = rooms.get(roomId);\n if (!room) return json({ ok: false, error: \"Room not found\" }, 404);\n if (!validateAuth(room, playerId, token)) return json({ ok: false, error: \"Unauthorized\" }, 401);\n\n const encoder = new TextEncoder();\n const lastEventIdRaw = req.headers.get(\"last-event-id\") || \"0\";\n const lastEventId = Number(lastEventIdRaw) || 0;\n\n const stream = new ReadableStream({\n start(controller) {\n room.sseClients.set(playerId, { controller, encoder, lastSentAt: now() });\n\n const hello = `event: hello\\ndata: ${JSON.stringify({ ok: true, roomId, playerId, ts: now() })}\\n\\n`;\n controller.enqueue(encoder.encode(hello));\n\n // Replay buffered events after reconnect.\n for (const ev of room.events) {\n if (ev.id > lastEventId) controller.enqueue(encoder.encode(ev.frame));\n }\n\n const keepAlive = setInterval(() => {\n try {\n controller.enqueue(encoder.encode(`: keepalive ${now()}\\n\\n`));\n } catch {\n clearInterval(keepAlive);\n room.sseClients.delete(playerId);\n }\n }, 15000);\n\n req.signal.addEventListener(\"abort\", () => {\n clearInterval(keepAlive);\n room.sseClients.delete(playerId);\n try {\n controller.close();\n } catch {\n // already closed\n }\n });\n },\n cancel() {\n room.sseClients.delete(playerId);\n },\n });\n\n return new Response(stream, {\n headers: withCors({\n \"content-type\": \"text/event-stream\",\n \"cache-control\": \"no-cache, no-transform\",\n connection: \"keep-alive\",\n }),\n });\n}\n\nfunction handleLanding() {\n const html = `\n\n\n \n \n Top-Down Shooter\n \n\n\n

Arena Prototype

Join a room and drop straight into the firefight.

This is a lightweight Quake-like browser shooter running over HTTP POST plus Server-Sent Events. Pick a callsign, keep the default room, or type another one and jump in.

Default room: alpha

20Hz server tick

Mouse aim + WASD movement

\n Player Name\n \n

\n Room\n \n

\n \n

If you skip the room, the game uses alpha. Your name is saved locally for the next session.

Controls: WASD or arrows to move, mouse to aim, hold mouse button to fire.

\n\n \n\n`;\n\n return new Response(html, {\n headers: withCors({ \"content-type\": \"text/html; charset=utf-8\" }),\n });\n}\n\nfunction handleClient(req) {\n const roomId = new URL(req.url).searchParams.get(\"room\") || \"alpha\";\n const html = `\n\n\n \n \n Top-Down Shooter\n \n\n\n

Room:

Connecting...

\n Lobby\n

Initializing metrics...

Move: WASD or Arrows. Aim: Mouse. Fire: Hold mouse button.

\n\n \n\n`;\n\n return new Response(html, {\n headers: withCors({ \"content-type\": \"text/html; charset=utf-8\" }),\n });\n}\n\nfunction handleApiIndex() {\n return json({\n ok: true,\n game: \"top-down-multiplayer-shooter\",\n transport: \"SSE + HTTP POST\",\n play: \"/\",\n gameClient: \"/client\",\n optionalRoomRoute: \"/client?room=alpha\",\n endpoints: {\n join: { method: \"POST\", path: \"/join\", body: { roomId: \"alpha\", name: \"player1\" } },\n input: {\n method: \"POST\",\n path: \"/input\",\n body: { roomId: \"alpha\", playerId: \"...\", token: \"...\", mx: 0, my: -1, aim: 180, shoot: true, seq: 1 },\n },\n stream: {\n method: \"GET\",\n path: \"/stream?roomId=alpha&playerId=...&token=...\",\n notes: \"Use EventSource; auto-reconnect with Last-Event-ID.\",\n },\n },\n metrics: {\n clientOverlay: true,\n serverStateFields: [\"tickDurationMs\", \"peakTickDurationMs\", \"players\", \"bullets\", \"streamClients\", \"bufferedEvents\", \"totalRooms\"],\n },\n });\n}\n\nstartLoop();\n\nexport default async function(req) {\n if (req.method === \"OPTIONS\") return new Response(null, { status: 204, headers: withCors() });\n\n const url = new URL(req.url);\n const path = url.pathname;\n\n if (req.method === \"GET\" && path === \"/\") return handleLanding();\n if (req.method === \"GET\" && path === \"/client\") return handleClient(req);\n if (req.method === \"GET\" && path === \"/api\") return handleApiIndex();\n if (req.method === \"POST\" && path === \"/join\") return handleJoin(req);\n if (req.method === \"POST\" && path === \"/input\") return handleInput(req);\n if (req.method === \"GET\" && path === \"/stream\") return handleStream(req);\n\n return json({ ok: false, error: \"Not found\" }, 404);\n}\n","// Top-down multiplayer shooter prototype for Val Town without WebSockets.\n// Transport model: POST for client input, SSE for server->client state stream.\n\nconst TICK_MS = 50; // 20Hz\nconst WORLD_W = 1400;\nconst WORLD_H = 900;\nconst PLAYER_SPEED = 220;\nconst PLAYER_RADIUS = 14;\nconst BULLET_SPEED = 620;\nconst BULLET_RADIUS = 4;\nconst BULLET_TTL_MS = 1200;\nconst FIRE_COOLDOWN_MS = 140;\nconst HIT_DAMAGE = 34;\nconst MAX_HP = 100;\nconst ROOM_IDLE_MS = 1000 * 60 * 20;\nconst PLAYER_IDLE_MS = 1000 * 30;\nconst EVENT_BUFFER_SIZE = 200;\n\nconst rooms = new Map();\nlet loopStarted = false;\n\nfunction now() {\n return Date.now();\n}\n\nfunction clamp(n, min, max) {\n return Math.min(max, Math.max(min, n));\n}\n\nfunction round(n, digits = 1) {\n const factor = 10 ** digits;\n return Math.round(n * factor) / factor;\n}\n\nfunction randomId() {\n return crypto.randomUUID().slice(0, 12);\n}\n\nfunction randomSpawn() {\n return {\n x: 80 + Math.random() * (WORLD_W - 160),\n y: 80 + Math.random() * (WORLD_H - 160),\n };\n}\n\nfunction randomColor() {\n const palette = [\"#ef4444\", \"#22c55e\", \"#3b82f6\", \"#eab308\", \"#f97316\", \"#a855f7\", \"#14b8a6\"];\n return palette[Math.floor(Math.random() * palette.length)];\n}\n\nfunction withCors(headers = {}) {\n return {\n \"access-control-allow-origin\": \"*\",\n \"access-control-allow-methods\": \"GET,HEAD,POST,OPTIONS\",\n \"access-control-allow-headers\": \"content-type,authorization\",\n ...headers,\n };\n}\n\nfunction json(data, status = 200) {\n return new Response(JSON.stringify(data), {\n status,\n headers: withCors({ \"content-type\": \"application/json; charset=utf-8\" }),\n });\n}\n\nfunction parseBody(req) {\n return req.json().catch(() => null);\n}\n\nfunction getRoom(roomId) {\n let room = rooms.get(roomId);\n if (!room) {\n room = {\n id: roomId,\n players: new Map(),\n inputs: new Map(),\n bullets: [],\n sseClients: new Map(),\n eventId: 0,\n events: [],\n lastActiveAt: now(),\n metrics: {\n tickCount: 0,\n lastTickDurationMs: 0,\n peakTickDurationMs: 0,\n lastStateAt: 0,\n },\n };\n rooms.set(roomId, room);\n }\n room.lastActiveAt = now();\n return room;\n}\n\nfunction emitEvent(room, event, payload) {\n room.eventId += 1;\n const frame = `id: ${room.eventId}\\nevent: ${event}\\ndata: ${JSON.stringify(payload)}\\n\\n`;\n room.events.push({ id: room.eventId, frame });\n if (room.events.length > EVENT_BUFFER_SIZE) room.events.shift();\n\n for (const [playerId, client] of room.sseClients) {\n try {\n client.controller.enqueue(client.encoder.encode(frame));\n client.lastSentAt = now();\n } catch {\n room.sseClients.delete(playerId);\n }\n }\n}\n\nfunction startLoop() {\n if (loopStarted) return;\n loopStarted = true;\n\n setInterval(() => {\n const t = now();\n\n for (const [roomId, room] of rooms) {\n const tickStartedAt = now();\n\n // Cleanup stale players.\n for (const [playerId, p] of room.players) {\n if (t - p.lastInputAt > PLAYER_IDLE_MS) {\n room.players.delete(playerId);\n room.inputs.delete(playerId);\n room.sseClients.delete(playerId);\n emitEvent(room, \"leave\", { playerId });\n }\n }\n\n // Advance players from latest inputs.\n for (const [playerId, p] of room.players) {\n const input = room.inputs.get(playerId) || { mx: 0, my: 0, aim: 0, shoot: false };\n const len = Math.hypot(input.mx, input.my) || 1;\n const mx = len > 1 ? input.mx / len : input.mx;\n const my = len > 1 ? input.my / len : input.my;\n\n p.aim = Number.isFinite(input.aim) ? input.aim : p.aim;\n\n p.x = clamp(p.x + mx * PLAYER_SPEED * (TICK_MS / 1000), PLAYER_RADIUS, WORLD_W - PLAYER_RADIUS);\n p.y = clamp(p.y + my * PLAYER_SPEED * (TICK_MS / 1000), PLAYER_RADIUS, WORLD_H - PLAYER_RADIUS);\n\n if (input.shoot && p.hp > 0 && t - p.lastShotAt >= FIRE_COOLDOWN_MS) {\n const r = (p.aim * Math.PI) / 180;\n const dx = Math.cos(r);\n const dy = Math.sin(r);\n room.bullets.push({\n id: randomId(),\n ownerId: playerId,\n x: p.x + dx * (PLAYER_RADIUS + 8),\n y: p.y + dy * (PLAYER_RADIUS + 8),\n vx: dx * BULLET_SPEED,\n vy: dy * BULLET_SPEED,\n expiresAt: t + BULLET_TTL_MS,\n });\n p.lastShotAt = t;\n }\n }\n\n // Advance bullets and resolve hits.\n const nextBullets = [];\n for (const b of room.bullets) {\n if (t >= b.expiresAt) continue;\n\n b.x += b.vx * (TICK_MS / 1000);\n b.y += b.vy * (TICK_MS / 1000);\n\n if (b.x < 0 || b.x > WORLD_W || b.y < 0 || b.y > WORLD_H) continue;\n\n let hit = false;\n for (const [targetId, p] of room.players) {\n if (targetId === b.ownerId || p.hp <= 0) continue;\n const d = Math.hypot(p.x - b.x, p.y - b.y);\n if (d <= PLAYER_RADIUS + BULLET_RADIUS) {\n p.hp = Math.max(0, p.hp - HIT_DAMAGE);\n hit = true;\n if (p.hp === 0) {\n const killer = room.players.get(b.ownerId);\n if (killer) killer.score += 1;\n const spawn = randomSpawn();\n p.x = spawn.x;\n p.y = spawn.y;\n p.hp = MAX_HP;\n emitEvent(room, \"frag\", { killerId: b.ownerId, victimId: targetId });\n }\n break;\n }\n }\n\n if (!hit) nextBullets.push(b);\n }\n room.bullets = nextBullets;\n\n const tickDurationMs = round(performance.now() - tickStartedAt, 2);\n room.metrics.tickCount += 1;\n room.metrics.lastTickDurationMs = tickDurationMs;\n room.metrics.peakTickDurationMs = Math.max(room.metrics.peakTickDurationMs, tickDurationMs);\n room.metrics.lastStateAt = t;\n\n // Broadcast current state at tick rate.\n const players = [];\n for (const [id, p] of room.players) {\n players.push({\n id,\n name: p.name,\n x: round(p.x, 1),\n y: round(p.y, 1),\n aim: round(p.aim, 1),\n hp: p.hp,\n score: p.score,\n color: p.color,\n });\n }\n\n const bullets = room.bullets.map((b) => ({\n id: b.id,\n x: round(b.x, 1),\n y: round(b.y, 1),\n }));\n\n emitEvent(room, \"state\", {\n roomId,\n ts: t,\n world: { w: WORLD_W, h: WORLD_H },\n players,\n bullets,\n metrics: {\n tickMs: TICK_MS,\n tickCount: room.metrics.tickCount,\n tickDurationMs: room.metrics.lastTickDurationMs,\n peakTickDurationMs: room.metrics.peakTickDurationMs,\n players: room.players.size,\n bullets: room.bullets.length,\n streamClients: room.sseClients.size,\n bufferedEvents: room.events.length,\n totalRooms: rooms.size,\n },\n });\n\n // Remove truly idle empty rooms.\n if (room.players.size === 0 && t - room.lastActiveAt > ROOM_IDLE_MS) {\n rooms.delete(roomId);\n }\n }\n }, TICK_MS);\n}\n\nfunction validateAuth(room, playerId, token) {\n const p = room.players.get(playerId);\n if (!p) return false;\n return p.token === token;\n}\n\nasync function handleJoin(req) {\n const body = await parseBody(req);\n if (!body || !body.roomId) {\n return json({ ok: false, error: \"Missing roomId\" }, 400);\n }\n\n const roomId = String(body.roomId).slice(0, 64);\n const name = String(body.name || \"player\").slice(0, 20);\n const room = getRoom(roomId);\n\n const playerId = randomId();\n const token = randomId() + randomId();\n const spawn = randomSpawn();\n\n room.players.set(playerId, {\n id: playerId,\n token,\n name,\n x: spawn.x,\n y: spawn.y,\n aim: 0,\n hp: MAX_HP,\n score: 0,\n color: randomColor(),\n lastShotAt: 0,\n lastInputAt: now(),\n });\n room.inputs.set(playerId, { mx: 0, my: 0, aim: 0, shoot: false, seq: 0 });\n\n emitEvent(room, \"join\", { playerId, name, spawn });\n\n return json({\n ok: true,\n roomId,\n playerId,\n token,\n tickMs: TICK_MS,\n world: { w: WORLD_W, h: WORLD_H },\n });\n}\n\nasync function handleInput(req) {\n const body = await parseBody(req);\n if (!body || !body.roomId || !body.playerId || !body.token) {\n return json({ ok: false, error: \"Missing roomId/playerId/token\" }, 400);\n }\n\n const room = rooms.get(String(body.roomId));\n if (!room) return json({ ok: false, error: \"Room not found\" }, 404);\n\n const playerId = String(body.playerId);\n const token = String(body.token);\n if (!validateAuth(room, playerId, token)) return json({ ok: false, error: \"Unauthorized\" }, 401);\n\n const mx = clamp(Number(body.mx) || 0, -1, 1);\n const my = clamp(Number(body.my) || 0, -1, 1);\n const aim = Number(body.aim) || 0;\n const shoot = Boolean(body.shoot);\n const seq = Number(body.seq) || 0;\n\n const prev = room.inputs.get(playerId);\n if (prev && seq < prev.seq) {\n return json({ ok: true, dropped: true });\n }\n\n room.inputs.set(playerId, { mx, my, aim, shoot, seq });\n\n const p = room.players.get(playerId);\n if (p) p.lastInputAt = now();\n\n return json({ ok: true });\n}\n\nfunction handleStream(req) {\n const url = new URL(req.url);\n const roomId = url.searchParams.get(\"roomId\") || \"\";\n const playerId = url.searchParams.get(\"playerId\") || \"\";\n const token = url.searchParams.get(\"token\") || \"\";\n\n if (!roomId || !playerId || !token) {\n return json({ ok: false, error: \"Missing roomId/playerId/token\" }, 400);\n }\n\n const room = rooms.get(roomId);\n if (!room) return json({ ok: false, error: \"Room not found\" }, 404);\n if (!validateAuth(room, playerId, token)) return json({ ok: false, error: \"Unauthorized\" }, 401);\n\n const encoder = new TextEncoder();\n const lastEventIdRaw = req.headers.get(\"last-event-id\") || \"0\";\n const lastEventId = Number(lastEventIdRaw) || 0;\n\n const stream = new ReadableStream({\n start(controller) {\n room.sseClients.set(playerId, { controller, encoder, lastSentAt: now() });\n\n const hello = `event: hello\\ndata: ${JSON.stringify({ ok: true, roomId, playerId, ts: now() })}\\n\\n`;\n controller.enqueue(encoder.encode(hello));\n\n // Replay buffered events after reconnect.\n for (const ev of room.events) {\n if (ev.id > lastEventId) controller.enqueue(encoder.encode(ev.frame));\n }\n\n const keepAlive = setInterval(() => {\n try {\n controller.enqueue(encoder.encode(`: keepalive ${now()}\\n\\n`));\n } catch {\n clearInterval(keepAlive);\n room.sseClients.delete(playerId);\n }\n }, 15000);\n\n req.signal.addEventListener(\"abort\", () => {\n clearInterval(keepAlive);\n room.sseClients.delete(playerId);\n try {\n controller.close();\n } catch {\n // already closed\n }\n });\n },\n cancel() {\n room.sseClients.delete(playerId);\n },\n });\n\n return new Response(stream, {\n headers: withCors({\n \"content-type\": \"text/event-stream\",\n \"cache-control\": \"no-cache, no-transform\",\n connection: \"keep-alive\",\n }),\n });\n}\n\nfunction handleLanding() {\n const html = `\n\n\n \n \n Top-Down Shooter\n \n\n\n

Diff · v15