[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_166":167,"_168":169},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":-7,"_18":19,"_17":-7,"_125":-5,"_20":126,"_22":127,"_128":129,"_130":131,"_26":132,"_24":133,"_134":-5,"_135":-5,"_136":51,"_137":138,"_139":42,"_140":-5,"_141":-5,"_142":143},"routes/_app.x.$handle.$name.code.$",{"_11":12,"_13":14,"_15":16,"_17":-7,"_18":19,"_20":21,"_22":23,"_24":25,"_26":27,"_28":-5,"_29":-5,"_30":-5,"_31":-5},"handle","cephalization","name","smsjournalertextrelay","branchName","main","version","path","main.tsx","project",{"_32":68,"_13":14,"_43":69,"_70":-5,"_71":42,"_72":73,"_74":73,"_75":-5,"_76":-5,"_77":78,"_79":35,"_80":42,"_81":-5,"_82":-5,"_83":84,"_85":86,"_87":88,"_89":90,"_91":92,"_93":-5,"_94":95,"_96":95,"_97":98,"_99":98,"_100":98,"_101":95,"_102":95,"_103":104,"_105":106,"_107":108,"_109":51},"tree",[54,55],"file",{"_32":33,"_13":19,"_34":35,"_36":-5,"_37":38,"_39":40,"_41":42,"_43":44,"_17":45,"_46":47,"_48":49,"_50":51,"_52":-5,"_18":53},"contents",[],"upstream","pull","ahead","behind","id","ef70fa98-26cb-11f0-9439-569c3dd06744","fileId","edc54136-26cb-11f0-9439-569c3dd06744","parentId","branchId","edc01c38-26cb-11f0-9439-569c3dd06744","branchVersion",57,"latest",true,"createdAt",["D",1725717380138],56,"fileType","http","content","/**\n * This val creates a webhook endpoint that receives text messages and sends SMS replies using the TextBelt API.\n * It uses blob storage to keep track of message history and conversation state.\n * The TextBelt API is used for sending SMS messages without requiring an API key.\n * The conversation history is stored as an array of message objects containing sender, content, date, and phone number.\n * OpenAI's GPT-4 is used to generate contextual responses based on the conversation history.\n */\n\nimport { blob } from \"https://esm.town/v/std/blob\";\nimport { OpenAI } from \"https://esm.town/v/std/openai\";\nimport { Buffer } from \"node:buffer\";\nimport { createHmac, timingSafeEqual } from \"node:crypto\";\n\n// Change this to your own val URL\nconst selfURL = \"https://cephalization-smsjournalertextrelay.web.val.run\";\n// Set these up\n// This is the code that users must enter to register on the registration app\nconst systemRegistrationKey = Deno.env.get(\"smsjournalerregistrationkey\");\n// This is the secret shared with the registration app in order to register users\nconst sharedSecret = Deno.env.get(\"smsjournalersecret\");\n// This is the key for the TextBelt API\nconst textbeltKey = Deno.env.get(\"textbeltkey\");\n\n// Define the structure for a message object\ninterface Message {\n sender: string;\n content: string;\n date: string;\n phone?: string; // Optional phone number field\n}\n\nconst makeBlobKey = (phone: string) => `conversation_${phone}`;\n\n// this is either broken or textbelt is not sending me the right stuff\n// this is implemented per the textbelt docs but i cant verify the sig...\nfunction validateTextbeltRequestSignature(\n apiKey: string,\n timestamp: string,\n requestSignature: string,\n requestPayload: string,\n) {\n const mySignature = createHmac(\"sha256\", apiKey)\n .update(\n timestamp + requestPayload,\n )\n .digest(\"hex\");\n\n return timingSafeEqual(\n Buffer.from(requestSignature),\n Buffer.from(mySignature),\n );\n}\n\n// Helper function to send SMS using TextBelt API\nasync function sendSMS(phone: string, message: string) {\n const response = await fetch(\"https://textbelt.com/text\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n phone,\n message,\n key: textbeltKey,\n // this val url\n replyWebhookUrl: selfURL,\n }),\n });\n return response.json();\n}\n\n// Helper function to get conversation history\nasync function getConversationHistory(phone: string): Promise {\n const key = makeBlobKey(phone);\n const history = await blob.getJSON(key) as Message[] | null;\n return history || [];\n}\n\n// Helper function to update conversation history\nasync function updateConversationHistory(phone: string, message: Message) {\n const key = makeBlobKey(phone);\n const history = await getConversationHistory(phone);\n history.push(message);\n await blob.setJSON(key, history);\n}\n\n// Helper function to generate AI response\nasync function generateAIResponse(history: Message[]): Promise {\n const openai = new OpenAI();\n const messages: { role: \"user\" | \"assistant\" | \"system\"; content: string }[] = history.map(msg => ({\n role: msg.sender === \"User\" ? \"user\" : \"assistant\",\n content: msg.content,\n }));\n\n messages.unshift({\n role: \"system\",\n content:\n \"You are an AI assistant communicating via SMS. Keep your responses concise and under 160 characters. Your task is to help the user organize their daily work activities and provide brief, helpful responses.\",\n });\n\n const completion = await openai.chat.completions.create({\n messages,\n model: \"gpt-4-0613\",\n max_tokens: 100,\n });\n\n return completion.choices[0].message.content.trim();\n}\n\nexport default async function server(request: Request): Promise {\n const quotaResponse = await fetch(\n `https://textbelt.com/quota/${textbeltKey}`,\n )\n .then(res => res.json()).then(data => data.quotaRemaining);\n // Add a simple HTML page to view the source\n const htmlResponse = `\n \n \n \n \n \n SMS Webhook Handler\n \n \n

SMS Webhook Handler

Text Messages Remaining: ${quotaResponse}

This is a webhook endpoint for handling incoming SMS messages and sending AI-generated replies.

View the source code: Source

\n \n \n `;\n\n // Handle GET requests to display the HTML page\n if (request.method === \"GET\") {\n return new Response(htmlResponse, {\n headers: { \"Content-Type\": \"text/html\" },\n });\n }\n\n if (request.method !== \"POST\") {\n return new Response(\"This endpoint only accepts POST requests\", { status: 405 });\n }\n\n if (request.url.endsWith(\"/register\")) {\n // validate bearer auth is the same as the shared secret\n const auth = request.headers.get(\"authorization\");\n if (!auth || auth !== `Bearer ${sharedSecret}`) {\n return new Response(\"Unauthorized\", { status: 401 });\n }\n // register a new phone number by sending an sms to it\n const { phone, registrationKey } = await request.json();\n if (!registrationKey) {\n return new Response(\"Missing required field: registrationKey\", { status: 400 });\n }\n if (!phone) {\n return new Response(\"Missing required field: phone\", { status: 400 });\n }\n // validate the registration key\n if (registrationKey !== systemRegistrationKey) {\n return new Response(\"Invalid registration key\", { status: 401 });\n }\n // check if we have a blob already\n const blobKey = makeBlobKey(phone);\n if (await blob.getJSON(blobKey)) {\n return new Response(\"Phone number already registered\", { status: 400 });\n }\n const smsResult = await sendSMS(\n phone,\n \"Thanks for registering! Let me know what you are working on day to day, and I will keep it organized for you.\",\n );\n return new Response(smsResult.success ? \"SMS sent successfully\" : \"SMS failed to send\");\n }\n\n try {\n const rawBody = await request.text();\n const signature = request.headers.get(\"x-textbelt-signature\");\n const timestamp = request.headers.get(\"x-textbelt-timestamp\");\n\n if (!signature || !timestamp) {\n return new Response(\"Invalid request\", { status: 400 });\n }\n\n const isValid = validateTextbeltRequestSignature(textbeltKey, timestamp, signature, rawBody);\n if (!isValid) {\n return new Response(rawBody + ` timestamp:${timestamp} signature:${signature}`, { status: 401 });\n }\n\n const data = JSON.parse(rawBody);\n const { fromNumber: from, text: message } = data;\n\n if (!from || !message) {\n return new Response(\"Missing required fields: from and message\", { status: 400 });\n }\n\n // Create a new message object\n const userMessage: Message = {\n sender: \"User\",\n content: message,\n date: new Date().toISOString(),\n phone: from,\n };\n\n // Update conversation history\n await updateConversationHistory(from, userMessage);\n\n // Get the entire conversation history\n const history = await getConversationHistory(from);\n\n // Generate AI response\n const aiReply = await generateAIResponse(history);\n\n // Send SMS reply\n const smsResult = await sendSMS(from, aiReply);\n\n if (smsResult.success) {\n // Create a new message object for the AI reply\n const aiMessage: Message = {\n sender: \"AI\",\n content: aiReply,\n date: new Date().toISOString(),\n phone: \"system\",\n };\n\n // Update conversation history with the AI reply\n await updateConversationHistory(from, aiMessage);\n\n return new Response(JSON.stringify({ status: \"success\", message: \"Reply sent successfully\" }), {\n status: 200,\n headers: { \"Content-Type\": \"application/json\" },\n });\n } else {\n return new Response(JSON.stringify({ status: \"error\", message: smsResult.error }), {\n status: 500,\n headers: { \"Content-Type\": \"application/json\" },\n });\n }\n } catch (error) {\n return new Response(JSON.stringify({ status: \"error\", message: \"Internal server error\", error: error.message }), {\n status: 500,\n headers: { \"Content-Type\": \"application/json\" },\n });\n }\n}","deleted",false,"label",[19],{"_32":60,"_13":61,"_34":62,"_36":-5,"_37":38,"_39":63,"_41":42,"_43":64,"_17":65,"_46":24,"_48":-5,"_50":51,"_52":-5,"_57":66,"_18":67},{"_32":33,"_13":19,"_34":35,"_36":-5,"_37":38,"_39":40,"_41":42,"_43":56,"_17":45,"_46":47,"_48":-5,"_50":51,"_52":-5,"_57":58,"_18":59},["D",1725717380138],"children",[],[19],"edc54a32-26cb-11f0-9439-569c3dd06744","README.md","edc54af0-26cb-11f0-9439-569c3dd06744",1,["D",1724426160053],0,[],[61],"edbf735a-26cb-11f0-9439-569c3dd06744",["D",1746131775742],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","userId","0e9a6c58-1319-49d2-9191-de080babba05","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",2,"orgId","84cc2160-bbd8-4074-8f66-91c66cb703c5","tursoName","edbf735a26cb11f09439569c3dd06744","tursoHostname","edbf735a26cb11f09439569c3dd06744-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1790904666556],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_11":12,"_124":120},"org",{"_11":12,"_118":-5,"_119":120,"_77":78,"_121":122,"_123":51},"branch",{"_17":40,"_13":16,"_32":38,"_110":68,"_111":-5,"_112":-5,"_113":-5,"_114":-5,"_115":-5,"_116":14,"_117":12},"isOwned","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18yZ0JrNE1JdGVXYU83TERmNjhueURmNHR5M2QifQ","tier","free","canRestrictVals","profileImageUrl","adoptOrgId",{"_32":68,"_13":14,"_43":161,"_70":-5,"_71":42,"_72":73,"_74":73,"_75":-5,"_76":-5,"_77":78,"_79":35,"_80":42,"_81":-5,"_82":-5,"_83":84,"_85":86,"_87":88,"_89":90,"_91":162,"_93":-5,"_94":95,"_96":95,"_97":98,"_99":98,"_100":98,"_101":95,"_102":95,"_103":163,"_105":164,"_107":165,"_109":51},[155,156],"files",[155,156],"counts",{"_145":65,"_146":65,"_147":65,"_148":149,"_150":151},[],{"_32":33,"_13":19,"_34":35,"_36":-5,"_37":38,"_39":40,"_41":42,"_43":44,"_17":45,"_46":47,"_48":49,"_50":51,"_52":-5,"_18":144},"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},[19],"pulls","branches","forks","envVars",{"_152":65,"_154":65},"connections",{"_152":65,"_153":65},"count","unfilledCount","emptyCount",{"_32":60,"_13":61,"_34":62,"_36":-5,"_37":38,"_39":63,"_41":42,"_43":64,"_17":65,"_46":24,"_48":-5,"_50":51,"_52":-5,"_57":159,"_18":160},{"_32":33,"_13":19,"_34":35,"_36":-5,"_37":38,"_39":40,"_41":42,"_43":56,"_17":45,"_46":47,"_48":-5,"_50":51,"_52":-5,"_57":157,"_18":158},[],[19],[],[61],["D",1746131775742],["D",1790904666556],{"_11":12,"_124":120},{"_11":12,"_118":-5,"_119":120,"_77":78,"_121":122,"_123":51},{"_17":40,"_13":16,"_32":38,"_110":68,"_111":-5,"_112":-5,"_113":-5,"_114":-5,"_115":-5,"_116":14,"_117":12},"ctx",{"_103":-5,"_199":200,"_141":201,"_202":203,"_204":205,"_206":51,"_207":51,"_208":51,"_209":42,"_210":-5,"_211":-7,"_212":-7,"_213":65,"_214":51,"_215":51,"_216":-5},"ENV",{"_170":171,"_172":173,"_174":16,"_175":176,"_177":178,"_179":180,"_181":182,"_183":184,"_185":186,"_187":188,"_189":190,"_191":192,"_193":194,"_195":196,"_197":198},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","71e81aef79ce72fa91852412b991c30c889a63aa","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","aiChatModels",[217,218,219,220,221],[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","navCollapsed","currentOrgId",{"_222":246,"_52":247,"_225":248,"_75":249,"_228":42,"_229":42,"_230":231,"_232":42},{"_222":241,"_52":242,"_225":243,"_75":244,"_228":42,"_229":51,"_230":245,"_232":51},{"_222":237,"_52":238,"_225":239,"_75":240,"_228":42,"_229":42,"_230":231,"_232":51},{"_222":233,"_52":234,"_225":235,"_75":236,"_228":42,"_229":42,"_230":231,"_232":51},{"_222":223,"_52":224,"_225":226,"_75":227,"_228":42,"_229":42,"_230":231,"_232":51},"value","fable","Claude Fable 5.1","shortLabel","Fable","Most capable; 2× Opus pricing","imageInput","thinking","contextWindowSize",1000000,"isDefault","opus55","Claude Opus 5.5","Opus","Highly capable for complex work","sonnet55","Claude Sonnet 5.5","Sonnet","Balanced speed and capability","haiku","Claude Haiku 4.5","Haiku","Fastest; best for simple edits",200000,"deepseekflash","DeepSeek V4.1 Flash","DeepSeek Flash","Smart and very cheap"]