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","label",[99],"permalink","https://www.val.town/x/cephalization/smsjournalertextrelay/code/main.tsx","extension","actionData","errors"]