[{"_1":2,"_178":-5,"_179":-5},"loaderData",{"_3":4,"_93":94},"root",{"_5":6,"_36":37,"_66":67},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":-5,"_32":33,"_34":20,"_35":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","preferencesChatPanelState","notificationCount",0,"flagDenols","isTeamOrgMember","ENV",{"_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":65},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","7721b06a805a6662fde743a1ec849364175efb5b","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",{"_68":69},"__internal_clerk_state",{"_70":71,"_72":47,"_73":74,"_75":74,"_76":20,"_77":74,"_78":74,"_79":74,"_80":74,"_81":82,"_91":20,"_92":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",{"_83":20,"_19":20,"_84":74,"_85":86,"_87":74,"_88":47,"_89":20,"_90":74},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_95":96,"_97":98,"_99":100,"_101":102,"_155":156,"_175":176,"_177":-5},"handle","ashryanio","name","index-now","path","indexnow.http.ts","project",{"_103":104,"_97":98,"_105":106,"_107":-5,"_108":20,"_109":110,"_111":74,"_112":-5,"_12":113,"_114":-5,"_115":20,"_116":-5,"_117":-5,"_118":33,"_14":119,"_120":121,"_122":123,"_124":125,"_126":125,"_127":128,"_129":128,"_130":128,"_131":125,"_132":125,"_23":133,"_136":137,"_141":142,"_154":20},"id","e5fae6ec-04d1-11f1-9f4e-42dde27851f2","createdAt",["D",1770543497825],"deletedAt","legacyEnvVars","privacy","public","description","imageUrl","97567c3b-8285-4589-880d-547c23383b76","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","112e17ac-118d-4072-aca6-a4ddc6b3970f","tursoName","e5fae6ec04d111f19f4e42dde27851f2","tursoHostname","e5fae6ec04d111f19f4e42dde27851f2-val-town.aws-us-east-2.turso.io","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_95":96,"_134":135},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18yaG5kR0hRRTM0S1BSeXlIR2hCdjFqb1dTS3AifQ","org",{"_95":96,"_138":135,"_12":113,"_139":140},"avatar","tier","pro","branch",{"_143":144,"_97":45,"_103":145,"_146":104,"_147":-5,"_148":-5,"_149":-5,"_150":-5,"_151":-5,"_152":98,"_153":96},"version",360,"e5fb619e-04d1-11f1-9f4e-42dde27851f2","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_103":157,"_97":100,"_158":159,"_160":-5,"_161":145,"_162":163,"_164":165,"_105":166,"_143":167,"_168":169,"_170":171,"_172":20,"_173":98,"_99":174},"8c1fa7c4-07ac-11f1-bd38-42dde27851f2","fileId","8b018dec-04d4-11f1-a059-42dde27851f2","parentId","branchId","branchVersion",357,"latest",true,["D",1770857309136],25,"fileType","http","content","import monitorHandler, { loadMonitorSnapshotFromUrl } from \"./indexnow.monitor.ts\";\nimport { email } from \"https://esm.town/v/std/email\";\nimport { parseProject, readFile, serveFile } from \"https://esm.town/v/std/utils@85-main/index.ts\";\nimport {\n backfillSnapshots,\n loadRuntimeConfig,\n type IndexNowBackfillSummary,\n type IndexNowRunSummary,\n loadRunUrlStatusesByOutcome,\n type RunUrlStatusEntry,\n type RunUrlStatusesByOutcome,\n runIndexNow,\n} from \"./lib/indexnow.ts\";\nimport type { IndexNowMonitorResponse } from \"./shared/monitor-types.ts\";\n\nconst RUN_PATH = \"/run\";\nconst BACKFILL_PATH = \"/backfill\";\nconst MONITOR_PATH = \"/monitor\";\nconst FRONTEND_PATH_PREFIX = \"/frontend/\";\nconst ROBOTS_PATH = \"/robots.txt\";\nconst FAVICON_PATH = \"/favicon.ico\";\nconst RUN_TOKEN_ENV_VAR = \"INDEXNOW_RUN_TOKEN\";\nconst FORCE_TOKEN_ENV_VAR = \"INDEXNOW_FORCE_TOKEN\";\nconst ALERTS_ENABLED_ENV_VAR = \"INDEXNOW_ALERTS_ENABLED\";\nconst PUBLIC_BASE_URL_ENV_VAR = \"INDEXNOW_PUBLIC_BASE_URL\";\nconst RUN_TOKEN_HEADER = \"x-indexnow-token\";\nconst FORCE_TOKEN_HEADER = \"x-indexnow-force-token\";\nconst REASON_HEADER = \"x-indexnow-reason\";\nconst RUN_ALERT_STATUS_SAMPLE_LIMIT = 10;\nconst RUN_ALERT_ERROR_SAMPLE_LIMIT = 20;\nconst DASHBOARD_BOOTSTRAP_MARKER = \"\";\nconst DASHBOARD_BOOTSTRAP_GLOBAL = \"__INDEXNOW_BOOTSTRAP__\";\n\ntype RunReason = \"manual_run_endpoint\" | \"cron_entrypoint\";\n\ninterface DashboardBootstrapPayload {\n initialMonitor: IndexNowMonitorResponse;\n valProjectUrl: string;\n}\n\nfunction normalizePath(pathname: string): string {\n if (pathname === \"/\") {\n return \"/\";\n }\n return pathname.endsWith(\"/\") ? pathname.slice(0, -1) : pathname;\n}\n\nfunction parseRunReason(value: string | null): RunReason {\n return value === \"cron_entrypoint\" ? \"cron_entrypoint\" : \"manual_run_endpoint\";\n}\n\ninterface RunAlertDecision {\n shouldSend: boolean;\n hasIssues: boolean;\n hasSubmissions: boolean;\n acceptedTotal: number;\n submittedTotal: number;\n pendingTotal: number;\n deferredTotal: number;\n changedTotal: number;\n queuedTotal: number;\n}\n\ntype SiteRun = IndexNowRunSummary[\"siteRuns\"][number];\ntype AlertOutcome = \"submitted\" | \"pending\" | \"deferred\" | \"failed\";\n\nconst ALERT_OUTCOME_ORDER: AlertOutcome[] = [\"submitted\", \"pending\", \"deferred\", \"failed\"];\nconst ALERT_OUTCOME_LABELS: Record = {\n submitted: \"Submitted\",\n pending: \"Pending\",\n deferred: \"Deferred\",\n failed: \"Failed\",\n};\n\ninterface RunAlertLinkConfig {\n baseUrl: URL | null;\n unavailableReason: string | null;\n}\n\nfunction alertsEnabled(): boolean {\n const rawValue = Deno.env.get(ALERTS_ENABLED_ENV_VAR);\n if (!rawValue) {\n return true;\n }\n const normalized = rawValue.trim().toLowerCase();\n return ![\"0\", \"false\", \"off\", \"no\"].includes(normalized);\n}\n\nfunction needsAttention(site: SiteRun): boolean {\n return site.errors.length > 0 ||\n site.deferredCount > 0 ||\n site.queuedCount > (site.submittedCount + site.pendingCount);\n}\n\nfunction shouldAlertForSite(site: SiteRun): boolean {\n return (site.submittedCount + site.pendingCount) > 0 || needsAttention(site);\n}\n\nfunction resolveAlertRecipient(\n siteHost: string,\n siteConfigByHost: Map,\n): string | null {\n const alertEnvVar = siteConfigByHost.get(siteHost.toLowerCase());\n if (!alertEnvVar) {\n return null;\n }\n const resolved = Deno.env.get(alertEnvVar)?.trim() ?? \"\";\n return resolved.length > 0 ? resolved : null;\n}\n\nfunction groupSiteRunsByRecipient(\n summary: IndexNowRunSummary,\n siteConfigByHost: Map,\n): Array<{ recipient: string | null; siteRuns: SiteRun[] }> {\n const grouped = new Map();\n\n for (const siteRun of summary.siteRuns) {\n if (!shouldAlertForSite(siteRun)) {\n continue;\n }\n\n const recipient = resolveAlertRecipient(siteRun.host, siteConfigByHost);\n const key = recipient ?? \"__owner_default__\";\n const existing = grouped.get(key);\n if (existing) {\n existing.siteRuns.push(siteRun);\n continue;\n }\n grouped.set(key, {\n recipient,\n siteRuns: [siteRun],\n });\n }\n\n return Array.from(grouped.values());\n}\n\nfunction buildRunAlertDecision(summary: IndexNowRunSummary): RunAlertDecision {\n const submittedTotal = summary.siteRuns.reduce((acc, site) => acc + site.submittedCount, 0);\n const pendingTotal = summary.siteRuns.reduce((acc, site) => acc + site.pendingCount, 0);\n const acceptedTotal = submittedTotal + pendingTotal;\n const deferredTotal = summary.siteRuns.reduce((acc, site) => acc + site.deferredCount, 0);\n const changedTotal = summary.siteRuns.reduce((acc, site) => acc + site.changedCount, 0);\n const queuedTotal = summary.siteRuns.reduce((acc, site) => acc + site.queuedCount, 0);\n const hasSubmissions = acceptedTotal > 0;\n const hasIssues = summary.hasErrors ||\n summary.siteRuns.some((site) =>\n site.deferredCount > 0 || site.queuedCount > (site.submittedCount + site.pendingCount)\n );\n return {\n shouldSend: !summary.dryRun && (hasSubmissions || hasIssues),\n hasIssues,\n hasSubmissions,\n acceptedTotal,\n submittedTotal,\n pendingTotal,\n deferredTotal,\n changedTotal,\n queuedTotal,\n };\n}\n\nfunction buildSiteScope(summary: IndexNowRunSummary): string {\n return summary.siteRuns.length === 1\n ? summary.siteRuns[0].host\n : `${summary.siteRuns.length} sites`;\n}\n\nfunction emptyRunUrlStatusesByOutcome(): RunUrlStatusesByOutcome {\n return {\n submitted: [],\n pending: [],\n deferred: [],\n failed: [],\n dry_run: [],\n no_change: [],\n ignored: [],\n suppressed: [],\n };\n}\n\nfunction siteRunMapKey(siteRun: SiteRun): string {\n return `${siteRun.host.toLowerCase()}::${siteRun.runId}`;\n}\n\nfunction resolveRunAlertLinkConfig(): RunAlertLinkConfig {\n const rawBaseUrl = Deno.env.get(PUBLIC_BASE_URL_ENV_VAR)?.trim() ?? \"\";\n if (rawBaseUrl.length === 0) {\n return {\n baseUrl: null,\n unavailableReason: `Dashboard links unavailable: set ${PUBLIC_BASE_URL_ENV_VAR} to your public val URL.`,\n };\n }\n\n try {\n const parsed = new URL(rawBaseUrl);\n if (parsed.protocol !== \"https:\" && parsed.protocol !== \"http:\") {\n throw new Error(\"protocol must be http or https\");\n }\n parsed.search = \"\";\n parsed.hash = \"\";\n parsed.pathname = parsed.pathname.replace(/\\/+$/, \"\");\n return {\n baseUrl: parsed,\n unavailableReason: null,\n };\n } catch {\n return {\n baseUrl: null,\n unavailableReason: `Dashboard links unavailable: ${PUBLIC_BASE_URL_ENV_VAR} must be a valid absolute http(s) URL.`,\n };\n }\n}\n\nfunction buildRunDashboardLink(siteRun: SiteRun, linkConfig: RunAlertLinkConfig): string | null {\n if (!linkConfig.baseUrl) {\n return null;\n }\n\n const link = new URL(\"/\", linkConfig.baseUrl);\n link.searchParams.set(\"runs\", \"50\");\n link.searchParams.set(\"site\", siteRun.host);\n link.searchParams.set(\"run\", String(siteRun.runId));\n return link.toString();\n}\n\nfunction toPathWithQuery(urlText: string): string {\n try {\n const parsed = new URL(urlText);\n return `${parsed.pathname}${parsed.search}` || \"/\";\n } catch {\n return urlText;\n }\n}\n\nfunction formatStatusPath(entry: RunUrlStatusEntry): string {\n if (entry.slug.startsWith(\"/\")) {\n return entry.slug;\n }\n const fallback = toPathWithQuery(entry.url);\n if (fallback.startsWith(\"/\")) {\n return fallback;\n }\n return entry.slug.length > 0 ? entry.slug : entry.url;\n}\n\nfunction buildStatusSectionLines(outcome: AlertOutcome, entries: RunUrlStatusEntry[]): string[] {\n const label = ALERT_OUTCOME_LABELS[outcome];\n if (entries.length === 0) {\n return [`${label} URLs: 0`];\n }\n\n const sampled = entries.slice(0, RUN_ALERT_STATUS_SAMPLE_LIMIT);\n const remaining = entries.length - sampled.length;\n const lines = [`${label} URLs: ${entries.length}`];\n for (const entry of sampled) {\n lines.push(`- ${formatStatusPath(entry)}`);\n }\n if (remaining > 0) {\n lines.push(`- +${remaining} more ${outcome} URLs not shown`);\n }\n return lines;\n}\n\nasync function loadStatusesForSiteRuns(siteRuns: SiteRun[]): Promise> {\n const loaded = await Promise.all(siteRuns.map(async (siteRun) => {\n const statuses = await loadRunUrlStatusesByOutcome(siteRun.host, siteRun.runId);\n return [siteRunMapKey(siteRun), statuses] as const;\n }));\n return new Map(loaded);\n}\n\nfunction totalFailedUrls(siteRuns: SiteRun[], statusesBySiteRun: Map): number {\n return siteRuns.reduce((acc, siteRun) => {\n const statuses = statusesBySiteRun.get(siteRunMapKey(siteRun));\n return acc + (statuses?.failed.length ?? 0);\n }, 0);\n}\n\nfunction buildRunAlertSubject(\n summary: IndexNowRunSummary,\n decision: RunAlertDecision,\n failedTotal: number,\n): string {\n const siteScope = buildSiteScope(summary);\n if (decision.hasIssues) {\n return `IndexNow attention required for ${siteScope} (submitted=${decision.submittedTotal}, pending=${decision.pendingTotal}, deferred=${decision.deferredTotal}, failed=${failedTotal})`;\n }\n return `${decision.acceptedTotal} URLs accepted by IndexNow for ${siteScope}`;\n}\n\nfunction buildRunAlertText(\n summary: IndexNowRunSummary,\n decision: RunAlertDecision,\n statusesBySiteRun: Map,\n linkConfig: RunAlertLinkConfig,\n failedTotal: number,\n): string {\n const lines: string[] = [\n decision.hasIssues\n ? \"IndexNow run needs attention.\"\n : \"Your URLs were accepted by IndexNow.\",\n `Reason: ${summary.reason}`,\n `Started: ${summary.startedAt}`,\n `Finished: ${summary.finishedAt}`,\n `Force mode: ${summary.force ? \"yes\" : \"no\"}`,\n `Endpoint: ${summary.endpoint}`,\n `Run URL limit: ${summary.runUrlLimit}`,\n `Totals: changed=${decision.changedTotal}, queued=${decision.queuedTotal}, submitted=${decision.submittedTotal}, pending=${decision.pendingTotal}, deferred=${decision.deferredTotal}, failed=${failedTotal}`,\n ];\n\n if (linkConfig.unavailableReason) {\n lines.push(linkConfig.unavailableReason);\n }\n\n lines.push(\"\", \"Per-site:\");\n\n for (const siteRun of summary.siteRuns) {\n const statuses = statusesBySiteRun.get(siteRunMapKey(siteRun)) ?? emptyRunUrlStatusesByOutcome();\n const dashboardLink = buildRunDashboardLink(siteRun, linkConfig);\n const baseUrl = `https://${siteRun.host}`;\n\n lines.push(\"\");\n lines.push(`Site: ${siteRun.host}`);\n lines.push(`Run ID: ${siteRun.runId}`);\n lines.push(\n `Counts: changed=${siteRun.changedCount}, queued=${siteRun.queuedCount}, submitted=${siteRun.submittedCount}, pending=${siteRun.pendingCount}, deferred=${siteRun.deferredCount}, failed=${statuses.failed.length}`,\n );\n lines.push(\n `Informational: ignored=${statuses.ignored.length}, no_change=${statuses.no_change.length}, suppressed=${statuses.suppressed.length}`,\n );\n if (dashboardLink) {\n lines.push(`Dashboard: ${dashboardLink}`);\n } else {\n lines.push(\"Dashboard: unavailable\");\n }\n lines.push(`Base URL: ${baseUrl}`);\n\n for (const outcome of ALERT_OUTCOME_ORDER) {\n lines.push(\"\");\n lines.push(...buildStatusSectionLines(outcome, statuses[outcome]));\n }\n\n if (siteRun.errors.length > 0) {\n lines.push(\"\");\n lines.push(`Errors (${siteRun.errors.length}):`);\n lines.push(...siteRun.errors.slice(0, RUN_ALERT_ERROR_SAMPLE_LIMIT).map((error) => `- ${error}`));\n if (siteRun.errors.length > RUN_ALERT_ERROR_SAMPLE_LIMIT) {\n lines.push(`- +${siteRun.errors.length - RUN_ALERT_ERROR_SAMPLE_LIMIT} more errors not shown`);\n }\n }\n }\n\n return lines.join(\"\\n\");\n}\n\nasync function maybeSendRunAlert(summary: IndexNowRunSummary): Promise {\n if (!alertsEnabled() || summary.dryRun) {\n return;\n }\n\n const runtimeConfig = await loadRuntimeConfig();\n const siteConfigByHost = new Map(\n runtimeConfig.sites.map((site) => [site.host.toLowerCase(), site.alertToEnvVar]),\n );\n const groupedRuns = groupSiteRunsByRecipient(summary, siteConfigByHost);\n if (groupedRuns.length === 0) {\n return;\n }\n const linkConfig = resolveRunAlertLinkConfig();\n\n for (const group of groupedRuns) {\n const groupedSummary: IndexNowRunSummary = {\n ...summary,\n siteRuns: group.siteRuns,\n hasErrors: group.siteRuns.some((site) => site.errors.length > 0),\n };\n const decision = buildRunAlertDecision(groupedSummary);\n if (!decision.shouldSend) {\n continue;\n }\n const statusesBySiteRun = await loadStatusesForSiteRuns(groupedSummary.siteRuns);\n const failedTotal = totalFailedUrls(groupedSummary.siteRuns, statusesBySiteRun);\n\n await email({\n ...(group.recipient ? { to: group.recipient } : {}),\n subject: buildRunAlertSubject(groupedSummary, decision, failedTotal),\n text: buildRunAlertText(groupedSummary, decision, statusesBySiteRun, linkConfig, failedTotal),\n });\n }\n}\n\nfunction jsonResponse(data: unknown, status: number): Response {\n return new Response(JSON.stringify(data, null, 2), {\n status,\n headers: {\n \"content-type\": \"application/json; charset=utf-8\",\n \"cache-control\": \"no-store\",\n },\n });\n}\n\nfunction robotsResponse(): Response {\n const body = [\n \"User-agent: *\",\n \"Disallow: /\",\n ].join(\"\\n\");\n\n return new Response(body, {\n status: 200,\n headers: {\n \"content-type\": \"text/plain; charset=utf-8\",\n \"cache-control\": \"public, max-age=3600\",\n \"x-robots-tag\": \"noindex, nofollow, noarchive\",\n },\n });\n}\n\nfunction faviconResponse(): Response {\n return new Response(null, {\n status: 204,\n headers: {\n \"cache-control\": \"public, max-age=86400\",\n },\n });\n}\n\nfunction methodNotAllowedResponse(allowed: string, message: string): Response {\n return new Response(\n JSON.stringify(\n {\n error: \"Method Not Allowed\",\n message,\n },\n null,\n 2,\n ),\n {\n status: 405,\n headers: {\n \"content-type\": \"application/json; charset=utf-8\",\n \"cache-control\": \"no-store\",\n \"allow\": allowed,\n },\n },\n );\n}\n\nfunction jsonToInlineScript(value: unknown): string {\n return JSON.stringify(value)\n .replaceAll(\"<\", \"\\\\u003c\")\n .replaceAll(\">\", \"\\\\u003e\")\n .replaceAll(\"&\", \"\\\\u0026\")\n .replaceAll(\"\\u2028\", \"\\\\u2028\")\n .replaceAll(\"\\u2029\", \"\\\\u2029\");\n}\n\nasync function dashboardHtmlResponse(requestUrl: URL): Promise {\n const monitor = await loadMonitorSnapshotFromUrl(requestUrl);\n const assetVersion = monitor.generatedAt.replaceAll(/[^0-9]/g, \"\");\n const bootstrapPayload: DashboardBootstrapPayload = {\n initialMonitor: monitor,\n valProjectUrl: parseProject(import.meta.url).links.self.project,\n };\n let html = await readFile(\"/frontend/index.html\", import.meta.url);\n const bootstrapScript = ``;\n html = html.includes(DASHBOARD_BOOTSTRAP_MARKER)\n ? html.replace(DASHBOARD_BOOTSTRAP_MARKER, bootstrapScript)\n : html.replace(\"\", `${bootstrapScript}`);\n html = html\n .replace(\"/frontend/styles.css\", `/frontend/styles.css?v=${assetVersion}`)\n .replace(\"/frontend/index.tsx\", `/frontend/index.tsx?v=${assetVersion}`);\n\n return new Response(html, {\n status: 200,\n headers: {\n \"content-type\": \"text/html; charset=utf-8\",\n \"cache-control\": \"no-store\",\n },\n });\n}\n\nfunction readBearerToken(headerValue: string | null): string | null {\n if (!headerValue) {\n return null;\n }\n const trimmed = headerValue.trim();\n if (!trimmed.toLowerCase().startsWith(\"bearer \")) {\n return null;\n }\n const token = trimmed.slice(\"bearer \".length).trim();\n return token.length > 0 ? token : null;\n}\n\nfunction readRunToken(req: Request): string | null {\n const bearer = readBearerToken(req.headers.get(\"authorization\"));\n if (bearer) {\n return bearer;\n }\n const headerToken = req.headers.get(RUN_TOKEN_HEADER)?.trim() ?? \"\";\n return headerToken.length > 0 ? headerToken : null;\n}\n\nfunction readForceToken(req: Request): string | null {\n const headerToken = req.headers.get(FORCE_TOKEN_HEADER)?.trim() ?? \"\";\n return headerToken.length > 0 ? headerToken : null;\n}\n\nfunction readConfiguredRunToken(): string {\n return Deno.env.get(RUN_TOKEN_ENV_VAR)?.trim() ?? \"\";\n}\n\nfunction authorizeRunToken(req: Request): Response | null {\n const configuredRunToken = readConfiguredRunToken();\n if (configuredRunToken.length === 0) {\n return jsonResponse(\n {\n error: \"Server Misconfigured\",\n message: `${RUN_TOKEN_ENV_VAR} is not configured.`,\n },\n 503,\n );\n }\n\n const providedRunToken = readRunToken(req);\n if (providedRunToken !== configuredRunToken) {\n return jsonResponse(\n {\n error: \"Unauthorized\",\n message: `Provide a valid Bearer token or ${RUN_TOKEN_HEADER} header.`,\n },\n 401,\n );\n }\n\n return null;\n}\n\nasync function handleRunRequest(req: Request, requestUrl: URL): Promise {\n if (req.method !== \"POST\") {\n return new Response(\n JSON.stringify(\n {\n error: \"Method Not Allowed\",\n message: \"Use POST for /run.\",\n },\n null,\n 2,\n ),\n {\n status: 405,\n headers: {\n \"content-type\": \"application/json; charset=utf-8\",\n \"cache-control\": \"no-store\",\n \"allow\": \"POST\",\n },\n },\n );\n }\n\n const authFailure = authorizeRunToken(req);\n if (authFailure) {\n return authFailure;\n }\n\n const dryRun = requestUrl.searchParams.get(\"dryRun\") === \"1\";\n const force = requestUrl.searchParams.get(\"force\") === \"1\";\n const siteHost = requestUrl.searchParams.get(\"site\") ?? undefined;\n\n if (force) {\n const configuredForceToken = Deno.env.get(FORCE_TOKEN_ENV_VAR)?.trim() ?? \"\";\n if (configuredForceToken.length === 0) {\n return jsonResponse(\n {\n error: \"Forbidden\",\n message: `force=1 is disabled because ${FORCE_TOKEN_ENV_VAR} is not configured.`,\n },\n 403,\n );\n }\n\n const providedForceToken = readForceToken(req);\n if (providedForceToken !== configuredForceToken) {\n return jsonResponse(\n {\n error: \"Forbidden\",\n message: `force=1 requires a valid ${FORCE_TOKEN_HEADER} header.`,\n },\n 403,\n );\n }\n }\n\n const reason = parseRunReason(req.headers.get(REASON_HEADER));\n\n const summary = await runIndexNow({\n dryRun,\n force,\n siteHost,\n reason,\n });\n\n try {\n await maybeSendRunAlert(summary);\n } catch (error) {\n const message = error instanceof Error ? error.message : String(error);\n console.error(`IndexNow alert email failed: ${message}`);\n }\n\n return jsonResponse(summary, summary.hasErrors ? 500 : 200);\n}\n\nasync function handleBackfillRequest(req: Request, requestUrl: URL): Promise {\n if (req.method !== \"POST\") {\n return new Response(\n JSON.stringify(\n {\n error: \"Method Not Allowed\",\n message: \"Use POST for /backfill.\",\n },\n null,\n 2,\n ),\n {\n status: 405,\n headers: {\n \"content-type\": \"application/json; charset=utf-8\",\n \"cache-control\": \"no-store\",\n \"allow\": \"POST\",\n },\n },\n );\n }\n\n const authFailure = authorizeRunToken(req);\n if (authFailure) {\n return authFailure;\n }\n\n const dryRunRaw = requestUrl.searchParams.get(\"dryRun\");\n if (dryRunRaw !== null && dryRunRaw !== \"0\" && dryRunRaw !== \"1\") {\n return jsonResponse(\n {\n error: \"Bad Request\",\n message: \"dryRun must be 0 or 1 when provided.\",\n },\n 400,\n );\n }\n const dryRun = dryRunRaw === null ? true : dryRunRaw === \"1\";\n\n const siteHost = requestUrl.searchParams.get(\"site\") ?? undefined;\n const limitRaw = requestUrl.searchParams.get(\"limit\");\n let limitPerSite: number | undefined;\n if (limitRaw !== null) {\n const parsed = Number.parseInt(limitRaw, 10);\n if (!Number.isFinite(parsed) || parsed <= 0) {\n return jsonResponse(\n {\n error: \"Bad Request\",\n message: \"limit must be a positive integer when provided.\",\n },\n 400,\n );\n }\n limitPerSite = parsed;\n }\n\n const summary: IndexNowBackfillSummary = await backfillSnapshots({\n dryRun,\n siteHost,\n limitPerSite,\n });\n\n return jsonResponse(summary, summary.hasErrors ? 500 : 200);\n}\n\nfunction buildRequestWithUrl(req: Request, url: URL): Request {\n return new Request(url.toString(), {\n method: req.method,\n headers: req.headers,\n });\n}\n\nexport async function handleIndexNowHttp(req: Request): Promise {\n const requestUrl = new URL(req.url);\n const pathname = normalizePath(requestUrl.pathname);\n\n if (pathname.startsWith(FRONTEND_PATH_PREFIX)) {\n if (req.method !== \"GET\") {\n return methodNotAllowedResponse(\"GET\", \"Use GET for frontend assets.\");\n }\n const assetPath = pathname;\n const assetResponse = await serveFile(assetPath, import.meta.url);\n const headers = new Headers(assetResponse.headers);\n headers.set(\"cache-control\", \"no-store\");\n return new Response(assetResponse.body, {\n status: assetResponse.status,\n headers,\n });\n }\n\n if (pathname === ROBOTS_PATH) {\n return robotsResponse();\n }\n\n if (pathname === FAVICON_PATH) {\n return faviconResponse();\n }\n\n if (pathname === RUN_PATH) {\n return handleRunRequest(req, requestUrl);\n }\n\n if (pathname === BACKFILL_PATH) {\n return handleBackfillRequest(req, requestUrl);\n }\n\n if (pathname === MONITOR_PATH) {\n if (req.method !== \"GET\") {\n return methodNotAllowedResponse(\"GET\", \"Use GET for /monitor.\");\n }\n return monitorHandler(buildRequestWithUrl(req, requestUrl));\n }\n\n if (pathname === \"/\") {\n if (req.method !== \"GET\") {\n return methodNotAllowedResponse(\"GET\", \"Use GET for /.\");\n }\n return dashboardHtmlResponse(requestUrl);\n }\n\n return jsonResponse(\n {\n error: \"Not Found\",\n message: \"Supported paths: /, /run, /backfill, /monitor\",\n },\n 404,\n );\n}\n\nexport default handleIndexNowHttp;\n","deleted","label",[100],"permalink","https://www.val.town/x/ashryanio/index-now/code/indexnow.http.ts","extension","actionData","errors"]