Merge pull request #51 from Permissionless-Software-Foundation/dh-nostr-relays

feat(nostr): Handle multiple nostr relays

package-lock.json

@@ -15,7 +15,7 @@
         "@fortawesome/react-fontawesome": "0.2.2",
         "@noble/hashes": "^1.8.0",
         "axios": "0.27.2",
-        "bch-dex-lib": "2.0.3",
+        "bch-dex-lib": "2.2.0",
         "bch-message-lib": "2.2.1",
         "bch-nostr": "1.3.4",
         "bch-token-sweep": "2.2.1",
@@ -10043,9 +10043,9 @@
       "license": "MIT"
     },
     "node_modules/bch-dex-lib": {
-      "version": "2.0.3",
-      "resolved": "https://registry.npmjs.org/bch-dex-lib/-/bch-dex-lib-2.0.3.tgz",
-      "integrity": "sha512-aPZIlDcRziZBRKRhEuAv6G/skFjZ28+sE30fkoUY8isUIAe3C0YS7yQMoOmGSA6N46/XuhRbfQi0SRQJfrASpA==",
+      "version": "2.2.0",
+      "resolved": "https://registry.npmjs.org/bch-dex-lib/-/bch-dex-lib-2.2.0.tgz",
+      "integrity": "sha512-SORqn4qNmbxfL2SbbapOpbcCB+FtqasR+GT0XRifdkXFjA3aDL0gwMsHjh8IzLZnKtPYSBcfgzKQFxEsXCJNug==",
       "license": "MIT",
       "dependencies": {
         "@chris.troutner/retry-queue": "1.0.10",

package.json

@@ -9,7 +9,7 @@
     "@fortawesome/react-fontawesome": "0.2.2",
     "@noble/hashes": "^1.8.0",
     "axios": "0.27.2",
-    "bch-dex-lib": "2.0.3",
+    "bch-dex-lib": "2.2.0",
     "bch-message-lib": "2.2.1",
     "bch-nostr": "1.3.4",
     "bch-token-sweep": "2.2.1",

src/components/app-body/nostr/content-creators/content-creators-list.js

@@ -31,9 +31,12 @@ function ContentCreators (props) {
 
   const [followList, setFollowList] = useState([])
 
+  // Get the list of profiles followed by the user.
+  // It aggregates all the followers from all the relays.
   const getFollowList = useCallback(async () => {
     const list = await new Promise((resolve, reject) => {
       let list = []
+      let closedRelays = 0
       const { nostrKeyPair } = appData.bchWalletState
 
       const pool = RelayPool(config.nostrRelays)
@@ -43,49 +46,62 @@ function ContentCreators (props) {
       })
 
       pool.on('eose', relay => {
-        console.log('Closing Relay')
         relay.close()
-        /** This ensures to return an empty array if no records are found!
-         *  Applies for new users that don't have a follow list
-        */
-        resolve(list)
+        closedRelays++
+        // Resolve list if all relays are closed
+        if (closedRelays === config.nostrRelays.length) {
+          resolve(list)
+        }
       })
 
       pool.on('event', (relay, subId, ev) => {
-        console.log('Received event:', ev)
-        list = ev.tags
-        resolve(list)
+        // console.log('Received event:', ev)
+        // Merge list received from all relays
+        list = [...list, ...ev.tags]
       })
     })
 
-    console.log('Follow List', list)
+    // console.log('Follow List', list)
     setFollowList(list)
   }, [appData])
 
+  // Load profile from nostr relays
+  // It uses multiple relays. It will exit after the first successful retrieval
+  // from any relay. If one relay fails, it will move on to the next one.
   const loadProfile = useCallback(async (pubKey) => {
-    return new Promise((resolve) => {
-      // const pool = RelayPool(config.nostrRelays)
-      const pool = RelayPool([config.nostrRelay])
-      pool.on('open', relay => {
-        relay.subscribe('subid', { limit: 5, kinds: [0], authors: [pubKey] })
-      })
+    // Looking for the profile in each relay sequentially
+    for (let i = 0; i < config.nostrRelays.length; i++) {
+      const profile = await new Promise((resolve) => {
+        const relay = config.nostrRelays[i]
+        // const pool = RelayPool(config.nostrRelays)
+        const pool = RelayPool([relay])
+        pool.on('open', relay => {
+          relay.subscribe('subid', { limit: 5, kinds: [0], authors: [pubKey] })
+        })
 
-      pool.on('eose', relay => {
-        console.log('Closing Relay')
-        relay.close()
-        resolve(false)
-      })
-
-      pool.on('event', (relay, subId, ev) => {
-        try {
-          const profile = JSON.parse(ev.content)
-          // console.log('profile', profile)
-          resolve(profile)
-        } catch (error) {
+        pool.on('eose', relay => {
+          console.log('Closing Relay')
+          relay.close()
           resolve(false)
-        }
+        })
+
+        pool.on('event', (relay, subId, ev) => {
+          try {
+            const profile = JSON.parse(ev.content)
+            // console.log('profile', profile)
+            console.log(`Profile found  for ${pubKey} at ${relay.url}`)
+            resolve(profile)
+          } catch (error) {
+            resolve(false)
+          }
+          relay.close()
+        })
       })
-    })
+      // Stop looking for profile if found
+      if (profile) {
+        return profile
+      }
+    }
   }, [])
 
   useEffect(() => {