From a8b5888e6db6a94a3358bd113bef9af93ce9b819 Mon Sep 17 00:00:00 2001
From: Alex Gleason <alex@alexgleason.me>
Date: Wed, 20 Mar 2024 13:20:12 -0500
Subject: [PATCH] pipeline: get nip05 domain correctly

---
 src/pipeline.ts | 18 +++++++++++-------
 1 file changed, 11 insertions(+), 7 deletions(-)

diff --git a/src/pipeline.ts b/src/pipeline.ts
index 9d65b13..7fd7ee9 100644
--- a/src/pipeline.ts
+++ b/src/pipeline.ts
@@ -11,7 +11,7 @@ import { purifyEvent } from '@/storages/hydrate.ts';
 import { cache, client, eventsDB, reqmeister } from '@/storages.ts';
 import { Sub } from '@/subs.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 { TrendsWorker } from '@/workers/trends.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;
 
   // Track pubkey domain.
-  const [, domain] = nip05.split('@');
-  await db
-    .insertInto('pubkey_domains')
-    .values({ pubkey, domain })
-    .execute()
-    .catch(debug);
+  try {
+    const { domain } = parseNip05(nip05);
+    await db
+      .insertInto('pubkey_domains')
+      .values({ pubkey, domain })
+      .execute()
+      .catch(debug);
+  } catch (_e) {
+    // do nothing
+  }
 }
 
 /** Query to-be-deleted events, ensure their pubkey matches, then delete them from the database. */