(?:<!\\[CDATA\\[)?(.*?)(?:\\]\\]>)?<\\/title>/i)?.[1] || \"\";\n const link = itemXml.match(/<link>(.*?)<\\/link>/i)?.[1] || \"\";\n const pubDate = itemXml.match(/<pubDate>(.*?)<\\/pubDate>/i)?.[1] || \"\";\n const guid = itemXml.match(/<guid.*?>(.*?)<\\/guid>/i)?.[1] || \"\";\n\n // Try to get description from either <description> or <content:encoded>\n let description = itemXml.match(\n /<description>(?:<!\\[CDATA\\[)?([\\s\\S]*?)(?:\\]\\]>)?<\\/description>/i,\n )?.[1] || \"\";\n\n const contentEncoded = itemXml.match(\n /<content:encoded>(?:<!\\[CDATA\\[)?([\\s\\S]*?)(?:\\]\\]>)?<\\/content:encoded>/i,\n )?.[1];\n\n if (contentEncoded && contentEncoded.length > description.length) {\n description = contentEncoded;\n }\n\n // Extract enclosure URL (mp3 link)\n const enclosureMatch = itemXml.match(\n /<enclosure\\s+url=[\"']([^\"']+)[\"']/i,\n );\n const enclosureUrl = enclosureMatch?.[1] || \"\";\n\n // Also look for mp3 links in the content\n const mp3Links = description.match(/https?:\\/\\/[^\\s<>\"]+\\.mp3/gi) || [];\n\n items.push({\n title: title.trim(),\n link: link.trim(),\n pubDate: pubDate.trim(),\n guid: guid.trim() || link.trim(), // Use link as GUID fallback\n description: description.trim(),\n enclosureUrl: enclosureUrl.trim(),\n mp3Links,\n });\n }\n\n return items;\n}\n\n/**\n * Main cron function\n */\nexport default async function () {\n console.log(\"Starting RSS poll at\", new Date().toISOString());\n\n try {\n // Initialize database\n await initDatabase();\n\n // Fetch RSS feed\n const response = await fetch(RSS_FEED_URL);\n if (!response.ok) {\n throw new Error(`Failed to fetch RSS feed: ${response.statusText}`);\n }\n\n const xmlText = await response.text();\n const items = parseRSS(xmlText);\n\n console.log(`Found ${items.length} total items in RSS feed`);\n\n let newEpisodesCount = 0;\n\n // Process each item\n for (const item of items) {\n // Check if this is a \"3-track\" post\n const is3Track = item.title.toLowerCase().includes(\"3-track\") ||\n item.description.toLowerCase().includes(\"3-track\");\n\n if (!is3Track) {\n continue;\n }\n\n // Check if already processed\n if (await isRssItemProcessed(item.guid)) {\n console.log(`Already processed: ${item.title}`);\n continue;\n }\n\n // Find the mp3 URL\n let audioUrl = item.enclosureUrl;\n if (!audioUrl && item.mp3Links.length > 0) {\n audioUrl = item.mp3Links[0];\n }\n\n if (!audioUrl) {\n console.warn(`No audio URL found for: ${item.title}`);\n continue;\n }\n\n // Create episode object\n const episode: Episode = {\n source: \"rss\",\n title: item.title,\n audioUrl,\n pubDate: item.pubDate || new Date().toISOString(),\n description: item.description,\n guid: item.guid,\n };\n\n // Add to database\n await addEpisode(episode);\n await markRssItemProcessed(item.guid);\n\n newEpisodesCount++;\n console.log(`Added new episode: ${item.title}`);\n }\n\n console.log(`RSS poll complete. Added ${newEpisodesCount} new episodes.`);\n } catch (error) {\n console.error(\"Error in RSS poller:\", error);\n throw error;\n }\n}\n",[],[144,184],"4d7ba492-bbb1-11f0-93d2-42dde27851f2","feed-generator.ts",9,["D",1762503063198],"/**\n * Podcast Feed Generator - HTTP trigger to serve aggregated RSS feed\n * This val serves a standard podcast RSS feed with all aggregated episodes\n */\n\nimport { initDatabase } from \"./database/schema.ts\";\nimport { getAllEpisodes } from \"./database/queries.ts\";\nimport type { Episode } from \"../shared/types.ts\";\n\n/**\n * Escape XML special characters\n */\nfunction escapeXml(unsafe: string): string {\n return unsafe\n .replace(/&/g, \"&\")\n .replace(/</g, \"<\")\n .replace(/>/g, \">\")\n .replace(/\"/g, \""\")\n .replace(/'/g, \"'\");\n}\n\n/**\n * Convert ISO date to RFC 822 format (required for RSS)\n */\nfunction toRFC822(isoDate: string): string {\n try {\n const date = new Date(isoDate);\n return date.toUTCString();\n } catch {\n return new Date().toUTCString();\n }\n}\n\n/**\n * Generate podcast RSS feed XML\n */\nfunction generateRSSFeed(episodes: Episode[], baseUrl: string): string {\n const now = new Date().toUTCString();\n\n const episodeItems = episodes\n .map(\n (episode) => `\n <item>\n <title>${escapeXml(episode.title)}

[{"_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",{"_97":96,"_31":42,"_105":87,"_26":50,"_13":14,"_106":-5,"_11":107,"_108":109,"_110":111,"_112":113,"_114":115,"_20":-5,"_116":-5,"_117":-5,"_118":24,"_119":120,"_121":24,"_122":-5,"_123":-5,"_124":125},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_40":41,"_31":42,"_35":43,"_44":-5,"_45":24,"_46":47,"_48":47,"_49":50,"_51":-5,"_18":52,"_53":54,"_55":56,"_57":56,"_58":-5,"_59":60,"_61":62,"_63":64,"_65":66,"_67":68,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":80,"_81":82,"_83":84,"_85":24},"version",11,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":-7,"_23":24,"_25":24,"_26":27,"_28":27},"file",{"_29":30,"_31":27,"_32":20,"_33":34,"_35":36,"_37":14,"_38":39,"_23":24},"previous","deleted",false,"deletedHere","path","deno.json","latestPath","fileId","4d8f9b0a-bbb1-11f0-b6b9-42dde27851f2","name","fileType","content","{\n \"$schema\": \"https://raw.githubusercontent.com/denoland/deno/98f62cee78e85bfc47c62ed703777c6bc8794f1c/cli/schemas/config-file.v1.json\",\n \"lock\": false,\n \"compilerOptions\": {\n \"noImplicitAny\": false,\n \"strict\": true,\n \"types\": [\"https://www.val.town/types/valtown.d.ts\"],\n \"lib\": [\n \"dom\",\n \"dom.iterable\",\n \"dom.asynciterable\",\n \"deno.ns\",\n \"deno.unstable\"\n ]\n },\n \"lint\": {\n \"include\": [\"deno:/https/esm.town/**/*\"],\n \"rules\": {\n \"exclude\": [\"no-explicit-any\"]\n }\n },\n \"node_modules_dir\": false,\n \"experimental\": {\n \"unstable-node-globals\": true,\n \"unstable-temporal\": true,\n \"unstable-worker-options\": true,\n \"unstable-sloppy-imports\": true\n }\n}","createdAt",["D",1762503063326],"branchVersion","branchId","9363c592-bbad-11f0-98ad-42dde27851f2","id","93638eb0-bbad-11f0-98ad-42dde27851f2","gator",["D",1762501462497],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","","imageUrl","019a1633-2013-759e-8afb-72b87d8e75e3","pinnedFileId","4d7ba546-bbb1-11f0-93d2-42dde27851f2","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","019a1633-2013-759e-8afb-744404a5f5e3","tursoName","93638eb0bbad11f098ad42dde27851f2","tursoHostname","93638eb0bbad11f098ad42dde27851f2-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789542098478],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_97":96,"_104":100},"org",{"_97":96,"_98":-5,"_99":100,"_18":52,"_101":102,"_103":24},"branch",{"_13":86,"_31":87,"_40":39,"_88":41,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":42,"_95":96},"isOwned",39,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","figleaf","handle","displayName","avatar","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/f5d90c6c-8ea7-493d-4a3e-abb94ff90b00/square512?exp=1789585199&sig=ea87bd817d3d3c06d14e4a15674ac1de646f0bd248fc15ba98402f0a7da89037","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_40":41,"_31":42,"_35":245,"_44":-5,"_45":24,"_46":47,"_48":47,"_49":50,"_51":-5,"_18":52,"_53":54,"_55":56,"_57":56,"_58":-5,"_59":60,"_61":62,"_63":64,"_65":66,"_67":246,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":247,"_81":248,"_83":249,"_85":24},"tree",[165,167,174,175],"files",[165,166,167,168,169,170,171,172,173,174,175],"counts",{"_155":60,"_156":152,"_157":60,"_158":159,"_160":161},"contents",[126,127,128,129],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_40":149,"_31":150,"_29":151,"_131":-5,"_38":39,"_37":152,"_132":56,"_35":153,"_13":60,"_32":141,"_33":-5,"_23":24,"_134":-5,"_26":154},{"_40":143,"_31":144,"_29":145,"_131":-5,"_38":39,"_37":146,"_132":56,"_35":147,"_13":60,"_32":141,"_33":-5,"_23":24,"_134":-5,"_26":148},{"_40":136,"_31":137,"_29":138,"_131":-5,"_38":39,"_37":139,"_132":56,"_35":140,"_13":60,"_32":141,"_33":-5,"_23":24,"_134":-5,"_26":142},{"_40":130,"_31":27,"_29":30,"_131":-5,"_38":39,"_37":14,"_132":56,"_35":133,"_13":60,"_32":20,"_33":34,"_23":24,"_134":-5,"_26":135},"4d8f9a24-bbb1-11f0-b6b9-42dde27851f2","parentId","latest",["D",1762503063326],"label",[27],"4cdfbf46-bbb1-11f0-bb00-42dde27851f2","shared","4cdfc054-bbb1-11f0-bb00-42dde27851f2",3,["D",1762503062158],"directory",[137],"4cac544e-bbb1-11f0-8c89-42dde27851f2","backend","4cac555c-bbb1-11f0-8c89-42dde27851f2",2,["D",1762503061835],[144],"4c2ad194-bbb1-11f0-9f10-42dde27851f2",".claude","4c2ad266-bbb1-11f0-9f10-42dde27851f2",1,["D",1762503060988],[150],"pulls","branches","forks","envVars",{"_162":152,"_164":60},"connections",{"_162":60,"_163":60},"count","unfilledCount","emptyCount",{"_40":149,"_31":150,"_29":151,"_131":-5,"_38":39,"_37":152,"_132":56,"_35":242,"_13":60,"_32":141,"_33":-5,"_23":24,"_134":-5,"_177":243,"_26":244},{"_40":234,"_31":235,"_29":236,"_131":151,"_38":39,"_37":237,"_132":56,"_35":238,"_13":60,"_32":20,"_33":239,"_23":24,"_134":-5,"_177":240,"_26":241},{"_40":143,"_31":144,"_29":145,"_131":-5,"_38":39,"_37":146,"_132":56,"_35":231,"_13":60,"_32":141,"_33":-5,"_23":24,"_134":-5,"_177":232,"_26":233},{"_40":226,"_31":217,"_29":211,"_131":145,"_38":39,"_37":227,"_132":56,"_35":228,"_13":60,"_32":141,"_33":-5,"_23":24,"_134":-5,"_177":229,"_26":230},{"_40":218,"_31":219,"_29":220,"_131":211,"_38":39,"_37":221,"_132":24,"_35":222,"_13":60,"_32":188,"_33":223,"_23":24,"_134":-5,"_177":224,"_26":225},{"_40":208,"_31":209,"_29":210,"_131":211,"_38":39,"_37":212,"_132":24,"_35":213,"_13":60,"_32":188,"_33":214,"_23":24,"_134":-5,"_177":215,"_26":216},{"_40":199,"_31":200,"_29":201,"_131":145,"_38":39,"_37":202,"_132":24,"_35":203,"_13":60,"_32":204,"_33":205,"_23":24,"_134":-5,"_177":206,"_26":207},{"_40":192,"_31":193,"_29":54,"_131":145,"_38":39,"_37":194,"_132":24,"_35":195,"_13":60,"_32":188,"_33":196,"_23":24,"_134":-5,"_177":197,"_26":198},{"_40":183,"_31":184,"_29":185,"_131":145,"_38":39,"_37":186,"_132":24,"_35":187,"_13":60,"_32":188,"_33":189,"_23":24,"_134":-5,"_177":190,"_26":191},{"_40":136,"_31":137,"_29":138,"_131":-5,"_38":39,"_37":139,"_132":56,"_35":180,"_13":60,"_32":141,"_33":-5,"_23":24,"_134":-5,"_177":181,"_26":182},{"_40":130,"_31":27,"_29":30,"_131":-5,"_38":39,"_37":14,"_132":56,"_35":176,"_13":60,"_32":20,"_33":34,"_23":24,"_134":-5,"_177":178,"_26":179},["D",1762503063326],"children",[],[27],["D",1762503062158],[],[137],"4d81f95a-bbb1-11f0-82a8-42dde27851f2","rss-poller.ts","4d81fa54-bbb1-11f0-82a8-42dde27851f2",10,["D",1762503063198],"script","/**\n * RSS Poller - Cron trigger to poll RSS feed daily\n * This val runs on a schedule to check for new \"3-track\" posts\n */\n\nimport { initDatabase } from \"./database/schema.ts\";\nimport {\n addEpisode,\n isRssItemProcessed,\n markRssItemProcessed,\n} from \"./database/queries.ts\";\nimport type { Episode } from \"../shared/types.ts\";\n\nconst RSS_FEED_URL = \"https://nnnnnnnn.co/rss.xml\";\n\n/**\n * Parse RSS XML and extract items\n */\nfunction parseRSS(xmlText: string): any[] {\n const items: any[] = [];\n\n // Simple regex-based RSS parsing\n const itemRegex = /([\\s\\S]*?)<\\/item>/gi;\n const matches = xmlText.matchAll(itemRegex);\n\n for (const match of matches) {\n const itemXml = match[1];\n\n const title = itemXml.match(/(?:<!\\[CDATA\\[)?(.*?)(?:\\]\\]>)?<\\/title>/i)?.[1] || \"\";\n const link = itemXml.match(/<link>(.*?)<\\/link>/i)?.[1] || \"\";\n const pubDate = itemXml.match(/<pubDate>(.*?)<\\/pubDate>/i)?.[1] || \"\";\n const guid = itemXml.match(/<guid.*?>(.*?)<\\/guid>/i)?.[1] || \"\";\n\n // Try to get description from either <description> or <content:encoded>\n let description = itemXml.match(\n /<description>(?:<!\\[CDATA\\[)?([\\s\\S]*?)(?:\\]\\]>)?<\\/description>/i,\n )?.[1] || \"\";\n\n const contentEncoded = itemXml.match(\n /<content:encoded>(?:<!\\[CDATA\\[)?([\\s\\S]*?)(?:\\]\\]>)?<\\/content:encoded>/i,\n )?.[1];\n\n if (contentEncoded && contentEncoded.length > description.length) {\n description = contentEncoded;\n }\n\n // Extract enclosure URL (mp3 link)\n const enclosureMatch = itemXml.match(\n /<enclosure\\s+url=[\"']([^\"']+)[\"']/i,\n );\n const enclosureUrl = enclosureMatch?.[1] || \"\";\n\n // Also look for mp3 links in the content\n const mp3Links = description.match(/https?:\\/\\/[^\\s<>\"]+\\.mp3/gi) || [];\n\n items.push({\n title: title.trim(),\n link: link.trim(),\n pubDate: pubDate.trim(),\n guid: guid.trim() || link.trim(), // Use link as GUID fallback\n description: description.trim(),\n enclosureUrl: enclosureUrl.trim(),\n mp3Links,\n });\n }\n\n return items;\n}\n\n/**\n * Main cron function\n */\nexport default async function () {\n console.log(\"Starting RSS poll at\", new Date().toISOString());\n\n try {\n // Initialize database\n await initDatabase();\n\n // Fetch RSS feed\n const response = await fetch(RSS_FEED_URL);\n if (!response.ok) {\n throw new Error(`Failed to fetch RSS feed: ${response.statusText}`);\n }\n\n const xmlText = await response.text();\n const items = parseRSS(xmlText);\n\n console.log(`Found ${items.length} total items in RSS feed`);\n\n let newEpisodesCount = 0;\n\n // Process each item\n for (const item of items) {\n // Check if this is a \"3-track\" post\n const is3Track = item.title.toLowerCase().includes(\"3-track\") ||\n item.description.toLowerCase().includes(\"3-track\");\n\n if (!is3Track) {\n continue;\n }\n\n // Check if already processed\n if (await isRssItemProcessed(item.guid)) {\n console.log(`Already processed: ${item.title}`);\n continue;\n }\n\n // Find the mp3 URL\n let audioUrl = item.enclosureUrl;\n if (!audioUrl && item.mp3Links.length > 0) {\n audioUrl = item.mp3Links[0];\n }\n\n if (!audioUrl) {\n console.warn(`No audio URL found for: ${item.title}`);\n continue;\n }\n\n // Create episode object\n const episode: Episode = {\n source: \"rss\",\n title: item.title,\n audioUrl,\n pubDate: item.pubDate || new Date().toISOString(),\n description: item.description,\n guid: item.guid,\n };\n\n // Add to database\n await addEpisode(episode);\n await markRssItemProcessed(item.guid);\n\n newEpisodesCount++;\n console.log(`Added new episode: ${item.title}`);\n }\n\n console.log(`RSS poll complete. Added ${newEpisodesCount} new episodes.`);\n } catch (error) {\n console.error(\"Error in RSS poller:\", error);\n throw error;\n }\n}\n",[],[144,184],"4d7ba492-bbb1-11f0-93d2-42dde27851f2","feed-generator.ts",9,["D",1762503063198],"/**\n * Podcast Feed Generator - HTTP trigger to serve aggregated RSS feed\n * This val serves a standard podcast RSS feed with all aggregated episodes\n */\n\nimport { initDatabase } from \"./database/schema.ts\";\nimport { getAllEpisodes } from \"./database/queries.ts\";\nimport type { Episode } from \"../shared/types.ts\";\n\n/**\n * Escape XML special characters\n */\nfunction escapeXml(unsafe: string): string {\n return unsafe\n .replace(/&/g, \"&\")\n .replace(/</g, \"<\")\n .replace(/>/g, \">\")\n .replace(/\"/g, \""\")\n .replace(/'/g, \"'\");\n}\n\n/**\n * Convert ISO date to RFC 822 format (required for RSS)\n */\nfunction toRFC822(isoDate: string): string {\n try {\n const date = new Date(isoDate);\n return date.toUTCString();\n } catch {\n return new Date().toUTCString();\n }\n}\n\n/**\n * Generate podcast RSS feed XML\n */\nfunction generateRSSFeed(episodes: Episode[], baseUrl: string): string {\n const now = new Date().toUTCString();\n\n const episodeItems = episodes\n .map(\n (episode) => `\n <item>\n <title>${escapeXml(episode.title)}\n \n ${escapeXml(episode.audioUrl)}\n ${escapeXml(episode.guid)}\n ${toRFC822(episode.pubDate)}\n \n Podcast Aggregator\n \n `,\n )\n .join(\"\\n\");\n\n return `\n\n \n Aggregated Podcast Feed\n A curated feed of audio content from multiple sources\n ${escapeXml(baseUrl)}\n en-us\n ${now}\n ${now}\n Podcast Aggregator\n A curated feed of audio content from multiple sources including emails and RSS feeds\n \n Podcast Aggregator\n \n no\n \n${episodeItems}\n \n`;\n}\n\n/**\n * Main HTTP handler\n */\nexport default async function (req: Request): Promise {\n try {\n // Initialize database\n await initDatabase();\n\n // Get all episodes\n const episodes = await getAllEpisodes();\n\n // Get base URL from request\n const url = new URL(req.url);\n const baseUrl = `${url.protocol}//${url.host}`;\n\n // Generate RSS feed\n const rssFeed = generateRSSFeed(episodes, baseUrl);\n\n // Return RSS feed with proper content type\n return new Response(rssFeed, {\n headers: {\n \"Content-Type\": \"application/rss+xml; charset=utf-8\",\n \"Cache-Control\": \"public, max-age=300\", // Cache for 5 minutes\n },\n });\n } catch (error) {\n console.error(\"Error generating feed:\", error);\n return new Response(`Error generating feed: ${error.message}`, {\n status: 500,\n headers: { \"Content-Type\": \"text/plain\" },\n });\n }\n}\n",[],[144,193],"4d597854-bbb1-11f0-93d2-42dde27851f2","email-handler.ts","4d59791c-bbb1-11f0-93d2-42dde27851f2",8,["D",1762503062818],"email","/**\n * Email Handler - Email trigger to process incoming emails\n * This val receives emails and extracts audio attachments\n */\n\nimport { initDatabase } from \"./database/schema.ts\";\nimport { addEpisode, episodeExists } from \"./database/queries.ts\";\nimport type { Episode } from \"../shared/types.ts\";\n\ninterface Email {\n from: string;\n to: string;\n subject: string;\n text?: string;\n html?: string;\n attachments?: Array<{\n filename: string;\n contentType: string;\n size: number;\n url: string;\n }>;\n date?: string;\n messageId?: string;\n}\n\n/**\n * Extract text content from email\n */\nfunction getEmailContent(email: Email): string {\n if (email.text) {\n return email.text;\n }\n if (email.html) {\n // Basic HTML to text conversion - strip tags\n return email.html\n .replace(/]*>[\\s\\S]*?<\\/style>/gi, \"\")\n .replace(/]*>[\\s\\S]*?<\\/script>/gi, \"\")\n .replace(/<[^>]+>/g, \" \")\n .replace(/\\s+/g, \" \")\n .trim();\n }\n return \"\";\n}\n\n/**\n * Main email handler function\n */\nexport default async function (email: Email) {\n console.log(\"Received email:\", {\n from: email.from,\n subject: email.subject,\n attachmentCount: email.attachments?.length || 0,\n });\n\n try {\n // Initialize database\n await initDatabase();\n\n // Check if email has audio attachments\n const audioAttachments = email.attachments?.filter(\n (att) =>\n att.contentType.startsWith(\"audio/\") ||\n att.filename.match(/\\.(mp3|m4a|wav|ogg|aac|flac)$/i),\n ) || [];\n\n if (audioAttachments.length === 0) {\n console.log(\"No audio attachments found in email\");\n return;\n }\n\n // Process each audio attachment\n for (const attachment of audioAttachments) {\n // Create a unique GUID for this episode\n const guid = email.messageId\n ? `email:${email.messageId}:${attachment.filename}`\n : `email:${Date.now()}:${attachment.filename}`;\n\n // Check if this episode already exists\n if (await episodeExists(guid)) {\n console.log(`Episode already exists: ${guid}`);\n continue;\n }\n\n // Extract email content for description\n const description = getEmailContent(email);\n\n // Create episode object\n const episode: Episode = {\n source: \"email\",\n title: email.subject || `Audio from ${email.from}`,\n audioUrl: attachment.url,\n pubDate: email.date || new Date().toISOString(),\n description: description || \"No description provided\",\n guid,\n };\n\n // Add to database\n await addEpisode(episode);\n\n console.log(`Added new episode from email: ${episode.title}`);\n }\n\n console.log(\n `Email processing complete. Added ${audioAttachments.length} episodes.`,\n );\n } catch (error) {\n console.error(\"Error processing email:\", error);\n throw error;\n }\n}\n",[],[144,200],"4d4ad39e-bbb1-11f0-830f-42dde27851f2","schema.ts","4d4ad5f6-bbb1-11f0-830f-42dde27851f2","4d104986-bbb1-11f0-82a8-42dde27851f2",7,["D",1762503062831],"import { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\n\nconst EPISODES_TABLE = \"episodes\";\nconst PROCESSED_RSS_TABLE = \"processed_rss_items\";\n\n/**\n * Initialize database tables\n * Run this once on startup or when schema changes\n */\nexport async function initDatabase() {\n // Create episodes table\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${EPISODES_TABLE} (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n source TEXT NOT NULL,\n title TEXT NOT NULL,\n audio_url TEXT NOT NULL,\n pub_date TEXT NOT NULL,\n description TEXT,\n guid TEXT UNIQUE NOT NULL,\n created_at TEXT NOT NULL\n )\n `);\n\n // Create index on guid for faster lookups\n await sqlite.execute(`\n CREATE INDEX IF NOT EXISTS idx_episodes_guid\n ON ${EPISODES_TABLE}(guid)\n `);\n\n // Create index on pub_date for sorting\n await sqlite.execute(`\n CREATE INDEX IF NOT EXISTS idx_episodes_pub_date\n ON ${EPISODES_TABLE}(pub_date DESC)\n `);\n\n // Create processed RSS items table\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${PROCESSED_RSS_TABLE} (\n guid TEXT PRIMARY KEY,\n processed_at TEXT NOT NULL\n )\n `);\n}\n\nexport { EPISODES_TABLE, PROCESSED_RSS_TABLE };\n",[],[144,217,209],"database","4d452548-bbb1-11f0-9e28-42dde27851f2","queries.ts","4d452610-bbb1-11f0-9e28-42dde27851f2",6,["D",1762503062830],"import { sqlite } from \"https://esm.town/v/stevekrouse/sqlite\";\nimport type { Episode, ProcessedRssItem } from \"../../shared/types.ts\";\nimport { EPISODES_TABLE, PROCESSED_RSS_TABLE } from \"./schema.ts\";\n\n/**\n * Add a new episode to the database\n */\nexport async function addEpisode(episode: Episode): Promise {\n const now = new Date().toISOString();\n\n await sqlite.execute(\n `INSERT INTO ${EPISODES_TABLE}\n (source, title, audio_url, pub_date, description, guid, created_at)\n VALUES (?, ?, ?, ?, ?, ?, ?)`,\n [\n episode.source,\n episode.title,\n episode.audioUrl,\n episode.pubDate,\n episode.description,\n episode.guid,\n now,\n ],\n );\n}\n\n/**\n * Get all episodes sorted by publication date (newest first)\n */\nexport async function getAllEpisodes(): Promise {\n const result = await sqlite.execute(\n `SELECT id, source, title, audio_url as audioUrl, pub_date as pubDate,\n description, guid, created_at as createdAt\n FROM ${EPISODES_TABLE}\n ORDER BY pub_date DESC`,\n );\n\n return result.rows as Episode[];\n}\n\n/**\n * Check if an RSS item has already been processed\n */\nexport async function isRssItemProcessed(guid: string): Promise {\n const result = await sqlite.execute(\n `SELECT guid FROM ${PROCESSED_RSS_TABLE} WHERE guid = ?`,\n [guid],\n );\n\n return result.rows.length > 0;\n}\n\n/**\n * Mark an RSS item as processed\n */\nexport async function markRssItemProcessed(guid: string): Promise {\n const now = new Date().toISOString();\n\n await sqlite.execute(\n `INSERT OR IGNORE INTO ${PROCESSED_RSS_TABLE} (guid, processed_at)\n VALUES (?, ?)`,\n [guid, now],\n );\n}\n\n/**\n * Check if an episode with the given GUID exists\n */\nexport async function episodeExists(guid: string): Promise {\n const result = await sqlite.execute(\n `SELECT guid FROM ${EPISODES_TABLE} WHERE guid = ?`,\n [guid],\n );\n\n return result.rows.length > 0;\n}\n",[],[144,217,219],"4d1048dc-bbb1-11f0-82a8-42dde27851f2",4,["D",1762503062492],[169,170],[144,217],["D",1762503061835],[168,171,172,173],[144],"4d41586e-bbb1-11f0-82a8-42dde27851f2","settings.local.json","4d415936-bbb1-11f0-82a8-42dde27851f2",5,["D",1762503062814],"{\n \"permissions\": {\n \"allow\": [\n \"Bash(tree:*)\"\n ],\n \"deny\": [],\n \"ask\": []\n }\n}\n",[],[150,235],["D",1762503060988],[166],[150],["D",1762501462497],["D",1789542098478],{"_97":96,"_104":100},{"_97":96,"_98":-5,"_99":100,"_18":52,"_101":102,"_103":24},{"_13":86,"_31":87,"_40":39,"_88":41,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":42,"_95":96},"ctx",{"_79":-5,"_123":283,"_284":285,"_286":287,"_288":24,"_289":24,"_290":24,"_291":56,"_292":-5,"_293":-7,"_294":-7,"_295":60,"_296":24,"_297":24,"_298":-5,"_299":24,"_300":24,"_301":24,"_302":-5},"ENV",{"_254":255,"_256":257,"_258":87,"_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","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 · v11