[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_250":251,"_252":253},"routes/_app.x.$handle.$name",{"_109":108,"_38":56,"_117":99,"_33":111,"_13":14,"_118":-5,"_11":119,"_120":121,"_122":123,"_124":125,"_126":127,"_27":-5,"_128":-5,"_129":-5,"_130":31,"_131":132,"_133":31,"_134":-5,"_135":-5,"_136":137},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":-5},"project",{"_54":55,"_38":56,"_44":57,"_58":-5,"_59":31,"_60":61,"_62":61,"_63":64,"_65":-5,"_19":66,"_67":-5,"_68":31,"_69":-5,"_70":-5,"_71":72,"_73":74,"_75":76,"_77":78,"_79":80,"_81":-5,"_82":83,"_84":83,"_85":86,"_87":86,"_88":86,"_89":83,"_90":83,"_91":92,"_93":94,"_95":96,"_97":31},"version",10,"changes",[25,26],"aiChatInfo",{"_20":21,"_22":-5,"_23":-5,"_24":-5},"userId","aiChatMessageId","b0c26829-c3c8-4cd6-a549-4ef89faeebfd","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle",{"_27":49,"_29":-7,"_30":31,"_32":31,"_33":50,"_35":50},{"_27":28,"_29":-7,"_30":31,"_32":31,"_33":34,"_35":34},"file",{"_36":37,"_38":39,"_40":41,"_42":43,"_44":45,"_46":14,"_47":48,"_30":31},"previous","deleted",false,"deletedHere","path","scripts/smoke-test.ts","latestPath","fileId","b2591bee-b20d-11f1-a33b-1607ee4eb77e","name","smoke-test.ts","fileType","script","content","/**\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\");","createdAt",["D",1789590732153],"branchVersion","branchId","7b1f7eb3-1f90-4b89-bc30-a5817ab59c76",{"_36":51,"_38":50,"_40":52,"_42":-5,"_44":53,"_46":14,"_47":48,"_30":31},"scripts","68926185-0dcc-4025-b344-11069b51005e","directory",["D",1789590732153],"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",{"_109":108,"_116":111},"org",{"_109":108,"_110":111,"_112":111,"_19":66,"_113":114,"_115":31},"branch",{"_13":98,"_38":99,"_54":48,"_100":55,"_101":-5,"_102":-5,"_103":-5,"_104":-5,"_105":-5,"_106":56,"_107":108},"isOwned",46,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","motest","handle","displayName","","avatar","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_54":55,"_38":56,"_44":245,"_58":-5,"_59":31,"_60":61,"_62":61,"_63":64,"_65":-5,"_19":66,"_67":-5,"_68":31,"_69":-5,"_70":-5,"_71":72,"_73":74,"_75":76,"_77":78,"_79":246,"_81":-5,"_82":83,"_84":83,"_85":86,"_87":86,"_88":86,"_89":83,"_90":83,"_91":247,"_93":248,"_95":249,"_97":31},"tree",[174,181,183],"files",[174,175,176,177,178,179,180,181,182,183],"counts",{"_163":72,"_164":148,"_165":72,"_166":167,"_168":169},"contents",[138,139,140],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_54":157,"_38":158,"_36":159,"_144":-5,"_47":48,"_46":160,"_146":154,"_44":161,"_13":72,"_40":52,"_42":-5,"_30":31,"_151":-5,"_33":162},{"_54":153,"_38":50,"_36":51,"_144":-5,"_47":48,"_46":14,"_146":154,"_44":155,"_13":72,"_40":52,"_42":-5,"_30":31,"_151":-5,"_33":156},{"_54":141,"_38":142,"_36":143,"_144":-5,"_47":48,"_46":145,"_146":31,"_44":147,"_13":148,"_40":149,"_42":150,"_30":31,"_151":-5,"_33":152},"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",[142],"4ab75f96-c9b6-4b0e-ad07-f09c2f292158",true,["D",1789590732153],[50],"3552ec96-097b-43ff-a276-c539b5fd3f15","lib","49f6b9da-c744-4653-8d32-c1d1321abcb4",2,["D",1789590686836],[158],"pulls","branches","forks","envVars",{"_170":172,"_173":72},"connections",{"_170":72,"_171":72},"count","unfilledCount",4,"emptyCount",{"_54":157,"_38":158,"_36":159,"_144":-5,"_47":48,"_46":160,"_146":154,"_44":242,"_13":72,"_40":52,"_42":-5,"_30":31,"_151":-5,"_185":243,"_33":244},{"_54":234,"_38":235,"_36":236,"_144":159,"_47":48,"_46":237,"_146":31,"_44":238,"_13":148,"_40":41,"_42":239,"_30":31,"_151":-5,"_185":240,"_33":241},{"_54":227,"_38":228,"_36":229,"_144":159,"_47":48,"_46":160,"_146":31,"_44":230,"_13":72,"_40":41,"_42":231,"_30":31,"_151":-5,"_185":232,"_33":233},{"_54":219,"_38":220,"_36":221,"_144":159,"_47":48,"_46":222,"_146":31,"_44":223,"_13":72,"_40":41,"_42":224,"_30":31,"_151":-5,"_185":225,"_33":226},{"_54":211,"_38":212,"_36":213,"_144":159,"_47":48,"_46":214,"_146":31,"_44":215,"_13":72,"_40":41,"_42":216,"_30":31,"_151":-5,"_185":217,"_33":218},{"_54":203,"_38":204,"_36":205,"_144":159,"_47":48,"_46":206,"_146":31,"_44":207,"_13":72,"_40":41,"_42":208,"_30":31,"_151":-5,"_185":209,"_33":210},{"_54":195,"_38":196,"_36":197,"_144":159,"_47":48,"_46":198,"_146":31,"_44":199,"_13":72,"_40":41,"_42":200,"_30":31,"_151":-5,"_185":201,"_33":202},{"_54":153,"_38":50,"_36":51,"_144":-5,"_47":48,"_46":14,"_146":154,"_44":192,"_13":72,"_40":52,"_42":-5,"_30":31,"_151":-5,"_185":193,"_33":194},{"_54":188,"_38":39,"_36":37,"_144":51,"_47":48,"_46":14,"_146":31,"_44":189,"_13":72,"_40":41,"_42":43,"_30":31,"_151":-5,"_185":190,"_33":191},{"_54":141,"_38":142,"_36":143,"_144":-5,"_47":48,"_46":145,"_146":31,"_44":184,"_13":148,"_40":149,"_42":150,"_30":31,"_151":-5,"_185":186,"_33":187},["D",1789590714285],"children",[],[142],"762b3e40-197d-431b-a638-fd60db35fdf8",["D",1789590732153],[],[50,39],["D",1789590732153],[182],[50],"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}",[],[158,196],"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}",[],[158,204],"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}",[],[158,212],"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}",[],[158,220],"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}",[],[158,228],"94f08106-a30d-4456-ae8d-dcd841daa196","db.ts","97b7469e-b20d-11f1-8580-1607ee4eb77e",9,["D",1789590732104],"/**\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}/** 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 sqlite.execute({\n sql: \"DELETE FROM processed_trending_videos WHERE video_id = ?\",\n args: [videoId],\n });\n}",[],[158,235],["D",1789590686836],[175,176,177,178,179,180],[158],["D",1789590675077],["D",1789591281607],{"_109":108,"_116":111},{"_109":108,"_110":111,"_112":111,"_19":66,"_113":114,"_115":31},{"_13":98,"_38":99,"_54":48,"_100":55,"_101":-5,"_102":-5,"_103":-5,"_104":-5,"_105":-5,"_106":56,"_107":108},"ctx",{"_91":-5,"_135":283,"_284":285,"_286":287,"_288":31,"_289":31,"_290":31,"_291":154,"_292":-5,"_293":-7,"_294":-7,"_295":72,"_296":31,"_297":31,"_298":-5,"_299":31,"_300":31,"_301":31,"_302":-5},"ENV",{"_254":255,"_256":257,"_258":99,"_259":260,"_261":262,"_263":264,"_265":266,"_267":268,"_269":270,"_271":272,"_273":274,"_275":276,"_277":278,"_279":280,"_281":282},"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 · v10