${escapeXml(episode.title)}

[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_230":231,"_232":233},"routes/_app.x.$handle.$name",{"_98":97,"_31":44,"_106":88,"_26":52,"_13":14,"_107":-5,"_11":108,"_109":110,"_111":112,"_113":114,"_115":116,"_20":-5,"_117":-5,"_118":-5,"_119":24,"_120":121,"_122":24,"_123":-5,"_124":-5,"_125":126},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_42":43,"_31":44,"_37":45,"_46":-5,"_47":24,"_48":49,"_50":49,"_51":52,"_53":-5,"_18":54,"_55":30,"_56":57,"_58":57,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":69,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":81,"_82":83,"_84":85,"_86":24},"version",9,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":-7,"_23":24,"_25":24,"_26":27,"_28":27},"file",{"_29":30,"_31":32,"_33":34,"_35":36,"_37":38,"_39":14,"_40":41,"_23":24},"previous","deleted",false,"deletedHere","path","backend/feed-generator.ts","latestPath","fileId","4d7ba546-bbb1-11f0-93d2-42dde27851f2","name","feed-generator.ts","fileType","script","content","/**\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}\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 \n ${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","createdAt",["D",1762503063198],"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","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",{"_98":97,"_105":101},"org",{"_98":97,"_99":-5,"_100":101,"_18":54,"_102":103,"_104":24},"branch",{"_13":87,"_31":88,"_42":41,"_89":43,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":44,"_96":97},"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=1789592399&sig=c364b970043dd0adc80dd2d6e319fae5e4757b8550a17eba9f3d4068346465b5","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_42":43,"_31":44,"_37":225,"_46":-5,"_47":24,"_48":49,"_50":49,"_51":52,"_53":-5,"_18":54,"_55":30,"_56":57,"_58":57,"_59":-5,"_60":61,"_62":63,"_64":65,"_66":67,"_68":226,"_70":-5,"_71":72,"_73":72,"_74":75,"_76":75,"_77":75,"_78":72,"_79":72,"_80":227,"_82":228,"_84":229,"_86":24},"tree",[162,164,170],"files",[162,163,164,165,166,167,168,169,170],"counts",{"_152":61,"_153":149,"_154":61,"_155":156,"_157":158},"contents",[127,128,129],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_42":146,"_31":147,"_29":148,"_133":-5,"_40":41,"_39":149,"_135":57,"_37":150,"_13":61,"_33":137,"_35":-5,"_23":24,"_138":-5,"_26":151},{"_42":140,"_31":141,"_29":142,"_133":-5,"_40":41,"_39":143,"_135":57,"_37":144,"_13":61,"_33":137,"_35":-5,"_23":24,"_138":-5,"_26":145},{"_42":130,"_31":131,"_29":132,"_133":-5,"_40":41,"_39":134,"_135":57,"_37":136,"_13":61,"_33":137,"_35":-5,"_23":24,"_138":-5,"_26":139},"4cdfbf46-bbb1-11f0-bb00-42dde27851f2","shared","4cdfc054-bbb1-11f0-bb00-42dde27851f2","parentId",3,"latest",["D",1762503062158],"directory","label",[131],"4cac544e-bbb1-11f0-8c89-42dde27851f2","backend","4cac555c-bbb1-11f0-8c89-42dde27851f2",2,["D",1762503061835],[141],"4c2ad194-bbb1-11f0-9f10-42dde27851f2",".claude","4c2ad266-bbb1-11f0-9f10-42dde27851f2",1,["D",1762503060988],[147],"pulls","branches","forks","envVars",{"_159":149,"_161":61},"connections",{"_159":61,"_160":61},"count","unfilledCount","emptyCount",{"_42":146,"_31":147,"_29":148,"_133":-5,"_40":41,"_39":149,"_135":57,"_37":222,"_13":61,"_33":137,"_35":-5,"_23":24,"_138":-5,"_172":223,"_26":224},{"_42":214,"_31":215,"_29":216,"_133":148,"_40":41,"_39":217,"_135":57,"_37":218,"_13":61,"_33":20,"_35":219,"_23":24,"_138":-5,"_172":220,"_26":221},{"_42":140,"_31":141,"_29":142,"_133":-5,"_40":41,"_39":143,"_135":57,"_37":211,"_13":61,"_33":137,"_35":-5,"_23":24,"_138":-5,"_172":212,"_26":213},{"_42":206,"_31":197,"_29":191,"_133":142,"_40":41,"_39":207,"_135":57,"_37":208,"_13":61,"_33":137,"_35":-5,"_23":24,"_138":-5,"_172":209,"_26":210},{"_42":198,"_31":199,"_29":200,"_133":191,"_40":41,"_39":201,"_135":24,"_37":202,"_13":61,"_33":34,"_35":203,"_23":24,"_138":-5,"_172":204,"_26":205},{"_42":188,"_31":189,"_29":190,"_133":191,"_40":41,"_39":192,"_135":24,"_37":193,"_13":61,"_33":34,"_35":194,"_23":24,"_138":-5,"_172":195,"_26":196},{"_42":179,"_31":180,"_29":181,"_133":142,"_40":41,"_39":182,"_135":24,"_37":183,"_13":61,"_33":184,"_35":185,"_23":24,"_138":-5,"_172":186,"_26":187},{"_42":175,"_31":32,"_29":30,"_133":142,"_40":41,"_39":14,"_135":24,"_37":176,"_13":61,"_33":34,"_35":36,"_23":24,"_138":-5,"_172":177,"_26":178},{"_42":130,"_31":131,"_29":132,"_133":-5,"_40":41,"_39":134,"_135":57,"_37":171,"_13":61,"_33":137,"_35":-5,"_23":24,"_138":-5,"_172":173,"_26":174},["D",1762503062158],"children",[],[131],"4d7ba492-bbb1-11f0-93d2-42dde27851f2",["D",1762503063198],[],[141,32],"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",[],[141,180],"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",[],[141,197,189],"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",[],[141,197,199],"4d1048dc-bbb1-11f0-82a8-42dde27851f2",4,["D",1762503062492],[166,167],[141,197],["D",1762503061835],[165,168,169],[141],"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",[],[147,215],["D",1762503060988],[163],[147],["D",1762501462497],["D",1789542098478],{"_98":97,"_105":101},{"_98":97,"_99":-5,"_100":101,"_18":54,"_102":103,"_104":24},{"_13":87,"_31":88,"_42":41,"_89":43,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":44,"_96":97},"ctx",{"_80":-5,"_124":263,"_264":265,"_266":267,"_268":24,"_269":24,"_270":24,"_271":57,"_272":-5,"_273":-7,"_274":-7,"_275":61,"_276":24,"_277":24,"_278":-5,"_279":24,"_280":24,"_281":24,"_282":-5},"ENV",{"_234":235,"_236":237,"_238":88,"_239":240,"_241":242,"_243":244,"_245":246,"_247":248,"_249":250,"_251":252,"_253":254,"_255":256,"_257":258,"_259":260,"_261":262},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","5015b8df46402d8bba4f485ecc37aec202b0e06b","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 · v9