From 9d15eef074f9c4d351a1f074c748909e562f5f3e Mon Sep 17 00:00:00 2001
From: Mohamed Bassem <me@mbassem.com>
Date: Sat, 10 Jan 2026 17:01:08 +0000
Subject: fix: depri mass admin actions

---
 packages/trpc/routers/admin.ts | 41 +++++++++++++++++++++++++++++++----------
 1 file changed, 31 insertions(+), 10 deletions(-)

(limited to 'packages/trpc/routers/admin.ts')

diff --git a/packages/trpc/routers/admin.ts b/packages/trpc/routers/admin.ts
index 31ecaedc..44a51cad 100644
--- a/packages/trpc/routers/admin.ts
+++ b/packages/trpc/routers/admin.ts
@@ -217,10 +217,15 @@ export const adminAppRouter = router({
 
       await Promise.all(
         bookmarkIds.map((b) =>
-          LinkCrawlerQueue.enqueue({
-            bookmarkId: b.id,
-            runInference: input.runInference,
-          }),
+          LinkCrawlerQueue.enqueue(
+            {
+              bookmarkId: b.id,
+              runInference: input.runInference,
+            },
+            {
+              priority: 50,
+            },
+          ),
         ),
       );
     }),
@@ -233,7 +238,13 @@ export const adminAppRouter = router({
       },
     });
 
-    await Promise.all(bookmarkIds.map((b) => triggerSearchReindex(b.id)));
+    await Promise.all(
+      bookmarkIds.map((b) =>
+        triggerSearchReindex(b.id, {
+          priority: 50,
+        }),
+      ),
+    );
   }),
   reprocessAssetsFixMode: adminProcedure.mutation(async ({ ctx }) => {
     const bookmarkIds = await ctx.db.query.bookmarkAssets.findMany({
@@ -244,10 +255,15 @@ export const adminAppRouter = router({
 
     await Promise.all(
       bookmarkIds.map((b) =>
-        AssetPreprocessingQueue.enqueue({
-          bookmarkId: b.id,
-          fixMode: true,
-        }),
+        AssetPreprocessingQueue.enqueue(
+          {
+            bookmarkId: b.id,
+            fixMode: true,
+          },
+          {
+            priority: 50,
+          },
+        ),
       ),
     );
   }),
@@ -277,7 +293,12 @@ export const adminAppRouter = router({
 
       await Promise.all(
         bookmarkIds.map((b) =>
-          OpenAIQueue.enqueue({ bookmarkId: b.id, type: input.type }),
+          OpenAIQueue.enqueue(
+            { bookmarkId: b.id, type: input.type },
+            {
+              priority: 50,
+            },
+          ),
         ),
       );
     }),
-- 
cgit v1.2.3-70-g09d2