${\n      escapeHtml(text)\n    }

`,\n };\n // Only set `to` when configured, so std/email falls back to the owner.\n if (to) message.to = to;\n\n try {\n await email(message as Parameters[0]);\n console.log(`[notify] sent \"${subject}\" to ${to ?? \"the val owner\"}`);\n return true;\n } catch (err) {\n console.error(\"[notify] email failed:\", err);\n return false;\n }\n}\n\nexport type FailureContext = {\n videoId?: string;\n /** Attempt number this failure represents, counting from 1. */\n attempts?: number;\n maxAttempts?: number;\n /** True when the pipeline will stop retrying this video. */\n exhausted?: boolean;\n /**\n * True when the failure is a credential/configuration problem rather than a\n * problem with the video. Changes the wording and the subject line.\n */\n auth?: boolean;\n};\n\n/** Format and send a failure report for one pipeline step. */\nexport async function reportStepFailure(\n step: string,\n err: unknown,\n context: FailureContext = {},\n): Promise {\n const detail = err instanceof Error ? `${err.name}: ${err.message}` : String(err);\n\n const lines: string[] = [];\n\n if (context.auth) {\n lines.push(`⚠️ Credential problem in step \"${step}\".`);\n lines.push(\n \"This is not the video's fault — its retry budget was left untouched.\",\n );\n } else {\n lines.push(`❌ Step \"${step}\" failed.`);\n }\n\n lines.push(\"\", detail.slice(0, 4000));\n\n if (context.videoId) {\n lines.push(\"\", `Video: ${context.videoId}`);\n }\n if (context.attempts !== undefined && context.maxAttempts !== undefined) {\n lines.push(\n `Attempt: ${context.attempts}/${context.maxAttempts}` +\n (context.exhausted ? \" — giving up on this video\" : \"\"),\n );\n }\n\n lines.push(\"\");\n if (context.auth) {\n lines.push(\"The pipeline will keep skipping publishing until this is fixed.\");\n } else if (context.exhausted) {\n lines.push(\"The next run will skip this video and try a different one.\");\n } else {\n lines.push(\"The next scheduled run will try again.\");\n }\n\n await sendNotification(\n context.auth ? `Action needed — ${step}` : `Failed — ${step}`,\n lines.join(\"\\n\"),\n );\n}",[],[184,304],"06071853-c085-4861-8574-5fff81f37b37","env.ts","9772dc3e-b20d-11f1-8580-1607ee4eb77e",38,["D",1789591726739],"/**\n * Central registry of the environment variables this val reads.\n *\n * Keeping the names in one place lets the cron handler check them all up front\n * and report every missing key in a single message, instead of dying on\n * whichever one it happens to touch first.\n *\n * TikTok is special-cased: it needs *either* a static `TIKTOK_ACCESS_TOKEN`\n * *or* the refresh triple (`TIKTOK_CLIENT_KEY` + `TIKTOK_CLIENT_SECRET` +\n * `TIKTOK_REFRESH_TOKEN`). See `findMissingTikTokEnv`.\n */\n\nexport const ENV = {\n YOUTUBE_API_KEY: \"YOUTUBE_API_KEY\",\n OPUS_CLIP_API_KEY: \"OPUS_CLIP_API_KEY\",\n /** Optional — only needed when the Opus account belongs to several orgs. */\n OPUS_ORG_ID: \"OPUS_ORG_ID\",\n /** Optional — defaults to the val owner's own address. */\n NOTIFY_EMAIL: \"NOTIFY_EMAIL\",\n TIKTOK_ACCESS_TOKEN: \"TIKTOK_ACCESS_TOKEN\",\n TIKTOK_CLIENT_KEY: \"TIKTOK_CLIENT_KEY\",\n TIKTOK_CLIENT_SECRET: \"TIKTOK_CLIENT_SECRET\",\n TIKTOK_REFRESH_TOKEN: \"TIKTOK_REFRESH_TOKEN\",\n} as const;\n\nexport type EnvName = (typeof ENV)[keyof typeof ENV];\n\n/** Keys needed regardless of how TikTok is configured. */\nexport const REQUIRED_ENV: EnvName[] = [\n ENV.YOUTUBE_API_KEY,\n ENV.OPUS_CLIP_API_KEY,\n];\n\n/** The triple that enables automatic TikTok token renewal. */\nexport const TIKTOK_REFRESH_ENV: EnvName[] = [\n ENV.TIKTOK_CLIENT_KEY,\n ENV.TIKTOK_CLIENT_SECRET,\n ENV.TIKTOK_REFRESH_TOKEN,\n];\n\nexport class MissingEnvError extends Error {\n constructor(readonly keys: EnvName[]) {\n super(`Missing environment variable(s): ${keys.join(\", \")}`);\n this.name = \"MissingEnvError\";\n }\n}\n\n/** Read an env var, or `undefined` when it is unset or blank. */\nexport function optionalEnv(name: EnvName): string | undefined {\n return Deno.env.get(name)?.trim() || undefined;\n}\n\n/** Read a required env var, throwing if it is unset or blank. */\nexport function requireEnv(name: EnvName): string {\n const value = optionalEnv(name);\n if (!value) throw new MissingEnvError([name]);\n return value;\n}\n\n/** Which of `names` are unset or blank. */\nexport function findMissingEnv(names: EnvName[] = REQUIRED_ENV): EnvName[] {\n return names.filter((name) => !optionalEnv(name));\n}\n\n/**\n * Which TikTok keys are missing, if any.\n *\n * A static `TIKTOK_ACCESS_TOKEN` is enough on its own. Otherwise all three\n * refresh keys are needed. Returns `[]` when TikTok is configured either way.\n */\nexport function findMissingTikTokEnv(): EnvName[] {\n if (optionalEnv(ENV.TIKTOK_ACCESS_TOKEN)) return [];\n return findMissingEnv(TIKTOK_REFRESH_ENV);\n}\n\n/** True when the val can renew its own TikTok token. */\nexport function canRefreshTikTokToken(): boolean {\n return findMissingEnv(TIKTOK_REFRESH_ENV).length === 0;\n}\n\n/**\n * A human-readable explanation of what TikTok still needs, or `undefined` when\n * it is configured. More useful than a bare list of missing keys, because\n * \"client key and secret set, but no token at all\" is a different situation\n * from \"nothing set\".\n */\nexport function tiktokConfigProblem(): string | undefined {\n if (optionalEnv(ENV.TIKTOK_ACCESS_TOKEN)) return undefined;\n if (findMissingEnv(TIKTOK_REFRESH_ENV).length === 0) return undefined;\n\n const hasClientCreds = findMissingEnv([\n ENV.TIKTOK_CLIENT_KEY,\n ENV.TIKTOK_CLIENT_SECRET,\n ]).length === 0;\n\n return hasClientCreds\n ? \"TikTok has a client key and secret but no token. Either set \" +\n \"TIKTOK_ACCESS_TOKEN, or run the OAuth authorization_code flow once — \" +\n \"TikTok returns an access token AND a refresh token together — and set \" +\n \"TIKTOK_REFRESH_TOKEN so the val can renew itself.\"\n : \"TikTok is not configured. Set TIKTOK_ACCESS_TOKEN, or set all of: \" +\n TIKTOK_REFRESH_ENV.join(\", \") + \".\";\n}",[],[184,312],["D",1789591051285],[],[184,68],"6d3922ec-e685-449f-86e1-38cbcfca784a","config.ts","6001f0f4-b20e-11f1-b7d7-1607ee4eb77e",39,["D",1789591726850],"/**\n * Tunables for the pipeline.\n *\n * Everything you're likely to want to adjust lives here, so you don't have to\n * hunt through the individual step modules.\n */\n\n/**\n * How many times a single video may fail before the pipeline stops retrying it\n * and moves on to the next candidate. Each scheduled run counts as one attempt,\n * so with the default 12-hour cron, 3 attempts ≈ 36 hours of retrying.\n *\n * Credential problems (an expired TikTok token, say) do NOT count as attempts —\n * see `main.ts`. Only real per-video failures do.\n */\nexport const MAX_ATTEMPTS = 3;\n\n/**\n * How long to wait before repeating an \"action needed\" alert while the problem\n * persists. Keeps a dead TikTok token from mailing you twice a day.\n */\nexport const AUTH_ALERT_REPEAT_HOURS = 24;\n\n/** Trending search keywords, tried in order until an unprocessed video turns up. */\nexport const SEARCH_QUERIES = [\n \"podcast highlights\",\n \"tech trends\",\n \"founder interview\",\n \"viral moments\",\n];\n\n/**\n * Opus Clip curation model.\n * \"ClipBasic\" — optimised for talking-head video (podcasts, interviews).\n * \"ClipAnything\" — multimodal, better for vlogs, sports, TV, music.\n * Our search keywords target podcasts and interviews, so ClipBasic is the fit.\n */\nexport const OPUS_CURATION_MODEL = \"ClipBasic\";\n\n/** Longest clip to ask Opus Clip for, in seconds. */\nexport const CLIP_MAX_SECONDS = 90;",[],[184,323],"3552ec96-097b-43ff-a276-c539b5fd3f15",["D",1789590686836],[197,198,199,200,201,202,203],[184],["D",1789590675077],["D",1789591281607],{"_11":12,"_151":74},{"_11":12,"_147":74,"_73":74,"_30":72,"_148":149,"_150":24},{"_41":138,"_13":16,"_35":38,"_139":101,"_140":-5,"_141":-5,"_142":-5,"_143":-5,"_144":-5,"_145":14,"_146":12},"ctx",{"_56":-5,"_170":372,"_373":374,"_375":376,"_377":24,"_378":24,"_379":24,"_380":177,"_381":-5,"_382":-7,"_383":-7,"_384":26,"_385":24,"_386":24,"_387":-5,"_388":24,"_389":24,"_390":24,"_391":-5},"ENV",{"_343":344,"_345":346,"_347":16,"_348":349,"_350":351,"_352":353,"_354":355,"_356":357,"_358":359,"_360":361,"_362":363,"_364":365,"_366":367,"_368":369,"_370":371},"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",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

History · db.ts