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

feat(pipeline): insert ditto_domains values inside the parseMetadata function

Browse source
This commit is contained in:
P. Reis 2024-08-13 18:28:35 -03:00
parent d26709e947
commit 16ea9de4c2
1 changed files with 9 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
src/pipeline.ts
View file

@ -21,6 +21,7 @@ import { updateStats } from '@/utils/stats.ts';
import { getTagSet } from '@/utils/tags.ts';
import { getAmount } from '@/utils/bolt11.ts';
import { DittoTables } from '@/db/DittoTables.ts';
import { fetchDittoDomain } from '@/utils/domains.ts';
const debug = Debug('ditto:pipeline');
@ -151,6 +152,14 @@ async function parseMetadata(event: NostrEvent, signal: AbortSignal): Promise<vo
const { kysely } = await DittoDB.getInstance();
const { domain } = parseNip05(nip05);
const dittoDomain = await fetchDittoDomain(domain);
if (dittoDomain) {
await kysely.insertInto('ditto_domains')
.values(dittoDomain)
.onConflict((oc) => oc.column('domain').doUpdateSet(dittoDomain))
.execute();
}
await sql`
INSERT INTO pubkey_domains (pubkey, domain, last_updated_at)
VALUES (${pubkey}, ${domain}, ${event.created_at})