From 9a950e1068a7309d0cb36ffd33ecd2cd0af5c004 Mon Sep 17 00:00:00 2001
From: Mohamed Bassem <me@mbassem.com>
Date: Wed, 25 Dec 2024 23:53:46 +0000
Subject: refactor: Move asset preprocessing to its own worker out of the
 inference worker

---
 packages/trpc/routers/bookmarks.ts | 10 ++++++++--
 1 file changed, 8 insertions(+), 2 deletions(-)

(limited to 'packages/trpc/routers')

diff --git a/packages/trpc/routers/bookmarks.ts b/packages/trpc/routers/bookmarks.ts
index 8a4170cd..254ac6c2 100644
--- a/packages/trpc/routers/bookmarks.ts
+++ b/packages/trpc/routers/bookmarks.ts
@@ -26,6 +26,7 @@ import serverConfig from "@hoarder/shared/config";
 import { InferenceClientFactory } from "@hoarder/shared/inference";
 import { buildSummaryPrompt } from "@hoarder/shared/prompts";
 import {
+  AssetPreprocessingQueue,
   LinkCrawlerQueue,
   OpenAIQueue,
   triggerSearchDeletion,
@@ -378,13 +379,18 @@ export const bookmarksAppRouter = router({
           });
           break;
         }
-        case BookmarkTypes.TEXT:
-        case BookmarkTypes.ASSET: {
+        case BookmarkTypes.TEXT: {
           await OpenAIQueue.enqueue({
             bookmarkId: bookmark.id,
           });
           break;
         }
+        case BookmarkTypes.ASSET: {
+          await AssetPreprocessingQueue.enqueue({
+            bookmarkId: bookmark.id,
+          });
+          break;
+        }
       }
       await triggerSearchReindex(bookmark.id);
       return bookmark;
-- 
cgit v1.2.3-70-g09d2