2 files changed, 4 insertions, 10 deletions
diff --git a/apps/workers/crawlerWorker.ts b/apps/workers/crawlerWorker.ts
index f2e0e4a8..58f1aa85 100644
--- a/apps/workers/crawlerWorker.ts
+++ b/apps/workers/crawlerWorker.ts
@@ -39,7 +39,7 @@ import {
   LinkCrawlerQueue,
   OpenAIQueue,
   queueConnectionDetails,
-  SearchIndexingQueue,
+  triggerSearchReindex,
   zCrawlLinkRequestSchema,
 } from "@hoarder/shared/queues";
 
@@ -490,10 +490,7 @@ async function runCrawler(job: Job<ZCrawlLinkRequest, void>) {
   }
 
   // Update the search index
-  SearchIndexingQueue.add("search_indexing", {
-    bookmarkId,
-    type: "index",
-  });
+  triggerSearchReindex(bookmarkId);
 
   // Do the archival as a separate last step as it has the potential for failure
   if (serverConfig.crawler.fullPageArchive) {
diff --git a/apps/workers/openaiWorker.ts b/apps/workers/openaiWorker.ts
index 7b74e4c3..776d6828 100644
--- a/apps/workers/openaiWorker.ts
+++ b/apps/workers/openaiWorker.ts
@@ -17,7 +17,7 @@ import logger from "@hoarder/shared/logger";
 import {
   OpenAIQueue,
   queueConnectionDetails,
-  SearchIndexingQueue,
+  triggerSearchReindex,
   zOpenAIRequestSchema,
 } from "@hoarder/shared/queues";
 
@@ -396,8 +396,5 @@ async function runOpenAI(job: Job<ZOpenAIRequest, void>) {
   await connectTags(bookmarkId, tags, bookmark.userId);
 
   // Update the search index
-  SearchIndexingQueue.add("search_indexing", {
-    bookmarkId,
-    type: "index",
-  });
+  triggerSearchReindex(bookmarkId);
 }