feat(database): delete things from meili

yjl9903 · Jan 29, 2024 · 87fb32d · 87fb32d
1 parent e31c583
commit 87fb32d
Showing 1 changed file with 12 additions and 6 deletions.
diff --git a/packages/database/src/meilisearch.ts b/packages/database/src/meilisearch.ts
@@ -13,12 +13,18 @@ export function connectMeiliSearch(host: string, key: string): MeiliSearch {
 
 export async function insertResourceDocuments(client: MeiliSearch, resources: Resource[]) {
   const resp = await client.index('resources').addDocuments(
-    resources.map((d) => ({
-      ...d,
-      // Map to number, used for lt or gt
-      createdAt: d.createdAt!.getTime(),
-      fetchedAt: d.fetchedAt!.getTime()
-    }))
+    resources
+      .filter((r) => !r.isDeleted)
+      .map((d) => ({
+        ...d,
+        // Map to number, used for lt or gt
+        createdAt: d.createdAt!.getTime(),
+        fetchedAt: d.fetchedAt!.getTime()
+      }))
   );
+  const deleted = resources.filter((r) => r.isDeleted);
+  if (deleted.length > 0) {
+    await client.index('resources').deleteDocuments(deleted.map((r) => r.id));
+  }
   return resp;
 }