From 6821257def80ffa655b6feb893dd74ca2a13b9f1 Mon Sep 17 00:00:00 2001
From: Mohamed Bassem <me@mbassem.com>
Date: Thu, 27 Nov 2025 16:02:18 +0000
Subject: fix: Propagate group ids in queue calls (#2177)

* fix: Propagate group ids

* fix tests
---
 packages/trpc/lib/__tests__/ruleEngine.test.ts | 15 ++++++++++-----
 packages/trpc/lib/ruleEngine.ts                | 15 ++++++++++-----
 2 files changed, 20 insertions(+), 10 deletions(-)

(limited to 'packages/trpc/lib')

diff --git a/packages/trpc/lib/__tests__/ruleEngine.test.ts b/packages/trpc/lib/__tests__/ruleEngine.test.ts
index a108ede7..ede22ec6 100644
--- a/packages/trpc/lib/__tests__/ruleEngine.test.ts
+++ b/packages/trpc/lib/__tests__/ruleEngine.test.ts
@@ -528,11 +528,16 @@ describe("RuleEngine", () => {
       const action: RuleEngineAction = { type: "downloadFullPageArchive" };
       const result = await engine.executeAction(action);
       expect(result).toBe(`Enqueued full page archive`);
-      expect(LinkCrawlerQueue.enqueue).toHaveBeenCalledWith({
-        bookmarkId: bookmarkId,
-        archiveFullPage: true,
-        runInference: false,
-      });
+      expect(LinkCrawlerQueue.enqueue).toHaveBeenCalledWith(
+        {
+          bookmarkId: bookmarkId,
+          archiveFullPage: true,
+          runInference: false,
+        },
+        {
+          groupId: userId,
+        },
+      );
     });
 
     it("should execute favouriteBookmark action", async () => {
diff --git a/packages/trpc/lib/ruleEngine.ts b/packages/trpc/lib/ruleEngine.ts
index 2d5deae6..c191619b 100644
--- a/packages/trpc/lib/ruleEngine.ts
+++ b/packages/trpc/lib/ruleEngine.ts
@@ -189,11 +189,16 @@ export class RuleEngine {
         return `Removed from list ${action.listId}`;
       }
       case "downloadFullPageArchive": {
-        await LinkCrawlerQueue.enqueue({
-          bookmarkId: this.bookmark.id,
-          archiveFullPage: true,
-          runInference: false,
-        });
+        await LinkCrawlerQueue.enqueue(
+          {
+            bookmarkId: this.bookmark.id,
+            archiveFullPage: true,
+            runInference: false,
+          },
+          {
+            groupId: this.bookmark.userId,
+          },
+        );
         return `Enqueued full page archive`;
       }
       case "favouriteBookmark": {
-- 
cgit v1.2.3-70-g09d2