aboutsummaryrefslogtreecommitdiffstats
path: root/packages/trpc/routers/feeds.ts
diff options
context:
space:
mode:
authorMohamed Bassem <me@mbassem.com>2025-11-27 16:02:18 +0000
committerGitHub <noreply@github.com>2025-11-27 16:02:18 +0000
commit6821257def80ffa655b6feb893dd74ca2a13b9f1 (patch)
tree34d02cefca4f9f4b69a07db268f7c1df289aa1fb /packages/trpc/routers/feeds.ts
parent54268759492df88644e4279fdcc600214f922f43 (diff)
downloadkarakeep-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.ts11
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,
+ },
+ );
}),
});