[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_208":209,"_210":211},"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",5,"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/youtube.ts","latestPath","fileId","97bcce84-b20d-11f1-8580-1607ee4eb77e","name","youtube.ts","fileType","script","content","/**\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}","createdAt",["D",1789590687515],"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":203,"_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":204,"_75":-5,"_76":77,"_78":77,"_79":80,"_81":80,"_82":80,"_83":77,"_84":77,"_85":205,"_87":206,"_89":207,"_91":30},"tree",[164,169],"files",[164,165,166,167,168,169],"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":200,"_13":66,"_39":151,"_41":-5,"_29":30,"_143":-5,"_171":201,"_32":202},{"_48":193,"_37":194,"_35":195,"_137":147,"_46":47,"_45":162,"_139":30,"_43":196,"_13":66,"_39":40,"_41":197,"_29":30,"_143":-5,"_171":198,"_32":199},{"_48":186,"_37":187,"_35":188,"_137":147,"_46":47,"_45":148,"_139":30,"_43":189,"_13":66,"_39":40,"_41":190,"_29":30,"_143":-5,"_171":191,"_32":192},{"_48":178,"_37":179,"_35":180,"_137":147,"_46":47,"_45":181,"_139":30,"_43":182,"_13":66,"_39":40,"_41":183,"_29":30,"_143":-5,"_171":184,"_32":185},{"_48":174,"_37":38,"_35":36,"_137":147,"_46":47,"_45":14,"_139":30,"_43":175,"_13":66,"_39":40,"_41":42,"_29":30,"_143":-5,"_171":176,"_32":177},{"_48":134,"_37":135,"_35":136,"_137":-5,"_46":47,"_45":138,"_139":30,"_43":170,"_13":66,"_39":141,"_41":142,"_29":30,"_143":-5,"_171":172,"_32":173},["D",1789590675113],"children",[],[135],"97d0bf8c-0512-4ad8-a28f-9130f60d52e0",["D",1789590687515],[],[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,179],"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,187],"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,194],["D",1789590686836],[165,166,167,168],[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":241,"_242":243,"_244":245,"_246":30,"_247":30,"_248":30,"_249":149,"_250":-5,"_251":-7,"_252":-7,"_253":66,"_254":30,"_255":30,"_256":-5,"_257":30,"_258":30,"_259":30,"_260":-5},"ENV",{"_212":213,"_214":215,"_216":93,"_217":218,"_219":220,"_221":222,"_223":224,"_225":226,"_227":228,"_229":230,"_231":232,"_233":234,"_235":236,"_237":238,"_239":240},"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 · v5