[{"_1":2,"_175":-5,"_176":-5},"loaderData",{"_3":4,"_92":93},"root",{"_5":6,"_35":36,"_65":66},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":32,"_33":20,"_34":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","isTeamOrgMember","ENV",{"_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":64},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","4207e8ad4ddbe7f6e8b804339ca1b2ec4ab76c50","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",{"_67":68},"__internal_clerk_state",{"_69":70,"_71":46,"_72":73,"_74":73,"_75":20,"_76":73,"_77":73,"_78":73,"_79":73,"_80":81,"_90":20,"_91":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",{"_82":20,"_19":20,"_83":73,"_84":85,"_86":73,"_87":46,"_88":20,"_89":73},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_94":95,"_96":97,"_98":99,"_100":101,"_154":155,"_172":173,"_174":-5},"handle","dcm31","name","live-reload2","path","utils.ts","project",{"_102":103,"_96":97,"_104":105,"_106":-5,"_107":20,"_108":109,"_110":-5,"_111":-5,"_12":112,"_113":114,"_115":116,"_117":-5,"_118":119,"_120":32,"_14":121,"_122":123,"_124":123,"_125":126,"_127":126,"_128":126,"_129":123,"_130":123,"_23":131,"_134":135,"_137":138,"_153":20},"id","9ed7b34a-2763-11f0-977a-569c3dd06744","createdAt",["D",1746196926855],"deletedAt","legacyEnvVars","privacy","public","description","imageUrl","9319c175-2593-4f88-ba21-04f2ef7b1c28","pinnedFileId","6b97571b-ee27-4738-8feb-6952f5f10230","pinPreview",true,"pinMigrated","screenshotVersion",16,"likeCount","d663a026-6449-42f6-9156-1d4a2d64d38c","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_94":95,"_132":133},"profileImageUrl","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/260ec866-bb5d-4641-4bfe-526cca896a00/square512","org",{"_94":95,"_136":133,"_12":112},"avatar","branch",{"_139":119,"_96":44,"_102":140,"_141":103,"_142":143,"_144":145,"_146":109,"_147":148,"_149":150,"_151":97,"_152":95},"version","9edb6602-2763-11f0-977a-569c3dd06744","projectId","forkedBranchId","c1f3680e-13d8-11f0-a31b-569c3dd06744","forkedBranchVersion",243,"forkedProjectPrivacy","forkedProjectId","c1f31c00-13d8-11f0-a31b-569c3dd06744","forkedProjectOrgId","e81e7335-6d4c-4764-a902-d0962bbfa9f7","projectName","userHandle","isOwned","file",{"_102":156,"_96":99,"_157":158,"_159":-5,"_160":140,"_161":162,"_163":116,"_104":164,"_139":32,"_165":166,"_167":168,"_169":20,"_170":-5,"_98":171},"9ede9f2a-2763-11f0-977a-569c3dd06744","fileId","15c7895c-889e-42d9-9865-cb4b1ee585c6","parentId","branchId","branchVersion",1,"latest",["D",1746196926855],"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",[99],"permalink","https://www.val.town/x/dcm31/live-reload2/code/utils.ts","extension","actionData","errors"]