${\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}",[19,80],"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}",[19,88],"47924209-48d6-4928-8738-30d124b25a2b","db.ts","97b7469e-b20d-11f1-8580-1607ee4eb77e",16,["D",1789591051285],3,"/**\n * Val Town SQLite (val-scoped database).\n *\n * The table tracks not just *which* videos we've seen but *how they went*, so a\n * video that fails permanently can't block the pipeline forever:\n *\n * status = 'posted' → done, never retry\n * status = 'failed' → retry until `attempts` reaches MAX_ATTEMPTS\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 status TEXT NOT NULL DEFAULT 'pending',\n attempts INTEGER NOT NULL DEFAULT 0,\n last_error TEXT\n)`;\n\n/**\n * Columns added after the original two-column release. `ALTER TABLE ADD COLUMN`\n * has no `IF NOT EXISTS`, so these run one at a time and the \"duplicate column\n * name\" error is swallowed — that's what makes the migration idempotent.\n */\nconst MIGRATIONS = [\n \"ALTER TABLE processed_trending_videos ADD COLUMN status TEXT NOT NULL DEFAULT 'pending'\",\n \"ALTER TABLE processed_trending_videos ADD COLUMN attempts INTEGER NOT NULL DEFAULT 0\",\n \"ALTER TABLE processed_trending_videos ADD COLUMN last_error TEXT\",\n];\n\nconst RETRY_ATTEMPTS = 3;\nconst RETRY_BACKOFF_MS = 500;\n/** Keep error strings from bloating the table. */\nconst MAX_ERROR_LEN = 1000;\n\nexport type VideoStatus = \"pending\" | \"posted\" | \"failed\";\n\nexport type VideoRecord = {\n video_id: string;\n processed_at: string;\n status: VideoStatus;\n attempts: number;\n last_error: string | null;\n};\n\ntype SqlInput = string | { sql: string; args: (string | number | null)[] };\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(input: SqlInput, attempts = RETRY_ATTEMPTS) {\n let lastError: unknown;\n for (let attempt = 1; attempt <= attempts; attempt++) {\n try {\n return await sqlite.execute(\n input as Parameters[0],\n );\n } catch (err) {\n lastError = err;\n if (attempt < attempts) {\n console.warn(\n `[db] attempt ${attempt}/${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\n/** Apply the post-release column additions. Safe to run on every startup. */\nasync function migrate(): Promise {\n for (const statement of MIGRATIONS) {\n try {\n // One attempt: a duplicate-column error is expected, not transient.\n await run(statement, 1);\n console.log(`[db] migration applied: ${statement}`);\n } catch (err) {\n const message = err instanceof Error ? err.message : String(err);\n if (/duplicate column name/i.test(message)) continue;\n throw err;\n }\n }\n}\n\nlet ready: Promise | undefined;\n\n/** Create and migrate the table. Idempotent; safe to call anywhere. */\nexport function initDb(): Promise {\n ready ??= run(CREATE_TABLE)\n .then(migrate)\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/** The stored row for a video, or `undefined` if we've never seen it. */\nexport async function getRecord(\n videoId: string,\n): Promise {\n await initDb();\n const { rows } = await run({\n sql:\n \"SELECT video_id, processed_at, status, attempts, last_error FROM processed_trending_videos WHERE video_id = ? LIMIT 1\",\n args: [videoId],\n });\n return rows[0] as VideoRecord | undefined;\n}\n\n/**\n * Should discovery skip this video?\n *\n * Yes once it has been posted, or once it has burned through `maxAttempts`\n * failed tries. Passed to the YouTube step as its filter.\n */\nexport async function shouldSkip(\n videoId: string,\n maxAttempts: number,\n): Promise {\n const record = await getRecord(videoId);\n if (!record) return false;\n if (record.status === \"posted\") return true;\n return record.attempts >= maxAttempts;\n}\n\n/** Record a successful publish. Clears any earlier error. */\nexport async function markPosted(videoId: string): Promise {\n await initDb();\n await run({\n sql: `INSERT INTO processed_trending_videos (video_id, processed_at, status, attempts, last_error)\n VALUES (?, ?, 'posted', 1, NULL)\n ON CONFLICT(video_id) DO UPDATE SET\n processed_at = excluded.processed_at,\n status = 'posted',\n attempts = processed_trending_videos.attempts + 1,\n last_error = NULL`,\n args: [videoId, new Date().toISOString()],\n });\n}\n\n/**\n * Record a failed attempt and return the new attempt count, so the caller can\n * tell whether the video has just been given up on.\n */\nexport async function recordFailure(\n videoId: string,\n error: unknown,\n): Promise {\n await initDb();\n const message = (error instanceof Error\n ? `${error.name}: ${error.message}`\n : String(error)).slice(0, MAX_ERROR_LEN);\n\n await run({\n sql: `INSERT INTO processed_trending_videos (video_id, processed_at, status, attempts, last_error)\n VALUES (?, ?, 'failed', 1, ?)\n ON CONFLICT(video_id) DO UPDATE SET\n processed_at = excluded.processed_at,\n status = 'failed',\n attempts = processed_trending_videos.attempts + 1,\n last_error = excluded.last_error`,\n args: [videoId, new Date().toISOString(), message],\n });\n\n const record = await getRecord(videoId);\n return record?.attempts ?? 1;\n}\n\n/** Remove a video entirely 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 successfully posted. */\nexport async function postedCount(): Promise {\n await initDb();\n const { rows } = await run(\n \"SELECT COUNT(*) AS n FROM processed_trending_videos WHERE status = 'posted'\",\n );\n return Number(rows[0]?.n ?? 0);\n}\n\n/** Row counts grouped by status — handy for a run summary. */\nexport async function stats(): Promise> {\n await initDb();\n const { rows } = await run(\n \"SELECT status, COUNT(*) AS n FROM processed_trending_videos GROUP BY status\",\n );\n const out: Record = {};\n for (const row of rows as { status: string; n: number }[]) {\n out[row.status] = Number(row.n);\n }\n return out;\n}\n\n/** Most recently touched videos, newest first. */\nexport async function recentProcessed(limit = 10): Promise {\n await initDb();\n const { rows } = await run({\n sql: `SELECT video_id, processed_at, status, attempts, last_error\n FROM processed_trending_videos\n ORDER BY processed_at DESC\n LIMIT ?`,\n args: [limit],\n });\n return rows as VideoRecord[];\n}",[19,95],"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;",[19,103],"3552ec96-097b-43ff-a276-c539b5fd3f15",["D",1789590686836],"directory",[19],{"_40":109,"_13":19,"_43":46,"_45":-5,"_47":48,"_49":55,"_51":52,"_53":189,"_17":84,"_56":111,"_58":-5,"_60":61,"_62":-5,"_125":190,"_18":191},{"_40":136,"_13":137,"_43":138,"_45":-5,"_47":48,"_49":139,"_51":52,"_53":140,"_17":84,"_56":111,"_58":-5,"_60":61,"_62":-5,"_125":141,"_18":142},{"_40":128,"_13":129,"_43":130,"_45":-5,"_47":48,"_49":131,"_51":52,"_53":132,"_17":55,"_56":24,"_58":133,"_60":61,"_62":-5,"_125":134,"_18":135},{"_40":117,"_13":118,"_43":119,"_45":-5,"_47":48,"_49":120,"_51":52,"_53":121,"_17":122,"_56":123,"_58":124,"_60":61,"_62":-5,"_125":126,"_18":127},"2819f123-538d-45fd-af0b-4804ed4c1a34","main.ts","90593b32-b20d-11f1-b41f-1607ee4eb77e",41,["D",1789591734103],6,"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 by email\n *\n * Each step is isolated in its own try/catch: a failure logs, records the\n * attempt, emails you, and returns cleanly so future cron executions still run.\n *\n * Two things are deliberately not counted as the video's fault:\n * - credential problems (a dead TikTok token) — see `TikTokAuthError`\n * - infrastructure problems (YouTube or SQLite being down)\n * Only real per-video failures spend an attempt from `MAX_ATTEMPTS`.\n *\n * Learn more: https://docs.val.town/vals/cron/\n */\nimport { MAX_ATTEMPTS, SEARCH_QUERIES } from \"./lib/config.ts\";\nimport { findMissingEnv, REQUIRED_ENV, tiktokConfigProblem } from \"./lib/env.ts\";\nimport {\n initDb,\n markPosted,\n recordFailure,\n shouldSkip,\n stats,\n} from \"./lib/db.ts\";\nimport {\n findUnprocessedTrendingVideo,\n type TrendingVideo,\n} from \"./lib/youtube.ts\";\nimport { createClip } from \"./lib/opus.ts\";\nimport { publishVideoToTikTok, TikTokAuthError } from \"./lib/tiktok.ts\";\nimport { reportStepFailure, sendNotification } from \"./lib/notify.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* problem at once -------------\n const missing = findMissingEnv(REQUIRED_ENV);\n const tiktokProblem = tiktokConfigProblem();\n if (missing.length > 0 || tiktokProblem) {\n const problems: string[] = [];\n if (missing.length > 0) {\n problems.push(`missing env var(s): ${missing.join(\", \")}`);\n }\n if (tiktokProblem) problems.push(tiktokProblem);\n\n const message = `Trend AutoPoster skipped this run.\\n\\n${\n problems.map((p) => `• ${p}`).join(\"\\n\\n\")\n }`;\n console.error(`[trend-autoposter] ${message}`);\n await sendNotification(\"Action needed — configuration\", message);\n return;\n }\n\n // --- Step 0: schema (creates + migrates) ---------------------------------\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 console.log(\n `[trend-autoposter] history: ${\n JSON.stringify(await stats().catch(() => ({})))\n }`,\n );\n\n // --- Step 1: discover a trending video we haven't handled ----------------\n let video: TrendingVideo | undefined;\n try {\n video = await findUnprocessedTrendingVideo(\n (videoId) => shouldSkip(videoId, MAX_ATTEMPTS),\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 const counts = await stats().catch(() => ({}));\n const parked = counts.failed ?? 0;\n await sendNotification(\n \"No new video this run\",\n \"No new trending video to process this run.\" +\n (parked > 0\n ? `\\n\\n${parked} video(s) are parked after ${MAX_ATTEMPTS} failed attempts.`\n : \"\"),\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, { title: video.title });\n } catch (err) {\n await handleFailure(video, \"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 if (err instanceof TikTokAuthError) {\n // The video is fine — a dead credential must not spend one of its\n // attempts, and must not mail you twice a day forever.\n console.error(\n `[trend-autoposter] TikTok credential problem: ${err.message}`,\n );\n if (err.shouldNotify) {\n await reportStepFailure(\"TikTok publish (credential)\", err, {\n videoId: video.videoId,\n auth: true,\n });\n } else {\n console.warn(\n \"[trend-autoposter] suppressing repeat credential alert (already sent recently)\",\n );\n }\n return;\n }\n await handleFailure(video, \"TikTok publish\", err);\n return;\n }\n\n // --- Step 4: record the success, then report -----------------------------\n try {\n await markPosted(video.videoId);\n } catch (err) {\n console.error(\"[trend-autoposter] failed to record posted video:\", err);\n await reportStepFailure(\"record posted video (SQLite)\", err, {\n videoId: video.videoId,\n });\n return;\n }\n\n const counts = await stats().catch(() => ({}));\n\n await sendNotification(\n \"🚀 Posted to TikTok\",\n [\n `Success: Trending video parsed, clipped, and posted directly to TikTok! Video ID: ${video.videoId}`,\n \"\",\n `Title: ${video.title}`,\n `Channel: ${video.channelTitle}`,\n `Watch: ${video.url}`,\n `Publish ID: ${published.publishId} (${published.status})`,\n `Posted total: ${counts.posted ?? 0}`,\n ].join(\"\\n\"),\n );\n\n console.log(\n `[trend-autoposter] done in ${Date.now() - startedAt}ms — publish id ${published.publishId}`,\n );\n}\n\n/**\n * Record a failed attempt for a video, then report it.\n *\n * Recording first means the retry budget advances even if email is down.\n */\nasync function handleFailure(\n video: TrendingVideo,\n step: string,\n err: unknown,\n): Promise {\n console.error(`[trend-autoposter] ${step} failed for ${video.videoId}:`, err);\n\n let attempts: number | undefined;\n try {\n attempts = await recordFailure(video.videoId, err);\n } catch (dbErr) {\n console.error(\"[trend-autoposter] could not record the failure:\", dbErr);\n }\n\n const exhausted = attempts !== undefined && attempts >= MAX_ATTEMPTS;\n if (exhausted) {\n console.warn(\n `[trend-autoposter] giving up on ${video.videoId} after ${attempts} attempt(s)`,\n );\n }\n\n await reportStepFailure(step, err, {\n videoId: video.videoId,\n attempts,\n maxAttempts: MAX_ATTEMPTS,\n exhausted,\n });\n}","children",[],[118],"74302a10-786d-4eae-b086-ecbf17f31fa8","README.md","11271b94-b20e-11f1-9ad2-1607ee4eb77e",30,["D",1789591526714],"# 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\n**email you** the result.\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{shouldSkip?
posted, or out of attempts}\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 · status=posted in SQLite]\n G --> H[Email: 🚀 Posted to TikTok]\n E -. error .-> R[recordFailure: attempts += 1]\n F -. non-credential error .-> R\n R --> H3[Email: Failed
with attempt N of 3]\n F -. credential error .-> AUTH[TikTokAuthError
attempt NOT spent]\n AUTH --> H4[Email: Action needed
at most once per 24h]\n B -. missing key .-> H2[Email: Action needed]\n C -. error .-> H3\n```\n\nEvery step is wrapped in its own `try/catch`. A failure logs to the console,\nrecords the attempt, emails you, 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/config.ts` | Tunables: `MAX_ATTEMPTS`, `AUTH_ALERT_REPEAT_HOURS`, `SEARCH_QUERIES` |\n| `lib/env.ts` | Env var names, required-key preflight |\n| `lib/db.ts` | SQLite schema, migrations, retry bookkeeping |\n| `lib/youtube.ts` | Step 1 — trending video discovery |\n| `lib/opus.ts` | Step 2 — AI clipping |\n| `lib/tiktok.ts` | Step 3 — token handling + direct publishing |\n| `lib/notify.ts` | Email notifications (never throws) |\n| `scripts/smoke-test.ts` | Exercises the SQLite layer; safe to run anytime |\n| `scripts/send-test-email.ts` | Sends one test email; safe to run anytime |\n\n## Environment variables\n\n| Key | Required? | Where to get it |\n| --- | --- | --- |\n| `YOUTUBE_API_KEY` | **yes** | Google Cloud Console → enable **YouTube Data API v3** → API key |\n| `OPUS_CLIP_API_KEY` | **yes** | Opus Clip account / API access |\n| `TIKTOK_ACCESS_TOKEN` | **yes**¹ | TikTok for Developers → Content Posting API (scope `video.publish`) |\n| `NOTIFY_EMAIL` | no | Where to send notifications. Omit it to mail the val owner's own address. |\n| `TIKTOK_CLIENT_KEY` | optional² | Your TikTok app's client key |\n| `TIKTOK_CLIENT_SECRET` | optional² | Your TikTok app's client secret |\n| `TIKTOK_REFRESH_TOKEN` | optional² | From the OAuth flow — the seed for automatic renewal |\n\n¹ Or use the refresh triple instead — see below.\n² Only needed if you want the val to renew its own TikTok token.\n\nThe job skips itself and emails you if anything required is missing.\n\n## TikTok tokens without a refresh token\n\nIf you only have an access token — no `refresh_token` — that's fully supported.\nSet `TIKTOK_ACCESS_TOKEN` and leave the three `TIKTOK_CLIENT_*` /\n`TIKTOK_REFRESH_TOKEN` keys unset.\n\nTikTok access tokens expire in ~24 hours, which is shorter than the gap between\nruns, so a token *will* die between runs. When that happens the val:\n\n1. Recognises it as a **credential** problem, not a problem with the video, and\n **does not spend one of the video's retry attempts** — so a good video isn't\n parked because your token lapsed.\n2. Remembers a SHA-256 fingerprint of the rejected token in blob storage, so\n later runs fail immediately without calling TikTok at all.\n3. Emails you **once**, then re-alerts at most every `AUTH_ALERT_REPEAT_HOURS`\n (default 24) instead of twice a day.\n4. Clears all of that automatically the moment a working token appears — just\n paste a new `TIKTOK_ACCESS_TOKEN` and the next run resumes.\n\nIf you *do* get a refresh token later, set the three `TIKTOK_CLIENT_KEY` /\n`TIKTOK_CLIENT_SECRET` / `TIKTOK_REFRESH_TOKEN` keys and the val renews itself\nindefinitely. TikTok rotates the refresh token on every exchange, so the new\npair is cached in blob storage and the env var is only the initial seed.\n\n## Retry budget\n\nThe table tracks how each video went, so one bad video can't block the pipeline\nforever:\n\n```sql\nCREATE TABLE IF NOT EXISTS processed_trending_videos (\n video_id TEXT PRIMARY KEY,\n processed_at DATETIME NOT NULL,\n status TEXT NOT NULL DEFAULT 'pending', -- 'posted' | 'failed'\n attempts INTEGER NOT NULL DEFAULT 0,\n last_error TEXT\n);\n```\n\n- `status = 'posted'` → never retried.\n- `status = 'failed'` → retried until `attempts` reaches `MAX_ATTEMPTS`\n (default **3**, so ≈36 hours of retrying at one run per 12h), then skipped.\n\nThe first two columns are the original schema; the other three are added by an\nidempotent `ALTER TABLE` migration on startup, so an existing table upgrades\nitself.\n\nTune the budget in `lib/config.ts`. To give a parked video another chance, call\n`forgetProcessed(videoId)` — or just delete the row.\n\n## Things to know before you turn it on\n\nThese are real constraints of the 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. **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.\n5. **Opus Clip renders can outlast a run.** Polling gives up after 5 minutes; if\n the render is slower, that run records a failure and the next one retries.\n\n## Verifying\n\n- Run [scripts/send-test-email.ts](url:scripts/send-test-email.ts) to confirm\n email delivery works.\n- Run [scripts/smoke-test.ts](url:scripts/smoke-test.ts) to check the SQLite\n layer, the retry bookkeeping and the cleanup. It leaves the database untouched.\n- Run [main.ts](url:main.ts) manually from the editor to exercise the full\n pipeline without waiting for the cron.",[],[129],"4ab75f96-c9b6-4b0e-ad07-f09c2f292158","scripts","68926185-0dcc-4025-b344-11069b51005e",10,["D",1789590732153],[143,144,145,146,147],[137],{"_40":181,"_13":182,"_43":183,"_45":138,"_47":48,"_49":184,"_51":52,"_53":185,"_17":55,"_56":57,"_58":186,"_60":61,"_62":-5,"_125":187,"_18":188},{"_40":173,"_13":174,"_43":175,"_45":138,"_47":48,"_49":176,"_51":52,"_53":177,"_17":153,"_56":57,"_58":178,"_60":61,"_62":-5,"_125":179,"_18":180},{"_40":165,"_13":166,"_43":167,"_45":138,"_47":48,"_49":168,"_51":52,"_53":169,"_17":84,"_56":57,"_58":170,"_60":61,"_62":-5,"_125":171,"_18":172},{"_40":157,"_13":158,"_43":159,"_45":138,"_47":48,"_49":160,"_51":52,"_53":161,"_17":84,"_56":57,"_58":162,"_60":61,"_62":-5,"_125":163,"_18":164},{"_40":148,"_13":149,"_43":150,"_45":138,"_47":48,"_49":151,"_51":52,"_53":152,"_17":153,"_56":57,"_58":154,"_60":61,"_62":-5,"_125":155,"_18":156},"23ccbaff-0072-458e-b39f-ee8a2924dfb8","smoke-test.ts","b2591bee-b20d-11f1-a33b-1607ee4eb77e",21,["D",1789591076786],1,"/**\n * Smoke test for the SQLite layer.\n *\n * Run this from the val editor before the first scheduled run (or any time you\n * change `lib/db.ts`) to confirm the schema, the retry bookkeeping and the\n * cleanup all behave. It uses one clearly-fake video id and deletes it again, so\n * it leaves the database exactly as it found it.\n */\nimport {\n forgetProcessed,\n getRecord,\n initDb,\n markPosted,\n recordFailure,\n shouldSkip,\n stats,\n} from \"../lib/db.ts\";\n\nconst TEST_ID = \"__smoke_test_video__\";\nconst MAX_ATTEMPTS = 3;\n\nawait initDb();\nconsole.log(\"schema ready\");\n\nconst checks: Record = {};\n\n// A video we've never seen must be a candidate.\nchecks.freshIsNotSkipped = (await shouldSkip(TEST_ID, MAX_ATTEMPTS)) === false;\n\n// Failures accumulate, and the video stays a candidate until the budget runs out.\nchecks.attempt1 = await recordFailure(TEST_ID, new Error(\"boom\"));\nchecks.stillTrying = (await shouldSkip(TEST_ID, MAX_ATTEMPTS)) === false;\nchecks.attempt2 = await recordFailure(TEST_ID, new Error(\"boom again\"));\nchecks.attempt3 = await recordFailure(TEST_ID, new Error(\"boom once more\"));\nchecks.nowSkipped = (await shouldSkip(TEST_ID, MAX_ATTEMPTS)) === true;\n\nconst failed = await getRecord(TEST_ID);\nchecks.statusIsFailed = failed?.status === \"failed\";\nchecks.lastErrorStored = failed?.last_error?.includes(\"boom once more\") ?? false;\n\n// A successful post wins over the failure history and clears the error.\nawait markPosted(TEST_ID);\nconst posted = await getRecord(TEST_ID);\nchecks.statusIsPosted = posted?.status === \"posted\";\nchecks.postedClearsError = posted?.last_error === null;\nchecks.postedIsSkipped = (await shouldSkip(TEST_ID, MAX_ATTEMPTS)) === true;\n\nchecks.stats = await stats();\n\n// Cleanup.\nawait forgetProcessed(TEST_ID);\nchecks.cleanedUp = (await getRecord(TEST_ID)) === undefined;\n\nconsole.log(checks);\n\nconst passed = checks.freshIsNotSkipped === true &&\n checks.attempt1 === 1 &&\n checks.stillTrying === true &&\n checks.attempt2 === 2 &&\n checks.attempt3 === 3 &&\n checks.nowSkipped === true &&\n checks.statusIsFailed === true &&\n checks.lastErrorStored === true &&\n checks.statusIsPosted === true &&\n checks.postedClearsError === true &&\n checks.postedIsSkipped === true &&\n checks.cleanedUp === true;\n\nif (!passed) throw new Error(\"smoke test failed — check the SQLite layer\");\nconsole.log(\"✅ SQLite layer OK\");",[],[137,149],"8e6c63dd-bf24-4802-b4da-38c747750bae","send-test-email.ts","786574ee-b20f-11f1-9d94-1607ee4eb77e",28,["D",1789591493914],"/**\n * Sends one test notification, so you can confirm email delivery works before\n * relying on it. Safe to run any time — it touches nothing else.\n */\nimport { ENV, optionalEnv } from \"../lib/env.ts\";\nimport { sendNotification } from \"../lib/notify.ts\";\n\nconst to = optionalEnv(ENV.NOTIFY_EMAIL);\nconsole.log(\n to\n ? `NOTIFY_EMAIL is set — sending to ${to}`\n : \"NOTIFY_EMAIL is unset — sending to the val owner's own address\",\n);\n\nconst ok = await sendNotification(\n \"Test notification\",\n [\n \"If you're reading this, Trend AutoPoster can reach you by email.\",\n \"\",\n `Sent at ${new Date().toISOString()}`,\n ].join(\"\\n\"),\n);\n\nif (!ok) throw new Error(\"email delivery failed — see the logs above\");\nconsole.log(\"✅ test email sent\");",[],[137,158],"659198b9-ab3a-42aa-b97d-b86fbd92d1fc","probe-opus.ts","ee7e592a-b20f-11f1-bd03-1607ee4eb77e",37,["D",1789591692060],"/**\n * Diagnostic only — probes the Opus Clip API surface to find the real endpoint.\n *\n * `api.opus.pro` answers (so the host is real), but `/v1/clips` returns a 404\n * \"Cannot POST\" from what looks like a LoopBack/NestJS server. This walks a few\n * plausible paths and prints what each one says.\n *\n * Delete this file once the correct endpoint is known.\n */\nconst BASE = \"https://api.opus.pro\";\n\nconst PATHS = [\n \"/\",\n \"/v1\",\n \"/v1/\",\n \"/api/v1/clips\",\n \"/v2/clips\",\n \"/clips\",\n \"/v1/projects\",\n \"/v1/openapi.json\",\n \"/openapi.json\",\n \"/docs\",\n];\n\nfor (const path of PATHS) {\n const url = `${BASE}${path}`;\n try {\n const res = await fetch(url, {\n method: \"GET\",\n headers: { Accept: \"application/json, text/html;q=0.9, */*;q=0.8\" },\n });\n const body = (await res.text()).slice(0, 220).replace(/\\s+/g, \" \");\n console.log(`${String(res.status).padEnd(4)} ${path.padEnd(20)} ${body}`);\n } catch (err) {\n console.log(\n `ERR ${path.padEnd(20)} ${err instanceof Error ? err.message : err}`,\n );\n }\n}",[],[137,166],"32df39e3-9214-4ed7-a18f-9697d3d66f18","dry-run.ts","e396e1d0-b20f-11f1-80c8-1607ee4eb77e",42,["D",1789591734646],"/**\n * Dry run — exercises the real steps without publishing anything.\n *\n * It answers two questions: \"is my YouTube key actually working?\" and \"where\n * does the pipeline stop?\".\n *\n * Nothing here writes to SQLite, calls TikTok, or sends email. Safe to run any\n * number of times.\n */\nimport { SEARCH_QUERIES } from \"../lib/config.ts\";\nimport {\n ENV,\n findMissingEnv,\n optionalEnv,\n REQUIRED_ENV,\n tiktokConfigProblem,\n} from \"../lib/env.ts\";\nimport { searchTrendingVideos } from \"../lib/youtube.ts\";\nimport { createClip } from \"../lib/opus.ts\";\n\n/** Keep the Opus poll short so the dry run can't hang for minutes. */\nconst DRY_RUN_POLL_MS = 30_000;\n\nconst out = (text = \"\") => console.log(text);\n\nout(\"=== Trend AutoPoster — dry run ===\");\nout(`started ${new Date().toISOString()}`);\nout(\"\");\n\n// --- Configuration ---------------------------------------------------------\nout(\"1. Configuration\");\nconst missing = findMissingEnv(REQUIRED_ENV);\nout(\n missing.length\n ? ` ✗ missing: ${missing.join(\", \")}`\n : ` ✓ ${REQUIRED_ENV.join(\", \")} are all set`,\n);\n\nconst tiktokProblem = tiktokConfigProblem();\nout(tiktokProblem ? ` ✗ TikTok: ${tiktokProblem}` : \" ✓ TikTok configured\");\nout(\"\");\n\n// --- Step 1: YouTube -------------------------------------------------------\nout(\"2. YouTube discovery\");\nlet candidates: Awaited> = [];\ntry {\n candidates = await searchTrendingVideos({ queries: SEARCH_QUERIES });\n out(` ✓ ${candidates.length} candidate(s) returned`);\n for (const [index, video] of candidates.slice(0, 5).entries()) {\n out(\n ` ${index + 1}. ${video.videoId} \"${video.title.slice(0, 55)}\" [${\n video.channelTitle.slice(0, 25)\n }]`,\n );\n }\n if (candidates.length === 0) {\n out(\" ⚠ zero results — check the keywords in lib/config.ts\");\n }\n} catch (err) {\n out(` ✗ ${err instanceof Error ? err.message : String(err)}`);\n}\nout(\"\");\n\n// --- Step 2: Opus Clip -----------------------------------------------------\nout(\"3. Opus Clip\");\nif (candidates.length === 0) {\n out(\" skipped — step 2 produced no candidate\");\n} else {\n const target = candidates[0];\n out(` submitting ${target.url}`);\n try {\n const clip = await createClip(target.url, {\n title: target.title,\n maxPollMs: DRY_RUN_POLL_MS,\n });\n out(` ✓ clip id: ${clip.clipId}`);\n out(` download: ${clip.downloadUrl}`);\n out(` caption: ${clip.caption.slice(0, 140) || \"(none)\"}`);\n out(` hashtags: ${clip.hashtags.join(\" \") || \"(none)\"}`);\n } catch (err) {\n out(` ✗ ${err instanceof Error ? err.message : String(err)}`);\n }\n}\nout(\"\");\n\n// --- Step 3: TikTok --------------------------------------------------------\nout(\"4. TikTok publish\");\nout(\n tiktokProblem\n ? \" skipped — no TikTok token configured (this is why a full run stops here)\"\n : ` token present (${\n optionalEnv(ENV.TIKTOK_ACCESS_TOKEN) ? \"static\" : \"refresh flow\"\n }) — not called by this dry run`,\n);\nout(\"\");\n\nout(\"=== dry run complete — nothing published, recorded, or emailed ===\");",[],[137,174],"3b04cf4d-c8ef-4a79-915f-914484c062ac","check-opus-project.ts","29676a0e-b210-11f1-806a-1607ee4eb77e",45,["D",1789592027383],"/**\n * Debug helper — poll an existing OpusClip project until its clips appear.\n *\n * Set PROJECT_ID below to the id you want to inspect. The pipeline logs it as\n * `[opus] project created for …`. Handy when a run gave up polling before\n * the render finished.\n */\nimport { ENV, optionalEnv, requireEnv } from \"../lib/env.ts\";\n\nconst PROJECT_ID = \"P3091620n1Hj\";\nconst POLL_INTERVAL_MS = 20_000;\nconst MAX_WAIT_MS = 150_000;\n\nconst apiKey = requireEnv(ENV.OPUS_CLIP_API_KEY);\nconst headers: Record = {\n Authorization: `Bearer ${apiKey}`,\n Accept: \"application/json\",\n};\nconst orgId = optionalEnv(ENV.OPUS_ORG_ID);\nif (orgId) headers[\"x-opus-org-id\"] = orgId;\n\ntype ClipRow = {\n id?: string;\n durationMs?: number;\n title?: string;\n hashtags?: string;\n uriForExport?: string;\n};\n\nasync function fetchClips(): Promise {\n const params = new URLSearchParams({\n q: \"findByProjectId\",\n projectId: PROJECT_ID,\n });\n const res = await fetch(\n `https://api.opus.pro/api/exportable-clips?${params}`,\n { headers },\n );\n const text = await res.text();\n if (!res.ok) {\n throw new Error(`HTTP ${res.status}: ${text.slice(0, 300)}`);\n }\n const payload = JSON.parse(text) as unknown;\n if (Array.isArray(payload)) return payload as ClipRow[];\n const record = payload as Record;\n return (record.data ?? record.clips ?? record.items ?? []) as ClipRow[];\n}\n\nconst deadline = Date.now() + MAX_WAIT_MS;\nlet clips: ClipRow[] = [];\nlet attempt = 0;\n\nwhile (Date.now() < deadline) {\n attempt++;\n clips = await fetchClips();\n console.log(\n `poll ${attempt}: ${clips.length} clip(s) for ${PROJECT_ID}`,\n );\n if (clips.length > 0) break;\n if (Date.now() + POLL_INTERVAL_MS >= deadline) break;\n await new Promise((resolve) => setTimeout(resolve, POLL_INTERVAL_MS));\n}\n\nif (clips.length === 0) {\n console.log(\n `⚠ still no clips after ${attempt} poll(s) — OpusClip is taking longer than ${\n Math.round(MAX_WAIT_MS / 1000)\n }s for this video`,\n );\n} else {\n // Dump the whole object so we can see exactly which URL fields exist.\n console.log(JSON.stringify(clips[0], null, 2).slice(0, 2500));\n}",[],[137,182],["D",1789590686836],[192,193,194,195,196,197,198],[19],{"_40":102,"_13":103,"_43":104,"_45":46,"_47":48,"_49":105,"_51":52,"_53":217,"_17":55,"_56":57,"_58":107,"_60":61,"_62":-5,"_125":218,"_18":219},{"_40":94,"_13":95,"_43":96,"_45":46,"_47":48,"_49":97,"_51":52,"_53":214,"_17":99,"_56":57,"_58":100,"_60":61,"_62":-5,"_125":215,"_18":216},{"_40":87,"_13":88,"_43":89,"_45":46,"_47":48,"_49":90,"_51":52,"_53":211,"_17":76,"_56":57,"_58":92,"_60":61,"_62":-5,"_125":212,"_18":213},{"_40":79,"_13":80,"_43":81,"_45":46,"_47":48,"_49":82,"_51":52,"_53":208,"_17":84,"_56":57,"_58":85,"_60":61,"_62":-5,"_125":209,"_18":210},{"_40":71,"_13":72,"_43":73,"_45":46,"_47":48,"_49":74,"_51":52,"_53":205,"_17":76,"_56":57,"_58":77,"_60":61,"_62":-5,"_125":206,"_18":207},{"_40":64,"_13":65,"_43":66,"_45":46,"_47":48,"_49":67,"_51":52,"_53":202,"_17":55,"_56":57,"_58":69,"_60":61,"_62":-5,"_125":203,"_18":204},{"_40":41,"_13":42,"_43":44,"_45":46,"_47":48,"_49":50,"_51":52,"_53":199,"_17":55,"_56":57,"_58":59,"_60":61,"_62":-5,"_125":200,"_18":201},["D",1789591068432],[],[19,42],["D",1789591493687],[],[19,65],["D",1789592203711],[],[19,72],["D",1789591475255],[],[19,80],["D",1789591726739],[],[19,88],["D",1789591051285],[],[19,95],["D",1789591726850],[],[19,103],"fe948bec-46cd-4016-a1ac-e2216d0acfcb",["D",1789590675077],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","YouTube trend → AI clip → TikTok auto-post, every 12 hours","imageUrl","userId","fddfc1a6-8d1e-4681-b49d-92beee01dfa0","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","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",{"_11":12,"_276":271},"org",{"_11":12,"_270":271,"_272":271,"_230":231,"_273":274,"_275":61},"branch",{"_17":74,"_13":16,"_40":48,"_262":220,"_263":-5,"_264":-5,"_265":-5,"_266":-5,"_267":-5,"_268":14,"_269":12},"isOwned","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","","avatar","tier","free","canRestrictVals","profileImageUrl","adoptOrgId",{"_40":220,"_13":14,"_53":368,"_222":-5,"_223":61,"_224":225,"_226":225,"_227":228,"_229":-5,"_230":231,"_232":-5,"_233":61,"_234":-5,"_235":-5,"_236":84,"_237":238,"_239":240,"_241":242,"_243":369,"_245":-5,"_246":247,"_248":247,"_249":250,"_251":250,"_252":250,"_253":247,"_254":247,"_255":370,"_257":371,"_259":372,"_261":61},[320,328,334,335],"files",[320,321,322,323,324,325,326,327,328,329,330,331,332,333,334,335],"counts",{"_311":84,"_312":153,"_313":84,"_32":314,"_315":316},[297,298,299,300,301,302,303],{"_40":109,"_13":19,"_43":46,"_45":-5,"_47":48,"_49":55,"_51":52,"_53":110,"_17":84,"_56":111,"_58":-5,"_60":61,"_62":-5,"_18":296},"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},[19],{"_40":102,"_13":103,"_43":104,"_45":46,"_47":48,"_49":105,"_51":52,"_53":106,"_17":55,"_56":57,"_58":107,"_60":61,"_62":-5,"_18":310},{"_40":94,"_13":95,"_43":96,"_45":46,"_47":48,"_49":97,"_51":52,"_53":98,"_17":99,"_56":57,"_58":100,"_60":61,"_62":-5,"_18":309},{"_40":87,"_13":88,"_43":89,"_45":46,"_47":48,"_49":90,"_51":52,"_53":91,"_17":76,"_56":57,"_58":92,"_60":61,"_62":-5,"_18":308},{"_40":79,"_13":80,"_43":81,"_45":46,"_47":48,"_49":82,"_51":52,"_53":83,"_17":84,"_56":57,"_58":85,"_60":61,"_62":-5,"_18":307},{"_40":71,"_13":72,"_43":73,"_45":46,"_47":48,"_49":74,"_51":52,"_53":75,"_17":76,"_56":57,"_58":77,"_60":61,"_62":-5,"_18":306},{"_40":64,"_13":65,"_43":66,"_45":46,"_47":48,"_49":67,"_51":52,"_53":68,"_17":55,"_56":57,"_58":69,"_60":61,"_62":-5,"_18":305},{"_40":41,"_13":42,"_43":44,"_45":46,"_47":48,"_49":50,"_51":52,"_53":54,"_17":55,"_56":57,"_58":59,"_60":61,"_62":-5,"_18":304},[19,42],[19,65],[19,72],[19,80],[19,88],[19,95],[19,103],"pulls","branches","forks",{"_317":76,"_319":84},"connections",{"_317":84,"_318":84},"count","unfilledCount","emptyCount",{"_40":109,"_13":19,"_43":46,"_45":-5,"_47":48,"_49":55,"_51":52,"_53":189,"_17":84,"_56":111,"_58":-5,"_60":61,"_62":-5,"_125":366,"_18":367},{"_40":102,"_13":103,"_43":104,"_45":46,"_47":48,"_49":105,"_51":52,"_53":217,"_17":55,"_56":57,"_58":107,"_60":61,"_62":-5,"_125":364,"_18":365},{"_40":94,"_13":95,"_43":96,"_45":46,"_47":48,"_49":97,"_51":52,"_53":214,"_17":99,"_56":57,"_58":100,"_60":61,"_62":-5,"_125":362,"_18":363},{"_40":87,"_13":88,"_43":89,"_45":46,"_47":48,"_49":90,"_51":52,"_53":211,"_17":76,"_56":57,"_58":92,"_60":61,"_62":-5,"_125":360,"_18":361},{"_40":79,"_13":80,"_43":81,"_45":46,"_47":48,"_49":82,"_51":52,"_53":208,"_17":84,"_56":57,"_58":85,"_60":61,"_62":-5,"_125":358,"_18":359},{"_40":71,"_13":72,"_43":73,"_45":46,"_47":48,"_49":74,"_51":52,"_53":205,"_17":76,"_56":57,"_58":77,"_60":61,"_62":-5,"_125":356,"_18":357},{"_40":64,"_13":65,"_43":66,"_45":46,"_47":48,"_49":67,"_51":52,"_53":202,"_17":55,"_56":57,"_58":69,"_60":61,"_62":-5,"_125":354,"_18":355},{"_40":41,"_13":42,"_43":44,"_45":46,"_47":48,"_49":50,"_51":52,"_53":199,"_17":55,"_56":57,"_58":59,"_60":61,"_62":-5,"_125":352,"_18":353},{"_40":136,"_13":137,"_43":138,"_45":-5,"_47":48,"_49":139,"_51":52,"_53":140,"_17":84,"_56":111,"_58":-5,"_60":61,"_62":-5,"_125":350,"_18":351},{"_40":181,"_13":182,"_43":183,"_45":138,"_47":48,"_49":184,"_51":52,"_53":185,"_17":55,"_56":57,"_58":186,"_60":61,"_62":-5,"_125":348,"_18":349},{"_40":173,"_13":174,"_43":175,"_45":138,"_47":48,"_49":176,"_51":52,"_53":177,"_17":153,"_56":57,"_58":178,"_60":61,"_62":-5,"_125":346,"_18":347},{"_40":165,"_13":166,"_43":167,"_45":138,"_47":48,"_49":168,"_51":52,"_53":169,"_17":84,"_56":57,"_58":170,"_60":61,"_62":-5,"_125":344,"_18":345},{"_40":157,"_13":158,"_43":159,"_45":138,"_47":48,"_49":160,"_51":52,"_53":161,"_17":84,"_56":57,"_58":162,"_60":61,"_62":-5,"_125":342,"_18":343},{"_40":148,"_13":149,"_43":150,"_45":138,"_47":48,"_49":151,"_51":52,"_53":152,"_17":153,"_56":57,"_58":154,"_60":61,"_62":-5,"_125":340,"_18":341},{"_40":128,"_13":129,"_43":130,"_45":-5,"_47":48,"_49":131,"_51":52,"_53":132,"_17":55,"_56":24,"_58":133,"_60":61,"_62":-5,"_125":338,"_18":339},{"_40":117,"_13":118,"_43":119,"_45":-5,"_47":48,"_49":120,"_51":52,"_53":121,"_17":122,"_56":123,"_58":124,"_60":61,"_62":-5,"_125":336,"_18":337},[],[118],[],[129],[],[137,149],[],[137,158],[],[137,166],[],[137,174],[],[137,182],[329,330,331,332,333],[137],[],[19,42],[],[19,65],[],[19,72],[],[19,80],[],[19,88],[],[19,95],[],[19,103],[321,322,323,324,325,326,327],[19],["D",1789590675077],["D",1789591281607],{"_11":12,"_276":271},{"_11":12,"_270":271,"_272":271,"_230":231,"_273":274,"_275":61},{"_17":74,"_13":16,"_40":48,"_262":220,"_263":-5,"_264":-5,"_265":-5,"_266":-5,"_267":-5,"_268":14,"_269":12},"ctx",{"_255":-5,"_293":406,"_407":408,"_409":410,"_411":61,"_412":61,"_413":61,"_414":52,"_415":-5,"_416":-7,"_417":-7,"_418":84,"_419":61,"_420":61,"_421":-5,"_422":61,"_423":61,"_424":61,"_425":-5},"ENV",{"_377":378,"_379":380,"_381":16,"_382":383,"_384":385,"_386":387,"_388":389,"_390":391,"_392":393,"_394":395,"_396":397,"_398":399,"_400":401,"_402":403,"_404":405},"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"]