${cdata(video.title)}

[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8},"actionData","errors","root",{"_103":104,"_105":106},"routes/embed.x.$handle.$name.$",{"_9":10,"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":-5},"handle","mikefrischknecht","name","watson-videos-rss","path","videos.ts","project",{"_22":45,"_11":12,"_33":46,"_47":-5,"_48":42,"_49":50,"_51":50,"_52":53,"_54":-5,"_55":56,"_57":25,"_58":32,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":-5,"_66":-5,"_67":-5,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":79,"_80":81,"_82":83,"_84":42},"file",{"_22":23,"_11":14,"_24":25,"_26":-5,"_27":28,"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":40,"_41":42,"_43":-5,"_13":44},"permalink","https://www.val.town/x/mikefrischknecht/watson-videos-rss/code/videos.ts","extension","id","f45fda11-dbdc-45df-be8b-422d051a13b7","fileId","3d03d8d6-aedc-11f1-90d3-1607ee4eb77e","parentId","branchId","4a625aed-4688-444b-9900-cde19c5d3b5f","branchVersion",23,"latest",true,"createdAt",["D",1789241075420],"version",15,"fileType","http","content","import * as cheerio from \"npm:cheerio@1.0.0\";\n\nconst SOURCE_URL = \"https://www.watson.ch\";\nconst OVERVIEW_URL = `${SOURCE_URL}/videos/`;\nconst FEED_IMAGE = `${SOURCE_URL}/_watsui/static/img/icons/icon_180_ch.png`;\nconst USER_AGENT =\n \"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/126.0.0.0 Safari/537.36\";\n\n// Wie viele Videos maximal in den Feed kommen\nconst MAX_ITEMS = 25;\n// Wie viele Videoseiten maximal geprüft werden, bevor nach Datum gekürzt wird\nconst MAX_CANDIDATES = 45;\n// Wie viele Videoseiten gleichzeitig abgerufen werden\nconst CONCURRENCY = 8;\n// JW-Player-Key von watson (Teil der Embed-URL: /players/-.html)\nconst DEFAULT_PLAYER_ID = \"AB26tHLH\";\n\n// Video-URLs von watson sehen so aus: /videos/!53081\nconst VIDEO_PATH_RE = /^\\/videos\\/!([a-z0-9]{4,})\\/?$/i;\n\ninterface VideoItem {\n title: string;\n link: string;\n numericId?: number;\n jwId?: string;\n playerId?: string;\n image?: string;\n pubDate?: Date;\n}\n\nfunction cdata(value: string): string {\n // \"]]>\" innerhalb von CDATA aufbrechen, sonst bricht das XML\n return `/g, \"]]]]>\")}]]>`;\n}\n\nfunction escapeXml(value: string): string {\n return value.replace(/&/g, \"&\").replace(//g, \">\");\n}\n\n/** Baut die Description exakt im Format des bisherigen rss.app-Feeds. */\nfunction buildDescription(item: VideoItem): string {\n if (!item.jwId) {\n return item.image\n ? `

`\n : \"\";\n }\n const playerId = item.playerId || DEFAULT_PLAYER_ID;\n const thumb = item.image ?? `https://cdn.jwplayer.com/thumbs/${item.jwId}-720.jpg`;\n const embed = `https://cdn.jwplayer.com/players/${item.jwId}-${playerId}.html`;\n return `

` +\n `

` +\n `` +\n `

`;\n}\n\n/** Einfacher Concurrency-Pool, damit nicht alle Videoseiten gleichzeitig abgerufen werden. */\nasync function runWithConcurrency(\n items: T[],\n limit: number,\n worker: (item: T) => Promise,\n): Promise {\n const results: R[] = new Array(items.length);\n let index = 0;\n\n async function next(): Promise {\n const current = index++;\n if (current >= items.length) return;\n results[current] = await worker(items[current]);\n return next();\n }\n\n await Promise.all(\n Array.from({ length: Math.min(limit, items.length) }, () => next()),\n );\n return results;\n}\n\n/**\n * Sammelt die Video-Links von der Übersichtsseite /videos/.\n *\n * Wichtig: Das oberste (= neueste) Video steckt auf der Seite nicht in einem\n * , sondern nur im Rohdokument. Deshalb werden zusätzlich zu den\n * Links auch alle /videos/!-Vorkommen aus dem HTML gelesen – sonst fehlt\n * ausgerechnet das aktuellste Video im Feed.\n */\nasync function discoverVideos(): Promise<{ items: VideoItem[]; heroJwId?: string }> {\n const res = await fetch(OVERVIEW_URL, {\n headers: {\n \"User-Agent\": USER_AGENT,\n Accept: \"text/html,application/xhtml+xml\",\n \"Accept-Language\": \"de-CH,de;q=0.9\",\n // Immer die frische Seite holen, nie eine Zwischenkopie\n \"Cache-Control\": \"no-cache\",\n Pragma: \"no-cache\",\n },\n });\n if (!res.ok) throw new Error(`Übersichtsseite nicht erreichbar (${res.status})`);\n\n const html = await res.text();\n const $ = cheerio.load(html);\n const seen = new Set();\n const items: VideoItem[] = [];\n\n // Das Hauptvideo (grosser Player zuoberst) ist das erste JW-Embed im\n // Dokument. Seine ID wird gemerkt, damit dieses Video am Ende garantiert\n // im Feed steht – egal wie die Übersichtsseite sonst sortiert ist.\n const heroJwId = html.match(/jwplayer\\.com\\/players\\/([A-Za-z0-9]{8})-/)?.[1];\n\n function add(pathname: string, title = \"\") {\n const cleanLink = `${SOURCE_URL}${pathname.replace(/\\/$/, \"\")}`;\n if (seen.has(cleanLink)) return;\n seen.add(cleanLink);\n const id = pathname.match(/!([a-z0-9]+)/i)?.[1] ?? \"\";\n items.push({ title, link: cleanLink, numericId: /^\\d+$/.test(id) ? Number(id) : undefined });\n }\n\n // 1) Verlinkte Videos (Kacheln, Listen)\n $(\"a[href]\").each((_, el) => {\n const href = $(el).attr(\"href\");\n if (!href) return;\n let url: URL;\n try {\n url = new URL(href, SOURCE_URL);\n } catch {\n return;\n }\n if (url.hostname.replace(/^www\\./, \"\") !== \"watson.ch\") return;\n if (!VIDEO_PATH_RE.test(url.pathname)) return;\n add(url.pathname, $(el).text().replace(/\\s+/g, \" \").trim());\n });\n\n // 2) Nicht verlinkte Vorkommen im Rohdokument (u.a. das Hero-Video oben)\n for (const match of html.matchAll(/\\/videos\\/!([a-z0-9]{4,})/gi)) {\n add(`/videos/!${match[1]}`);\n }\n\n // Die Übersichtsseite listet über 200 Videos in unzuverlässiger Reihenfolge –\n // das Hero-Video steht sogar zuhinterst. Watsons Video-IDs laufen aber\n // aufsteigend, deshalb wird danach vorsortiert: so landen garantiert die\n // neusten Videos in der Kandidatenliste und nicht irgendwelche alten.\n items.sort((a, b) => (b.numericId ?? -1) - (a.numericId ?? -1));\n\n // Etwas mehr Kandidaten holen, als am Ende ausgegeben werden – nach dem\n // Abruf wird nach echtem Upload-Datum sortiert und auf MAX_ITEMS gekürzt.\n return { items: items.slice(0, MAX_CANDIDATES), heroJwId };\n}\n\n/**\n * Holt Titel, Datum, Vorschaubild und JW-Player-IDs einer Videoseite.\n * Watson liefert pro Video ein schema.org-VideoObject – das ist die\n * zuverlässigste Quelle; die Regex-Fallbacks greifen nur, falls das fehlt.\n */\nasync function enrichVideo(item: VideoItem): Promise {\n const controller = new AbortController();\n const timeout = setTimeout(() => controller.abort(), 8000);\n\n try {\n const res = await fetch(item.link, {\n headers: {\n \"User-Agent\": USER_AGENT,\n Accept: \"text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8\",\n \"Accept-Language\": \"de-CH,de;q=0.9\",\n },\n signal: controller.signal,\n });\n if (!res.ok) return item;\n\n const html = await res.text();\n const $ = cheerio.load(html);\n\n let title = $('meta[property=\"og:title\"]').attr(\"content\")?.trim() || item.title;\n let image = $('meta[property=\"og:image\"]').attr(\"content\")?.trim();\n const link = $('link[rel=\"canonical\"]').attr(\"href\")?.trim() ||\n $('meta[property=\"og:url\"]').attr(\"content\")?.trim() ||\n item.link;\n\n let jwId: string | undefined;\n let playerId: string | undefined;\n let pubDate: Date | undefined;\n\n $('script[type=\"application/ld+json\"]').each((_, el) => {\n if (jwId && pubDate) return;\n try {\n const data = JSON.parse($(el).contents().text());\n const nodes = Array.isArray(data) ? data : [data];\n for (const node of nodes) {\n const graph = Array.isArray(node?.[\"@graph\"]) ? node[\"@graph\"] : [node];\n for (const g of graph) {\n const type = g?.[\"@type\"];\n const isVideo = type === \"VideoObject\" ||\n (Array.isArray(type) && type.includes(\"VideoObject\"));\n if (!isVideo) continue;\n\n if (g.name) title = String(g.name).trim();\n if (g.thumbnailUrl) image = String(g.thumbnailUrl).trim();\n\n const date = g.uploadDate || g.datePublished;\n if (!pubDate && date && !isNaN(new Date(date).getTime())) {\n pubDate = new Date(date);\n }\n\n const embedMatch = String(g.embedUrl ?? \"\").match(\n /jwplayer\\.com\\/players\\/([A-Za-z0-9]{8})-([A-Za-z0-9]{8})/,\n );\n if (embedMatch) {\n jwId = embedMatch[1];\n playerId = embedMatch[2];\n } else {\n const idMatch = `${g.contentUrl ?? \"\"} ${g.thumbnailUrl ?? \"\"}`.match(\n /(?:jwplayer|jwplatform)\\.com\\/(?:thumbs|videos|v2\\/media)\\/([A-Za-z0-9]{8})/,\n );\n if (idMatch && !jwId) jwId = idMatch[1];\n }\n }\n }\n } catch {\n // ungültiges JSON-LD ignorieren\n }\n });\n\n // Fallback: erste Embed-URL direkt aus dem Rohdokument\n if (!jwId) {\n const embedMatch = html.match(\n /jwplayer\\.com\\/players\\/([A-Za-z0-9]{8})-([A-Za-z0-9]{8})/,\n );\n if (embedMatch) {\n jwId = embedMatch[1];\n playerId = embedMatch[2];\n }\n }\n\n // Datum-Fallback über Meta-Tags\n if (!pubDate) {\n const meta = $('meta[property=\"article:published_time\"]').attr(\"content\")?.trim();\n if (meta && !isNaN(new Date(meta).getTime())) pubDate = new Date(meta);\n }\n\n return { ...item, title, link, image, jwId, playerId, pubDate };\n } catch {\n return item;\n } finally {\n clearTimeout(timeout);\n }\n}\n\nexport default async function (req: Request): Promise {\n try {\n const { items: candidates, heroJwId } = await discoverVideos();\n const enriched = (await runWithConcurrency(candidates, CONCURRENCY, enrichVideo))\n .filter((v) => v.title && v.jwId);\n\n // Dasselbe Video kann über zwei URL-Varianten auftauchen – über die\n // JW-Player-ID entdoppeln, damit es nicht zweimal im Feed steht.\n const byJwId = new Map();\n for (const video of enriched) {\n if (!byJwId.has(video.jwId!)) byJwId.set(video.jwId!, video);\n }\n\n const videos = [...byJwId.values()]\n .sort((a, b) => {\n const da = a.pubDate?.getTime();\n const db = b.pubDate?.getTime();\n // Beide mit Datum: neustes zuoberst\n if (da !== undefined && db !== undefined) return db - da;\n // Nur eines mit Datum: das datierte gewinnt\n if (da !== undefined) return -1;\n if (db !== undefined) return 1;\n // Keines mit Datum: höhere Video-ID = neuer\n return (b.numericId ?? -1) - (a.numericId ?? -1);\n })\n .slice(0, MAX_ITEMS);\n\n // Sicherheitsnetz: Das Hauptvideo von der Übersichtsseite muss immer im\n // Feed sein. Falls es durch Sortierung oder Kürzung rausgefallen ist,\n // wird es hier nachgezogen.\n if (heroJwId && !videos.some((v) => v.jwId === heroJwId)) {\n const hero = byJwId.get(heroJwId);\n if (hero) {\n videos.unshift(hero);\n videos.length = Math.min(videos.length, MAX_ITEMS);\n }\n }\n\n const now = new Date();\n const itemsXml = videos.map((video) => {\n const date = video.pubDate ?? now;\n return [\n \" \",\n ` ${cdata(video.title)}`,\n ` ${cdata(buildDescription(video))}`,\n ` ${escapeXml(video.link)}`,\n ` ${escapeXml(video.link)}`,\n \" watson.ch\",\n ` ${date.toUTCString()}`,\n \" \",\n ].join(\"\\n\");\n }).join(\"\\n\");\n\n const xml = `\n\n \n ${cdata(\"Videos\")}\n ${cdata(\"Alle Videos von watson.ch\")}\n ${OVERVIEW_URL}\n \n ${FEED_IMAGE}\n ${cdata(\"Videos\")}\n ${OVERVIEW_URL}\n \n Val.town RSS Scraper (cheerio)\n ${now.toUTCString()}\n \n de\n${itemsXml}\n \n`;\n\n return new Response(xml, {\n status: 200,\n headers: {\n \"Content-Type\": \"application/rss+xml; charset=utf-8\",\n // Kurze Cache-Zeit, damit Reader neue Videos zeitnah sehen\n \"Cache-Control\": \"public, max-age=300\",\n },\n });\n } catch (err) {\n return new Response(\n `Fehler beim Erzeugen des RSS-Feeds: ${\n err instanceof Error ? err.message : String(err)\n }`,\n { status: 500, headers: { \"Content-Type\": \"text/plain; charset=utf-8\" } },\n );\n }\n}\n","deleted",false,"label",[14],"70041be8-5679-4e10-9b21-719279d7d87e",["D",1789239636372],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","RSS-Feed für watson.ch/videos mit JW-Player-Embeds","imageUrl","userId","dbf2ae7a-e596-4450-9e80-f48182352e08","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","01a03d75-a2dc-7129-bcfe-464f7359f782","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_9":10,"_102":98},"org",{"_9":10,"_95":96,"_97":98,"_55":56,"_99":100,"_101":42},"branch",{"_35":85,"_11":86,"_22":28,"_87":45,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":12,"_94":10},"isOwned",31,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Mike Frischknecht","avatar","https://lh3.googleusercontent.com/a/ACg8ocJYhZ6TlQC9Px9BhWVC2KxGG5zXrx2pRqdDuxsgIfio5QgUBBEd=s96-c","tier","free","canRestrictVals","profileImageUrl","ctx",{"_78":-5,"_136":137,"_138":139,"_140":141,"_142":42,"_143":42,"_144":42,"_145":32,"_146":-5,"_147":-7,"_148":-7,"_149":62,"_150":42,"_151":42,"_152":-5,"_153":42,"_154":42,"_155":42,"_156":-5},"ENV",{"_107":108,"_109":110,"_111":86,"_112":113,"_114":115,"_116":117,"_118":119,"_120":121,"_122":123,"_124":125,"_126":127,"_128":129,"_130":131,"_132":133,"_134":135},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","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","orgs",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]