mirror/ditto
mirror/ditto
1
0
Fork 0
mirror of https://gitlab.com/soapbox-pub/ditto.git synced 2025-12-06 03:19:46 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

refactor: insert each event per iteration in for loop - db:populate-search

Browse source
This commit is contained in:
P. Reis 2024-09-15 16:52:49 -03:00
parent f99ea7c33f
commit d7ae3722c8
1 changed files with 15 additions and 18 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

33
scripts/db-populate-search.ts
View file

@ -1,12 +1,9 @@
import { NSchema as n } from '@nostrify/nostrify'; import { NSchema as n } from '@nostrify/nostrify';
import { Storages } from '@/storages.ts'; import { Storages } from '@/storages.ts';
import { DittoTables } from '@/db/DittoTables.ts';
const store = await Storages.db(); const store = await Storages.db();
const kysely = await Storages.kysely(); const kysely = await Storages.kysely();
const values: DittoTables['author_search'][] = [];
for await (const msg of store.req([{ kinds: [0] }])) { for await (const msg of store.req([{ kinds: [0] }])) {
if (msg[0] === 'EVENT') { if (msg[0] === 'EVENT') {
const { pubkey, content } = msg[2]; 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 { name, nip05 } = n.json().pipe(n.metadata()).catch({}).parse(content);
const search = [name, nip05].filter(Boolean).join(' ').trim(); const search = [name, nip05].filter(Boolean).join(' ').trim();
values.push({ try {
pubkey: pubkey, await kysely.insertInto('author_search').values({
search, 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(); Deno.exit();