Fetch first profile from any relay.

src/nostr/relays.ts

@@ -95,6 +95,26 @@ export const _initRelays = async ({
   return relayPool;
 };
 
+export const getFirstEventFromAnyRelay = (filter: nostrify.NostrFilter) => {
+  return new Promise<nostrify.NostrEvent | void>((resolve, reject) => {
+    _initRelays().then(async (relays) => {
+      const subscription = relays.req([filter]);
+      for await (const message of subscription) {
+        const [messageType, , event] = message;
+        if (messageType === "EVENT") {
+          return resolve(event);
+        }
+        if (messageType === "EOSE") {
+          return resolve();
+        }
+        if (messageType === "CLOSED") {
+          return resolve();
+        }
+      }
+    });
+  });
+};
+
 export const _publish = async (event: NostrEvent): Promise<void> => {
   const relayPool = await _initRelays();
   return relayPool.event(event);

src/nostr/subscribe.ts

@@ -9,7 +9,7 @@ import {
   TRUSTED_VALIDATION_PUBKEYS,
 } from "../constants";
 import { Kind30398Event, MetadataEvent } from "../types";
-import { _initRelays } from "./relays";
+import { _initRelays, getFirstEventFromAnyRelay } from "./relays";
 import {
   doesStringPassSanitisation,
   getProfileFromEvent,
@@ -126,10 +126,9 @@ function fetchProfileFactory(pubKey) {
       return;
     }
 
-    const relayPool = await _initRelays();
-    const events = (await relayPool.query([profileFilter])) as MetadataEvent[];
-    if (events.length > 0) {
-      onProfileEvent(events[0]);
+    const event = await getFirstEventFromAnyRelay(profileFilter);
+    if (typeof event !== "undefined") {
+      onProfileEvent(event as MetadataEvent);
     }
   };
 }