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/App.js

@@ -14,7 +14,10 @@ import NavMenu from './components/nav-menu'
 import useAppState from './hooks/state'
 import { UninitializedView, InitializedView } from './components/starter-views'
 
-const sigleViewPaths = ['/profile']
+// Paths with custom async loader
+// Single Views, load minimal async services in order to prevent the long-time screen loader.
+const sigleViewPaths = ['/profile', 'user-data']
+
 function App (props) {
   // Load all the app state into a single object that can be passed to child
   // components.

src/components/app-body/nfts-for-sale/index.js

@@ -172,7 +172,7 @@ function NftsForSale (props) {
     } catch (error) {
       setIconsAreLoaded(true)
     }
-  }, [fetchTokenMutableData, appData])
+  }, [fetchTokenMutableData])
 
   //  Check if token data exists in the cache and add it to the tokens object.
   const reviewNftCachedData = useCallback(async (offers) => {

src/components/app-body/nfts-for-sale/info-button.js

@@ -98,17 +98,16 @@ function InfoButton (props) {
             </Row>
 
             {mutableDataCid && (
-              <Row>
+              <Row style={{ paddingTop: '10px' }}>
                 <Col xs={4}><b>User Data</b>:</Col>
                 <Col xs={8}>
-                  <a
-                    href={`/user-data/${props.token.tokenId}`}
+                  <Button
+                    href={`/user-data/${props.token.tokenId}#single-view`}
                     target='_blank'
                     rel='noopener noreferrer'
-                    className='btn btn-link p-0'
                   >
                     View User Data
-                  </a>
+                  </Button>
                 </Col>
               </Row>
             )}

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

@@ -1,9 +1,21 @@
+/*
+  This component is used to display the list of content creators.
+
+  TODO:
+  - getFollowList() should aggregate all the followers from all the relays.
+    Currently each relay overwrites the last one.
+
+  - loadProfile() should use multiple relays. It should exit after the first
+    successful retrieval of data from a relay. If the relay fails to give data,
+    it should move on to the next relay.
+*/
+
 import React, { useState, useEffect, useCallback } from 'react'
 import { Container, Spinner, Dropdown } from 'react-bootstrap'
 import { FontAwesomeIcon } from '@fortawesome/react-fontawesome'
 import { faFilter } from '@fortawesome/free-solid-svg-icons'
-
 import axios from 'axios'
+
 // Local libraries
 import config from '../../../../config'
 import ContentCard from './content-card'
@@ -19,62 +31,77 @@ 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 psf = 'wss://nostr-relay.psfoundation.info'
 
-      const pool = RelayPool([psf])
+      const pool = RelayPool(config.nostrRelays)
+      // const pool = RelayPool([config.nostrRelay])
       pool.on('open', relay => {
         relay.subscribe('subid', { limit: 1, kinds: [3], authors: [nostrKeyPair.pubHex] })
       })
 
       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 psf = 'wss://nostr-relay.psfoundation.info'
+    // 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] })
+        })
 
-      const pool = RelayPool([psf])
-      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(() => {

src/components/app-body/nostr/feeds/feed-card.js

@@ -25,6 +25,7 @@ function FeedCard (props) {
   const [isLiked, setIsLiked] = useState(false)
   const [likesCount, setLikesCount] = useState(null)
   const [likesFetched, setLikesFetched] = useState(false)
+  const [profilePictureError, setProfilePictureError] = useState(false)
 
   // function to fetch a post likes reaction
   const handleLikes = useCallback(async (post, userPubKey) => {
@@ -76,6 +77,15 @@ function FeedCard (props) {
       console.warn(error)
     }
   }, [])
+
+  const handleProfilePictureError = () => {
+    setProfilePictureError(true)
+  }
+
+  const handleProfilePictureLoad = () => {
+    setProfilePictureError(false)
+  }
+
   // Get npub from pubkey
   useEffect(() => {
     const npub = nip19.npubEncode(post.pubkey)
@@ -170,7 +180,20 @@ function FeedCard (props) {
               background: 'linear-gradient(45deg, #6c757d, #495057)'
             }}
           >
-            <FontAwesomeIcon icon={faUser} size='1x' color='#7c7c7d' />
+            {profile?.picture && !profilePictureError
+              ? (
+                <img
+                  src={profile.picture}
+                  alt='Profile'
+                  className='rounded-circle w-100 h-100'
+                  style={{ objectFit: 'cover' }}
+                  onError={handleProfilePictureError}
+                  onLoad={handleProfilePictureLoad}
+                />
+                )
+              : (
+                <FontAwesomeIcon icon={faUser} size='1x' color='#7c7c7d' />
+                )}
           </div>
           <div className='flex-grow-1'>
             <div className='fw-bold mb-1'>

src/components/app-body/nostr/feeds/following.js

@@ -4,9 +4,10 @@
 // Global npm libraries
 import React, { useEffect, useState } from 'react'
 import { Container, Spinner } from 'react-bootstrap'
-
 import { RelayPool } from 'nostr'
 
+// Local libraries
+import config from '../../../../config'
 import FeedCard from './feed-card'
 
 function Following (props) {
@@ -19,9 +20,8 @@ function Following (props) {
       const followingList = await new Promise((resolve, reject) => {
         let list = []
         const { nostrKeyPair } = appData.bchWalletState
-        const psf = 'wss://nostr-relay.psfoundation.info'
 
-        const pool = RelayPool([psf])
+        const pool = RelayPool(config.nostrRelays)
         pool.on('open', relay => {
           relay.subscribe('subid', { limit: 1, kinds: [3], authors: [nostrKeyPair.pubHex] })
         })

src/components/app-body/nostr/feeds/index.js

@@ -1,13 +1,27 @@
 /*
-Component for reading the nostr feeds.
+  Component for reading the nostr feeds.
+
+  TODO:
+  - fetchProfile() should retrieve a profile from multiple relays. If the first relay returns a profile,
+    then that profile can be used and promise resolved. If the first relay returns no profile, the next
+    one should be tried until all relays are exhausted or one returns a profile.
+
+  - useEffect() retrieves the feeds. This should cycle through each relay and posts from each one.
+    Once each relays has been tried, the posts should remove duplicate entries. Finally posts should
+    be sorted by date.
+
+  - Clicking on a profile picture, name, or npub should open the profile for that user in a new tab.
 */
 
 // Global npm libraries
 import React, { useState, useEffect, useCallback } from 'react'
 import { Container, Nav, Tab, Spinner } from 'react-bootstrap'
+import { RelayPool } from 'nostr'
+
+// Local libraries
 import Feed from './feed'
 import Following from './following'
-import { RelayPool } from 'nostr'
+import config from '../../../../config'
 
 function Feeds (props) {
   const { appData } = props
@@ -19,18 +33,23 @@ function Feeds (props) {
   const [profiles, setProfiles] = useState({})
 
   // function to fetch profile and set it to profiles state
-  const fetchProfile = useCallback((pubkey) => {
+  const fetchProfile = useCallback(async (pubkey) => {
     // no fetch profile again if it exist
+    let hasProfileRequest = false
     setProfiles(currentProfiles => {
       if (currentProfiles[pubkey]) {
+        hasProfileRequest = true
         return currentProfiles
+      } else {
+        const newProfiles = { ...currentProfiles }
+        newProfiles[pubkey] = { loaded: false }
+        return newProfiles
       }
-      return currentProfiles
     })
+    if (hasProfileRequest) return
 
-    const psf = 'wss://nostr-relay.psfoundation.info'
-
-    const pool = RelayPool([psf])
+    // const pool = RelayPool(config.nostrRelays)
+    const pool = RelayPool([config.nostrRelay])
     pool.on('open', relay => {
       relay.subscribe('subid', { limit: 5, kinds: [0], authors: [pubkey] })
     })
@@ -48,6 +67,7 @@ function Feeds (props) {
           return currentProfiles
         })
       } catch (error) {
+        console.warn(error)
         // skip error
       }
     })
@@ -70,9 +90,8 @@ function Feeds (props) {
   // Get global feed posts
   useEffect(() => {
     const start = () => {
-      const psf = 'wss://nostr-relay.psfoundation.info'
-
-      const pool = RelayPool([psf])
+      // const pool = RelayPool(config.nostrRelays)
+      const pool = RelayPool([config.nostrRelay])
       pool.on('open', relay => {
         relay.subscribe('REQ', { limit: 10, kinds: [1], '#t': ['slpdex-socialmedia'] })
       })

src/components/app-body/nostr/nostr-format.js

@@ -26,7 +26,7 @@ const NostrFormat = ({ content }) => {
   }
 
   return (
-    <div dangerouslySetInnerHTML={{ __html: formatContent(content) }} />
+    <div style={{ overflow: 'auto' }} dangerouslySetInnerHTML={{ __html: formatContent(content) }} />
   )
 }
 

src/components/app-body/nostr/nostr-post/index.js.js

@@ -1,10 +1,12 @@
 /*
-Component for posting nostr information.
+  Component for posting nostr information.
 */
 
 // Global npm libraries
 import React from 'react'
 import { Container } from 'react-bootstrap'
+
+// Local libraries
 import ProfilePost from './profile-post'
 import PublicPost from './public-post'
 

src/components/app-body/nostr/nostr-post/profile-post.js

@@ -11,6 +11,9 @@ import { Relay } from 'nostr-tools/relay'
 import { hexToBytes } from '@noble/hashes/utils' // already an installed dependency
 import { RelayPool } from 'nostr'
 
+// Local libraries
+import config from '../../../../config'
+
 function ProfilePost (props) {
   const { bchWalletState } = props.appData
   const [accordionKey, setAccordionKey] = useState(null)
@@ -90,7 +93,7 @@ function ProfilePost (props) {
       const privateKeyBin = hexToBytes(nostrKeyPair.privHex)
 
       // Relay list
-      const psf = 'wss://nostr-relay.psfoundation.info'
+      // const psf = 'wss://nostr-relay.psfoundation.info'
 
       const formDataString = JSON.stringify(formData)
 
@@ -107,16 +110,24 @@ function ProfilePost (props) {
       const signedEvent = finalizeEvent(eventTemplate, privateKeyBin)
       console.log('signedEvent: ', signedEvent)
 
-      // Connect to a relay.
-      const relay = await Relay.connect(psf)
-      console.log(`connected to ${relay.url}`)
+      // Publish the post to each relay.
+      config.nostrRelays.map(async (relayUrl) => {
+        try {
+          // Connect to a relay.
+          const relay = await Relay.connect(relayUrl)
+          console.log(`connected to ${relay.url}`)
 
-      // Publish the message to the relay.
-      const result = await relay.publish(signedEvent)
-      console.log('result: ', result)
+          // Publish the message to the relay.
+          const result = await relay.publish(signedEvent)
+          console.log('result: ', result)
+
+          // Close the connection to the relay.
+          relay.close()
+        } catch (err) {
+          console.warn(`Skipping publishing to ${relayUrl} due to error: ${err}`)
+        }
+      })
 
-      // Close the connection to the relay.
-      relay.close()
       setSuccessMsg('Post successfully published!')
       setOnFetch(false)
     } catch (error) {

src/components/app-body/nostr/nostr-post/public-post.js

@@ -1,5 +1,5 @@
 /*
-Component for posting nostr information on kind 1.
+  Component for posting nostr information on kind 1.
 */
 
 // Global npm libraries
@@ -10,8 +10,11 @@ import { finalizeEvent } from 'nostr-tools/pure'
 import { Relay } from 'nostr-tools/relay'
 import { hexToBytes } from '@noble/hashes/utils' // already an installed dependency
 
+// Local libraries
+import config from '../../../../config'
+
 function PublicPost (props) {
-  const [accordionKey, setAccordionKey] = useState(null)
+  const [accordionKey, setAccordionKey] = useState('0')
   const [onFetch, setOnFetch] = useState(false)
   const { bchWalletState } = props.appData
   const [formData, setFormData] = useState({
@@ -44,9 +47,6 @@ function PublicPost (props) {
       // Convert private key to binary
       const privateKeyBin = hexToBytes(nostrKeyPair.privHex)
 
-      // Relay list
-      const psf = 'wss://nostr-relay.psfoundation.info'
-
       // BCH address of the user.
       const bchAddr = bchWalletState.address
 
@@ -63,16 +63,24 @@ function PublicPost (props) {
       const signedEvent = finalizeEvent(eventTemplate, privateKeyBin)
       console.log('signedEvent: ', signedEvent)
 
-      // Connect to a relay.
-      const relay = await Relay.connect(psf)
-      console.log(`connected to ${relay.url}`)
+      // Publish the post to each relay.
+      config.nostrRelays.map(async (relayUrl) => {
+        try {
+          // Connect to a relay.
+          const relay = await Relay.connect(relayUrl)
+          console.log(`connected to ${relay.url}`)
 
-      // Publish the message to the relay.
-      const result = await relay.publish(signedEvent)
-      console.log('result: ', result)
+          // Publish the message to the relay.
+          const result = await relay.publish(signedEvent)
+          console.log('result: ', result)
+
+          // Close the connection to the relay.
+          relay.close()
+        } catch (err) {
+          console.warn(`Skipping publishing to ${relayUrl} due to error: ${err}`)
+        }
+      })
 
-      // Close the connection to the relay.
-      relay.close()
       resetForm()
       setSuccessMsg('Post successfully published!')
       setOnFetch(false)

src/components/app-body/nostr/profile/profile-read.js

@@ -1,15 +1,23 @@
 /**
- * Component for read nostr information kind 0
+ * Component to read nostr information kind 0 (normal posts)
+ *
+ * TODO:
+ * - Currently feeds are retrieved from only one relay. It should retrieve Kind
+ *   0 posts from all relays. It should then remove any duplicate entries.
  */
+
 // Global npm libraries
 import React, { useEffect, useState } from 'react'
 import { Container, Button } from 'react-bootstrap'
 import CopyOnClick from '../../bch-wallet/copy-on-click.js'
 import { FontAwesomeIcon } from '@fortawesome/react-fontawesome'
 import { faUser, faGlobe } from '@fortawesome/free-solid-svg-icons'
+import * as nip19 from 'nostr-tools/nip19'
+
+// Local libraries
+import config from '../../../../config'
 import NostrFormat from '../nostr-format'
 import { RelayPool } from 'nostr'
-import * as nip19 from 'nostr-tools/nip19'
 
 function ProfileRead (props) {
   const { npub } = props
@@ -22,9 +30,9 @@ function ProfileRead (props) {
     const start = () => {
       const pubHexData = nip19.decode(npub)
       const pubHex = pubHexData.data
-      const psf = 'wss://nostr-relay.psfoundation.info'
 
-      const pool = RelayPool([psf])
+      // const pool = RelayPool(config.nostrRelays)
+      const pool = new RelayPool([config.nostrRelay])
       pool.on('open', relay => {
         relay.subscribe('subid', { limit: 5, kinds: [0], authors: [pubHex] })
         setLoaded(true)

src/components/app-body/nostr/profile/public-read.js

@@ -6,15 +6,19 @@ import React, { useEffect, useState } from 'react'
 import { Container, Card, Spinner } from 'react-bootstrap'
 import { FontAwesomeIcon } from '@fortawesome/react-fontawesome'
 import { faUser } from '@fortawesome/free-solid-svg-icons'
-import NostrFormat from '../nostr-format'
 import { RelayPool } from 'nostr'
 import * as nip19 from 'nostr-tools/nip19'
 
+// Local libraries
+import config from '../../../../config'
+import NostrFormat from '../nostr-format'
+
 function PublicRead (props) {
   const { npub } = props
   const { bchWalletState } = props.appData
   const [posts, setPosts] = useState([])
   const [loaded, setLoaded] = useState(false)
+  const [profilePictureError, setProfilePictureError] = useState(false)
 
   useEffect(() => {
     // Get Last post from a author
@@ -22,9 +26,8 @@ function PublicRead (props) {
       const pubHexData = nip19.decode(npub)
       const pubHex = pubHexData.data
       console.log('pubhex', pubHex)
-      const psf = 'wss://nostr-relay.psfoundation.info'
 
-      const pool = RelayPool([psf])
+      const pool = RelayPool(config.nostrRelays)
       pool.on('open', relay => {
         relay.subscribe('subid', { limit: 5, kinds: [1], authors: [pubHex] })
         setLoaded(true)
@@ -47,6 +50,14 @@ function PublicRead (props) {
     }
   }, [bchWalletState, loaded, npub])
 
+  const handleProfilePictureError = () => {
+    setProfilePictureError(true)
+  }
+
+  const handleProfilePictureLoad = () => {
+    setProfilePictureError(false)
+  }
+
   return (
     <Container className='mt-4 mb-5'>
       {/* Nostr Feed Section */}
@@ -74,7 +85,20 @@ function PublicRead (props) {
                       background: 'linear-gradient(45deg, #6c757d, #495057)'
                     }}
                   >
-                    <FontAwesomeIcon icon={faUser} size='1x' color='#7c7c7d' />
+                    {props.profile?.picture && !profilePictureError
+                      ? (
+                        <img
+                          src={props.profile.picture}
+                          alt='Profile'
+                          className='rounded-circle w-100 h-100'
+                          style={{ objectFit: 'cover' }}
+                          onError={handleProfilePictureError}
+                          onLoad={handleProfilePictureLoad}
+                        />
+                        )
+                      : (
+                        <FontAwesomeIcon icon={faUser} size='1x' color='#7c7c7d' />
+                        )}
                   </div>
                   <div className='flex-grow-1'>
                     <div className='fw-bold mb-1'>{props.profile?.name}</div>

src/config/index.js

@@ -18,7 +18,12 @@ const config = {
   // dexServer: 'http://localhost:5700',
 
   nostrTopic: 'bch-dex-test-topic-02',
-  nostrRelay: 'wss://nostr-relay.psfoundation.info'
+  nostrRelay: 'wss://nostr-relay.psfoundation.info',
+  nostrRelays: [
+    'wss://nostr-relay.psfoundation.info',
+    'wss://nos.lol',
+    'wss://relay.damus.io'
+  ]
 
 }