Update outbox status on outbound Twilio webhook calls

beverloo · Apr 17, 2024 · 56a653e · 56a653e
1 parent ba5f009
commit 56a653e
Show file tree

Hide file tree

Showing 2 changed files with 23 additions and 3 deletions.
diff --git a/app/admin/system/outbox/TwilioDataTable.tsx b/app/admin/system/outbox/TwilioDataTable.tsx
@@ -112,10 +112,10 @@ export function TwilioDataTable(props: TwilioDataTableProps) {
         {
             field: 'delivered',
             display: 'flex',
-            headerName: 'Accepted',
+            headerName: 'Delivered',
             headerAlign: 'center',
             align: 'center',
-            description: 'Whether the message was accepted by Twilio',
+            description: 'Whether the message was successfully delivered',
             sortable: true,
             width: 100,
 

diff --git a/app/api/webhook/twilio/outbound/route.ts b/app/api/webhook/twilio/outbound/route.ts
@@ -5,6 +5,7 @@ import type { NextRequest } from 'next/server';
 
 import { TwilioWebhookEndpoint } from '@lib/database/Types';
 import { authenticateAndRecordTwilioRequest } from '../authenticateAndRecordTwilioRequest';
+import db, { tOutboxTwilio } from '@lib/database';
 
 /**
  * Webhook invoked when the status of an outbound message has been updated. This may happen minutes,
@@ -14,7 +15,26 @@ export async function POST(request: NextRequest) {
     const { authenticated, body } =
         await authenticateAndRecordTwilioRequest(request, TwilioWebhookEndpoint.Outbound);
 
-    // TODO: Do something with the `body`
+    if (!authenticated || !body) {
+        return new Response(undefined, {
+            status: /* HTTP Forbidden= */ 403,
+        });
+    }
+
+    const from = body.get('From');
+    const messageSid = body.get('MessageSid');
+    const messageStatus = body.get('MessageStatus');
+
+    if (!!from && !!messageSid && !!messageStatus) {
+        const normalisedFrom = from.replace(/.*\:/, '');  // whatsapp:+44... -> +44...
+        await db.update(tOutboxTwilio)
+            .set({
+                outboxSender: normalisedFrom,
+                outboxResultStatus: messageStatus
+            })
+            .where(tOutboxTwilio.outboxResultSid.equals(messageSid))
+            .executeUpdate();
+    }
 
     return new Response(undefined, {
         status: /* HTTP OK= */ 200,