[{"_1":2,"_174":-5,"_175":-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","a31a1550ad486cf340b818a53bc6ddc8c7db0295","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,"_153":154,"_171":172,"_173":-5},"handle","dcm31","name","live-reload5","path","utils.ts","project",{"_101":102,"_95":96,"_103":104,"_105":-5,"_106":20,"_107":108,"_109":-5,"_110":-5,"_12":111,"_112":113,"_114":115,"_116":-5,"_117":118,"_119":32,"_14":120,"_121":122,"_123":122,"_124":125,"_126":125,"_127":125,"_128":122,"_129":122,"_23":130,"_133":134,"_136":137,"_152":20},"id","c1713afc-276d-11f0-99c0-569c3dd06744","createdAt",["D",1746201279876],"deletedAt","legacyEnvVars","privacy","public","description","imageUrl","9319c175-2593-4f88-ba21-04f2ef7b1c28","pinnedFileId","6321b082-6beb-41b8-8369-fa84044bbb3f","pinPreview",true,"pinMigrated","screenshotVersion",12,"likeCount","d663a026-6449-42f6-9156-1d4a2d64d38c","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_93":94,"_131":132},"profileImageUrl","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/260ec866-bb5d-4641-4bfe-526cca896a00/square512","org",{"_93":94,"_135":132,"_12":111},"avatar","branch",{"_138":139,"_95":43,"_101":140,"_141":102,"_142":143,"_144":145,"_146":108,"_147":148,"_149":120,"_150":96,"_151":94},"version",18,"c1733f1e-276d-11f0-99c0-569c3dd06744","projectId","forkedBranchId","f9959c40-276b-11f0-800a-569c3dd06744","forkedBranchVersion",11,"forkedProjectPrivacy","forkedProjectId","f9926840-276b-11f0-800a-569c3dd06744","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_101":155,"_95":98,"_156":157,"_158":-5,"_159":140,"_160":161,"_162":115,"_103":163,"_138":32,"_164":165,"_166":167,"_168":20,"_169":-5,"_97":170},"c17571bc-276d-11f0-99c0-569c3dd06744","fileId","252c276a-aa5b-4d4f-9153-999c21ce24d9","parentId","branchId","branchVersion",1,"latest",["D",1746201279876],"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/dcm31/live-reload5/code/utils.ts","extension","actionData","errors"]