From d7ae3722c8e3a4557e997ed787e52b99c449b19b Mon Sep 17 00:00:00 2001
From: "P. Reis" <patrickpereirareal1@gmail.com>
Date: Sun, 15 Sep 2024 16:52:49 -0300
Subject: [PATCH] refactor: insert each event per iteration in for loop -
 db:populate-search

---
 scripts/db-populate-search.ts | 33 +++++++++++++++------------------
 1 file changed, 15 insertions(+), 18 deletions(-)

diff --git a/scripts/db-populate-search.ts b/scripts/db-populate-search.ts
index beec2d52..e34aaa75 100644
--- a/scripts/db-populate-search.ts
+++ b/scripts/db-populate-search.ts
@@ -1,12 +1,9 @@
 import { NSchema as n } from '@nostrify/nostrify';
 import { Storages } from '@/storages.ts';
-import { DittoTables } from '@/db/DittoTables.ts';
 
 const store = await Storages.db();
 const kysely = await Storages.kysely();
 
-const values: DittoTables['author_search'][] = [];
-
 for await (const msg of store.req([{ kinds: [0] }])) {
   if (msg[0] === 'EVENT') {
     const { pubkey, content } = msg[2];
@@ -14,22 +11,22 @@ for await (const msg of store.req([{ kinds: [0] }])) {
     const { name, nip05 } = n.json().pipe(n.metadata()).catch({}).parse(content);
     const search = [name, nip05].filter(Boolean).join(' ').trim();
 
-    values.push({
-      pubkey: pubkey,
-      search,
-    });
+    try {
+      await kysely.insertInto('author_search').values({
+        pubkey,
+        search,
+      }).onConflict(
+        (oc) =>
+          oc.column('pubkey')
+            .doUpdateSet((eb) => ({ search: eb.ref('excluded.search') })),
+      )
+        .execute();
+    } catch {
+      // do nothing
+    }
+  } else {
+    break;
   }
 }
 
-try {
-  await kysely.insertInto('author_search').values(values).onConflict(
-    (oc) =>
-      oc.column('pubkey')
-        .doUpdateSet((eb) => ({ search: eb.ref('excluded.search') })),
-  )
-    .execute();
-} catch {
-  // do nothing
-}
-
 Deno.exit();