[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_271":272,"_273":274},"routes/_app.x.$handle.$name",{"_105":104,"_38":52,"_113":95,"_33":107,"_13":14,"_114":-5,"_11":115,"_116":117,"_118":119,"_120":121,"_122":123,"_26":-5,"_124":-5,"_125":-5,"_126":31,"_127":128,"_129":31,"_130":-5,"_131":-5,"_132":133},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":-5},"project",{"_50":51,"_38":52,"_45":53,"_54":-5,"_55":31,"_56":57,"_58":57,"_59":60,"_61":-5,"_19":62,"_63":-5,"_64":31,"_65":-5,"_66":-5,"_67":68,"_69":70,"_71":72,"_73":74,"_75":76,"_77":-5,"_78":79,"_80":79,"_81":82,"_83":82,"_84":82,"_85":79,"_86":79,"_87":88,"_89":90,"_91":92,"_93":31},"version",14,"changes",[25],"aiChatInfo",{"_20":21,"_22":-5,"_23":-5,"_24":-5},"userId","aiChatMessageId","f23476a0-430f-4e64-b1a2-1fcf040a0970","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle",{"_26":27,"_28":29,"_30":31,"_32":31,"_33":34,"_35":34},"file",{"_36":37,"_38":39,"_40":41,"_42":44,"_45":46,"_47":14,"_48":49,"_30":31},"previous",{"_36":37,"_38":39,"_40":41,"_42":43},"deleted",false,"deletedHere","path","lib/env.ts","latestPath","fileId","9772dc3e-b20d-11f1-8580-1607ee4eb77e","name","env.ts","fileType","script","content","/**\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 Telegram message, instead of dying\n * on whichever one it happens to touch first.\n */\n\nexport const ENV = {\n YOUTUBE_API_KEY: \"YOUTUBE_API_KEY\",\n OPUS_CLIP_API_KEY: \"OPUS_CLIP_API_KEY\",\n TIKTOK_ACCESS_TOKEN: \"TIKTOK_ACCESS_TOKEN\",\n TELEGRAM_BOT_TOKEN: \"TELEGRAM_BOT_TOKEN\",\n TELEGRAM_CHAT_ID: \"TELEGRAM_CHAT_ID\",\n} as const;\n\nexport type EnvName = (typeof ENV)[keyof typeof ENV];\n\n/** Every key the happy path needs. */\nexport const REQUIRED_ENV: EnvName[] = Object.values(ENV);\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 a required env var, throwing if it is unset or blank. */\nexport function requireEnv(name: EnvName): string {\n const value = Deno.env.get(name)?.trim();\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) => !Deno.env.get(name)?.trim());\n}","/**\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 Telegram message, instead of dying\n * on whichever one it happens to touch first.\n *\n * TikTok is special-cased: it can be configured either with a static\n * `TIKTOK_ACCESS_TOKEN` (manual, expires in ~24h) or with the refresh triple\n * (`TIKTOK_CLIENT_KEY` + `TIKTOK_CLIENT_SECRET` + `TIKTOK_REFRESH_TOKEN`),\n * which lets the val renew its own 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 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 TELEGRAM_BOT_TOKEN: \"TELEGRAM_BOT_TOKEN\",\n TELEGRAM_CHAT_ID: \"TELEGRAM_CHAT_ID\",\n} as const;\n\nexport type EnvName = (typeof ENV)[keyof typeof ENV];\n\n/** Keys needed regardless of which TikTok mode you use. */\nexport const REQUIRED_ENV: EnvName[] = [\n ENV.YOUTUBE_API_KEY,\n ENV.OPUS_CLIP_API_KEY,\n ENV.TELEGRAM_BOT_TOKEN,\n ENV.TELEGRAM_CHAT_ID,\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}","createdAt",["D",1789591031151],"branchVersion","branchId","7b1f7eb3-1f90-4b89-bc30-a5817ab59c76","id","fe948bec-46cd-4016-a1ac-e2216d0acfcb","trend-video-autoposter",["D",1789590675077],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","YouTube trend → AI clip → TikTok auto-post, every 12 hours","imageUrl","fddfc1a6-8d1e-4681-b49d-92beee01dfa0","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","01a0ab6a-d4b7-7696-9a1f-6d45e686e25c","tursoName","fe948bec46cd4016a1ace2216d0acfcb","tursoHostname","fe948bec46cd4016a1ace2216d0acfcb-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789591281607],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_105":104,"_112":107},"org",{"_105":104,"_106":107,"_108":107,"_19":62,"_109":110,"_111":31},"branch",{"_13":94,"_38":95,"_50":49,"_96":51,"_97":-5,"_98":-5,"_99":-5,"_100":-5,"_101":-5,"_102":52,"_103":104},"isOwned",46,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","motest","handle","displayName","","avatar","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_50":51,"_38":52,"_45":266,"_54":-5,"_55":31,"_56":57,"_58":57,"_59":60,"_61":-5,"_19":62,"_63":-5,"_64":31,"_65":-5,"_66":-5,"_67":68,"_69":70,"_71":72,"_73":74,"_75":267,"_77":-5,"_78":79,"_80":79,"_81":82,"_83":82,"_84":82,"_85":79,"_86":79,"_87":268,"_89":269,"_91":270,"_93":31},"tree",[182,190,192,193],"files",[182,183,184,185,186,187,188,189,190,191,192,193],"counts",{"_171":68,"_172":145,"_173":68,"_174":175,"_176":177},"contents",[134,135,136,137],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_50":165,"_38":166,"_36":167,"_141":-5,"_48":49,"_47":168,"_143":161,"_45":169,"_13":68,"_40":163,"_42":-5,"_30":31,"_148":-5,"_33":170},{"_50":157,"_38":158,"_36":159,"_141":-5,"_48":49,"_47":160,"_143":161,"_45":162,"_13":68,"_40":163,"_42":-5,"_30":31,"_148":-5,"_33":164},{"_50":150,"_38":151,"_36":152,"_141":-5,"_48":49,"_47":153,"_143":31,"_45":154,"_13":68,"_40":26,"_42":155,"_30":31,"_148":-5,"_33":156},{"_50":138,"_38":139,"_36":140,"_141":-5,"_48":49,"_47":142,"_143":31,"_45":144,"_13":145,"_40":146,"_42":147,"_30":31,"_148":-5,"_33":149},"0aa8925e-72a6-4b8b-a93f-fd1066997b8c","main.ts","90593b32-b20d-11f1-b41f-1607ee4eb77e","parentId",8,"latest",["D",1789590714285],1,"interval","/**\n * Trend Video AutoPoster — runs every 12 hours.\n *\n * discover trending YouTube video → AI clip it (Opus Clip) →\n * publish to TikTok → record in SQLite → report to Telegram\n *\n * Each step is isolated in its own try/catch: a failure logs, reports to\n * Telegram, and returns cleanly so future cron executions still run.\n *\n * Learn more: https://docs.val.town/vals/cron/\n */\nimport { ENV, findMissingEnv, REQUIRED_ENV } from \"./lib/env.ts\";\nimport { initDb, isProcessed, markProcessed, processedCount } from \"./lib/db.ts\";\nimport { findUnprocessedTrendingVideo, SEARCH_QUERIES } from \"./lib/youtube.ts\";\nimport { createClip } from \"./lib/opus.ts\";\nimport { publishVideoToTikTok } from \"./lib/tiktok.ts\";\nimport { escapeHtml, reportStepFailure, sendTelegram } from \"./lib/telegram.ts\";\n\nexport default async function (interval: Interval) {\n await runPipeline(interval.lastRunAt);\n}\n\n/** The whole pipeline. Exported so it can be invoked manually for testing. */\nexport async function runPipeline(lastRunAt?: Date): Promise {\n const startedAt = Date.now();\n console.log(\n `[trend-autoposter] run started ${new Date(startedAt).toISOString()} ` +\n `(lastRunAt: ${lastRunAt?.toISOString() ?? \"never\"})`,\n );\n\n // --- Preflight: fail fast, and report *every* missing key at once ---------\n const missing = findMissingEnv(REQUIRED_ENV);\n if (missing.length > 0) {\n const message =\n `⚠️ Trend AutoPoster skipped — missing env var(s): ${missing.join(\", \")}`;\n console.error(`[trend-autoposter] ${message}`);\n await sendTelegram(message);\n return;\n }\n\n // --- Step 0: schema ------------------------------------------------------\n try {\n await initDb();\n } catch (err) {\n console.error(\"[trend-autoposter] database init failed:\", err);\n await reportStepFailure(\"database init\", err);\n return;\n }\n\n // --- Step 1: discover a trending video we haven't handled ----------------\n let video;\n try {\n video = await findUnprocessedTrendingVideo(isProcessed, {\n queries: SEARCH_QUERIES,\n });\n } catch (err) {\n console.error(\"[trend-autoposter] discovery failed:\", err);\n await reportStepFailure(\"discover trending video (YouTube)\", err);\n return;\n }\n\n if (!video) {\n console.log(\"[trend-autoposter] no unprocessed trending video found\");\n await sendTelegram(\n \"ℹ️ Trend AutoPoster: no new trending video to process this run.\",\n );\n return;\n }\n\n console.log(\n `[trend-autoposter] picked ${video.videoId} — \"${video.title}\" (${video.channelTitle})`,\n );\n\n // --- Step 2: AI clipping -------------------------------------------------\n let clip;\n try {\n clip = await createClip(video.url);\n } catch (err) {\n console.error(\"[trend-autoposter] clipping failed:\", err);\n await reportStepFailure(\"AI clip creation (Opus Clip)\", err);\n return;\n }\n\n // --- Step 3: publish directly to TikTok ----------------------------------\n let published;\n try {\n published = await publishVideoToTikTok({\n videoUrl: clip.downloadUrl,\n caption: clip.caption,\n });\n } catch (err) {\n console.error(\"[trend-autoposter] publishing failed:\", err);\n await reportStepFailure(\"TikTok publish\", err);\n return;\n }\n\n // --- Step 4: record the video, then report -------------------------------\n try {\n await markProcessed(video.videoId);\n } catch (err) {\n console.error(\"[trend-autoposter] failed to record processed video:\", err);\n await reportStepFailure(\"record processed video (SQLite)\", err);\n return;\n }\n\n const total = await processedCount().catch(() => undefined);\n\n await sendTelegram(\n `🚀 Success: Trending video parsed, clipped, and posted directly to TikTok! Video ID: ${escapeHtml(video.videoId)}\\n\\n` +\n `Title: ${escapeHtml(video.title)}\\n` +\n `Channel: ${escapeHtml(video.channelTitle)}\\n` +\n `Publish ID: ${escapeHtml(published.publishId)} (${escapeHtml(published.status)})\\n` +\n (total !== undefined ? `Total processed: ${total}` : \"\"),\n );\n\n console.log(\n `[trend-autoposter] done in ${Date.now() - startedAt}ms — ${ENV.TIKTOK_ACCESS_TOKEN} post ${published.publishId}`,\n );\n}","label",[139],"7cbd97f0-5893-4a29-b5ac-a99a048e1da5","README.md","11271b94-b20e-11f1-9ad2-1607ee4eb77e",12,["D",1789590891211],"# Trend Video AutoPoster\n\nA scheduled Val Town job that runs **every 12 hours** (`0 */12 * * *`, UTC) and\nautomates the whole short-form content loop: find a trending YouTube video,\nhave AI cut it into a vertical clip, publish that clip straight to TikTok, and\nreport the result to Telegram.\n\n```mermaid\nflowchart TD\n A[cron: every 12h] --> B[Preflight: check env vars]\n B --> C[Step 1 · YouTube Data API v3
search trending videos]\n C --> D{Already in
processed_trending_videos?}\n D -- yes --> C\n D -- no --> E[Step 2 · Opus Clip
AI clip + captions + hashtags]\n E --> F[Step 3 · TikTok Content Posting API
PULL_FROM_URL, PUBLIC_TO_EVERYONE]\n F --> G[Step 4 · INSERT video_id into SQLite]\n G --> H[Telegram success report]\n B -. missing key .-> H2[Telegram warning]\n C -. error .-> H3[Telegram error report]\n E -. error .-> H3\n F -. error .-> H3\n```\n\nEvery step is wrapped in its own `try/catch`. A failure logs to the console,\nsends a Telegram error report, and **returns cleanly** — so the next scheduled\nrun still fires.\n\n## Files\n\n| File | Role |\n| --- | --- |\n| `main.ts` | The interval handler + pipeline orchestration |\n| `lib/env.ts` | Env var names, required-key preflight |\n| `lib/db.ts` | SQLite schema and queries (with transient-error retry) |\n| `lib/youtube.ts` | Step 1 — trending video discovery |\n| `lib/opus.ts` | Step 2 — AI clipping |\n| `lib/tiktok.ts` | Step 3 — direct publishing |\n| `lib/telegram.ts` | Notifications (never throws) |\n| `scripts/smoke-test.ts` | Verifies the SQLite layer; safe to run anytime |\n\n## Environment variables\n\nSet all five before the first run — the job skips itself and warns you if any\nare missing.\n\n| Key | Where to get it |\n| --- | --- |\n| `YOUTUBE_API_KEY` | Google Cloud Console → enable **YouTube Data API v3** → API key |\n| `OPUS_CLIP_API_KEY` | Opus Clip account / API access |\n| `TIKTOK_ACCESS_TOKEN` | TikTok for Developers → Content Posting API (scope `video.publish`) |\n| `TELEGRAM_BOT_TOKEN` | [@BotFather](https://t.me/BotFather) |\n| `TELEGRAM_CHAT_ID` | Your chat/channel id — message the bot first, then read `getUpdates` |\n\n## Database\n\nOne table, created automatically on the first run:\n\n```sql\nCREATE TABLE IF NOT EXISTS processed_trending_videos (\n video_id TEXT PRIMARY KEY,\n processed_at DATETIME NOT NULL\n);\n```\n\n`scripts/smoke-test.ts` writes one clearly-fake row and deletes it again, so it\nleaves the database untouched. Run it any time you want to confirm the SQLite\nlayer is healthy.\n\n## Things to know before you turn it on\n\nThese are real constraints of the three third-party APIs, not bugs in this val.\n\n1. **The Opus Clip endpoint is not a documented public API.** `POST\n https://api.opus.pro/v1/clips` follows the commonly-referenced contract, but\n Opus Clip does not publish a stable spec. `lib/opus.ts` is written to be\n forgiving — it walks the response for the first plausible clip URL, caption\n and hashtags, and polls for up to 5 minutes if the render is async — but if\n your account's contract differs you may need to adjust `createBody()` and the\n `*_KEYS` lists. Everything else in the pipeline stays the same.\n2. **TikTok `PULL_FROM_URL` requires a verified domain.** TikTok fetches the\n clip from the URL Opus returns, so that host must be registered as a verified\n URL property in your TikTok developer app. If it isn't, the post is rejected.\n3. **`PUBLIC_TO_EVERYONE` requires an audited app.** Until your TikTok app\n passes audit, TikTok forces `SELF_ONLY` and rejects public posts.\n4. **TikTok access tokens expire (~24 hours).** A cron running every 12 hours\n will hit this quickly. You'll need a refresh flow — store the refresh token\n and exchange it at `https://open.tiktokapis.com/v2/oauth/token/` before\n publishing. Ask and I'll wire that in.\n5. **YouTube quota.** `search.list` costs 100 units; the default daily quota is\n 10,000. With 4 queries × 2 runs/day that's 800 units/day — comfortable, but\n don't add dozens of keywords.\n6. **A video is only recorded on full success.** By design, a failure at any\n step leaves the video unrecorded so the next run retries it. The trade-off:\n a video that fails *permanently* (e.g. a clip URL TikTok will never accept)\n will be retried every 12 hours forever. If you'd rather skip it after N\n attempts, add a `status`/`attempts` column — say the word and I'll do it.",[151],"4ab75f96-c9b6-4b0e-ad07-f09c2f292158","scripts","68926185-0dcc-4025-b344-11069b51005e",10,true,["D",1789590732153],"directory",[158],"3552ec96-097b-43ff-a276-c539b5fd3f15","lib","49f6b9da-c744-4653-8d32-c1d1321abcb4",2,["D",1789590686836],[166],"pulls","branches","forks","envVars",{"_178":180,"_181":68},"connections",{"_178":68,"_179":68},"count","unfilledCount",4,"emptyCount",{"_50":165,"_38":166,"_36":167,"_141":-5,"_48":49,"_47":168,"_143":161,"_45":263,"_13":68,"_40":163,"_42":-5,"_30":31,"_148":-5,"_195":264,"_33":265},{"_50":255,"_38":256,"_36":257,"_141":167,"_48":49,"_47":258,"_143":31,"_45":259,"_13":68,"_40":41,"_42":260,"_30":31,"_148":-5,"_195":261,"_33":262},{"_50":247,"_38":248,"_36":249,"_141":167,"_48":49,"_47":250,"_143":31,"_45":251,"_13":168,"_40":41,"_42":252,"_30":31,"_148":-5,"_195":253,"_33":254},{"_50":243,"_38":39,"_36":37,"_141":167,"_48":49,"_47":14,"_143":31,"_45":244,"_13":145,"_40":41,"_42":44,"_30":31,"_148":-5,"_195":245,"_33":246},{"_50":235,"_38":236,"_36":237,"_141":167,"_48":49,"_47":238,"_143":31,"_45":239,"_13":68,"_40":41,"_42":240,"_30":31,"_148":-5,"_195":241,"_33":242},{"_50":227,"_38":228,"_36":229,"_141":167,"_48":49,"_47":230,"_143":31,"_45":231,"_13":68,"_40":41,"_42":232,"_30":31,"_148":-5,"_195":233,"_33":234},{"_50":219,"_38":220,"_36":221,"_141":167,"_48":49,"_47":222,"_143":31,"_45":223,"_13":68,"_40":41,"_42":224,"_30":31,"_148":-5,"_195":225,"_33":226},{"_50":211,"_38":212,"_36":213,"_141":167,"_48":49,"_47":214,"_143":31,"_45":215,"_13":68,"_40":41,"_42":216,"_30":31,"_148":-5,"_195":217,"_33":218},{"_50":157,"_38":158,"_36":159,"_141":-5,"_48":49,"_47":160,"_143":161,"_45":208,"_13":68,"_40":163,"_42":-5,"_30":31,"_148":-5,"_195":209,"_33":210},{"_50":201,"_38":202,"_36":203,"_141":159,"_48":49,"_47":160,"_143":31,"_45":204,"_13":68,"_40":41,"_42":205,"_30":31,"_148":-5,"_195":206,"_33":207},{"_50":150,"_38":151,"_36":152,"_141":-5,"_48":49,"_47":153,"_143":31,"_45":198,"_13":68,"_40":26,"_42":155,"_30":31,"_148":-5,"_195":199,"_33":200},{"_50":138,"_38":139,"_36":140,"_141":-5,"_48":49,"_47":142,"_143":31,"_45":194,"_13":145,"_40":146,"_42":147,"_30":31,"_148":-5,"_195":196,"_33":197},["D",1789590714285],"children",[],[139],["D",1789590891211],[],[151],"762b3e40-197d-431b-a638-fd60db35fdf8","smoke-test.ts","b2591bee-b20d-11f1-a33b-1607ee4eb77e",["D",1789590732153],"/**\n * Smoke test for the SQLite layer.\n *\n * Run this from the val editor before the first scheduled run to confirm the\n * table is created and the queries behave. It writes one clearly-fake row and\n * deletes it again, so it leaves the database exactly as it found it.\n */\nimport {\n forgetProcessed,\n initDb,\n isProcessed,\n markProcessed,\n processedCount,\n recentProcessed,\n} from \"../lib/db.ts\";\n\nconst TEST_ID = \"__smoke_test_video__\";\n\nawait initDb();\nconsole.log(\"schema ready\");\n\nconst before = await isProcessed(TEST_ID);\nawait markProcessed(TEST_ID);\nconst after = await isProcessed(TEST_ID);\nconst count = await processedCount();\nconst recent = await recentProcessed(3);\nawait forgetProcessed(TEST_ID);\nconst cleanedUp = !(await isProcessed(TEST_ID));\n\nconsole.log({ before, after, count, recent, cleanedUp });\n\nif (before !== false || after !== true || !cleanedUp) {\n throw new Error(\"smoke test failed — check the SQLite layer\");\n}\nconsole.log(\"✅ SQLite layer OK\");",[],[158,202],["D",1789590732153],[191],[158],"97d0bf8c-0512-4ad8-a28f-9130f60d52e0","youtube.ts","97bcce84-b20d-11f1-8580-1607ee4eb77e",5,["D",1789590687515],"/**\n * Step 1 — discover a trending YouTube video that we haven't handled yet.\n *\n * Uses the YouTube Data API v3 `search.list` endpoint. Note the quota cost:\n * each call to search.list costs 100 units against a default 10,000/day quota,\n * so keep SEARCH_QUERIES short.\n */\nimport { ENV, requireEnv } from \"./env.ts\";\n\nconst SEARCH_ENDPOINT = \"https://www.googleapis.com/youtube/v3/search\";\n\n/** 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\nexport type TrendingVideo = {\n videoId: string;\n title: string;\n channelTitle: string;\n publishedAt: string;\n url: string;\n};\n\nexport type SearchOptions = {\n queries?: string[];\n maxResultsPerQuery?: number;\n /** Only consider videos published within this many days. */\n withinDays?: number;\n};\n\ntype YouTubeSearchResponse = {\n items?: Array<{\n id?: { videoId?: string };\n snippet?: {\n title?: string;\n channelTitle?: string;\n publishedAt?: string;\n };\n }>;\n};\n\n/** Run every query and return a de-duplicated, ranked list of candidates. */\nexport async function searchTrendingVideos(\n options: SearchOptions = {},\n): Promise {\n const {\n queries = SEARCH_QUERIES,\n maxResultsPerQuery = 25,\n withinDays = 30,\n } = options;\n\n const key = requireEnv(ENV.YOUTUBE_API_KEY);\n const publishedAfter = new Date(Date.now() - withinDays * 86_400_000)\n .toISOString();\n\n const seen = new Set();\n const videos: TrendingVideo[] = [];\n\n for (const query of queries) {\n const params = new URLSearchParams({\n part: \"snippet\",\n type: \"video\",\n q: query,\n maxResults: String(maxResultsPerQuery),\n order: \"viewCount\",\n videoDuration: \"short\",\n safeSearch: \"moderate\",\n relevanceLanguage: \"en\",\n publishedAfter,\n key,\n });\n\n const res = await fetch(`${SEARCH_ENDPOINT}?${params}`);\n if (!res.ok) {\n const body = await res.text();\n throw new Error(\n `YouTube search failed (HTTP ${res.status}) for \"${query}\": ${\n body.slice(0, 300)\n }`,\n );\n }\n\n const data = await res.json() as YouTubeSearchResponse;\n for (const item of data.items ?? []) {\n const videoId = item.id?.videoId;\n if (!videoId || seen.has(videoId)) continue;\n seen.add(videoId);\n videos.push({\n videoId,\n title: item.snippet?.title ?? \"\",\n channelTitle: item.snippet?.channelTitle ?? \"\",\n publishedAt: item.snippet?.publishedAt ?? \"\",\n url: `https://www.youtube.com/watch?v=${videoId}`,\n });\n }\n }\n\n return videos;\n}\n\n/**\n * First candidate that is not already present in `processed_trending_videos`.\n * Returns `undefined` when everything found has been handled before.\n */\nexport async function findUnprocessedTrendingVideo(\n isProcessed: (videoId: string) => Promise,\n options?: SearchOptions,\n): Promise {\n const videos = await searchTrendingVideos(options);\n console.log(`[youtube] ${videos.length} candidate(s) from ${(options?.queries ?? SEARCH_QUERIES).length} quer(ies)`);\n\n for (const video of videos) {\n if (!(await isProcessed(video.videoId))) return video;\n }\n return undefined;\n}",[],[166,212],"0563a746-864c-4aca-b7f5-29c18bac6670","tiktok.ts","a3721626-b20d-11f1-aa57-1607ee4eb77e",7,["D",1789590706981],"/**\n * Step 3 — publish the generated clip to TikTok via the Content Posting API.\n *\n * Uses the `PULL_FROM_URL` source, which means TikTok fetches the clip from\n * `clip.downloadUrl` itself. Two things must be true for this to work:\n *\n * 1. The domain hosting the video URL must be verified in your TikTok\n * developer app (URL properties → verify domain).\n * 2. Your app must be audited for direct posting; until then TikTok forces\n * `SELF_ONLY` and `PUBLIC_TO_EVERYONE` is rejected.\n *\n * Access tokens also expire (~24h), so a long-running cron needs a refresh\n * flow — see the README.\n */\nimport { ENV, requireEnv } from \"./env.ts\";\n\nconst INIT_ENDPOINT = \"https://open.tiktokapis.com/v2/post/publish/video/init/\";\nconst STATUS_ENDPOINT = \"https://open.tiktokapis.com/v2/post/publish/status/fetch/\";\n\n/** TikTok truncates titles past 2200 characters. */\nconst MAX_TITLE_LEN = 2200;\nconst REQUEST_TIMEOUT_MS = 30_000;\n\nexport type PublishResult = {\n publishId: string;\n /** TikTok's processing status at the moment we checked, e.g. PROCESSING_UPLOAD. */\n status: string;\n};\n\ntype TikTokError = { code?: string; message?: string; log_id?: string };\n\ntype TikTokInitResponse = {\n data?: { publish_id?: string };\n error?: TikTokError;\n};\n\ntype TikTokStatusResponse = {\n data?: { status?: string };\n error?: TikTokError;\n};\n\nasync function postJson(\n url: string,\n token: string,\n body: unknown,\n label: string,\n): Promise {\n const controller = new AbortController();\n const timer = setTimeout(() => controller.abort(), REQUEST_TIMEOUT_MS);\n let res: Response;\n try {\n res = await fetch(url, {\n method: \"POST\",\n headers: {\n Authorization: `Bearer ${token}`,\n \"Content-Type\": \"application/json; charset=UTF-8\",\n },\n body: JSON.stringify(body),\n signal: controller.signal,\n });\n } finally {\n clearTimeout(timer);\n }\n\n const text = await res.text();\n let payload: unknown;\n try {\n payload = JSON.parse(text);\n } catch {\n throw new Error(`${label} returned non-JSON (HTTP ${res.status}): ${text.slice(0, 200)}`);\n }\n return payload;\n}\n\n/**\n * Kick off a direct post of `videoUrl` with `caption`.\n * Returns TikTok's publish id so the post can be tracked.\n */\nexport async function publishVideoToTikTok(\n opts: { videoUrl: string; caption: string },\n): Promise {\n const token = requireEnv(ENV.TIKTOK_ACCESS_TOKEN);\n const title = opts.caption.trim().slice(0, MAX_TITLE_LEN) || \"New clip\";\n\n const payload = await postJson(\n INIT_ENDPOINT,\n token,\n {\n post_info: {\n title,\n privacy_level: \"PUBLIC_TO_EVERYONE\",\n disable_duet: false,\n disable_comment: false,\n disable_stitch: false,\n video_cover_timestamp_ms: 1000,\n },\n source_info: {\n source: \"PULL_FROM_URL\",\n video_url: opts.videoUrl,\n },\n },\n \"TikTok publish init\",\n ) as TikTokInitResponse;\n\n const code = payload.error?.code;\n if (code && code !== \"ok\") {\n throw new Error(\n `TikTok publish rejected (code ${code}): ${payload.error?.message ?? \"\"}`.trim(),\n );\n }\n\n const publishId = payload.data?.publish_id;\n if (!publishId) {\n throw new Error(\n `TikTok publish returned no publish_id: ${JSON.stringify(payload).slice(0, 300)}`,\n );\n }\n\n const status = await fetchPublishStatus(publishId, token).catch((err) => {\n console.error(\"[tiktok] status check failed:\", err);\n return \"UNKNOWN\";\n });\n\n return { publishId, status };\n}\n\n/** Ask TikTok what happened to a previously created publish job. */\nexport async function fetchPublishStatus(\n publishId: string,\n token: string,\n): Promise {\n const payload = await postJson(\n STATUS_ENDPOINT,\n token,\n { publish_id: publishId },\n \"TikTok status fetch\",\n ) as TikTokStatusResponse;\n\n const code = payload.error?.code;\n if (code && code !== \"ok\") {\n throw new Error(`TikTok status fetch failed (code ${code}): ${payload.error?.message ?? \"\"}`);\n }\n return payload.data?.status ?? \"UNKNOWN\";\n}",[],[166,220],"53ffe6e7-6d1a-41ea-a58f-8fdf31933a7a","telegram.ts","97b0f6f4-b20d-11f1-8580-1607ee4eb77e",3,["D",1789590687373],"/**\n * Telegram notifications.\n *\n * Every function here is deliberately non-throwing: a failed notification must\n * never take down a cron run that otherwise succeeded.\n */\nimport { ENV } from \"./env.ts\";\n\n/** Telegram rejects messages over 4096 characters. */\nconst MAX_MESSAGE_LEN = 4000;\n\nexport function escapeHtml(text: string): string {\n return text\n .replace(/&/g, \"&\")\n .replace(//g, \">\");\n}\n\n/**\n * Send a message to the configured chat.\n * Returns `true` when Telegram accepted it, `false` on any failure.\n */\nexport async function sendTelegram(text: string): Promise {\n const token = Deno.env.get(ENV.TELEGRAM_BOT_TOKEN)?.trim();\n const chatId = Deno.env.get(ENV.TELEGRAM_CHAT_ID)?.trim();\n\n if (!token || !chatId) {\n console.error(\n \"[telegram] skipped — TELEGRAM_BOT_TOKEN and/or TELEGRAM_CHAT_ID not set\",\n );\n return false;\n }\n\n const body = text.length > MAX_MESSAGE_LEN\n ? `${text.slice(0, MAX_MESSAGE_LEN - 1)}…`\n : text;\n\n try {\n const res = await fetch(\n `https://api.telegram.org/bot${token}/sendMessage`,\n {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n chat_id: chatId,\n text: body,\n parse_mode: \"HTML\",\n disable_web_page_preview: true,\n }),\n },\n );\n\n if (!res.ok) {\n console.error(`[telegram] HTTP ${res.status}: ${await res.text()}`);\n return false;\n }\n return true;\n } catch (err) {\n console.error(\"[telegram] request failed:\", err);\n return false;\n }\n}\n\n/** Format and send a failure report for one pipeline step. */\nexport async function reportStepFailure(\n step: string,\n err: unknown,\n): Promise {\n const detail = err instanceof Error ? `${err.name}: ${err.message}` : String(err);\n await sendTelegram(\n `❌ Trend AutoPoster — step ${escapeHtml(step)} failed\\n` +\n `

${escapeHtml(detail.slice(0, 1200))}

\\n` +\n `The run stopped there. The next scheduled run will try again.`,\n );\n}",[],[166,228],"5a62188b-8845-4629-9bab-2a0cbc0636f7","opus.ts","a3368584-b20d-11f1-aa57-1607ee4eb77e",6,["D",1789590706751],"/**\n * Step 2 — AI clipping via Opus Clip.\n *\n * ⚠️ Opus Clip does not publish a stable, openly-documented REST API. The\n * request below follows the commonly-referenced `POST /v1/clips` contract, and\n * the response parsing is deliberately *tolerant*: instead of assuming exact\n * field names it walks the JSON for the first plausible clip URL, caption and\n * hashtags. If your account's contract differs, adjust `CREATE_BODY` and the\n * `*_KEYS` lists below — nothing else in the pipeline needs to change.\n *\n * The endpoint also runs asynchronously: it may return a finished clip\n * immediately, or a job/clip id that has to be polled until the render is done.\n * Both paths are handled.\n */\nimport { ENV, requireEnv } from \"./env.ts\";\n\nconst API_BASE = \"https://api.opus.pro/v1\";\nconst CREATE_PATH = \"/clips\";\nconst POLL_INTERVAL_MS = 15_000;\n/** Give up polling after this long; the next cron run can pick the video up. */\nconst MAX_POLL_MS = 5 * 60_000;\nconst REQUEST_TIMEOUT_MS = 30_000;\n\nexport type Clip = {\n clipId: string;\n downloadUrl: string;\n /** Ready-to-post caption: the AI caption plus its hashtags. */\n caption: string;\n hashtags: string[];\n raw: unknown;\n};\n\n/** Field names we'll accept, in priority order, when reading the response. */\nconst ID_KEYS = [\n \"clipId\",\n \"clip_id\",\n \"projectId\",\n \"project_id\",\n \"jobId\",\n \"job_id\",\n \"id\",\n];\nconst URL_KEYS = [\n \"downloadUrl\",\n \"download_url\",\n \"videoUrl\",\n \"video_url\",\n \"clipUrl\",\n \"clip_url\",\n \"mp4Url\",\n \"mp4_url\",\n \"uri\",\n \"url\",\n];\nconst CAPTION_KEYS = [\"caption\", \"title\", \"description\", \"summary\", \"text\"];\nconst HASHTAG_KEYS = [\"hashtags\", \"hashtag\", \"tags\"];\nconst STATUS_KEYS = [\"status\", \"state\", \"jobStatus\", \"job_status\"];\n\nconst READY_STATES = new Set([\n \"ready\",\n \"completed\",\n \"complete\",\n \"done\",\n \"success\",\n \"succeeded\",\n \"finished\",\n]);\nconst FAILED_STATES = new Set([\n \"failed\",\n \"error\",\n \"errored\",\n \"cancelled\",\n \"canceled\",\n]);\n\nconst delay = (ms: number) => new Promise((resolve) => setTimeout(resolve, ms));\n\nasync function fetchWithTimeout(\n url: string,\n init: RequestInit,\n timeoutMs = REQUEST_TIMEOUT_MS,\n): Promise {\n const controller = new AbortController();\n const timer = setTimeout(() => controller.abort(), timeoutMs);\n try {\n return await fetch(url, { ...init, signal: controller.signal });\n } finally {\n clearTimeout(timer);\n }\n}\n\n/** Depth-first search for the first non-empty string stored under any of `keys`. */\nfunction deepFindString(\n value: unknown,\n keys: string[],\n depth = 0,\n): string | undefined {\n if (depth > 8 || value === null || typeof value !== \"object\") return undefined;\n\n if (Array.isArray(value)) {\n for (const entry of value) {\n const found = deepFindString(entry, keys, depth + 1);\n if (found) return found;\n }\n return undefined;\n }\n\n const record = value as Record;\n for (const key of keys) {\n const candidate = record[key];\n if (typeof candidate === \"string\" && candidate.trim()) {\n return candidate.trim();\n }\n }\n for (const nested of Object.values(record)) {\n const found = deepFindString(nested, keys, depth + 1);\n if (found) return found;\n }\n return undefined;\n}\n\n/** Same as above but for arrays of strings (hashtags / tags). */\nfunction deepFindStringArray(\n value: unknown,\n keys: string[],\n depth = 0,\n): string[] {\n if (depth > 8 || value === null || typeof value !== \"object\") return [];\n\n if (Array.isArray(value)) {\n const strings = value.filter((v): v is string => typeof v === \"string\");\n if (strings.length) return strings;\n for (const entry of value) {\n const found = deepFindStringArray(entry, keys, depth + 1);\n if (found.length) return found;\n }\n return [];\n }\n\n const record = value as Record;\n for (const key of keys) {\n const candidate = record[key];\n if (Array.isArray(candidate)) {\n const strings = candidate.filter((v): v is string => typeof v === \"string\");\n if (strings.length) return strings;\n }\n if (typeof candidate === \"string\" && candidate.trim()) {\n return candidate.split(/[\\s,]+/);\n }\n }\n for (const nested of Object.values(record)) {\n const found = deepFindStringArray(nested, keys, depth + 1);\n if (found.length) return found;\n }\n return [];\n}\n\nfunction normalizeHashtags(raw: string[]): string[] {\n return raw\n .flatMap((tag) => tag.split(/[\\s,]+/))\n .map((tag) => tag.trim())\n .filter(Boolean)\n .map((tag) => (tag.startsWith(\"#\") ? tag : `#${tag}`))\n .slice(0, 30);\n}\n\nasync function readJson(res: Response, label: string): Promise {\n const text = await res.text();\n if (!res.ok) {\n throw new Error(\n `${label} failed (HTTP ${res.status}): ${text.slice(0, 400)}`,\n );\n }\n try {\n return JSON.parse(text);\n } catch {\n throw new Error(`${label} returned non-JSON: ${text.slice(0, 200)}`);\n }\n}\n\nfunction authHeaders(apiKey: string): Record {\n return {\n Authorization: `Bearer ${apiKey}`,\n \"Content-Type\": \"application/json\",\n Accept: \"application/json\",\n };\n}\n\n/** The create payload. `sourceUrl` is sent alongside `videoUrl` for tolerance. */\nfunction createBody(youtubeUrl: string) {\n return {\n videoUrl: youtubeUrl,\n sourceUrl: youtubeUrl,\n clipLength: \"auto\",\n aspectRatio: \"9:16\",\n captions: true,\n language: \"en\",\n };\n}\n\n/**\n * Submit a YouTube URL for AI clipping and return the first finished clip.\n * Throws when the job fails or doesn't finish inside `MAX_POLL_MS`.\n */\nexport async function createClip(youtubeUrl: string): Promise {\n const apiKey = requireEnv(ENV.OPUS_CLIP_API_KEY);\n const headers = authHeaders(apiKey);\n\n const createRes = await fetchWithTimeout(`${API_BASE}${CREATE_PATH}`, {\n method: \"POST\",\n headers,\n body: JSON.stringify(createBody(youtubeUrl)),\n });\n\n let payload = await readJson(createRes, \"Opus Clip create\");\n const clipId = deepFindString(payload, ID_KEYS) ?? \"\";\n console.log(`[opus] submitted ${youtubeUrl} → id ${clipId || \"(none returned)\"}`);\n\n const deadline = Date.now() + MAX_POLL_MS;\n while (\n !isReady(payload) && !isFailed(payload) && clipId && Date.now() < deadline\n ) {\n await delay(POLL_INTERVAL_MS);\n const pollRes = await fetchWithTimeout(\n `${API_BASE}${CREATE_PATH}/${encodeURIComponent(clipId)}`,\n { method: \"GET\", headers },\n );\n payload = await readJson(pollRes, \"Opus Clip poll\");\n console.log(`[opus] status: ${deepFindString(payload, STATUS_KEYS) ?? \"unknown\"}`);\n }\n\n const status = deepFindString(payload, STATUS_KEYS);\n if (isFailed(payload)) {\n throw new Error(\n `Opus Clip job ${clipId} reported status \"${status}\": ${\n JSON.stringify(payload).slice(0, 400)\n }`,\n );\n }\n\n const downloadUrl = deepFindString(payload, URL_KEYS);\n if (!downloadUrl) {\n throw new Error(\n `Opus Clip returned no clip URL (status \"${status ?? \"unknown\"}\"): ${\n JSON.stringify(payload).slice(0, 400)\n }`,\n );\n }\n\n const captionText = deepFindString(payload, CAPTION_KEYS) ?? \"\";\n const hashtags = normalizeHashtags(deepFindStringArray(payload, HASHTAG_KEYS));\n const caption = [captionText, hashtags.join(\" \")].filter(Boolean).join(\"\\n\\n\");\n\n return {\n clipId: clipId || deepFindString(payload, ID_KEYS) || \"unknown\",\n downloadUrl,\n caption,\n hashtags,\n raw: payload,\n };\n}\n\nfunction isReady(payload: unknown): boolean {\n const status = deepFindString(payload, STATUS_KEYS)?.toLowerCase();\n if (!status) return false;\n return READY_STATES.has(status);\n}\n\nfunction isFailed(payload: unknown): boolean {\n const status = deepFindString(payload, STATUS_KEYS)?.toLowerCase();\n if (!status) return false;\n return FAILED_STATES.has(status);\n}",[],[166,236],"e9a0d7da-8041-400f-ac10-6b638024f63c",["D",1789591031151],[],[166,39],"aa6426bd-3aea-4d30-a874-bbb42e7a1a43","db.ts","97b7469e-b20d-11f1-8580-1607ee4eb77e",11,["D",1789590753390],"/**\n * Val Town SQLite (val-scoped database).\n *\n * Schema is created lazily and memoized so repeated calls within one execution\n * don't re-run the DDL. Every statement goes through `run()`, which retries a\n * couple of times — the hosted libSQL endpoint occasionally answers with a\n * transient HTTP 500, and that shouldn't abort a whole cron run.\n */\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst CREATE_TABLE = `\nCREATE TABLE IF NOT EXISTS processed_trending_videos (\n video_id TEXT PRIMARY KEY,\n processed_at DATETIME NOT NULL\n)`;\n\nconst RETRY_ATTEMPTS = 3;\nconst RETRY_BACKOFF_MS = 500;\n\nconst delay = (ms: number) => new Promise((resolve) => setTimeout(resolve, ms));\n\n/** `sqlite.execute` with a small retry for transient transport errors. */\nasync function run(\n sql: string | { sql: string; args: (string | number | null)[] },\n) {\n let lastError: unknown;\n for (let attempt = 1; attempt <= RETRY_ATTEMPTS; attempt++) {\n try {\n return await sqlite.execute(sql as Parameters[0]);\n } catch (err) {\n lastError = err;\n if (attempt < RETRY_ATTEMPTS) {\n console.warn(\n `[db] attempt ${attempt}/${RETRY_ATTEMPTS} failed, retrying:`,\n err instanceof Error ? err.message : err,\n );\n await delay(RETRY_BACKOFF_MS * attempt);\n }\n }\n }\n throw lastError;\n}\n\nlet ready: Promise | undefined;\n\n/** Create the table if it doesn't exist. Idempotent; safe to call anywhere. */\nexport function initDb(): Promise {\n ready ??= run(CREATE_TABLE)\n .then(() => undefined)\n .catch((err) => {\n // Don't cache a rejection — let the next call retry.\n ready = undefined;\n throw err;\n });\n return ready;\n}\n\n/** Has this video already been through the pipeline? */\nexport async function isProcessed(videoId: string): Promise {\n await initDb();\n const { rows } = await run({\n sql: \"SELECT 1 AS hit FROM processed_trending_videos WHERE video_id = ? LIMIT 1\",\n args: [videoId],\n });\n return rows.length > 0;\n}\n\n/** Record a video as fully processed (discovered → clipped → published). */\nexport async function markProcessed(videoId: string): Promise {\n await initDb();\n await run({\n sql:\n \"INSERT OR REPLACE INTO processed_trending_videos (video_id, processed_at) VALUES (?, ?)\",\n args: [videoId, new Date().toISOString()],\n });\n}\n\n/** Remove a video from the table so it can be picked up and posted again. */\nexport async function forgetProcessed(videoId: string): Promise {\n await initDb();\n await run({\n sql: \"DELETE FROM processed_trending_videos WHERE video_id = ?\",\n args: [videoId],\n });\n}\n\n/** How many videos have been handled so far. */\nexport async function processedCount(): Promise {\n await initDb();\n const { rows } = await run(\n \"SELECT COUNT(*) AS n FROM processed_trending_videos\",\n );\n return Number(rows[0]?.n ?? 0);\n}\n\n/** Most recently processed videos, newest first. */\nexport async function recentProcessed(\n limit = 10,\n): Promise<{ video_id: string; processed_at: string }[]> {\n await initDb();\n const { rows } = await run({\n sql:\n \"SELECT video_id, processed_at FROM processed_trending_videos ORDER BY processed_at DESC LIMIT ?\",\n args: [limit],\n });\n return rows as { video_id: string; processed_at: string }[];\n}",[],[166,248],"8ae3fe34-7886-4c61-b1c3-44f9335d9e00","config.ts","6001f0f4-b20e-11f1-b7d7-1607ee4eb77e",13,["D",1789591023510],"/**\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 */\nexport const MAX_ATTEMPTS = 3;\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];",[],[166,256],["D",1789590686836],[183,184,185,186,187,188,189],[166],["D",1789590675077],["D",1789591281607],{"_105":104,"_112":107},{"_105":104,"_106":107,"_108":107,"_19":62,"_109":110,"_111":31},{"_13":94,"_38":95,"_50":49,"_96":51,"_97":-5,"_98":-5,"_99":-5,"_100":-5,"_101":-5,"_102":52,"_103":104},"ctx",{"_87":-5,"_131":304,"_305":306,"_307":308,"_309":31,"_310":31,"_311":31,"_312":161,"_313":-5,"_314":-7,"_315":-7,"_316":68,"_317":31,"_318":31,"_319":-5,"_320":31,"_321":31,"_322":31,"_323":-5},"ENV",{"_275":276,"_277":278,"_279":95,"_280":281,"_282":283,"_284":285,"_286":287,"_288":289,"_290":291,"_292":293,"_294":295,"_296":297,"_298":299,"_300":301,"_302":303},"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"]

Diff · v14