[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_108":109,"_110":111},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","nbbaier","name","utils","path","hot-reload.ts","project",{"_22":45,"_11":12,"_33":46,"_47":-5,"_48":42,"_49":50,"_51":50,"_52":53,"_54":-5,"_55":56,"_57":58,"_59":32,"_60":-5,"_61":-5,"_62":36,"_63":64,"_65":66,"_67":68,"_69":70,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":82,"_83":84,"_85":86,"_87":42},"file",{"_22":23,"_11":14,"_24":25,"_26":-5,"_27":28,"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":-5,"_13":44},"permalink","https://www.val.town/x/nbbaier/utils/code/hot-reload.ts","extension","id","f4525372-1788-4bae-94e9-ac11350e5054","fileId","01a03d11-cbf1-753f-94cb-f1bfecca85c9","parentId","branchId","de9e06b0-f317-4758-82be-5c34643ac5bf","branchVersion",1,"latest",true,"createdAt",["D",1787730971546],"version",0,"fileType","script","content","import ValTown from \"npm:@valtown/sdk@1.9.0\";\nimport { parseVal } from \"./parseImportMeta.ts\";\nimport { API_URL } from \"https://esm.town/v/std/API_URL\";\n\nconst POLL_PATH = \"/__vt_hot_reload\";\nconst HOLD_DURATION_MS = 30_000;\nconst CHECK_INTERVAL_MS = 500;\n\n/**\n * Wraps an HTTP handler to enable hot reload during development.\n *\n * When a val is served on a `.val.run` domain, this wrapper:\n * 1. Injects a small script into HTML responses that long-polls for version changes\n * 2. Handles the long-poll endpoint (`/__vt_hot_reload`)\n * 3. Actively checks the Val Town API for new versions of the current branch\n * 4. When a new version is deployed, the client detects the change and reloads the page\n *\n * On custom domains (non `.val.run`), the handler passes through unmodified.\n *\n * @param handler - Your HTTP fetch handler\n * @returns A wrapped handler with hot reload support\n *\n * @example\n * ```ts\n * import { hotReload } from \"https://esm.town/v/std/utils/index.ts\";\n *\n * export default hotReload(async (req: Request) => {\n * return new Response(\"

Hello!

\", {\n * headers: { \"Content-Type\": \"text/html\" },\n * });\n * });\n * ```\n */\nexport function hotReload(\n handler: (req: Request) => Response | Promise,\n): (req: Request) => Promise {\n const val = parseVal();\n const startVersion = parseInt(val.version, 10);\n\n // Lazily initialize the SDK and val/branch IDs on first poll request\n let pollContext:\n | Promise<{ vt: ValTown; valId: string; branchName: string }>\n | null = null;\n\n function getPollContext() {\n if (!pollContext) {\n pollContext = (async () => {\n const vt = new ValTown({ baseURL: API_URL });\n const { id: valId } = await vt.alias.username.valName.retrieve(\n val.username,\n val.name,\n );\n return { vt, valId, branchName: val.branch };\n })();\n }\n return pollContext;\n }\n\n return async (req: Request): Promise => {\n const url = new URL(req.url);\n\n // Only activate on val.run domains\n if (!url.hostname.endsWith(\".val.run\")) {\n return handler(req);\n }\n\n // Handle long-poll endpoint\n if (url.pathname === POLL_PATH) {\n return handlePoll(getPollContext, startVersion);\n }\n\n // Normal request — call user handler, maybe inject script\n const res = await handler(req);\n\n // Don't inject into iframe responses — Sec-Fetch-Dest is \"iframe\" for\n // iframe loads and \"document\" for top-level navigations.\n const fetchDest = req.headers.get(\"sec-fetch-dest\");\n if (fetchDest && fetchDest !== \"document\") {\n return res;\n }\n\n return maybeInjectScript(res, startVersion);\n };\n}\n\n/**\n * Handles the long-poll request from the client.\n *\n * Actively polls the Val Town API for branch version changes.\n * If the branch version has increased, respond immediately (triggering reload).\n * Otherwise, keep checking every ~1s for up to ~30s, then respond 304.\n */\nasync function handlePoll(\n getPollContext: () => Promise<\n { vt: ValTown; valId: string; branchName: string }\n >,\n startVersion: number,\n): Promise {\n const { vt, valId, branchName } = await getPollContext();\n const deadline = Date.now() + HOLD_DURATION_MS;\n\n while (Date.now() < deadline) {\n try {\n const latestVersion = await getBranchVersion(vt, valId, branchName);\n if (latestVersion !== null && latestVersion > startVersion) {\n return Response.json({ version: latestVersion });\n }\n } catch {\n // API error — don't crash, just retry next interval\n }\n // Wait before next check (but don't overshoot the deadline)\n const remaining = deadline - Date.now();\n if (remaining <= 0) break;\n await new Promise((resolve) =>\n setTimeout(resolve, Math.min(CHECK_INTERVAL_MS, remaining))\n );\n }\n\n return new Response(null, { status: 304 });\n}\n\n/**\n * Gets the current version of a branch from the Val Town API.\n */\nasync function getBranchVersion(\n vt: ValTown,\n valId: string,\n branchName: string,\n): Promise {\n const branches = await Array.fromAsync(vt.vals.branches.list(valId, {}));\n const branch = branches.find((b) => b.name === branchName);\n return branch ? branch.version : null;\n}\n\n/**\n * If the response is HTML, inject the hot-reload client script before or .\n * Otherwise, return the response unmodified.\n */\nasync function maybeInjectScript(\n res: Response,\n version: number,\n): Promise {\n const contentType = res.headers.get(\"content-type\") || \"\";\n if (!contentType.includes(\"text/html\")) {\n return res;\n }\n\n const script = clientScript(version);\n\n // If the response body is a ReadableStream, use the streaming injector\n if (res.body) {\n const injected = res.body\n .pipeThrough(new TextDecoderStream())\n .pipeThrough(new InjectBeforeCloseStream(script))\n .pipeThrough(new TextEncoderStream());\n\n return new Response(injected, {\n status: res.status,\n statusText: res.statusText,\n headers: res.headers,\n });\n }\n\n // Fallback for bodyless responses\n return res;\n}\n\n/**\n * Generates the inline client-side script that long-polls for version changes.\n */\nfunction clientScript(version: number): string {\n return ``;\n}\n\n/**\n * A TransformStream that injects a string before or in an HTML stream.\n * If neither tag is found, appends at the end.\n */\nclass InjectBeforeCloseStream extends TransformStream {\n constructor(content: string) {\n const state = { injected: false, buffer: \"\" };\n\n super({\n transform(chunk, controller) {\n if (state.injected) {\n controller.enqueue(chunk);\n return;\n }\n\n const combined = state.buffer + chunk;\n state.buffer = \"\";\n\n // Try to inject before or \n const bodyMatch = combined.match(/(<\\/body[\\s>])/i);\n const htmlMatch = combined.match(/(<\\/html[\\s>])/i);\n const match = bodyMatch || htmlMatch;\n\n if (match && match.index !== undefined) {\n const before = combined.slice(0, match.index);\n const after = combined.slice(match.index);\n controller.enqueue(before + content + after);\n state.injected = true;\n return;\n }\n\n // Buffer the tail in case = 1; i--) {\n const slice = combined.slice(-i);\n if (\"\".startsWith(slice) || \"\".startsWith(slice)) {\n state.buffer = slice;\n controller.enqueue(combined.slice(0, -i));\n return;\n }\n }\n\n controller.enqueue(combined);\n },\n flush(controller) {\n if (state.buffer) {\n controller.enqueue(state.buffer);\n }\n if (!state.injected) {\n controller.enqueue(content);\n }\n },\n });\n }\n}","deleted",false,"label",[14],"c584e4bf-473d-4b20-b69e-09392d167118",["D",1787730971546],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Val Town Utilities","imageUrl","userId","5d1042a9-7b0b-499d-8a72-3a8ac7a4e185","pinnedFileId","01a03d11-cbf1-753f-94cb-d4f250d3bdbe","pinPreview","pinMigrated","screenshotVersion","likeCount","orgId","5f80108f-7ca4-4327-b77b-089dbe4b5a82","tursoName","c584e4bf473d4b20b69e09392d167118","tursoHostname","c584e4bf473d4b20b69e09392d167118-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789563036726],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_107":103},"org",{"_9":10,"_101":-5,"_102":103,"_55":56,"_104":105,"_106":42},"branch",{"_35":30,"_11":88,"_22":28,"_89":45,"_90":91,"_92":93,"_94":50,"_95":96,"_97":98,"_99":12,"_100":10},"isOwned","main","projectId","forkedBranchId","bb8fa1c2-f528-11ef-b06d-569c3dd06744","forkedBranchVersion",285,"forkedProjectPrivacy","forkedProjectId","bb8f592e-f528-11ef-b06d-569c3dd06744","forkedProjectOrgId","c606f87f-4d7e-48c8-9c39-ef5ab94aec49","projectName","userHandle","displayName","avatar","https://secure.gravatar.com/avatar/0129a541b7b3574e92c4afd06c5e32da&d=identicon","tier","pro","canRestrictVals","profileImageUrl","ctx",{"_81":-5,"_141":142,"_143":144,"_145":146,"_147":42,"_148":42,"_149":42,"_150":32,"_151":-5,"_152":-7,"_153":-7,"_154":36,"_155":42,"_156":42,"_157":-5,"_158":42,"_159":42,"_160":42,"_161":-5},"ENV",{"_112":113,"_114":115,"_116":88,"_117":118,"_119":120,"_121":122,"_123":124,"_125":126,"_127":128,"_129":130,"_131":132,"_133":134,"_135":136,"_137":138,"_139":140},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","c73f21da490985bff19c279eb0e09db24d688e4f","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","orgs",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]