From 197b2c8c8b3b62e005134e405a430c55a0bbc0c5 Mon Sep 17 00:00:00 2001
From: "P. Reis" <patrickpereirareal1@gmail.com>
Date: Fri, 13 Sep 2024 18:49:20 -0300
Subject: [PATCH] refactor(populate search script): use store.req instead of
 streaming

---
 scripts/db-populate-search.ts | 24 ++++++++++++------------
 1 file changed, 12 insertions(+), 12 deletions(-)

diff --git a/scripts/db-populate-search.ts b/scripts/db-populate-search.ts
index 9c698c8f..beec2d52 100644
--- a/scripts/db-populate-search.ts
+++ b/scripts/db-populate-search.ts
@@ -2,23 +2,23 @@ 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 stream = kysely
-  .selectFrom('nostr_events')
-  .select(['pubkey', 'content'])
-  .where('kind', '=', 0)
-  .stream();
 
 const values: DittoTables['author_search'][] = [];
 
-for await (const author of stream) {
-  const { name, nip05 } = n.json().pipe(n.metadata()).catch({}).parse(author.content);
-  const search = [name, nip05].filter(Boolean).join(' ').trim();
+for await (const msg of store.req([{ kinds: [0] }])) {
+  if (msg[0] === 'EVENT') {
+    const { pubkey, content } = msg[2];
 
-  values.push({
-    pubkey: author.pubkey,
-    search,
-  });
+    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 {