ditto/scripts/db-populate-search.ts

import { DittoConf } from '@ditto/conf';
import { DittoPolyPg } from '@ditto/db';
import { NSchema as n } from '@nostrify/nostrify';

import { DittoPgStore } from '../packages/ditto/storages/DittoPgStore.ts';

const conf = new DittoConf(Deno.env);
const db = new DittoPolyPg(conf.databaseUrl);
const relay = new DittoPgStore({ db, pubkey: await conf.signer.getPublicKey() });

for await (const msg of relay.req([{ kinds: [0] }])) {
  if (msg[0] === 'EVENT') {
    const { pubkey, content } = msg[2];

    const { name, nip05 } = n.json().pipe(n.metadata()).catch({}).parse(content);
    const search = [name, nip05].filter(Boolean).join(' ').trim();

    try {
      await db.kysely.insertInto('author_stats').values({
        pubkey,
        search,
        followers_count: 0,
        following_count: 0,
        notes_count: 0,
      }).onConflict(
        (oc) =>
          oc.column('pubkey')
            .doUpdateSet((eb) => ({ search: eb.ref('excluded.search') })),
      )
        .execute();
    } catch {
      // do nothing
    }
  } else {
    break;
  }
}

Deno.exit();