Merge branch 'develop'

Author: sebastianmontero

package-lock.json

@@ -1,6 +1,6 @@
 {
   "name": "@smontero/smartvaults-js-client",
-  "version": "0.0.63",
+  "version": "0.0.64",
   "description": "SmartVaults javascript client",
   "main": "dist/index.js",
   "types": "dist/index.d.ts",

package.json

@@ -236,12 +236,6 @@ export class SmartVaults {
       .toFilters()
     const metadataEvents = await this.nostrClient.list(metadataFilter)
     const profiles: SmartVaultsTypes.Profile[] = await this.eventKindHandlerFactor.getHandler(Kind.Metadata).handle(metadataEvents)
-    const verifiedKeyAgentsPubkeys = new Set(await this.getVerifiedKeyAgentsPubKeys())
-    const unverifiedKeyAgentsPubkeys = await this.getUnverifiedKeyAgentEventsByPubkey()
-    profiles.forEach(profile => {
-      profile.isKeyAgent = unverifiedKeyAgentsPubkeys.has(profile.publicKey) || verifiedKeyAgentsPubkeys.has(profile.publicKey)
-      profile.isVerified = verifiedKeyAgentsPubkeys.has(profile.publicKey)
-    })
     return profiles
   }
 

src/SmartVaults.ts

@@ -42,7 +42,7 @@ export class MetadataHandler extends EventKindHandler {
         }
       }
 
-      this.store.store({ content: { publicKey, ...metadata }, id: event.id });
+      this.store.store({ content: { publicKey, ...metadata, isKeyAgent: false, isVerified: false }, id: event.id });
     });
 
     const results = await Promise.allSettled(fetchPromises);

src/event-kind-handler/MetadataHandler.ts

@@ -68,19 +68,45 @@ export class NostrClient {
       ok: [],
       failed: []
     }
-    function onResponse(status, relay) {
+
+    function onOkResponse(status: string, relay: string): void {
+      result[status].push(relay)
+      numRelays--
+      if (numRelays <= 0) {
+        listeners.forEach(cb => { cb(result) })
+        listeners = new Set()
+      }
+    }
+
+    const onFailedResponse = (status: string, relay: string, count: number): void => {
+      if (count === 1) console.log(`Event with id ${event.id} failed to publish to ${relay}, retrying...`)
+      if (count > 5) {
+        console.log(`Event with id ${event.id} failed to publish to ${relay}, max retries reached`)
+        return
+      }
       result[status].push(relay)
       numRelays--
+      // Retry 
+      setTimeout(() => {
+        const pub = this.pool.publish([relay], event)
+        pub.on('ok', (relay) => {
+          console.log(`Retry ${count} for event ${event.id} suceeded`, relay)
+        })
+        pub.on('failed', (relay) => {
+          console.log(`Retry ${count} for event ${event.id} failed, retrying...`, relay)
+          onFailedResponse('failed', relay, count + 1)
+        })
+      }, 61000)
       if (numRelays <= 0) {
         listeners.forEach(cb => { cb(result) })
         listeners = new Set()
       }
     }
     pub.on('ok', (relay) => {
-      onResponse('ok', relay)
+      onOkResponse('ok', relay)
     })
     pub.on('failed', (relay) => {
-      onResponse('failed', relay)
+      onFailedResponse('failed', relay, 1)
     })
     return {
       on(type, cb) {

src/service/NostrClient.ts

@@ -77,7 +77,7 @@ export function getTagValue(
  * @example
  * const isNip05Verified = await isNip05Verified([email protected], aliciesPublicKey);
  */
-export async function isNip05Verified(nip05: string, publicKey: string, timeout = 700): Promise<boolean> {
+export async function isNip05Verified(nip05: string, publicKey: string, timeout = 1000): Promise<boolean> {
 
   const HTTP_OK = 200;
   const nip05Array = nip05.split('@');