[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_222":223,"_224":225},"routes/_app.x.$handle.$name",{"_99":98,"_31":44,"_107":89,"_26":52,"_13":14,"_108":-5,"_11":109,"_110":111,"_112":113,"_114":115,"_116":117,"_20":-5,"_118":-5,"_119":-5,"_120":24,"_121":122,"_123":24,"_124":-5,"_125":-5,"_126":127},"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":56,"_57":58,"_59":58,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":70,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":82,"_83":84,"_85":86,"_87":24},"version",8,"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/email-handler.ts","latestPath","fileId","4d59791c-bbb1-11f0-93d2-42dde27851f2","name","email-handler.ts","fileType","email","content","/**\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","createdAt",["D",1762503062818],"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",{"_99":98,"_106":102},"org",{"_99":98,"_100":-5,"_101":102,"_18":54,"_103":104,"_105":24},"branch",{"_13":88,"_31":89,"_42":41,"_90":43,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":44,"_97":98},"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=1789588799&sig=935463cc83f35061de6a41257c83cf3c4b95d8450e1530846d6e545d4f30f609","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_42":43,"_31":44,"_37":217,"_46":-5,"_47":24,"_48":49,"_50":49,"_51":52,"_53":-5,"_18":54,"_55":56,"_57":58,"_59":58,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":218,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":219,"_83":220,"_85":221,"_87":24},"tree",[163,165,170],"files",[163,164,165,166,167,168,169,170],"counts",{"_153":62,"_154":150,"_155":62,"_156":157,"_158":159},"contents",[128,129,130],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_42":147,"_31":148,"_29":149,"_134":-5,"_40":41,"_39":150,"_136":58,"_37":151,"_13":62,"_33":138,"_35":-5,"_23":24,"_139":-5,"_26":152},{"_42":141,"_31":142,"_29":143,"_134":-5,"_40":41,"_39":144,"_136":58,"_37":145,"_13":62,"_33":138,"_35":-5,"_23":24,"_139":-5,"_26":146},{"_42":131,"_31":132,"_29":133,"_134":-5,"_40":41,"_39":135,"_136":58,"_37":137,"_13":62,"_33":138,"_35":-5,"_23":24,"_139":-5,"_26":140},"4cdfbf46-bbb1-11f0-bb00-42dde27851f2","shared","4cdfc054-bbb1-11f0-bb00-42dde27851f2","parentId",3,"latest",["D",1762503062158],"directory","label",[132],"4cac544e-bbb1-11f0-8c89-42dde27851f2","backend","4cac555c-bbb1-11f0-8c89-42dde27851f2",2,["D",1762503061835],[142],"4c2ad194-bbb1-11f0-9f10-42dde27851f2",".claude","4c2ad266-bbb1-11f0-9f10-42dde27851f2",1,["D",1762503060988],[148],"pulls","branches","forks","envVars",{"_160":150,"_162":62},"connections",{"_160":62,"_161":62},"count","unfilledCount","emptyCount",{"_42":147,"_31":148,"_29":149,"_134":-5,"_40":41,"_39":150,"_136":58,"_37":214,"_13":62,"_33":138,"_35":-5,"_23":24,"_139":-5,"_172":215,"_26":216},{"_42":206,"_31":207,"_29":208,"_134":149,"_40":41,"_39":209,"_136":58,"_37":210,"_13":62,"_33":20,"_35":211,"_23":24,"_139":-5,"_172":212,"_26":213},{"_42":141,"_31":142,"_29":143,"_134":-5,"_40":41,"_39":144,"_136":58,"_37":203,"_13":62,"_33":138,"_35":-5,"_23":24,"_139":-5,"_172":204,"_26":205},{"_42":198,"_31":189,"_29":182,"_134":143,"_40":41,"_39":199,"_136":58,"_37":200,"_13":62,"_33":138,"_35":-5,"_23":24,"_139":-5,"_172":201,"_26":202},{"_42":190,"_31":191,"_29":192,"_134":182,"_40":41,"_39":193,"_136":24,"_37":194,"_13":62,"_33":185,"_35":195,"_23":24,"_139":-5,"_172":196,"_26":197},{"_42":179,"_31":180,"_29":181,"_134":182,"_40":41,"_39":183,"_136":24,"_37":184,"_13":62,"_33":185,"_35":186,"_23":24,"_139":-5,"_172":187,"_26":188},{"_42":175,"_31":32,"_29":30,"_134":143,"_40":41,"_39":14,"_136":24,"_37":176,"_13":62,"_33":34,"_35":36,"_23":24,"_139":-5,"_172":177,"_26":178},{"_42":131,"_31":132,"_29":133,"_134":-5,"_40":41,"_39":135,"_136":58,"_37":171,"_13":62,"_33":138,"_35":-5,"_23":24,"_139":-5,"_172":173,"_26":174},["D",1762503062158],"children",[],[132],"4d597854-bbb1-11f0-93d2-42dde27851f2",["D",1762503062818],[],[142,32],"4d4ad39e-bbb1-11f0-830f-42dde27851f2","schema.ts","4d4ad5f6-bbb1-11f0-830f-42dde27851f2","4d104986-bbb1-11f0-82a8-42dde27851f2",7,["D",1762503062831],"script","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",[],[142,189,180],"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",[],[142,189,191],"4d1048dc-bbb1-11f0-82a8-42dde27851f2",4,["D",1762503062492],[167,168],[142,189],["D",1762503061835],[166,169],[142],"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",[],[148,207],["D",1762503060988],[164],[148],["D",1762501462497],["D",1789542098478],{"_99":98,"_106":102},{"_99":98,"_100":-5,"_101":102,"_18":54,"_103":104,"_105":24},{"_13":88,"_31":89,"_42":41,"_90":43,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":44,"_97":98},"ctx",{"_81":-5,"_125":255,"_256":257,"_258":259,"_260":24,"_261":24,"_262":24,"_263":58,"_264":-5,"_265":-7,"_266":-7,"_267":62,"_268":24,"_269":24,"_270":-5,"_271":24,"_272":24,"_273":24,"_274":-5},"ENV",{"_226":227,"_228":229,"_230":89,"_231":232,"_233":234,"_235":236,"_237":238,"_239":240,"_241":242,"_243":244,"_245":246,"_247":248,"_249":250,"_251":252,"_253":254},"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 · v8