[{"_1":2,"_173":-5,"_174":-5},"loaderData",{"_3":4,"_91":92},"root",{"_5":6,"_34":35,"_64":65},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":32,"_33":20},"auth",{"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20,"_21":22},"sessionClaims","sessionId","sessionStatus","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","isAuthenticated",false,"tokenType","session_token","user","preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","notificationCount",0,"flagDenols","ENV",{"_36":37,"_38":39,"_40":41,"_42":43,"_44":45,"_46":47,"_48":49,"_50":51,"_52":53,"_54":55,"_56":57,"_58":59,"_60":61,"_62":63},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","8a8b990148e6b1a9e66ac945d46b9f4b7b4ce2c4","RENDER_GIT_BRANCH","main","CLERK_PUBLISHABLE_KEY","pk_live_Y2xlcmsudmFsLnRvd24k","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","API_URL","https://api.val.town","clerkState",{"_66":67},"__internal_clerk_state",{"_68":69,"_70":45,"_71":72,"_73":72,"_74":20,"_75":72,"_76":72,"_77":72,"_78":72,"_79":80,"_89":20,"_90":20},"__clerk_ssr_state",{"_21":22,"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__clerk_debug",{"_81":20,"_19":20,"_82":72,"_83":84,"_85":72,"_86":45,"_87":20,"_88":72},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_93":94,"_95":96,"_97":98,"_99":100,"_150":151,"_170":171,"_172":-5},"handle","stevekrouse","name","live-reload","path","utils.ts","project",{"_101":102,"_95":96,"_103":104,"_105":-5,"_106":20,"_107":108,"_109":110,"_111":-5,"_12":112,"_113":114,"_115":20,"_116":117,"_118":119,"_14":120,"_121":122,"_123":122,"_124":125,"_126":125,"_127":125,"_128":122,"_129":122,"_23":130,"_133":134,"_136":137,"_149":20},"id","c1f31c00-13d8-11f0-a31b-569c3dd06744","createdAt",["D",1744048213626],"deletedAt","legacyEnvVars","privacy","public","description","Middleware for live-reloading HTTP vals when they change","imageUrl","a0bf3b31-15a5-4d5c-880e-4b1e22c9bc18","pinnedFileId","ca919ae4-13d8-11f0-b855-569c3dd06744","pinPreview","screenshotVersion",254,"likeCount",5,"e81e7335-6d4c-4764-a902-d0962bbfa9f7","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_93":94,"_131":132},"profileImageUrl","https://images.clerk.dev/uploaded/img_2PqHa2Gsy93xQrjh2w78Xu0cChW.jpeg","org",{"_93":94,"_135":132},"avatar","branch",{"_138":139,"_95":43,"_101":140,"_141":102,"_142":-5,"_143":-5,"_144":-5,"_145":-5,"_146":-5,"_147":96,"_148":94},"version",255,"c1f3680e-13d8-11f0-a31b-569c3dd06744","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_101":152,"_95":98,"_153":154,"_155":-5,"_156":140,"_157":158,"_159":160,"_103":161,"_138":162,"_163":164,"_165":166,"_167":20,"_168":-5,"_97":169},"6c0a8862-2753-11f0-9980-569c3dd06744","fileId","d1c7712a-16fe-11f0-aa50-569c3dd06744","parentId","branchId","branchVersion",243,"latest",true,["D",1746189969675],24,"fileType","script","content","import { parseProject } from \"https://esm.town/v/std/utils@85-main/index.ts\";\nimport { HTMLRewriter } from \"https://ghuc.cc/worker-tools/html-rewriter/index.ts\";\nimport ValTown from \"npm:@valtown/sdk@0.37.0\";\n\nconst client = new ValTown();\n\n/**\n * Retrieves project and branch IDs from a given import meta URL\n *\n * @param importMetaUrl - The import.meta.url string to parse\n * @returns {Promise<{project_id: string, branch_id: string}>} Object containing project and branch IDs\n * @throws {Error} If the specified branch is not found\n */\nexport async function getProjectIds(importMetaUrl: string) {\n const {\n name: projectName,\n branch: branchName,\n username,\n } = parseProject(importMetaUrl);\n const { id: project_id } = await client.alias.username.projectName.retrieve(username, projectName);\n const branches = await client.projects.branches.list(project_id, { limit: 100 });\n const branch = branches.data.find(branch => branch.name === branchName);\n if (!branch) {\n throw new Error(`Branch ${branchName} not found`);\n }\n const branch_id = branch.id;\n return { project_id, branch_id, version: branch.version };\n}\n\nasync function projectLastUpdated({ project_id, branch_id }: { project_id: string; branch_id: string }) {\n const { updatedAt, version } = await client.projects.branches.retrieve(\n project_id,\n branch_id,\n );\n return { lastUpdatedAt: new Date(updatedAt).getTime(), version };\n}\n\nasync function wait(ms: number) {\n return new Promise(resolve => setTimeout(resolve, ms));\n}\n\n/**\n * Creates a promise that resolves with the result of the original promise\n * or rejects with a timeout error if the original promise takes longer than the specified time.\n *\n * @param {Promise} promise - The promise to apply a timeout to\n * @param {number} timeoutMs - Timeout in milliseconds\n * @param {string} [errorMessage] - Optional custom error message\n * @returns {Promise} A new promise with timeout behavior\n */\nexport function timeout(\n promise: Promise,\n timeoutMs: number,\n errorMessage: string = \"Operation timed out\",\n): Promise {\n // Create a promise that rejects after the specified timeout\n const timeoutPromise = new Promise((_, reject) => {\n const timeoutId = setTimeout(() => {\n clearTimeout(timeoutId);\n reject(new Error(errorMessage));\n }, timeoutMs);\n });\n\n // Return a race between the original promise and the timeout promise\n return Promise.race([promise, timeoutPromise]) as Promise;\n}\n\nexport async function longPollLastUpdated({\n version,\n project_id,\n branch_id,\n}: {\n version: number;\n project_id: string;\n branch_id: string;\n}): Promise {\n const { lastUpdatedAt, version: newVersion } = await projectLastUpdated({ project_id, branch_id });\n if (newVersion > version) {\n return { lastUpdatedAt, version: newVersion };\n }\n\n // last edit < 15 min, poll in 500ms\n // last edit < 1 hour, poll in 1 seconds\n // last edit > 1 hour, poll in 5 seconds\n let waitTime = lastUpdatedAt > Date.now() - 15 * 60 * 1000\n ? 500\n : lastUpdatedAt > Date.now() - 3 * 60 * 60 * 1000\n ? 1000\n : 5000;\n await wait(waitTime);\n\n return longPollLastUpdated({ version, project_id, branch_id });\n}\n/**\n * Creates a wrapper around a fetch handler that injects an HTML string\n * into the document. It first checks for a tag; if missing,\n * it looks for an tag. If neither are present, it appends to\n * the full text response.\n *\n * @param handler The original fetch handler function\n * @param html The HTML content to inject\n * @returns A new fetch handler with HTML rewriting\n */\nexport function injectHTML(\n handler: (request: Request) => Promise,\n html: string,\n): (request: Request) => Promise {\n return async (request: Request) => {\n const response = await handler(request);\n return injectHTMLResponse(response, html);\n };\n}\n\nexport async function injectHTMLResponse(\n response: Response,\n html: string,\n): Promise {\n const contentType = response.headers.get(\"Content-Type\");\n\n // Only modify responses with HTML content\n if (contentType && contentType.includes(\"text/html\")) {\n // Clone the response so we can inspect its text without disturbing the original stream\n const clonedResponse = response.clone();\n const responseText = await clonedResponse.text();\n\n // Check if a tag exists in the HTML document\n if (/ is missing but the tag exists, inject into as a fallback\n else if (/ nor tags are found, simply append the HTML to the raw text response\n else {\n return new Response(responseText + html, {\n headers: response.headers,\n status: response.status,\n statusText: response.statusText,\n });\n }\n }\n\n // For non-HTML responses, return the original response unmodified\n return response;\n}","deleted","label",[98],"permalink","https://www.val.town/x/stevekrouse/live-reload/code/utils.ts","extension","actionData","errors"]