Airwolf C64

[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_215":216,"_217":218},"routes/_app.x.$handle.$name",{"_102":101,"_37":49,"_111":92,"_32":112,"_13":14,"_113":-5,"_11":114,"_115":116,"_117":118,"_119":120,"_121":122,"_26":-5,"_123":-5,"_124":-5,"_125":30,"_126":127,"_128":129,"_130":-5,"_131":-5,"_132":133},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":-5},"project",{"_47":48,"_37":49,"_42":50,"_51":-5,"_52":30,"_53":54,"_55":54,"_56":57,"_58":-5,"_19":59,"_60":-5,"_61":30,"_62":-5,"_63":-5,"_64":65,"_66":67,"_68":69,"_70":71,"_72":73,"_74":-5,"_75":76,"_77":76,"_78":79,"_80":79,"_81":79,"_82":76,"_83":76,"_84":85,"_86":87,"_88":89,"_90":30},"version",29,"changes",[25],"aiChatInfo",{"_20":21,"_22":-5,"_23":-5,"_24":-5},"userId","aiChatMessageId","de3d0c32-4b06-4175-87fc-db45ffdbc18e","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle",{"_26":27,"_28":-7,"_29":30,"_31":30,"_32":33,"_34":33},"file",{"_35":36,"_37":33,"_38":39,"_40":41,"_42":43,"_44":14,"_45":46,"_29":30},"previous","deleted",false,"deletedHere","path","harvest.ts","latestPath","fileId","38ef2b82-5fbe-11f1-8af5-1607ee4eb77e","name","fileType","interval","content","import { blob } from \"https://esm.town/v/std/blob\";\nimport { ensureSchema, insertVideoIds, countVideos } from \"./db.ts\";\nimport { fetchUploadsPage } from \"./playlist.ts\";\n\n// Where we remember our place in the playlist between runs, so each run picks\n// up where the last left off and we eventually walk the whole 33k+ catalog.\nconst CURSOR_KEY = \"harvest-cursor\";\n\n// Pages to pull per run. Each page = 50 IDs and costs just 1 quota unit, so\n// 40 pages = 2000 IDs/run for 40 units — trivial against the 10k/day budget.\nconst PAGES_PER_RUN = 40;\n\ninterface Cursor {\n pageToken?: string;\n}\n\n/**\n * Harvests video IDs from the uploads playlist into SQLite, resuming from the\n * saved cursor. When it reaches the end of the playlist it loops back to the\n * start so newly uploaded videos get picked up on the next pass.\n */\nexport default async function () {\n await ensureSchema();\n\n const cursor = (await blob.getJSON(CURSOR_KEY).catch(() => null)) as\n | Cursor\n | null;\n let pageToken = cursor?.pageToken;\n\n let pagesFetched = 0;\n let totalNew = 0;\n\n for (let i = 0; i < PAGES_PER_RUN; i++) {\n const { ids, nextPageToken } = await fetchUploadsPage(pageToken);\n totalNew += await insertVideoIds(ids);\n pagesFetched++;\n\n if (!nextPageToken) {\n // Reached the end — loop back to the beginning next run.\n pageToken = undefined;\n break;\n }\n pageToken = nextPageToken;\n }\n\n // Persist where to resume next time.\n await blob.setJSON(CURSOR_KEY, { pageToken } satisfies Cursor);\n\n const total = await countVideos();\n console.log(\n `Harvest: fetched ${pagesFetched} page(s), +${totalNew} new, ${total} cached total. Next token: ${pageToken ?? \"(restart)\"}`,\n );\n\n return { pagesFetched, totalNew, total };\n}\n","createdAt",["D",1780540602867],"branchVersion","branchId","2fe4d1fd-78d9-4cd3-8ad3-d439cbc41278","id","04284e5b-3156-4597-9696-34418890d921","airwolf-c64-player",["D",1780535469681],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Full-bleed shuffled YouTube stream of the Airwolf_C64 channel","imageUrl","908f60a4-277b-4f9e-9681-354ad21826b5","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019e8ee4-ae54-7718-b7bb-95bd619db6fb","tursoName","04284e5b31564597969634418890d921","tursoHostname","04284e5b31564597969634418890d921-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789511441255],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_102":101,"_110":106},"org",{"_102":101,"_103":104,"_105":106,"_19":59,"_107":108,"_109":30},"branch",{"_13":91,"_37":92,"_47":46,"_93":48,"_94":-5,"_95":-5,"_96":-5,"_97":-5,"_98":-5,"_99":49,"_100":101},"isOwned",42,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","cgio","handle","displayName","Chad G.","avatar","https://avatars.githubusercontent.com/u/20654198?v=4","tier","pro","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_47":48,"_37":49,"_42":210,"_51":-5,"_52":30,"_53":54,"_55":54,"_56":57,"_58":-5,"_19":59,"_60":-5,"_61":30,"_62":-5,"_63":-5,"_64":65,"_66":67,"_68":69,"_70":71,"_72":211,"_74":-5,"_75":76,"_77":76,"_78":79,"_80":79,"_81":79,"_82":76,"_83":76,"_84":212,"_86":213,"_88":214,"_90":30},"tree",[189,190,191,192,193],"files",[189,190,191,192,193],"counts",{"_178":65,"_179":180,"_181":65,"_182":183,"_184":185},"contents",[134,135,136,137,138],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_47":171,"_37":172,"_35":173,"_142":-5,"_45":46,"_44":174,"_144":129,"_42":175,"_13":65,"_38":147,"_40":176,"_29":30,"_149":-5,"_32":177},{"_47":168,"_37":33,"_35":36,"_142":-5,"_45":46,"_44":14,"_144":129,"_42":169,"_13":65,"_38":39,"_40":41,"_29":30,"_149":-5,"_32":170},{"_47":159,"_37":160,"_35":161,"_142":-5,"_45":46,"_44":162,"_144":30,"_42":163,"_13":164,"_38":165,"_40":166,"_29":30,"_149":-5,"_32":167},{"_47":151,"_37":152,"_35":153,"_142":-5,"_45":46,"_44":154,"_144":30,"_42":155,"_13":156,"_38":26,"_40":157,"_29":30,"_149":-5,"_32":158},{"_47":139,"_37":140,"_35":141,"_142":-5,"_45":46,"_44":143,"_144":30,"_42":145,"_13":146,"_38":147,"_40":148,"_29":30,"_149":-5,"_32":150},"6b1aaed9-b034-4c1b-a15c-6dc76ba2cdb9","playlist.ts","97a13b06-5fba-11f1-9f0c-1607ee4eb77e","parentId",28,"latest",["D",1780540593414],4,"script","// The Airwolf_C64 (\"C64!\") channel.\n// channel handle: https://www.youtube.com/@Airwolf_C64\n// channel id: UCl_r4u5k-IlxW6QB8_XRvTg\n// uploads list: UUl_r4u5k-IlxW6QB8_XRvTg\nexport const CHANNEL_ID = \"UCl_r4u5k-IlxW6QB8_XRvTg\";\nexport const UPLOADS_PLAYLIST_ID = \"UUl_r4u5k-IlxW6QB8_XRvTg\";\n\n// Keyword pool used to probe different slices of the channel's 20k+ catalog.\n// Each request searches one random keyword, so over time the whole history is\n// reachable rather than just the first playlist page.\nexport const SEARCH_KEYWORDS = [\n \"C64\",\n \"Amiga\",\n \"demo\",\n \"intro\",\n \"cracktro\",\n \"1993\",\n \"1994\",\n \"Amstrad\",\n \"Atari\",\n];\n\n/** Reads the YouTube Data API key from the environment. */\nfunction getApiKey(): string {\n const key = Deno.env.get(\"YOUTUBE_API_KEY\");\n if (!key) {\n throw new Error(\"Missing YOUTUBE_API_KEY environment variable\");\n }\n return key;\n}\n\n/** Picks one random element using standard Math.random() logic. */\nexport function pickRandom(items: readonly T[]): T {\n return items[Math.floor(Math.random() * items.length)];\n}\n\n/**\n * Searches the channel for a single random keyword and returns up to 50\n * matching video IDs. Using the search endpoint (instead of playlistItems)\n * lets us reach across the entire upload history, and varying the keyword each\n * request keeps results fresh.\n */\nexport async function fetchSearchVideoIds(\n keyword: string = pickRandom(SEARCH_KEYWORDS),\n channelId: string = CHANNEL_ID,\n): Promise {\n const key = getApiKey();\n const url =\n `https://www.googleapis.com/youtube/v3/search?part=snippet&channelId=${channelId}` +\n `&maxResults=50&q=${encodeURIComponent(keyword)}&type=video&key=${key}`;\n\n const res = await fetch(url);\n const data = await res.json();\n\n if (!res.ok || data.error) {\n const message = data?.error?.message ?? `HTTP ${res.status}`;\n throw new Error(`YouTube Data API error: ${message}`);\n }\n\n // Search results nest the id under `id.videoId` (unlike playlistItems).\n const items: Array<{ id?: { videoId?: string } }> = data.items ?? [];\n\n // Extract a clean array of just the 11-character videoId strings.\n return items\n .map((item) => item.id?.videoId)\n .filter((id): id is string => typeof id === \"string\" && id.length === 11);\n}\n\n/**\n * Returns a new array with the elements randomized using the\n * Fisher-Yates (Durstenfeld) shuffle.\n */\nexport function shuffle(input: readonly T[]): T[] {\n const arr = [...input];\n for (let i = arr.length - 1; i > 0; i--) {\n const j = Math.floor(Math.random() * (i + 1));\n [arr[i], arr[j]] = [arr[j], arr[i]];\n }\n return arr;\n}\n\n/**\n * Fetches one page (up to 50 IDs) of the uploads playlist via the cheap\n * playlistItems endpoint (1 quota unit per call). Returns the IDs plus the\n * nextPageToken (undefined when there are no more pages).\n */\nexport async function fetchUploadsPage(\n pageToken?: string,\n playlistId: string = UPLOADS_PLAYLIST_ID,\n): Promise<{ ids: string[]; nextPageToken?: string }> {\n const key = getApiKey();\n let url =\n `https://www.googleapis.com/youtube/v3/playlistItems?part=contentDetails` +\n `&maxResults=50&playlistId=${playlistId}&key=${key}`;\n if (pageToken) url += `&pageToken=${pageToken}`;\n\n const res = await fetch(url);\n const data = await res.json();\n\n if (!res.ok || data.error) {\n const message = data?.error?.message ?? `HTTP ${res.status}`;\n throw new Error(`YouTube Data API error: ${message}`);\n }\n\n const items: Array<{ contentDetails?: { videoId?: string } }> =\n data.items ?? [];\n const ids = items\n .map((item) => item.contentDetails?.videoId)\n .filter((id): id is string => typeof id === \"string\" && id.length === 11);\n\n return { ids, nextPageToken: data.nextPageToken };\n}\n","label",[140],"c109e8de-137b-4190-8f4a-59a65b463897","player.html","4881d722-5fb2-11f1-952c-1607ee4eb77e",19,["D",1780540071041],3,"\n\n\n \n \n Airwolf C64\n \n\n\n \n\n\n",[152],"98ca1213-f41e-479a-a9f5-79e30fc5d351","main.ts","455613a6-5fb2-11f1-952c-1607ee4eb77e",24,["D",1780540398760],7,"http","import { readFile } from \"https://esm.town/v/std/utils/index.ts\";\nimport { fetchSearchVideoIds, shuffle } from \"./playlist.ts\";\n\n// Streams the Airwolf_C64 (\"C64!\") channel, shuffled, full-bleed for the\n// Google TV Streamer display.\n//\n// Each request searches the channel for one random demoscene keyword via the\n// official YouTube Data API v3, reaching across the entire 20k+ upload history\n// for true catalog-wide randomization. The results are Fisher-Yates shuffled\n// and embedded as a native YouTube playlist so the TV remote can skip tracks.\nexport default async function (_req: Request): Promise {\n let videoIds: string[];\n try {\n const ids = await fetchSearchVideoIds();\n if (ids.length === 0) {\n return new Response(\"No videos found for the Airwolf_C64 channel\", {\n status: 502,\n });\n }\n // Fisher-Yates shuffle to fully randomize the play order.\n videoIds = shuffle(ids);\n } catch (err) {\n return new Response(`Failed to load videos: ${(err as Error).message}`, {\n status: 502,\n });\n }\n\n // Native embed playlist syntax:\n // /embed/FIRST?playlist=SECOND,THIRD,...\n // The first ID is the path; the remaining IDs form the comma-separated queue.\n const [firstId, ...restIds] = videoIds;\n const restCsv = restIds.join(\",\");\n\n const template = await readFile(\"/player.html\", import.meta.url);\n const html = template\n .replaceAll(\"__FIRST_VIDEO_ID__\", firstId)\n .replaceAll(\"__REST_VIDEO_IDS__\", restCsv);\n\n return new Response(html, {\n headers: {\n \"Content-Type\": \"text/html; charset=utf-8\",\n // Never cache, so each load re-searches and reshuffles.\n \"Cache-Control\": \"no-store\",\n },\n });\n}\n",[160],"e2dd2872-6820-4085-b5af-f8c0625f4176",["D",1780540602867],[33],"8fc6cd63-978b-4ddb-987d-70a065c46a9e","db.ts","29ba37ec-5fbe-11f1-abcc-1607ee4eb77e",26,["D",1780540577362],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\n// Bump this suffix if the schema ever changes in an incompatible way.\nconst TABLE = \"videos_v1\";\n\n/** Creates the videos table if it doesn't already exist. Idempotent. */\nexport async function ensureSchema(): Promise {\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS ${TABLE} (\n video_id TEXT PRIMARY KEY,\n added_at INTEGER NOT NULL DEFAULT (unixepoch())\n )`);\n}\n\n/**\n * Inserts a batch of 11-char video IDs, ignoring any that already exist.\n * Returns the number of rows actually inserted (new IDs).\n */\nexport async function insertVideoIds(ids: readonly string[]): Promise {\n const clean = ids.filter((id) => typeof id === \"string\" && id.length === 11);\n if (clean.length === 0) return 0;\n\n const before = await countVideos();\n\n // Chunk to keep each statement's parameter list reasonable.\n const CHUNK = 100;\n for (let i = 0; i < clean.length; i += CHUNK) {\n const chunk = clean.slice(i, i + CHUNK);\n const placeholders = chunk.map(() => \"(?)\").join(\",\");\n await sqlite.execute({\n sql: `INSERT OR IGNORE INTO ${TABLE} (video_id) VALUES ${placeholders}`,\n args: [...chunk],\n });\n }\n\n const after = await countVideos();\n return after - before;\n}\n\n/** Returns up to `limit` random video IDs from the cache. */\nexport async function getRandomVideoIds(limit = 50): Promise {\n const result = await sqlite.execute({\n sql: `SELECT video_id FROM ${TABLE} ORDER BY RANDOM() LIMIT ?`,\n args: [limit],\n });\n return result.rows.map((row) => String((row as { video_id: string }).video_id));\n}\n\n/** Total number of cached video IDs. */\nexport async function countVideos(): Promise {\n const result = await sqlite.execute(`SELECT COUNT(*) AS n FROM ${TABLE}`);\n return Number((result.rows[0] as { n: number }).n);\n}\n",[172],"pulls","branches",1,"forks","envVars",{"_186":180,"_188":65},"connections",{"_186":65,"_187":65},"count","unfilledCount","emptyCount",{"_47":171,"_37":172,"_35":173,"_142":-5,"_45":46,"_44":174,"_144":129,"_42":207,"_13":65,"_38":147,"_40":176,"_29":30,"_149":-5,"_195":208,"_32":209},{"_47":168,"_37":33,"_35":36,"_142":-5,"_45":46,"_44":14,"_144":129,"_42":204,"_13":65,"_38":39,"_40":41,"_29":30,"_149":-5,"_195":205,"_32":206},{"_47":159,"_37":160,"_35":161,"_142":-5,"_45":46,"_44":162,"_144":30,"_42":201,"_13":164,"_38":165,"_40":166,"_29":30,"_149":-5,"_195":202,"_32":203},{"_47":151,"_37":152,"_35":153,"_142":-5,"_45":46,"_44":154,"_144":30,"_42":198,"_13":156,"_38":26,"_40":157,"_29":30,"_149":-5,"_195":199,"_32":200},{"_47":139,"_37":140,"_35":141,"_142":-5,"_45":46,"_44":143,"_144":30,"_42":194,"_13":146,"_38":147,"_40":148,"_29":30,"_149":-5,"_195":196,"_32":197},["D",1780540593414],"children",[],[140],["D",1780540071041],[],[152],["D",1780540398760],[],[160],["D",1780540602867],[],[33],["D",1780540577362],[],[172],["D",1780535469681],["D",1789511441255],{"_102":101,"_110":106},{"_102":101,"_103":104,"_105":106,"_19":59,"_107":108,"_109":30},{"_13":91,"_37":92,"_47":46,"_93":48,"_94":-5,"_95":-5,"_96":-5,"_97":-5,"_98":-5,"_99":49,"_100":101},"ctx",{"_84":-5,"_131":248,"_249":250,"_251":252,"_253":30,"_254":30,"_255":30,"_256":129,"_257":-5,"_258":-7,"_259":-7,"_260":65,"_261":30,"_262":30,"_263":-5,"_264":30,"_265":30,"_266":30,"_267":-5},"ENV",{"_219":220,"_221":222,"_223":92,"_224":225,"_226":227,"_228":229,"_230":231,"_232":233,"_234":235,"_236":237,"_238":239,"_240":241,"_242":243,"_244":245,"_246":247},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","fdb67791413f4386b4dbf18f354029a617f6160f","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 · v29