[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_226":227,"_228":229},"routes/_app.x.$handle.$name",{"_103":102,"_37":50,"_111":93,"_32":105,"_13":14,"_112":-5,"_11":113,"_114":115,"_116":117,"_118":119,"_120":121,"_26":-5,"_122":-5,"_123":-5,"_124":30,"_125":126,"_127":30,"_128":-5,"_129":-5,"_130":131},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":-5},"project",{"_48":49,"_37":50,"_43":51,"_52":-5,"_53":30,"_54":55,"_56":55,"_57":58,"_59":-5,"_19":60,"_61":-5,"_62":30,"_63":-5,"_64":-5,"_65":66,"_67":68,"_69":70,"_71":72,"_73":74,"_75":-5,"_76":77,"_78":77,"_79":80,"_81":80,"_82":80,"_83":77,"_84":77,"_85":86,"_87":88,"_89":90,"_91":30},"version",7,"changes",[25],"aiChatInfo",{"_20":21,"_22":-5,"_23":-5,"_24":-5},"userId","aiChatMessageId","b0c26829-c3c8-4cd6-a549-4ef89faeebfd","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle",{"_26":27,"_28":-7,"_29":30,"_31":30,"_32":33,"_34":33},"file",{"_35":36,"_37":38,"_39":40,"_41":42,"_43":44,"_45":14,"_46":47,"_29":30},"previous","deleted",false,"deletedHere","path","lib/tiktok.ts","latestPath","fileId","a3721626-b20d-11f1-aa57-1607ee4eb77e","name","tiktok.ts","fileType","script","content","/**\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}","createdAt",["D",1789590706981],"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",{"_103":102,"_110":105},"org",{"_103":102,"_104":105,"_106":105,"_19":60,"_107":108,"_109":30},"branch",{"_13":92,"_37":93,"_48":47,"_94":49,"_95":-5,"_96":-5,"_97":-5,"_98":-5,"_99":-5,"_100":50,"_101":102},"isOwned",46,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","motest","handle","displayName","","avatar","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_48":49,"_37":50,"_43":221,"_52":-5,"_53":30,"_54":55,"_56":55,"_57":58,"_59":-5,"_19":60,"_61":-5,"_62":30,"_63":-5,"_64":-5,"_65":66,"_67":68,"_69":70,"_71":72,"_73":222,"_75":-5,"_76":77,"_78":77,"_79":80,"_81":80,"_82":80,"_83":77,"_84":77,"_85":223,"_87":224,"_89":225,"_91":30},"tree",[164,171],"files",[164,165,166,167,168,169,170,171],"counts",{"_153":66,"_154":138,"_155":66,"_156":157,"_158":159},"contents",[132,133],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_48":145,"_37":146,"_35":147,"_137":-5,"_46":47,"_45":148,"_139":149,"_43":150,"_13":66,"_39":151,"_41":-5,"_29":30,"_143":-5,"_32":152},{"_48":134,"_37":135,"_35":136,"_137":-5,"_46":47,"_45":138,"_139":30,"_43":140,"_13":66,"_39":141,"_41":142,"_29":30,"_143":-5,"_32":144},"b2c4318a-4568-48d1-bb24-b923a34afba1","main.ts","90593b32-b20d-11f1-b41f-1607ee4eb77e","parentId",1,"latest",["D",1789590675113],"interval","// Learn more: https://docs.val.town/vals/cron/\nexport default async function (interval: Interval) {\n console.log(interval);\n}\n","label",[135],"3552ec96-097b-43ff-a276-c539b5fd3f15","lib","49f6b9da-c744-4653-8d32-c1d1321abcb4",2,true,["D",1789590686836],"directory",[146],"pulls","branches","forks","envVars",{"_160":162,"_163":66},"connections",{"_160":66,"_161":66},"count","unfilledCount",4,"emptyCount",{"_48":145,"_37":146,"_35":147,"_137":-5,"_46":47,"_45":148,"_139":149,"_43":218,"_13":66,"_39":151,"_41":-5,"_29":30,"_143":-5,"_173":219,"_32":220},{"_48":211,"_37":212,"_35":213,"_137":147,"_46":47,"_45":162,"_139":30,"_43":214,"_13":66,"_39":40,"_41":215,"_29":30,"_143":-5,"_173":216,"_32":217},{"_48":204,"_37":205,"_35":206,"_137":147,"_46":47,"_45":148,"_139":30,"_43":207,"_13":66,"_39":40,"_41":208,"_29":30,"_143":-5,"_173":209,"_32":210},{"_48":196,"_37":197,"_35":198,"_137":147,"_46":47,"_45":199,"_139":30,"_43":200,"_13":66,"_39":40,"_41":201,"_29":30,"_143":-5,"_173":202,"_32":203},{"_48":188,"_37":189,"_35":190,"_137":147,"_46":47,"_45":191,"_139":30,"_43":192,"_13":66,"_39":40,"_41":193,"_29":30,"_143":-5,"_173":194,"_32":195},{"_48":184,"_37":38,"_35":36,"_137":147,"_46":47,"_45":14,"_139":30,"_43":185,"_13":66,"_39":40,"_41":42,"_29":30,"_143":-5,"_173":186,"_32":187},{"_48":176,"_37":177,"_35":178,"_137":147,"_46":47,"_45":179,"_139":30,"_43":180,"_13":66,"_39":40,"_41":181,"_29":30,"_143":-5,"_173":182,"_32":183},{"_48":134,"_37":135,"_35":136,"_137":-5,"_46":47,"_45":138,"_139":30,"_43":172,"_13":66,"_39":141,"_41":142,"_29":30,"_143":-5,"_173":174,"_32":175},["D",1789590675113],"children",[],[135],"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}",[],[146,177],"0563a746-864c-4aca-b7f5-29c18bac6670",["D",1789590706981],[],[146,38],"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}",[],[146,189],"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}",[],[146,197],"c5390772-40a2-4be8-983c-73afa6762df3","env.ts","9772dc3e-b20d-11f1-8580-1607ee4eb77e",["D",1789590686836],"/**\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}",[],[146,205],"174bd819-a72d-450c-a7ca-90085b70e3a6","db.ts","97b7469e-b20d-11f1-8580-1607ee4eb77e",["D",1789590687478],"/**\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.\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\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 ??= sqlite.execute(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 sqlite.execute({\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 sqlite.execute({\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/** How many videos have been handled so far. */\nexport async function processedCount(): Promise {\n await initDb();\n const { rows } = await sqlite.execute(\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 sqlite.execute({\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}",[],[146,212],["D",1789590686836],[165,166,167,168,169,170],[146],["D",1789590675077],["D",1789591281607],{"_103":102,"_110":105},{"_103":102,"_104":105,"_106":105,"_19":60,"_107":108,"_109":30},{"_13":92,"_37":93,"_48":47,"_94":49,"_95":-5,"_96":-5,"_97":-5,"_98":-5,"_99":-5,"_100":50,"_101":102},"ctx",{"_85":-5,"_129":259,"_260":261,"_262":263,"_264":30,"_265":30,"_266":30,"_267":149,"_268":-5,"_269":-7,"_270":-7,"_271":66,"_272":30,"_273":30,"_274":-5,"_275":30,"_276":30,"_277":30,"_278":-5},"ENV",{"_230":231,"_232":233,"_234":93,"_235":236,"_237":238,"_239":240,"_241":242,"_243":244,"_245":246,"_247":248,"_249":250,"_251":252,"_253":254,"_255":256,"_257":258},"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 · v7