From 2b420782450898c6a2ddfd7f958e031f66fabd26 Mon Sep 17 00:00:00 2001
From: Manoj K <saimanoj58@gmail.com>
Date: Mon, 28 Jul 2025 08:39:10 +0530
Subject: [PATCH] Fix: activity webhook

---
 .../webapp/app/trigger/utils/message-utils.ts | 19 +++++++++++++++++++
 .../webhooks/integration-webhook-delivery.ts  |  2 +-
 2 files changed, 20 insertions(+), 1 deletion(-)

diff --git a/apps/webapp/app/trigger/utils/message-utils.ts b/apps/webapp/app/trigger/utils/message-utils.ts
index 5ffc559..bffd94d 100644
--- a/apps/webapp/app/trigger/utils/message-utils.ts
+++ b/apps/webapp/app/trigger/utils/message-utils.ts
@@ -1,6 +1,8 @@
 import { PrismaClient } from "@prisma/client";
 import { type Message } from "@core/types";
 import { addToQueue } from "./queue";
+import { triggerWebhookDelivery } from "../webhooks/webhook-delivery";
+import { logger } from "@trigger.dev/sdk";
 
 const prisma = new PrismaClient();
 
@@ -157,6 +159,23 @@ export const createActivities = async ({
         activity.id,
       );
 
+      if (integrationAccount?.workspaceId) {
+        try {
+          await triggerWebhookDelivery(
+            activity.id,
+            integrationAccount?.workspaceId,
+          );
+          logger.log("Webhook delivery triggered for activity", {
+            activityId: activity.id,
+          });
+        } catch (error) {
+          logger.error("Failed to trigger webhook delivery", {
+            activityId: activity.id,
+            error,
+          });
+        }
+      }
+
       return {
         activityId: activity.id,
         queueId: queueResponse.id,
diff --git a/apps/webapp/app/trigger/webhooks/integration-webhook-delivery.ts b/apps/webapp/app/trigger/webhooks/integration-webhook-delivery.ts
index aff4794..db82471 100644
--- a/apps/webapp/app/trigger/webhooks/integration-webhook-delivery.ts
+++ b/apps/webapp/app/trigger/webhooks/integration-webhook-delivery.ts
@@ -76,7 +76,7 @@ export const integrationWebhookTask = task({
           integration: {
             id: integrationAccount.id,
             provider: integrationAccount.integrationDefinition.slug,
-            mcp_endpoint: mcpEndpoint,
+            mcpEndpoint: mcpEndpoint,
             name: integrationAccount.integrationDefinition.name,
             icon: integrationAccount.integrationDefinition.icon,
           },