2 files changed, 20 insertions, 10 deletions
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": {