diff options
| author | Mohamed Bassem <me@mbassem.com> | 2025-11-27 16:02:18 +0000 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2025-11-27 16:02:18 +0000 |
| commit | 6821257def80ffa655b6feb893dd74ca2a13b9f1 (patch) | |
| tree | 34d02cefca4f9f4b69a07db268f7c1df289aa1fb /packages/trpc/lib/ruleEngine.ts | |
| parent | 54268759492df88644e4279fdcc600214f922f43 (diff) | |
| download | karakeep-6821257def80ffa655b6feb893dd74ca2a13b9f1.tar.zst | |
fix: Propagate group ids in queue calls (#2177)
* fix: Propagate group ids
* fix tests
Diffstat (limited to 'packages/trpc/lib/ruleEngine.ts')
| -rw-r--r-- | packages/trpc/lib/ruleEngine.ts | 15 |
1 files changed, 10 insertions, 5 deletions
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": { |
