[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_178":179,"_180":181},"routes/_app.x.$handle.$name",{"_98":97,"_32":45,"_106":85,"_27":107,"_13":14,"_108":-5,"_11":109,"_110":111,"_112":113,"_114":115,"_116":117,"_20":-5,"_118":119,"_120":121,"_122":25,"_123":124,"_125":25,"_126":-5,"_127":-5,"_128":129},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":49,"_50":51,"_52":51,"_53":-5,"_54":-5,"_18":55,"_56":-5,"_57":49,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":78,"_79":80,"_81":82,"_83":25},"version",14,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","main.tsx","latestPath","fileId","08fdc1a8-27b7-11f0-aecd-569c3dd06744","name","fileType","email","content","import { encode } from \"https://deno.land/std@0.203.0/encoding/base64.ts\";\nimport { email } from \"https://esm.town/v/std/email\";\nimport { pdfText } from \"jsr:@pdf/pdftext\";\nimport OpenAI from \"https://esm.sh/openai@4.24.1\";\n\n// main controller function\nexport default async function(receivedEmail) {\n const apiKey = Deno.env.get(\"FIREWORKS_API_KEY\");\n const model = \"accounts/fireworks/models/deepseek-r1\";\n\n if (!apiKey) {\n throw new Error(\n \"FIREWORKS_API_KEY environment variable is not set. Please set it or replace this line with your API key.\",\n );\n }\n\n console.log(\"email received:\", receivedEmail.from, receivedEmail.subject);\n console.log(\"Full email object:\", JSON.stringify(receivedEmail, null, 2));\n\n // step 1: process email attachments\n const attachments = await extractAttachments(receivedEmail);\n\n let pdfTexts = [];\n\n if (attachments.length > 0) {\n console.log(\"attachments found:\", attachments.map((a) => a.filename).join(\", \"));\n pdfTexts = await extractPdfText(attachments);\n } else {\n console.log(\"no attachments found in the email.\");\n }\n\n // step 2: set email text as user prompt\n const emailText = receivedEmail.text.trim();\n\n // step 3: create final prompt with email and pdf text (if any)\n const prompt = generatePrompt(receivedEmail, pdfTexts, emailText);\n\n // step 4: send prompt to Fireworks.ai\n const aiResponse = await sendRequestToFireworks(prompt, apiKey, model);\n\n // step 5: parse the AI response\n const { parsedResponse, thinking } = parseAIResponse(aiResponse);\n\n // log the parsed AI response and thinking\n console.log(\"Parsed AI response:\", parsedResponse);\n console.log(\"AI thinking:\", thinking);\n\n // step 6: send the response back via email\n await sendResponseByEmail(receivedEmail, parsedResponse, thinking);\n\n console.log(\"response email sent.\");\n}\n\n// extract attachments (if any)\nasync function extractAttachments(email) {\n if (!email.attachments || email.attachments.length === 0) {\n return [];\n }\n\n const attachments = [];\n for (const file of email.attachments) {\n attachments.push({\n filename: file.name,\n content: encode(await file.arrayBuffer()),\n type: file.type,\n });\n }\n return attachments;\n}\n\nasync function extractPdfText(attachments) {\n const pdfTexts = [];\n\n for (const attachment of attachments) {\n if (attachment.type === \"application/pdf\") {\n console.log(`parsing PDF: ${attachment.filename}`);\n try {\n // decode Base64 content back to a buffer\n const pdfBuffer = Uint8Array.from(atob(attachment.content), (c) => c.charCodeAt(0)).buffer;\n\n // extract text from the PDF\n const pages = await pdfText(pdfBuffer);\n\n // combine all pages into a single string\n const fullText = Object.values(pages).join(\"\\n\");\n\n pdfTexts.push({\n filename: attachment.filename,\n text: fullText,\n });\n } catch (err) {\n console.error(`Error parsing PDF (${attachment.filename}):`, err);\n pdfTexts.push({\n filename: attachment.filename,\n text: \"Error parsing PDF\",\n });\n }\n }\n }\n\n return pdfTexts;\n}\n\n// helper function to generate a prompt for AI\nfunction generatePrompt(email, pdfTexts, emailText) {\n const senderName = email.from.split(\"<\")[0].trim().split(\" \")[0] || \"User\";\n const fullSenderName = email.from.split(\"<\")[0].trim() || \"User\";\n\n let prompt = `You are an AI assistant responding to an email. Respond directly to the email as if you were the recipient, in a natural and conversational manner. Do not mention that you are an AI or offer suggestions unless explicitly asked. Here are the details of the email you're responding to:\n\nFrom: ${fullSenderName}\nSubject: ${email.subject}\nBody: ${emailText}\n\n`;\n\n if (pdfTexts.length > 0) {\n prompt += `The email also includes the following PDF attachments:\n${pdfTexts.map((pdf) => `Filename: ${pdf.filename}\\nContent: ${pdf.text}`).join(\"\\n\\n\")}\n\nPlease consider the content of these PDFs in your response if relevant.\n\n`;\n }\n\n prompt += `Now, write a response to ${senderName} that directly addresses their email. Be concise, friendly, and to the point. If they're asking a question, answer it. If they're sharing information, acknowledge it appropriately. If they're requesting something, address their request. Sign off as \"AI Assistant\".\n\nAdditionally, include your chain of thought in tags after your response. This thinking should explain your reasoning process for the response you provided.`;\n\n return prompt;\n}\n\n// helper function to send a request to Fireworks.ai\nasync function sendRequestToFireworks(prompt, apiKey, model) {\n try {\n const client = new OpenAI({\n baseURL: \"https://api.fireworks.ai/inference/v1\",\n apiKey: apiKey,\n });\n\n const response = await client.chat.completions.create({\n model: model,\n messages: [{ role: \"user\", content: prompt }],\n });\n\n if (!response.choices || response.choices.length === 0 || !response.choices[0].message) {\n throw new Error(\"Unexpected response format from Fireworks.ai\");\n }\n\n const message = response.choices[0].message.content.trim();\n if (!message) {\n if (response.choices[0].finish_reason === \"length\") {\n return \"The response was cut off due to length limitations. Please try a shorter query or breaking your question into smaller parts.\";\n } else {\n throw new Error(\"Empty message from Fireworks.ai\");\n }\n }\n\n return message;\n } catch (error) {\n console.error(\"Fireworks.ai API Error:\", error);\n return `Error: ${error.message}`;\n }\n}\n\n// helper function to parse the AI response\nfunction parseAIResponse(response) {\n const thinkRegex = /([\\s\\S]*?)<\\/think>/;\n const match = response.match(thinkRegex);\n\n let parsedResponse = response;\n let thinking = \"\";\n\n if (match) {\n thinking = match[1].trim();\n parsedResponse = response.replace(thinkRegex, \"\").trim();\n }\n\n return { parsedResponse, thinking };\n}\n\n// helper function to send a response back via email\nasync function sendResponseByEmail(originalEmail, responseContent, thinking) {\n const subject = originalEmail.subject.startsWith(\"Re:\") \n ? originalEmail.subject \n : \"Re: \" + originalEmail.subject;\n\n let dateString = \"Unknown Date\";\n if (originalEmail.date) {\n const date = new Date(originalEmail.date);\n if (!isNaN(date.getTime())) {\n dateString = date.toUTCString();\n } else {\n console.error(\"Invalid date:\", originalEmail.date);\n // Fallback to using the current date\n dateString = new Date().toUTCString();\n }\n } else {\n console.error(\"No date field in the original email\");\n // Fallback to using the current date\n dateString = new Date().toUTCString();\n }\n\n const text = `${responseContent}\n\nAI Assistant's Thought Process:\n${thinking}\n\nOn ${dateString}, ${originalEmail.from} wrote:\n\n${originalEmail.text.split('\\n').map(line => '> ' + line).join('\\n')}`;\n\n await email({\n subject,\n text,\n to: originalEmail.from,\n from: \"sboesen.o1EmailHandler@valtown.email\"\n });\n}","import { encode } from \"https://deno.land/std@0.203.0/encoding/base64.ts\";\nimport { email } from \"https://esm.town/v/std/email\";\nimport { pdfText } from \"jsr:@pdf/pdftext\";\nimport OpenAI from \"https://esm.sh/openai@4.24.1\";\n\n// main controller function\nexport default async function(receivedEmail) {\n const apiKey = Deno.env.get(\"FIREWORKS_API_KEY\");\n const model = \"accounts/fireworks/models/deepseek-r1\";\n\n if (!apiKey) {\n throw new Error(\n \"FIREWORKS_API_KEY environment variable is not set. Please set it or replace this line with your API key.\",\n );\n }\n\n console.log(\"email received:\", receivedEmail.from, receivedEmail.subject);\n console.log(\"Full email object:\", JSON.stringify(receivedEmail, null, 2));\n\n // step 1: process email attachments\n const attachments = await extractAttachments(receivedEmail);\n\n let pdfTexts = [];\n\n if (attachments.length > 0) {\n console.log(\"attachments found:\", attachments.map((a) => a.filename).join(\", \"));\n pdfTexts = await extractPdfText(attachments);\n } else {\n console.log(\"no attachments found in the email.\");\n }\n\n // step 2: set email text as user prompt\n const emailText = receivedEmail.text.trim();\n\n // step 3: create final prompt with email and pdf text (if any)\n const prompt = generatePrompt(receivedEmail, pdfTexts, emailText);\n\n // step 4: send prompt to Fireworks.ai\n const aiResponse = await sendRequestToFireworks(prompt, apiKey, model);\n\n // step 5: parse the AI response\n const { parsedResponse, thinking } = parseAIResponse(aiResponse);\n\n // log the parsed AI response and thinking\n console.log(\"Parsed AI response:\", parsedResponse);\n console.log(\"AI thinking:\", thinking);\n\n // step 6: send the response back via email\n await sendResponseByEmail(receivedEmail, parsedResponse, thinking);\n\n console.log(\"response email sent.\");\n}\n\n// extract attachments (if any)\nasync function extractAttachments(email) {\n if (!email.attachments || email.attachments.length === 0) {\n return [];\n }\n\n const attachments = [];\n for (const file of email.attachments) {\n attachments.push({\n filename: file.name,\n content: encode(await file.arrayBuffer()),\n type: file.type,\n });\n }\n return attachments;\n}\n\nasync function extractPdfText(attachments) {\n const pdfTexts = [];\n\n for (const attachment of attachments) {\n if (attachment.type === \"application/pdf\") {\n console.log(`parsing PDF: ${attachment.filename}`);\n try {\n // decode Base64 content back to a buffer\n const pdfBuffer = Uint8Array.from(atob(attachment.content), (c) => c.charCodeAt(0)).buffer;\n\n // extract text from the PDF\n const pages = await pdfText(pdfBuffer);\n\n // combine all pages into a single string\n const fullText = Object.values(pages).join(\"\\n\");\n\n pdfTexts.push({\n filename: attachment.filename,\n text: fullText,\n });\n } catch (err) {\n console.error(`Error parsing PDF (${attachment.filename}):`, err);\n pdfTexts.push({\n filename: attachment.filename,\n text: \"Error parsing PDF\",\n });\n }\n }\n }\n\n return pdfTexts;\n}\n\n// helper function to generate a prompt for AI\nfunction generatePrompt(email, pdfTexts, emailText) {\n const senderName = email.from.split(\"<\")[0].trim().split(\" \")[0] || \"User\";\n const fullSenderName = email.from.split(\"<\")[0].trim() || \"User\";\n\n let prompt = `You are an AI assistant responding to an email. Respond directly to the email as if you were the recipient, in a natural and conversational manner. Do not mention that you are an AI or offer suggestions unless explicitly asked. Here are the details of the email you're responding to:\n\nFrom: ${fullSenderName}\nSubject: ${email.subject}\nBody: ${emailText}\n\n`;\n\n if (pdfTexts.length > 0) {\n prompt += `The email also includes the following PDF attachments:\n${pdfTexts.map((pdf) => `Filename: ${pdf.filename}\\nContent: ${pdf.text}`).join(\"\\n\\n\")}\n\nPlease consider the content of these PDFs in your response if relevant.\n\n`;\n }\n\n prompt += `Now, write a response to ${senderName} that directly addresses their email. Be concise, friendly, and to the point. If they're asking a question, answer it. If they're sharing information, acknowledge it appropriately. If they're requesting something, address their request. Sign off as \"AI Assistant\".\n\nAdditionally, include your chain of thought in tags after your response. This thinking should explain your reasoning process for the response you provided.`;\n\n return prompt;\n}\n\n// helper function to send a request to Fireworks.ai\nasync function sendRequestToFireworks(prompt, apiKey, model) {\n try {\n const client = new OpenAI({\n baseURL: \"https://api.fireworks.ai/inference/v1\",\n apiKey: apiKey,\n });\n\n const response = await client.chat.completions.create({\n model: model,\n messages: [{ role: \"user\", content: prompt }],\n });\n\n if (!response.choices || response.choices.length === 0 || !response.choices[0].message) {\n throw new Error(\"Unexpected response format from Fireworks.ai\");\n }\n\n const message = response.choices[0].message.content.trim();\n if (!message) {\n if (response.choices[0].finish_reason === \"length\") {\n return \"The response was cut off due to length limitations. Please try a shorter query or breaking your question into smaller parts.\";\n } else {\n throw new Error(\"Empty message from Fireworks.ai\");\n }\n }\n\n return message;\n } catch (error) {\n console.error(\"Fireworks.ai API Error:\", error);\n return `Error: ${error.message}`;\n }\n}\n\n// helper function to parse the AI response\nfunction parseAIResponse(response) {\n let parsedResponse = response;\n let thinking = \"\";\n\n const startTag = \"\";\n const endTag = \"\";\n const startIndex = parsedResponse.indexOf(startTag);\n const endIndex = parsedResponse.lastIndexOf(endTag);\n\n if (startIndex !== -1 && endIndex !== -1 && startIndex < endIndex) {\n thinking = parsedResponse.slice(startIndex + startTag.length, endIndex).trim();\n parsedResponse = parsedResponse.slice(0, startIndex).trim() + parsedResponse.slice(endIndex + endTag.length).trim();\n }\n\n return { parsedResponse, thinking };\n}\n\n// helper function to send a response back via email\nasync function sendResponseByEmail(originalEmail, responseContent, thinking) {\n const subject = originalEmail.subject.startsWith(\"Re:\") \n ? originalEmail.subject \n : \"Re: \" + originalEmail.subject;\n\n let dateString = \"Unknown Date\";\n if (originalEmail.date) {\n const date = new Date(originalEmail.date);\n if (!isNaN(date.getTime())) {\n dateString = date.toUTCString();\n } else {\n console.error(\"Invalid date:\", originalEmail.date);\n // Fallback to using the current date\n dateString = new Date().toUTCString();\n }\n } else {\n console.error(\"No date field in the original email\");\n // Fallback to using the current date\n dateString = new Date().toUTCString();\n }\n\n const text = `${responseContent}\n\nAI Assistant's Thought Process:\n${thinking}\n\nOn ${dateString}, ${originalEmail.from} wrote:\n\n${originalEmail.text.split('\\n').map(line => '> ' + line).join('\\n')}`;\n\n await email({\n subject,\n text,\n to: originalEmail.from,\n from: \"sboesen.o1EmailHandler@valtown.email\"\n });\n}","createdAt",["D",1737921074165],"branchVersion","branchId","08fb40e0-27b7-11f0-aecd-569c3dd06744","id","08faff04-27b7-11f0-aecd-569c3dd06744","r1",["D",1746232753163],"deletedAt","legacyEnvVars",true,"privacy","public","httpPrivacy","description","imageUrl","f2d631e7-e954-4843-874b-251b06e7fbef","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","ced6245d-1739-4c9a-b8cf-52da8da20144","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_98":97,"_105":101},"org",{"_98":97,"_99":-5,"_100":101,"_18":55,"_102":103,"_104":25},"branch",{"_13":84,"_32":85,"_43":42,"_86":44,"_87":88,"_89":61,"_90":51,"_91":92,"_93":94,"_95":45,"_96":97},"isOwned",20,"main","projectId","forkedBranchId","59a60f80-2798-11f0-9d52-569c3dd06744","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","59a5cc5a-2798-11f0-9d52-569c3dd06744","forkedProjectOrgId","b85ade96-e891-41d6-b890-6750e0387541","projectName","userHandle","sboesen","handle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18ybGlSNXN1T2dMbDRLVFRzdmJWZWd2cjB1aDkifQ","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":174,"_47":-5,"_48":49,"_50":51,"_52":51,"_53":-5,"_54":-5,"_18":55,"_56":-5,"_57":49,"_58":-5,"_59":-5,"_60":61,"_62":63,"_64":-5,"_65":-5,"_66":-5,"_67":-5,"_68":69,"_70":69,"_71":72,"_73":72,"_74":72,"_75":69,"_76":69,"_77":175,"_79":176,"_81":177,"_83":25},"tree",[165,166],"files",[165,166],"counts",{"_155":61,"_156":151,"_157":61,"_158":159,"_160":161},"contents",[139,140],"upstreamProject",{"_43":92,"_32":136,"_53":-5,"_54":-5,"_50":51,"_77":137},"upstreamBranch",{"_43":88,"_38":130,"_131":132,"_32":85,"_86":92,"_13":133,"_87":-5,"_89":-5,"_134":-5,"_47":-5,"_83":25,"_50":51,"_96":135,"_62":94,"_95":136},"emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},["D",1746219574101],"updatedAt",["D",1737125038297],6,"lockfileKey","simplescraper","aiEmailAssistant",{"_98":135,"_105":138},"https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvdXBsb2FkZWQvaW1nXzJqOTcyNjk3VGUyUjFJa2R0R0o5WWxnR2RoYiJ9",{"_43":148,"_32":149,"_30":150,"_142":-5,"_41":42,"_40":151,"_143":49,"_38":152,"_13":61,"_33":20,"_35":153,"_24":25,"_146":-5,"_27":154},{"_43":141,"_32":28,"_30":31,"_142":-5,"_41":42,"_40":14,"_143":25,"_38":144,"_13":145,"_33":34,"_35":37,"_24":25,"_146":-5,"_27":147},"09448c50-27b7-11f0-aecd-569c3dd06744","parentId","latest",["D",1737921074165],13,"label",[28],"08fdcb58-27b7-11f0-aecd-569c3dd06744","README.md","08fdcbe4-27b7-11f0-aecd-569c3dd06744",1,["D",1737132839735],"# R1 Email AI Assistant\n\nChat with R1 (with PDF attachment support)\n\n## What It Does\n\nThis script allows you to:\n- Send emails to R1. The text will be treated as the prompt\n- Parse PDF attachments and include their contents in the AI's analysis.\n- Get response directly to your inbox. Thinking response is included below the reply.\n\n## Setup guide\n\n1. Copy this Val and save it as an Email Val (choose Val type in top-right corner of editor)\n\n2. Add your Fireworks (or openai API compatible) API key to line 8 (or use an environment variable: https://docs.val.town/reference/environment-variables/)\n\n3. Copy the email address of the Val (click 3 dots in top-right > Copy > Copy email address)\n\n4. Write your email, include any attachments, and send it to the Val email address. The AI will respond after a few seconds.\n\n\n",[149],"pulls","branches","forks","envVars",{"_162":61,"_164":61},"connections",{"_162":61,"_163":61},"count","unfilledCount","emptyCount",{"_43":148,"_32":149,"_30":150,"_142":-5,"_41":42,"_40":151,"_143":49,"_38":171,"_13":61,"_33":20,"_35":153,"_24":25,"_146":-5,"_168":172,"_27":173},{"_43":141,"_32":28,"_30":31,"_142":-5,"_41":42,"_40":14,"_143":25,"_38":167,"_13":145,"_33":34,"_35":37,"_24":25,"_146":-5,"_168":169,"_27":170},["D",1737921074165],"children",[],[28],["D",1737132839735],[],[149],["D",1746232753163],{"_98":97,"_105":101},{"_98":97,"_99":-5,"_100":101,"_18":55,"_102":103,"_104":25},{"_13":84,"_32":85,"_43":42,"_86":44,"_87":88,"_89":61,"_90":51,"_91":92,"_93":94,"_95":45,"_96":97},"ctx",{"_77":-5,"_127":211,"_212":213,"_214":215,"_216":25,"_217":25,"_218":25,"_219":49,"_220":-5,"_221":-7,"_222":-7,"_223":61,"_224":25,"_225":25,"_226":-5,"_227":25,"_228":25,"_229":25,"_230":-5},"ENV",{"_182":183,"_184":185,"_186":85,"_187":188,"_189":190,"_191":192,"_193":194,"_195":196,"_197":198,"_199":200,"_201":202,"_203":204,"_205":206,"_207":208,"_209":210},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","811aa22498c9b0b5a47e8d778de579cdb990f332","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 · v14