From b4362b6c2942763cb014880f5019d8ca704ed4b8 Mon Sep 17 00:00:00 2001
From: Manoj K <saimanoj58@gmail.com>
Date: Mon, 28 Jul 2025 20:47:12 +0530
Subject: [PATCH] Fix: user rules for integrations

---
 .../app/services/knowledgeGraph.server.ts       | 17 ++++++++++++++++-
 1 file changed, 16 insertions(+), 1 deletion(-)

diff --git a/apps/webapp/app/services/knowledgeGraph.server.ts b/apps/webapp/app/services/knowledgeGraph.server.ts
index 9cbc9ec..50c1a25 100644
--- a/apps/webapp/app/services/knowledgeGraph.server.ts
+++ b/apps/webapp/app/services/knowledgeGraph.server.ts
@@ -1135,10 +1135,25 @@ export class KnowledgeGraphService {
         return null;
       }
 
+      const integrationAccount = await prisma.integrationAccount.findFirst({
+        where: {
+          integrationDefinition: {
+            slug: source,
+          },
+          workspaceId: user.Workspace.id,
+          isActive: true,
+          deleted: null,
+        },
+      });
+
+      if (!integrationAccount) {
+        return null;
+      }
+
       // Fetch active rules for this source
       const rules = await prisma.ingestionRule.findMany({
         where: {
-          source,
+          source: integrationAccount.id,
           workspaceId: user.Workspace.id,
           isActive: true,
           deleted: null,