feat: create script to populate author_search table

deno.json

@@ -18,7 +18,8 @@
     "stats:recompute": "deno run -A scripts/stats-recompute.ts",
     "soapbox": "curl -O https://dl.soapbox.pub/main/soapbox.zip && mkdir -p public && mv soapbox.zip public/ && cd public/ && unzip -o soapbox.zip && rm soapbox.zip",
     "trends": "deno run -A scripts/trends.ts",
-    "clean:deps": "deno cache --reload src/app.ts"
+    "clean:deps": "deno cache --reload src/app.ts",
+    "db:populate-search": "deno run -A scripts/db-populate-search.ts"
   },
   "unstable": ["cron", "ffi", "kv", "worker-options"],
   "exclude": ["./public"],

scripts/db-populate-search.ts

@@ -0,0 +1,35 @@
+import { NSchema as n } from '@nostrify/nostrify';
+import { Storages } from '@/storages.ts';
+import { DittoTables } from '@/db/DittoTables.ts';
+
+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();
+
+  values.push({
+    pubkey: author.pubkey,
+    search,
+  });
+}
+
+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();