From a5434730ede1272f195d6a4b13207b840a5ac2cf Mon Sep 17 00:00:00 2001
From: MohamedBassem <me@mbassem.com>
Date: Fri, 1 Mar 2024 21:01:00 +0000
Subject: feature: Add full text search support

---
 packages/workers/openai.ts | 24 +++++++++++++++++-------
 1 file changed, 17 insertions(+), 7 deletions(-)

(limited to 'packages/workers/openai.ts')

diff --git a/packages/workers/openai.ts b/packages/workers/openai.ts
index 8f85c4ec..cc456616 100644
--- a/packages/workers/openai.ts
+++ b/packages/workers/openai.ts
@@ -3,6 +3,7 @@ import logger from "@hoarder/shared/logger";
 import serverConfig from "@hoarder/shared/config";
 import {
   OpenAIQueue,
+  SearchIndexingQueue,
   ZOpenAIRequest,
   queueConnectionDetails,
   zOpenAIRequestSchema,
@@ -159,13 +160,16 @@ async function connectTags(bookmarkId: string, tagIds: string[]) {
   if (tagIds.length == 0) {
     return;
   }
-  await db.insert(tagsOnBookmarks).values(
-    tagIds.map((tagId) => ({
-      tagId,
-      bookmarkId,
-      attachedBy: "ai" as const,
-    })),
-  );
+  await db
+    .insert(tagsOnBookmarks)
+    .values(
+      tagIds.map((tagId) => ({
+        tagId,
+        bookmarkId,
+        attachedBy: "ai" as const,
+      })),
+    )
+    .onConflictDoNothing();
 }
 
 async function runOpenAI(job: Job<ZOpenAIRequest, void>) {
@@ -203,4 +207,10 @@ async function runOpenAI(job: Job<ZOpenAIRequest, void>) {
 
   const tagIds = await createTags(tags, bookmark.userId);
   await connectTags(bookmarkId, tagIds);
+
+  // Update the search index
+  SearchIndexingQueue.add("search_indexing", {
+    bookmarkId,
+    type: "index",
+  });
 }
-- 
cgit v1.2.3-70-g09d2