moon
/
ditto
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

pipeline: get nip05 domain correctly

This commit is contained in:
Alex Gleason 2024-03-20 13:20:12 -05:00
parent 84784cd46b
commit a8b5888e6d
No known key found for this signature in database
GPG Key ID: 7211D1F99744FBB7
1 changed files with 11 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
src/pipeline.ts
View File

@ -11,7 +11,7 @@ import { purifyEvent } from '@/storages/hydrate.ts';
import { cache, client, eventsDB, reqmeister } from '@/storages.ts'; import { cache, client, eventsDB, reqmeister } from '@/storages.ts';
import { Sub } from '@/subs.ts'; import { Sub } from '@/subs.ts';
import { getTagSet } from '@/tags.ts'; import { getTagSet } from '@/tags.ts';
import { eventAge, isRelay, nostrDate, nostrNow, Time } from '@/utils.ts'; import { eventAge, isRelay, nostrDate, nostrNow, parseNip05, Time } from '@/utils.ts';
import { fetchWorker } from '@/workers/fetch.ts'; import { fetchWorker } from '@/workers/fetch.ts';
import { TrendsWorker } from '@/workers/trends.ts'; import { TrendsWorker } from '@/workers/trends.ts';
import { verifyEventWorker } from '@/workers/verify.ts'; import { verifyEventWorker } from '@/workers/verify.ts';
@ -99,12 +99,16 @@ async function parseMetadata(event: NostrEvent, signal: AbortSignal): Promise<vo
if (pubkey !== event.pubkey) return; if (pubkey !== event.pubkey) return;
// Track pubkey domain. // Track pubkey domain.
const [, domain] = nip05.split('@'); try {
await db const { domain } = parseNip05(nip05);
.insertInto('pubkey_domains') await db
.values({ pubkey, domain }) .insertInto('pubkey_domains')
.execute() .values({ pubkey, domain })
.catch(debug); .execute()
.catch(debug);
} catch (_e) {
// do nothing
}
} }
/** Query to-be-deleted events, ensure their pubkey matches, then delete them from the database. */ /** Query to-be-deleted events, ensure their pubkey matches, then delete them from the database. */