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/routers/feeds.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/routers/feeds.ts')
| -rw-r--r-- | packages/trpc/routers/feeds.ts | 11 |
1 files changed, 8 insertions, 3 deletions
diff --git a/packages/trpc/routers/feeds.ts b/packages/trpc/routers/feeds.ts index 57c88084..8591c98c 100644 --- a/packages/trpc/routers/feeds.ts +++ b/packages/trpc/routers/feeds.ts @@ -57,8 +57,13 @@ export const feedsAppRouter = router({ .input(z.object({ feedId: z.string() })) .mutation(async ({ input, ctx }) => { await Feed.fromId(ctx, input.feedId); - await FeedQueue.enqueue({ - feedId: input.feedId, - }); + await FeedQueue.enqueue( + { + feedId: input.feedId, + }, + { + groupId: ctx.user.id, + }, + ); }), }); |
