feat: add Telegram notifications for call and assessment events

Author: AidaRezaei24

src/app/api/webhooks/assessment/status/route.ts

@@ -1,5 +1,6 @@
 import { NextRequest, NextResponse } from "next/server";
 import { prisma } from "@/lib/prisma";
+import { sendTelegramNotification } from "@/lib/telegram-api";
 
 export async function POST(req: NextRequest) {
   const formData = await req.formData();
@@ -16,10 +17,35 @@ export async function POST(req: NextRequest) {
 
   if (session.status !== "COMPLETED") {
     if (callStatus === "completed" || callStatus === "no-answer" || callStatus === "busy" || callStatus === "failed") {
+      const updatedStatus = session.status === "IN_PROGRESS" ? "COMPLETED" : "FAILED";
       await prisma.assessmentSession.update({
         where: { id: sessionId },
-        data: { status: session.status === "IN_PROGRESS" ? "COMPLETED" : "FAILED" },
+        data: { status: updatedStatus },
       });
+
+      // Send Telegram notification
+      try {
+        const profile = await prisma.elderlyProfile.findUnique({
+          where: { id: session.elderlyProfileId },
+        });
+        if (profile) {
+          if (updatedStatus === "COMPLETED" && session.overallScore !== null) {
+            const severity = session.severity || "GREEN";
+            const summary = session.summary || "";
+            await sendTelegramNotification(
+              session.elderlyProfileId,
+              `${profile.name}'s assessment: score ${Math.round((session.overallScore ?? 0) * 100)}% (${severity}).\n${summary}`
+            );
+          } else if (updatedStatus === "FAILED") {
+            await sendTelegramNotification(
+              session.elderlyProfileId,
+              `${profile.name}'s assessment call failed.`
+            );
+          }
+        }
+      } catch (err) {
+        console.error("Telegram notification error:", err);
+      }
     }
   }
 

src/app/api/webhooks/twilio/route.ts

@@ -1,5 +1,6 @@
 import { NextRequest, NextResponse } from "next/server";
 import { prisma } from "@/lib/prisma";
+import { sendTelegramNotification } from "@/lib/telegram-api";
 
 export async function POST(req: NextRequest) {
   const formData = await req.formData();
@@ -22,6 +23,7 @@ export async function POST(req: NextRequest) {
     // Only deactivate one-time reminders; recurring ones should keep firing
     const reminder = await prisma.reminder.findUnique({
       where: { id: log.reminderId },
+      include: { elderlyProfile: true, medication: true },
     });
     if (reminder && reminder.recurrence === "NONE") {
       await prisma.reminder.update({
@@ -30,6 +32,20 @@ export async function POST(req: NextRequest) {
       });
     }
 
+    // Send Telegram notification for confirmation
+    if (reminder) {
+      try {
+        const name = reminder.elderlyProfile.name;
+        const task = reminder.medication?.name || reminder.title;
+        await sendTelegramNotification(
+          reminder.elderlyProfileId,
+          `${name} confirmed their ${reminder.scheduledTime} ${task} reminder.`
+        );
+      } catch (err) {
+        console.error("Telegram notification error:", err);
+      }
+    }
+
     return new NextResponse(
       "<Response><Say>Thank you! Your confirmation has been recorded. Take care!</Say></Response>",
       { headers: { "Content-Type": "text/xml" } }

src/app/api/webhooks/twilio/status/route.ts

@@ -1,5 +1,6 @@
 import { NextRequest, NextResponse } from "next/server";
 import { prisma } from "@/lib/prisma";
+import { sendTelegramNotification } from "@/lib/telegram-api";
 
 export async function POST(req: NextRequest) {
   const logId = req.nextUrl.searchParams.get("logId");
@@ -18,6 +19,32 @@ export async function POST(req: NextRequest) {
       where: { id: logId },
       data: { status: newStatus },
     });
+
+    // Send Telegram notification
+    try {
+      const reminder = await prisma.reminder.findUnique({
+        where: { id: log.reminderId },
+        include: { elderlyProfile: true, medication: true },
+      });
+      if (reminder) {
+        const name = reminder.elderlyProfile.name;
+        const task = reminder.medication?.name || reminder.title;
+        const time = reminder.scheduledTime;
+        if (newStatus === "NO_ANSWER") {
+          await sendTelegramNotification(
+            reminder.elderlyProfileId,
+            `${name} didn't answer their ${time} ${task} reminder (attempt ${log.attemptNumber}).`
+          );
+        } else {
+          await sendTelegramNotification(
+            reminder.elderlyProfileId,
+            `${name}'s ${time} ${task} reminder call failed.`
+          );
+        }
+      }
+    } catch (err) {
+      console.error("Telegram notification error:", err);
+    }
   }
 
   return NextResponse.json({ ok: true });