Feat/twilio integration

.env.example

@@ -19,3 +19,7 @@ RAZORPAY_SECRET=""
 RAZORPAY_WEBHOOK_SECRET=""
 
 UPLOADTHING_TOKEN=""
+
+TWILIO_ACCOUNT_SID=""
+TWILIO_AUTH_TOKEN=""
+TWILIO_WHATSAPP_NUMBER=""

package.json

@@ -63,6 +63,7 @@
     "node-html-to-image": "^5.0.0",
     "nodemailer": "^6.9.16",
     "razorpay": "^2.9.5",
+    "twilio": "^5.4.0",
     "uploadthing": "^7.3.0",
     "uuid": "^11.0.3",
     "zod": "^3.23.8"

src/env.ts

@@ -34,6 +34,9 @@ export const env = createEnv({
     RAZORPAY_SECRET: z.string(),
     RAZORPAY_WEBHOOK_SECRET: z.string(),
     UPLOADTHING_TOKEN: z.string(),
+    TWILIO_ACCOUNT_SID: z.string(),
+    TWILIO_AUTH_TOKEN: z.string(),
+    TWILIO_WHATSAPP_NUMBER: z.string(),
   },
 
   /**
@@ -73,6 +76,9 @@ export const env = createEnv({
     RAZORPAY_SECRET: process.env.RAZORPAY_SECRET,
     RAZORPAY_WEBHOOK_SECRET: process.env.RAZORPAY_WEBHOOK_SECRET,
     UPLOADTHING_TOKEN: process.env.UPLOADTHING_TOKEN,
+    TWILIO_ACCOUNT_SID: process.env.TWILIO_ACCOUNT_SID,
+    TWILIO_AUTH_TOKEN: process.env.TWILIO_AUTH_TOKEN,
+    TWILIO_WHATSAPP_NUMBER: process.env.TWILIO_WHATSAPP_NUMBER,
   },
   /**
    * Run `build` or `dev` with `SKIP_ENV_VALIDATION` to skip env validation. This is especially

src/graphql/models/Twilio/mutation.ts

@@ -0,0 +1,128 @@
+import { builder } from "~/graphql/builder";
+import { sendWhatsAppMessage } from "~/services/twilio.service";
+
+builder.mutationField("sendEventRegistrationReminder", (t) =>
+  t.field({
+    type: "Boolean",
+    args: {
+      eventId: t.arg.id({ required: true }),
+    },
+    resolve: async (root, args, ctx) => {
+      try {
+        const user = await ctx.user;
+        if (!user) {
+          throw new Error("Not authenticated");
+        }
+        if (user.role !== "ORGANIZER") {
+          throw new Error("Not authorized to send WhatsApp notifications");
+        }
+
+        const event = await ctx.prisma.event.findUnique({
+          where: { id: Number(args.eventId) },
+          include: {
+            Teams: {
+              include: {
+                TeamMembers: {
+                  include: {
+                    User: true,
+                  },
+                },
+              },
+            },
+          },
+        });
+
+        if (!event) {
+          throw new Error("Event not found");
+        }
+
+        for (const team of event.Teams) {
+          for (const member of team.TeamMembers) {
+            const contentVariables = JSON.stringify({
+              "1": member.User.name,
+              "2": event.name,
+            });
+            await sendWhatsAppMessage(
+              member.User.phoneNumber!,
+              "HX154ff0082b3bd18082e22c5301927562",
+              contentVariables,
+            );
+          }
+        }
+        return true;
+      } catch (error) {
+        console.error(
+          "Error in sendEventRegistrationReminder mutation:",
+          error,
+        );
+        throw new Error(`Unexpected error: ${(error as Error).message}`);
+      }
+    },
+  }),
+);
+
+builder.mutationField("sendWinnerWhatsAppNotification", (t) =>
+  t.field({
+    type: "Boolean",
+    args: {
+      eventId: t.arg.id({ required: true }),
+    },
+    resolve: async (root, args, ctx) => {
+      try {
+        const user = await ctx.user;
+        if (!user) {
+          throw new Error("Not authenticated");
+        }
+        if (user.role !== "ORGANIZER") {
+          throw new Error("Not authorized to send WhatsApp notifications");
+        }
+
+        const event = await ctx.prisma.event.findUnique({
+          where: { id: Number(args.eventId) },
+          include: {
+            Winner: {
+              include: {
+                Team: {
+                  include: {
+                    TeamMembers: {
+                      include: {
+                        User: true,
+                      },
+                    },
+                  },
+                },
+              },
+            },
+          },
+        });
+
+        if (!event) {
+          throw new Error("Event not found");
+        }
+
+        for (const winner of event.Winner) {
+          for (const member of winner.Team.TeamMembers) {
+            const contentVariables = JSON.stringify({
+              "1": member.User.name,
+              "2": winner.Team.name,
+              "3": winner.type,
+              "4": event.name,
+            });
+            await sendWhatsAppMessage(
+              member.User.phoneNumber!,
+              "HX902d67cec04bbd3d3f9f0eb0c64a752a",
+              contentVariables,
+            );
+          }
+        }
+        return true;
+      } catch (error) {
+        console.error(
+          "Error in sendWinnerWhatsAppNotification mutation:",
+          error,
+        );
+        throw new Error(`Unexpected error: ${(error as Error).message}`);
+      }
+    },
+  }),
+);

src/graphql/models/index.ts

@@ -24,3 +24,4 @@ import "~/graphql/models/User";
 import "~/graphql/models/UserInHotel";
 import "~/graphql/models/Winner";
 import "~/graphql/models/XP";
+import "~/graphql/models/Twilio/mutation";

src/services/twilio.service.ts

@@ -0,0 +1,23 @@
+import Twilio from "twilio";
+import { env } from "~/env";
+
+const client = Twilio(env.TWILIO_ACCOUNT_SID, env.TWILIO_AUTH_TOKEN);
+
+export const sendWhatsAppMessage = async (
+  to: string,
+  contentSid: string,
+  contentVariables: string,
+) => {
+  try {
+    const message = await client.messages.create({
+      from: env.TWILIO_WHATSAPP_NUMBER,
+      contentSid,
+      contentVariables,
+      to: `whatsapp:${to}`,
+    });
+    return message;
+  } catch (error) {
+    console.error("Error sending WhatsApp message:", error);
+    throw new Error("Failed to send WhatsApp message");
+  }
+};