refactor: Move asset preprocessing to its own worker out of the inference worker

1 files changed, 8 insertions, 2 deletions

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;