testing comment replies

atharva20-coder · atharva20-coder · commit 617efda7e037 · 2025-02-24T01:18:12.000+05:30
diff --git a/src/app/(protected)/api/webhook/instagram/route.ts b/src/app/(protected)/api/webhook/instagram/route.ts
@@ -183,6 +183,15 @@ export async function POST(req: NextRequest) {
                 automation.User?.integrations[0].token!
               );
 
+              if (automation.listener.commentReply) {
+                await sendPrivateMessage(
+                  webhook_payload.entry[0].id,
+                  webhook_payload.entry[0].changes[0].value.id,
+                  automation.listener.commentReply,
+                  automation.User?.integrations[0].token!
+                );
+              }
+
               console.log("DM SENT", direct_message.data);
               if (direct_message.status === 200) {
                 const tracked = await trackResponses(automation.id, "COMMENT");
diff --git a/src/lib/fetch.ts b/src/lib/fetch.ts
@@ -60,6 +60,27 @@ export const sendPrivateMessage = async (
   );
 };
 
+export const sendCommentReply = async (
+  userId: string,
+  commentId: string,
+  reply: string,
+  token: string
+) => {
+  console.log("sending comment reply");
+  return await axios.post(
+    `${process.env.INSTAGRAM_BASE_URL}/${userId}/media/${commentId}/replies`,
+    {
+      message: reply,
+    },
+    {
+      headers: {
+        Authorization: `Bearer ${token}`,
+        "Content-Type": "application/json",
+      },
+    }
+  );
+};
+
 export const generateTokens = async (code: string) => {
   try {
     // Validate input
