diff --git a/src/pipeline.ts b/src/pipeline.ts index 2fb18649..fdff0c12 100644 --- a/src/pipeline.ts +++ b/src/pipeline.ts @@ -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 oc.column('domain').doUpdateSet(dittoDomain)) + .execute(); + } + await sql` INSERT INTO pubkey_domains (pubkey, domain, last_updated_at) VALUES (${pubkey}, ${domain}, ${event.created_at})