[{"_1":2,"_182":-5,"_183":-5},"loaderData",{"_3":4,"_93":94},"root",{"_5":6,"_36":37,"_66":67},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":-5,"_32":33,"_34":20,"_35":20},"auth",{"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20,"_21":22},"sessionClaims","sessionId","sessionStatus","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","isAuthenticated",false,"tokenType","session_token","user","preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesChatPanelState","notificationCount",0,"flagDenols","isTeamOrgMember","ENV",{"_38":39,"_40":41,"_42":43,"_44":45,"_46":47,"_48":49,"_50":51,"_52":53,"_54":55,"_56":57,"_58":59,"_60":61,"_62":63,"_64":65},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","939580425be10a31a46c456dba7cc90bab2194e6","RENDER_GIT_BRANCH","main","CLERK_PUBLISHABLE_KEY","pk_live_Y2xlcmsudmFsLnRvd24k","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","API_URL","https://api.val.town","clerkState",{"_68":69},"__internal_clerk_state",{"_70":71,"_72":47,"_73":74,"_75":74,"_76":20,"_77":74,"_78":74,"_79":74,"_80":74,"_81":82,"_91":20,"_92":20},"__clerk_ssr_state",{"_21":22,"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__clerk_debug",{"_83":20,"_19":20,"_84":74,"_85":86,"_87":74,"_88":47,"_89":20,"_90":74},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_95":96,"_97":98,"_99":100,"_101":102,"_156":157,"_179":180,"_181":-5},"handle","paulkinlan","name","email-agent","path","lib/attachments.ts","project",{"_103":104,"_97":98,"_105":106,"_107":-5,"_108":20,"_109":110,"_111":-5,"_112":-5,"_12":113,"_114":-5,"_115":20,"_116":-5,"_117":-5,"_118":33,"_14":119,"_120":121,"_122":123,"_124":-5,"_125":126,"_127":126,"_128":129,"_130":129,"_131":129,"_132":126,"_133":126,"_23":134,"_137":138,"_142":143,"_155":20},"id","2229998a-17f4-11f1-9791-42dde27851f2","createdAt",["D",1772647273772],"deletedAt","legacyEnvVars","privacy","public","description","imageUrl","25f41957-737e-448b-bae4-dec9937eed5b","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","f5d3fee2-e1c2-4f2b-b60d-716ec388aac8","tursoName","2229998a17f411f1979142dde27851f2","tursoHostname","2229998a17f411f1979142dde27851f2-val-town.aws-us-east-2.turso.io","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_95":96,"_135":136},"profileImageUrl","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18yWG9oT0R2UTMxam83NXp1d0RRaGJYVTY0aFYifQ","org",{"_95":96,"_139":136,"_12":113,"_140":141},"avatar","tier","pro","branch",{"_144":145,"_97":45,"_103":146,"_147":104,"_148":-5,"_149":-5,"_150":-5,"_151":-5,"_152":-5,"_153":98,"_154":96},"version",55,"222a1edc-17f4-11f1-9791-42dde27851f2","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_103":158,"_97":159,"_160":161,"_162":163,"_164":146,"_165":166,"_167":168,"_105":169,"_144":170,"_171":172,"_173":174,"_175":20,"_176":-5,"_99":177},"e8186e2e-181b-11f1-b9c4-42dde27851f2","attachments.ts","fileId","cf077a02-181a-11f1-81e1-42dde27851f2","parentId","edffb48e-180f-11f1-a610-42dde27851f2","branchId","branchVersion",49,"latest",true,["D",1772664356194],1,"fileType","script","content","/**\n * Attachment handling — inbound (receive & store) and outbound (generate & send).\n *\n * Inbound: email attachments → blob storage + attachments table\n * Outbound: generated files → blob storage + base64 for email\n *\n * Text-based files (txt, csv, json, md, html, xml) have their content\n * available for agent context. Binary files (images, PDFs, zips) are\n * stored but not fed to the agent as text.\n *\n * Blob keys follow the pattern: attachments/{userId}/{entryId}/{filename}\n */\n\nimport { blob } from \"https://esm.town/v/std/blob\";\nimport { addAttachment, getAttachmentsForEntry } from \"../db/queries.ts\";\nimport type { Attachment } from \"../db/queries.ts\";\n\n/** MIME types we consider \"text-readable\" — content can be fed to the agent */\nconst TEXT_MIME_TYPES = new Set([\n \"text/plain\",\n \"text/csv\",\n \"text/html\",\n \"text/xml\",\n \"text/markdown\",\n \"application/json\",\n \"application/xml\",\n \"application/csv\",\n \"text/tab-separated-values\",\n]);\n\n/** File extensions we consider text-readable (fallback when MIME is generic) */\nconst TEXT_EXTENSIONS = new Set([\n \".txt\",\n \".csv\",\n \".json\",\n \".md\",\n \".markdown\",\n \".html\",\n \".htm\",\n \".xml\",\n \".yml\",\n \".yaml\",\n \".toml\",\n \".ini\",\n \".cfg\",\n \".log\",\n \".tsv\",\n \".sql\",\n \".ts\",\n \".js\",\n \".py\",\n \".sh\",\n \".css\",\n]);\n\n/** Max text content to extract and store for agent context (100KB) */\nconst MAX_TEXT_CONTENT_BYTES = 100 * 1024;\n\nfunction isTextFile(filename: string, mimeType: string): boolean {\n if (TEXT_MIME_TYPES.has(mimeType)) return true;\n const ext = filename.toLowerCase().slice(filename.lastIndexOf(\".\"));\n return TEXT_EXTENSIONS.has(ext);\n}\n\nfunction blobKey(userId: number, entryId: number, filename: string): string {\n // Sanitize filename for use in blob key\n const safeName = filename.replace(/[^a-zA-Z0-9._-]/g, \"_\");\n return `attachments/${userId}/${entryId}/${safeName}`;\n}\n\n/**\n * Store an inbound email attachment in blob storage and record it in the DB.\n *\n * Val Town email attachments are File objects with:\n * - file.name: string\n * - file.type: string (MIME type)\n * - file.size: number\n * - file.text(): Promise\n * - file.arrayBuffer(): Promise\n */\nexport async function storeInboundAttachment(\n file: { name: string; type: string; size: number; text: () => Promise; arrayBuffer: () => Promise },\n userId: number,\n entryId: number,\n): Promise<{ attachmentId: number; textContent: string | null }> {\n const filename = file.name || \"unnamed\";\n const mimeType = file.type || \"application/octet-stream\";\n const isText = isTextFile(filename, mimeType);\n const key = blobKey(userId, entryId, filename);\n\n let textContent: string | null = null;\n\n if (isText && file.size <= MAX_TEXT_CONTENT_BYTES) {\n // Store as text in blob, and capture content for agent context\n textContent = await file.text();\n await blob.set(key, textContent);\n } else {\n // Store as binary\n const buffer = await file.arrayBuffer();\n const base64Content = btoa(\n String.fromCharCode(...new Uint8Array(buffer)),\n );\n // Store the base64 in blob (we'll decode when retrieving)\n await blob.set(key, base64Content);\n }\n\n const attachmentId = await addAttachment({\n entryId,\n userId,\n filename,\n mimeType,\n sizeBytes: file.size,\n blobKey: key,\n isText,\n });\n\n console.log(\n `📎 Stored attachment: ${filename} (${mimeType}, ${file.size} bytes, text=${isText})`,\n );\n\n return { attachmentId, textContent };\n}\n\n/**\n * Store an outbound attachment generated by the agent.\n * Returns the blob key and base64 content for email sending.\n */\nexport async function storeOutboundAttachment(opts: {\n filename: string;\n content: string;\n mimeType: string;\n userId: number;\n entryId: number;\n}): Promise<{ attachmentId: number; base64Content: string }> {\n const key = blobKey(opts.userId, opts.entryId, opts.filename);\n const isText = isTextFile(opts.filename, opts.mimeType);\n\n // Store in blob\n await blob.set(key, opts.content);\n\n const sizeBytes = new TextEncoder().encode(opts.content).length;\n\n const attachmentId = await addAttachment({\n entryId: opts.entryId,\n userId: opts.userId,\n filename: opts.filename,\n mimeType: opts.mimeType,\n sizeBytes,\n blobKey: key,\n isText,\n });\n\n // Base64 encode for email attachment\n const base64Content = btoa(opts.content);\n\n console.log(\n `📎 Created outbound attachment: ${opts.filename} (${opts.mimeType}, ${sizeBytes} bytes)`,\n );\n\n return { attachmentId, base64Content };\n}\n\n/**\n * Get the text content of text-based attachments for an entry.\n * Used to feed attachment content to the agent as context.\n */\nexport async function getTextAttachmentContents(\n entryId: number,\n): Promise<{ filename: string; content: string }[]> {\n const attachments = await getAttachmentsForEntry(entryId);\n const textAttachments = attachments.filter((a) => a.is_text);\n\n const results: { filename: string; content: string }[] = [];\n for (const att of textAttachments) {\n try {\n const content = await blob.get(att.blob_key);\n if (content) {\n const text = await content.text();\n results.push({ filename: att.filename, content: text });\n }\n } catch (e) {\n console.warn(`⚠️ Failed to read blob ${att.blob_key}:`, e);\n }\n }\n\n return results;\n}\n\n/**\n * Get attachment metadata for an entry (without downloading content).\n * Useful for listing what's attached.\n */\nexport async function getAttachmentSummaries(\n entryId: number,\n): Promise<{ filename: string; mimeType: string; sizeBytes: number; isText: boolean }[]> {\n const attachments = await getAttachmentsForEntry(entryId);\n return attachments.map((a) => ({\n filename: a.filename,\n mimeType: a.mime_type,\n sizeBytes: a.size_bytes,\n isText: a.is_text,\n }));\n}\n\n/**\n * Get a blob's raw content as base64 (for sending as email attachment).\n */\nexport async function getAttachmentBase64(attachment: Attachment): Promise {\n const content = await blob.get(attachment.blob_key);\n if (!content) throw new Error(`Blob not found: ${attachment.blob_key}`);\n\n if (attachment.is_text) {\n // Text files: encode the text as base64\n const text = await content.text();\n return btoa(text);\n } else {\n // Binary files: already stored as base64\n return await content.text();\n }\n}\n","deleted","label",[178,159],"lib","permalink","https://www.val.town/x/paulkinlan/email-agent/code/lib/attachments.ts","extension","actionData","errors"]