[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_231":232,"_233":234},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":16,"_154":155,"_37":-7,"_156":-5,"_17":157,"_158":159,"_160":161,"_162":163,"_164":165,"_51":-5,"_166":-5,"_167":-5,"_168":24,"_169":170,"_171":117,"_172":-5,"_173":-5,"_174":175},"routes/_app.x.$handle.$name.branch.$branch.history",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":22,"_23":24,"_25":-5},"handle","aisss","name","fal-proxy","branchName","main","project",{"_31":105,"_13":14,"_35":106,"_107":-5,"_108":24,"_109":110,"_111":110,"_112":113,"_114":-5,"_25":66,"_115":61,"_116":117,"_118":-5,"_119":-5,"_120":20,"_39":40,"_121":-5,"_122":-5,"_123":-5,"_124":-5,"_125":126,"_127":126,"_128":129,"_130":129,"_131":129,"_132":126,"_133":126,"_49":134,"_135":136,"_137":138,"_139":24},"page",0,"history",[26,27,28,29,30],"hasNext",false,"userId",{"_31":96,"_33":34,"_35":97,"_37":98,"_39":40,"_41":89,"_42":-5,"_43":72,"_44":-5,"_45":-5,"_46":-5,"_47":-5,"_48":-5,"_49":99,"_51":100,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":101},{"_31":89,"_33":34,"_35":90,"_37":91,"_39":40,"_41":80,"_42":-5,"_43":72,"_44":-5,"_45":-5,"_46":-5,"_47":-5,"_48":-5,"_49":92,"_51":93,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":94},{"_31":80,"_33":34,"_35":81,"_37":82,"_39":40,"_41":69,"_42":-5,"_43":72,"_44":-5,"_45":-5,"_46":-5,"_47":-5,"_48":-5,"_49":83,"_51":84,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":85},{"_31":69,"_33":34,"_35":70,"_37":71,"_39":40,"_41":32,"_42":-5,"_43":72,"_44":-5,"_45":-5,"_46":-5,"_47":-5,"_48":-5,"_49":73,"_51":74,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":75},{"_31":32,"_33":34,"_35":36,"_37":38,"_39":40,"_41":-5,"_42":-5,"_43":-5,"_44":-5,"_45":-5,"_46":-5,"_47":-5,"_48":-5,"_49":50,"_51":52,"_53":-5,"_54":-5,"_55":-5,"_56":-5,"_57":58},"id","cf852210-f7b0-42c7-8fe4-ae0c102c9aec","branchId","b4ad647d-1e52-4df1-998b-ced04d6f4e10","createdAt",["D",1784989084312],"version",1,"orgId","019f99a2-f250-749c-96aa-a8cae4c2aeea","parentId","incomingCommitId","aiChatMessageId","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle","source","clientLabel","user",{"_31":66,"_39":40,"_11":12,"_67":68},"file",{"_60":61,"_13":62,"_63":64,"_65":24},"pull","merge","revert","multiple","commits",[59],{"_31":32,"_33":34,"_35":36,"_37":38,"_39":40,"_41":-5,"_42":-5,"_43":-5,"_44":-5,"_45":-5,"_46":-5,"_47":-5,"_48":-5,"_49":50,"_51":52,"_53":-5,"_54":-5,"_55":-5},"fileId","a67f180e-8833-11f1-a178-1607ee4eb77e","main.ts","fileType","http","deleted","0ce58fb8-52f8-4608-a94a-226df5456dd1","avatar","https://lh3.googleusercontent.com/a/ACg8ocKqwXuu42CD8D9vfE9W-gEq_Oh3WbwNufExuI-UaXMd35_rHQ=s96-c","ea14bfc6-3a59-452b-b0dc-3a87ab101deb",["D",1784989104528],2,"6ba59c53-da01-49f8-b263-75b5f8f732dc",{"_31":66,"_39":40,"_11":12,"_67":68},{"_60":77,"_13":78,"_63":79,"_65":24},[76],{"_31":69,"_33":34,"_35":70,"_37":71,"_39":40,"_41":32,"_42":-5,"_43":72,"_44":-5,"_45":-5,"_46":-5,"_47":-5,"_48":-5,"_49":73,"_51":74,"_53":-5,"_54":-5,"_55":-5},"b28b8bf0-8833-11f1-9bd8-1607ee4eb77e","keyManager.ts","script","c0b374cd-3d55-44d8-801a-2722311de33a",["D",1784989120229],3,{"_31":66,"_39":40,"_11":12,"_67":68},{"_60":87,"_13":88,"_63":79,"_65":24},[86],{"_31":80,"_33":34,"_35":81,"_37":82,"_39":40,"_41":69,"_42":-5,"_43":72,"_44":-5,"_45":-5,"_46":-5,"_47":-5,"_48":-5,"_49":83,"_51":84,"_53":-5,"_54":-5,"_55":-5},"bbe76ebc-8833-11f1-a00d-1607ee4eb77e","sanitize.ts","3d0b634a-a047-4bba-b445-8be67ff5ddd2",["D",1784989142637],4,{"_31":66,"_39":40,"_11":12,"_67":68},{"_60":61,"_13":62,"_63":64,"_65":24},[95],{"_31":89,"_33":34,"_35":90,"_37":91,"_39":40,"_41":80,"_42":-5,"_43":72,"_44":-5,"_45":-5,"_46":-5,"_47":-5,"_48":-5,"_49":92,"_51":93,"_53":-5,"_54":-5,"_55":-5},"9c18428d-ea76-4442-8376-cde31854c77f",["D",1784989202383],5,{"_31":66,"_39":40,"_11":12,"_67":68},{"_60":103,"_13":104,"_63":51,"_65":24},[102],{"_31":96,"_33":34,"_35":97,"_37":98,"_39":40,"_41":89,"_42":-5,"_43":72,"_44":-5,"_45":-5,"_46":-5,"_47":-5,"_48":-5,"_49":99,"_51":100,"_53":-5,"_54":-5,"_55":-5},"ecded6ea-8833-11f1-a7a8-1607ee4eb77e","README.md","2b42abc2-cf71-42cb-8e35-ec6e0867ac24",["D",1784989084292],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","fal.ai proxy with auto key rotation (secret URL + key)","imageUrl","pinnedFileId","pinPreview",true,"pinMigrated","screenshotVersion","likeCount","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_11":12,"_153":68},"org",{"_11":12,"_148":149,"_67":68,"_25":66,"_150":151,"_152":24},"branch",{"_37":98,"_13":16,"_31":34,"_140":105,"_141":-5,"_142":-5,"_143":-5,"_144":-5,"_145":-5,"_146":14,"_147":12},"isOwned","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Rbxgscanner","tier","free","canRestrictVals","profileImageUrl","path","","adoptOrgId",{"_31":105,"_13":14,"_35":227,"_107":-5,"_108":24,"_109":110,"_111":110,"_112":113,"_114":-5,"_25":66,"_115":61,"_116":117,"_118":-5,"_119":-5,"_120":20,"_39":40,"_121":-5,"_122":-5,"_123":-5,"_124":-5,"_125":126,"_127":126,"_128":129,"_130":129,"_131":129,"_132":126,"_133":126,"_49":228,"_135":229,"_137":230,"_139":24},"tree",[210,211,212,213],"files",[210,211,212,213],"counts",{"_200":20,"_201":38,"_202":20,"_203":204,"_205":206},"contents",[176,177,178,179],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_31":196,"_13":104,"_60":103,"_41":-5,"_33":34,"_181":98,"_182":117,"_35":197,"_37":20,"_63":51,"_184":198,"_65":24,"_186":-5,"_154":199},{"_31":192,"_13":78,"_60":77,"_41":-5,"_33":34,"_181":71,"_182":117,"_35":193,"_37":20,"_63":79,"_184":194,"_65":24,"_186":-5,"_154":195},{"_31":188,"_13":62,"_60":61,"_41":-5,"_33":34,"_181":91,"_182":117,"_35":189,"_37":38,"_63":64,"_184":190,"_65":24,"_186":-5,"_154":191},{"_31":180,"_13":88,"_60":87,"_41":-5,"_33":34,"_181":82,"_182":117,"_35":183,"_37":20,"_63":79,"_184":185,"_65":24,"_186":-5,"_154":187},"a42fd481-557f-418c-a29e-31a402487b91","branchVersion","latest",["D",1784989120229],"content","// Ports the sanitize_payload / _content_is_empty / is_locked_balance_error\n// helpers from the original Python proxy.\n\nfunction contentIsEmpty(content: unknown): boolean {\n if (content === null || content === undefined) return true;\n if (typeof content === \"string\") return content.trim() === \"\";\n if (Array.isArray(content)) {\n for (const part of content) {\n if (part && typeof part === \"object\" && !Array.isArray(part)) {\n const p = part as Record;\n const t = p.type;\n if (t === \"text\" && String(p.text ?? \"\").trim()) return false;\n if ((t === \"image_url\" || t === \"input_audio\" || t === \"image\" || t === \"file\") && part) {\n return false;\n }\n } else if (typeof part === \"string\" && part.trim()) {\n return false;\n }\n }\n return true;\n }\n return false;\n}\n\nexport function sanitizePayload(bodyBytes: Uint8Array): { body: Uint8Array; isStream: boolean } {\n if (!bodyBytes || bodyBytes.length === 0) return { body: bodyBytes, isStream: false };\n try {\n const text = new TextDecoder().decode(bodyBytes);\n const data = JSON.parse(text);\n const isStream = Boolean(data.stream);\n\n if (Array.isArray(data.tools)) {\n const st: unknown[] = [];\n for (const tool of data.tools) {\n if (tool && typeof tool === \"object\") {\n const func = (tool as any).function ?? {};\n const name = func && typeof func === \"object\" ? func.name : (tool as any).name;\n if (name && String(name).trim()) st.push(tool);\n }\n }\n data.tools = st;\n if (data.tools.length === 0) delete data.tools;\n }\n\n if (Array.isArray(data.messages)) {\n const cm: unknown[] = [];\n for (const msg of data.messages) {\n if (!msg || typeof msg !== \"object\") {\n cm.push(msg);\n continue;\n }\n const m = msg as Record;\n const role = m.role;\n\n if (\"tool_calls\" in m) {\n const vc: unknown[] = [];\n for (const call of m.tool_calls ?? []) {\n const func = call?.function ?? {};\n if (func?.name && String(func.name).trim()) vc.push(call);\n }\n if (vc.length) m.tool_calls = vc;\n else delete m.tool_calls;\n }\n\n const htc = Boolean(m.tool_calls && (m.tool_calls as unknown[]).length);\n const ce = contentIsEmpty(m.content);\n\n if (ce) {\n if (role === \"assistant\" && htc) {\n m.content = \"\";\n cm.push(m);\n } else if (role === \"tool\") {\n if (m.content === null || m.content === undefined) m.content = \"\";\n cm.push(m);\n } else if (role === \"user\" || role === \"system\") {\n m.content = \" \";\n cm.push(m);\n } else {\n // drop\n }\n } else {\n cm.push(m);\n }\n }\n data.messages = cm;\n }\n\n return { body: new TextEncoder().encode(JSON.stringify(data)), isStream };\n } catch {\n return { body: bodyBytes, isStream: false };\n }\n}\n\nexport function isLockedBalanceError(status: number, body: string): boolean {\n // 402 = Payment Required (out of credits/balance) -> always a dead key.\n if (status === 402) return true;\n if (status !== 403) return false;\n const t = (body || \"\").toLowerCase();\n return (\n t.includes(\"locked\") ||\n t.includes(\"exhausted balance\") ||\n t.includes(\"top up\") ||\n t.includes(\"insufficient\") ||\n t.includes(\"payment\") ||\n t.includes(\"quota\")\n );\n}\n","label",[88],"482e24fa-85b0-45c9-b618-21b4defdd1a2",["D",1784989142637],"import { getKeyForRequest, rotateKey, UPSTREAM_URL } from \"./keyManager.ts\";\nimport { isLockedBalanceError, sanitizePayload } from \"./sanitize.ts\";\n\nconst MAX_RETRIES = 5;\n\n// Headers we never forward upstream.\nconst STRIP_HEADERS = new Set([\n \"host\",\n \"content-length\",\n \"accept-encoding\",\n \"authorization\",\n \"connection\",\n]);\n\nfunction buildUpstreamUrl(req: Request): string {\n const inUrl = new URL(req.url);\n // Everything after the leading slash becomes the upstream path.\n const path = inUrl.pathname.replace(/^\\/+/, \"\");\n return `${UPSTREAM_URL}/${path}${inUrl.search}`;\n}\n\nfunction baseHeaders(req: Request): Headers {\n const h = new Headers();\n for (const [k, v] of req.headers) {\n if (!STRIP_HEADERS.has(k.toLowerCase())) h.set(k, v);\n }\n return h;\n}\n\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n const method = req.method;\n\n // Health check (matches the Python \"/\" route).\n if (url.pathname === \"/\" || url.pathname === \"\") {\n return Response.json({ status: \"ok\", message: \"fal.ai Proxy is active!\" });\n }\n\n const upstreamUrl = buildUpstreamUrl(req);\n const rawBody = new Uint8Array(await req.arrayBuffer());\n\n let body: Uint8Array = rawBody;\n let isStream = false;\n if (method === \"POST\") {\n const s = sanitizePayload(rawBody);\n body = s.body;\n isStream = s.isStream;\n }\n\n const hasBody = method !== \"GET\" && method !== \"HEAD\" && body.length > 0;\n\n // ---------------- NON-STREAMING ----------------\n if (!isStream) {\n for (let attempt = 0; attempt < MAX_RETRIES; attempt++) {\n try {\n const key = await getKeyForRequest();\n const headers = baseHeaders(req);\n headers.set(\"authorization\", `Key ${key}`);\n\n const res = await fetch(upstreamUrl, {\n method,\n headers,\n body: hasBody ? body : undefined,\n });\n\n const buf = new Uint8Array(await res.arrayBuffer());\n const status = res.status;\n const ctype = res.headers.get(\"content-type\") || \"application/json\";\n\n // 402 (payment) or 403 (locked) -> key is dead, rotate + retry.\n if (isLockedBalanceError(status, new TextDecoder().decode(buf))) {\n console.log(`[non-stream] status ${status} (dead key) -> rotating...`);\n await rotateKey(true);\n continue;\n }\n\n return new Response(buf, {\n status,\n headers: { \"content-type\": ctype, \"Connection\": \"close\" },\n });\n } catch (e) {\n console.log(`[non-stream] attempt ${attempt + 1} failed: ${e}`);\n await new Promise((r) => setTimeout(r, 1000));\n }\n }\n return Response.json({ error: { message: \"Failed after retries\" } }, { status: 504 });\n }\n\n // ---------------- STREAMING ----------------\n const encoder = new TextEncoder();\n const stream = new ReadableStream({\n async start(controller) {\n const send = (s: string | Uint8Array) =>\n controller.enqueue(typeof s === \"string\" ? encoder.encode(s) : s);\n\n // Heartbeat immediately so clients get bytes right away.\n send(\": connected\\n\\n\");\n\n try {\n for (let attempt = 0; attempt < MAX_RETRIES; attempt++) {\n try {\n const key = await getKeyForRequest();\n const headers = baseHeaders(req);\n headers.set(\"authorization\", `Key ${key}`);\n\n const res = await fetch(upstreamUrl, {\n method,\n headers,\n body: hasBody ? body : undefined,\n });\n\n // 402 / 403 -> dead key, rotate + retry.\n if (res.status === 402 || res.status === 403) {\n const err = await res.text();\n if (isLockedBalanceError(res.status, err)) {\n console.log(`[stream] status ${res.status} (dead key) -> switching key...`);\n send(\": switching key\\n\\n\");\n await rotateKey(true);\n continue;\n }\n send(err);\n send(\"\\ndata: [DONE]\\n\\n\");\n return;\n }\n\n if (res.status >= 400) {\n await res.text();\n console.log(`[stream] status ${res.status}; retrying...`);\n send(\": retrying\\n\\n\");\n await new Promise((r) => setTimeout(r, 1000));\n continue;\n }\n\n if (!res.body) {\n console.log(\"[stream] empty; retrying...\");\n send(\": retrying\\n\\n\");\n await new Promise((r) => setTimeout(r, 1000));\n continue;\n }\n\n // Pass everything straight through as it arrives.\n const reader = res.body.getReader();\n let sawDone = false;\n let gotData = false;\n const decoder = new TextDecoder();\n while (true) {\n const { done, value } = await reader.read();\n if (done) break;\n if (value && value.length) {\n gotData = true;\n if (decoder.decode(value, { stream: true }).includes(\"[DONE]\")) sawDone = true;\n send(value);\n }\n }\n\n if (!gotData) {\n console.log(\"[stream] empty; retrying...\");\n send(\": retrying\\n\\n\");\n await new Promise((r) => setTimeout(r, 1000));\n continue;\n }\n\n if (!sawDone) send(\"\\ndata: [DONE]\\n\\n\");\n return;\n } catch (e) {\n console.log(`[stream] attempt ${attempt + 1} failed: ${e}`);\n send(\": retrying\\n\\n\");\n await new Promise((r) => setTimeout(r, 1000));\n }\n }\n send('data: {\"error\":{\"message\":\"Failed after retries\"}}\\n\\n');\n send(\"data: [DONE]\\n\\n\");\n } finally {\n controller.close();\n }\n },\n });\n\n return new Response(stream, {\n status: 200,\n headers: {\n \"Cache-Control\": \"no-cache\",\n \"X-Accel-Buffering\": \"no\",\n \"Connection\": \"close\",\n \"content-type\": \"text/event-stream\",\n },\n });\n}\n",[62],"33cfabe8-e717-4309-900c-dc5d71b717bb",["D",1784989104528],"import { blob } from \"https://esm.town/v/std/blob/main.ts\";\n\n// ---- Config (secrets via env vars) ----\n// UPSTREAM_URL : base URL to proxy to, e.g. https://fal.run (SECRET)\n// FAL_KEY : fallback/initial fal.ai key (SECRET)\n// KEY_ENDPOINT : URL that returns a fresh { apiKey } (SECRET)\n\nexport const UPSTREAM_URL = (Deno.env.get(\"UPSTREAM_URL\") || \"https://fal.run\").replace(/\\/+$/, \"\");\nconst KEY_ENDPOINT = Deno.env.get(\"KEY_ENDPOINT\") || \"https://dumpsters-aichat.hf.space/api/apikeys\";\nconst FALLBACK_KEY = Deno.env.get(\"FAL_KEY\") || \"\";\n\nconst KEY_FETCH_TIMEOUT = 120_000; // wait up to 2 min for a (cold) key endpoint\nconst ROTATE_INTERVAL = 7 * 60 * 1000; // 7 minutes\nconst ROTATE_COOLDOWN = 10_000; // dedupe racing rotations\n\n// State is persisted in blob storage because Val Town has no long-lived process.\nconst STATE_KEY = \"fal-proxy:key-state\";\n\ninterface KeyState {\n key: string;\n // monotonic-ish: we use Date.now() (ms). 0 means \"never rotated\".\n lastRotate: number;\n // whether the current key has actually been used at least once\n usedSinceRotate: boolean;\n}\n\nasync function loadState(): Promise {\n const s = (await blob.getJSON(STATE_KEY)) as KeyState | undefined;\n return s ?? { key: FALLBACK_KEY, lastRotate: 0, usedSinceRotate: false };\n}\n\nasync function saveState(s: KeyState): Promise {\n await blob.setJSON(STATE_KEY, s);\n}\n\nasync function fetchNewKey(): Promise {\n try {\n const ctrl = new AbortController();\n const t = setTimeout(() => ctrl.abort(), KEY_FETCH_TIMEOUT);\n console.log(\"[key] Requesting new key...\");\n const resp = await fetch(KEY_ENDPOINT, { signal: ctrl.signal });\n clearTimeout(t);\n if (resp.ok) {\n const data = await resp.json();\n const key = data?.apiKey;\n if (key && String(key).trim()) return String(key).trim();\n } else {\n console.log(`[key] Endpoint returned status ${resp.status}`);\n }\n } catch (e) {\n console.log(`[key] Failed to fetch new key: ${e}`);\n }\n return null;\n}\n\n/**\n * Rotate the key.\n * - force=true : always rotate (key confirmed dead / locked / out of balance).\n * - force=false : skip if rotated within ROTATE_COOLDOWN.\n */\nexport async function rotateKey(force = false): Promise {\n const state = await loadState();\n const now = Date.now();\n if (!force && state.lastRotate && now - state.lastRotate < ROTATE_COOLDOWN) {\n console.log(`[key] Skipped rotate (cooldown, ${((now - state.lastRotate) / 1000) | 0}s ago)`);\n return state.key;\n }\n console.log(\"[key] Fetching key...\");\n const newKey = await fetchNewKey();\n if (newKey) {\n const next: KeyState = { key: newKey, lastRotate: Date.now(), usedSinceRotate: false };\n await saveState(next);\n console.log(`[key] Got key: ${newKey.slice(0, 12)}...`);\n return newKey;\n }\n console.log(\"[key] Could not obtain a new key; keeping current.\");\n return state.key || FALLBACK_KEY;\n}\n\n/**\n * Returns the key to use for a request, rotating lazily when appropriate.\n * Mimics the Python auto-rotate loop, but on-demand:\n * - If we have no key yet -> fetch one.\n * - If the current key was used AND 7 min elapsed -> rotate.\n * - A fresh, never-used key is kept indefinitely.\n * Also marks the key as \"used\".\n */\nexport async function getKeyForRequest(): Promise {\n let state = await loadState();\n\n if (!state.key) {\n const k = await rotateKey(true);\n state = await loadState();\n state.key = k;\n }\n\n const now = Date.now();\n if (state.usedSinceRotate && state.lastRotate && now - state.lastRotate >= ROTATE_INTERVAL) {\n console.log(\"[auto] 7 min up and used -> rotating.\");\n const k = await rotateKey(false);\n state = await loadState();\n state.key = k;\n }\n\n // mark used\n if (!state.usedSinceRotate) {\n state.usedSinceRotate = true;\n await saveState(state);\n }\n\n return state.key;\n}\n",[78],"a5488e4e-40f7-4142-aa51-af75fda5e0b5",["D",1784989202383],"# fal-proxy\n\nA TypeScript/Deno port of the FastAPI fal.ai proxy. Forwards every request to an\nupstream base URL, auto-rotates the fal.ai key, sanitizes OpenAI-style payloads,\nand supports both streaming and non-streaming responses.\n\n## Usage\n\nPoint your OpenAI-compatible client at the val's endpoint. The path is passed\nstraight through to the upstream, so:\n\n```\nPOST /openrouter/router/openai/v1/chat/completions\n```\n\nforwards to `/openrouter/router/openai/v1/chat/completions`.\n\n`GET /` returns a health check.\n\n## Secrets (environment variables)\n\n| Key | What it is |\n| -------------- | ------------------------------------------------------ |\n| `UPSTREAM_URL` | Base URL to proxy to (e.g. `https://fal.run`) — secret |\n| `FAL_KEY` | Initial / fallback fal.ai key — secret |\n| `KEY_ENDPOINT` | URL returning `{ \"apiKey\": \"...\" }` for rotation |\n\nEdit them here:\n- 👉 https://www.val.town/x/aisss/fal-proxy/environment-variables?key=UPSTREAM_URL\n- 👉 https://www.val.town/x/aisss/fal-proxy/environment-variables?key=FAL_KEY\n- 👉 https://www.val.town/x/aisss/fal-proxy/environment-variables?key=KEY_ENDPOINT\n\n## Key rotation\n\nVal Town has no long-lived background process, so rotation happens on-demand\n(state persisted in blob storage) rather than via a background loop:\n\n- A freshly fetched key is kept until it's actually used.\n- Once used, it rotates after 7 minutes.\n- A `402` (out of balance) or a `403` \"locked/insufficient/quota\" response\n forces an immediate rotation and retry (up to 5 attempts).\n\n## Files\n\n```mermaid\nflowchart LR\n client -->|any path| main.ts\n main.ts -->|sanitize + isLockedBalanceError| sanitize.ts\n main.ts -->|getKeyForRequest / rotateKey| keyManager.ts\n keyManager.ts -->|fetch fresh key| KEY_ENDPOINT\n keyManager.ts -->|persist state| blob\n main.ts -->|proxy| UPSTREAM_URL\n```\n\n- `main.ts` — HTTP handler; proxying, streaming, retries.\n- `keyManager.ts` — key fetch/rotation + blob-persisted state.\n- `sanitize.ts` — payload cleanup and dead-key detection.\n",[104],"pulls","branches","forks","envVars",{"_207":82,"_209":20},"connections",{"_207":20,"_208":20},"count","unfilledCount","emptyCount",{"_31":196,"_13":104,"_60":103,"_41":-5,"_33":34,"_181":98,"_182":117,"_35":224,"_37":20,"_63":51,"_184":198,"_65":24,"_186":-5,"_215":225,"_154":226},{"_31":192,"_13":78,"_60":77,"_41":-5,"_33":34,"_181":71,"_182":117,"_35":221,"_37":20,"_63":79,"_184":194,"_65":24,"_186":-5,"_215":222,"_154":223},{"_31":188,"_13":62,"_60":61,"_41":-5,"_33":34,"_181":91,"_182":117,"_35":218,"_37":38,"_63":64,"_184":190,"_65":24,"_186":-5,"_215":219,"_154":220},{"_31":180,"_13":88,"_60":87,"_41":-5,"_33":34,"_181":82,"_182":117,"_35":214,"_37":20,"_63":79,"_184":185,"_65":24,"_186":-5,"_215":216,"_154":217},["D",1784989120229],"children",[],[88],["D",1784989142637],[],[62],["D",1784989104528],[],[78],["D",1784989202383],[],[104],["D",1784989084292],{"_11":12,"_153":68},{"_11":12,"_148":149,"_67":68,"_25":66,"_150":151,"_152":24},{"_37":98,"_13":16,"_31":34,"_140":105,"_141":-5,"_142":-5,"_143":-5,"_144":-5,"_145":-5,"_146":14,"_147":12},"ctx",{"_49":-5,"_173":264,"_265":266,"_267":268,"_269":24,"_270":24,"_271":24,"_272":117,"_273":-5,"_274":-7,"_275":-7,"_276":20,"_277":24,"_278":24,"_279":-5,"_280":24,"_281":24,"_282":24,"_283":-5},"ENV",{"_235":236,"_237":238,"_239":16,"_240":241,"_242":243,"_244":245,"_246":247,"_248":249,"_250":251,"_252":253,"_254":255,"_256":257,"_258":259,"_260":261,"_262":263},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","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"]

History