Merge pull request #54 from Permissionless-Software-Foundation/dh-nostr-library

feat(nostr): Created Nostr service library

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

@@ -19,7 +19,6 @@ import axios from 'axios'
 // Local libraries
 import config from '../../../../config'
 import ContentCard from './content-card'
-import { RelayPool } from 'nostr'
 
 // Global variables and constants
 const SERVER = config.dexServer
@@ -34,76 +33,13 @@ function ContentCreators (props) {
   // 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 { nostrKeyPair } = appData.bchWalletState
 
-      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 => {
-        relay.close()
-        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)
-        // Merge list received from all relays
-        list = [...list, ...ev.tags]
-      })
-    })
-
-    // console.log('Follow List', list)
+    const pubKeyHex = nostrKeyPair.pubHex
+    const list = await appData.nostrQueries.getFollowList(pubKeyHex)
     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) => {
-    // 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)
-            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(() => {
     const loadCreators = async () => {
       try {
@@ -116,7 +52,7 @@ function ContentCreators (props) {
         for (let i = 0; i < creators.length; i++) {
           try {
             const creator = creators[i]
-            const profile = await loadProfile(creator.pubkey)
+            const profile = await appData.nostrQueries.getProfile(creator.pubkey)
 
             // the folowing lines should re-render the ContentCard
             setCreators(prevCreators => {
@@ -137,7 +73,7 @@ function ContentCreators (props) {
       loadCreators()
       getFollowList()
     }
-  }, [loaded, followList, getFollowList, loadProfile])
+  }, [loaded, followList, getFollowList, appData])
 
   const filteredCreators = useCallback(() => {
     if (!creators || creators.length === 0) {

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

@@ -12,7 +12,7 @@ import * as nip19 from 'nostr-tools/nip19'
 import { finalizeEvent } from 'nostr-tools/pure'
 import { Relay } from 'nostr-tools/relay'
 import { hexToBytes } from '@noble/hashes/utils' // already an installed dependency
-import { RelayPool } from 'nostr'
+import config from '../../../../config/index.js'
 
 // Local libraries
 import CopyOnClick from '../../bch-wallet/copy-on-click.js'
@@ -33,53 +33,19 @@ function FeedCard (props) {
   // function to fetch a post likes reaction
   const handleLikes = useCallback(async (post, userPubKey) => {
     try {
-      const psf = 'wss://nostr-relay.psfoundation.info'
-      const res = await new Promise((resolve) => {
-        let likesCnt = 0
-        let userLikedCnt = 0
-        const pool = RelayPool([psf])
-        pool.on('open', relay => {
-          relay.subscribe('subid', { kinds: [7], '#e': [post.id] })
-        })
+      // Get all post likes events
+      const likesArr = await appData.nostrQueries.getPostLikes(post.id)
+      const likesCount = likesArr.length
 
-        pool.on('eose', relay => {
-          relay.close()
-          resolve({
-            count: likesCnt,
-            userLiked: userLikedCnt > 0
-          })
-        })
-
-        pool.on('event', (relay, subId, ev) => {
-          try {
-            // Count likes
-            if (ev.content === '+') {
-              likesCnt++
-              // Count user likes
-              if (ev.pubkey === userPubKey) {
-                userLikedCnt++
-              }
-            }
-            // Count dislikes
-            if (ev.content === '-') {
-              likesCnt--
-              // Count user dislikes.
-              if (ev.pubkey === userPubKey) {
-                userLikedCnt--
-              }
-            }
-          } catch (error) {
-            // skip error
-          }
-        })
-      })
-      setLikesCount(res.count)
-      setIsLiked(res.userLiked)
+      // Verify if the users pubkey is in the likes array
+      const userLikedPost = likesArr.find(val => { return val.pubkey === userPubKey })
+      setLikesCount(likesCount)
+      setIsLiked(userLikedPost)
       setLikesFetched(true)
     } catch (error) {
       console.warn(error)
     }
-  }, [])
+  }, [appData])
 
   const handleProfilePictureError = () => {
     setProfilePictureError(true)
@@ -122,9 +88,6 @@ function FeedCard (props) {
       // Convert private key to binary
       const privateKeyBin = hexToBytes(nostrKeyPair.privHex)
 
-      // Relay list
-      const psf = 'wss://nostr-relay.psfoundation.info'
-
       // Define if like or dislike
       let content = '+'
       if (isLiked) { content = '-' }
@@ -134,27 +97,32 @@ function FeedCard (props) {
         kind: 7,
         created_at: Math.floor(Date.now() / 1000),
         tags: [
-          ['e', post.id, psf],
-          ['p', psf, nostrKeyPair.pubHex]
+          ['e', post.id],
+          ['p', nostrKeyPair.pubHex]
         ],
         content
       }
       console.log(`eventTemplate: ${JSON.stringify(eventTemplate, null, 2)}`)
 
-      // Sign the post
-      const signedEvent = finalizeEvent(eventTemplate, privateKeyBin)
-      console.log('signedEvent: ', signedEvent)
+      config.nostrRelays.map(async (relayUrl) => {
+        try {
+          // Sign the post
+          const signedEvent = finalizeEvent(eventTemplate, privateKeyBin)
+          console.log('signedEvent: ', signedEvent)
+          // Connect to a relay.
+          const relay = await Relay.connect(relayUrl)
+          console.log(`connected to ${relay.url}`)
 
-      // Connect to a relay.
-      const relay = await Relay.connect(psf)
-      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()
+          // Close the connection to the relay.
+          relay.close()
+        } catch (err) {
+          console.warn(`Skipping publishing to ${relayUrl} due to error: ${err}`)
+        }
+      })
 
       await handleLikes(post, nostrKeyPair.pubHex)
       setLikesFetched(true)

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

@@ -3,14 +3,12 @@
 */
 
 // Global npm libraries
-import React, { useState, useEffect, useCallback } from 'react'
+import React, { useState, useEffect } 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 config from '../../../../config'
 
 function Feeds (props) {
   const { appData } = props
@@ -20,92 +18,12 @@ function Feeds (props) {
   const [loaded, setLoaded] = useState(false)
   const [profiles, setProfiles] = useState({})
 
-  // 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 fetchProfile = useCallback(async (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)
-            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
-      }
-    }
-  }, [])
-
-  // Get array of feeds from relays
-  const fetchFeeds = useCallback(async () => {
-    let feeds = await new Promise((resolve, reject) => {
-      let list = []
-      let closedRelays = 0
-
-      const pool = RelayPool(config.nostrRelays)
-      // const pool = RelayPool([config.nostrRelay])
-      pool.on('open', relay => {
-        relay.subscribe('REQ', { limit: 10, kinds: [1], '#t': ['slpdex-socialmedia'] })
-      })
-
-      pool.on('eose', relay => {
-        relay.close()
-        closedRelays++
-        // Resolve list if all relays are closed
-        if (closedRelays === config.nostrRelays.length) {
-          resolve(list)
-        }
-      })
-
-      pool.on('event', (relay, subId, ev) => {
-        // console.log('post retrieved from ', relay.url, ev.sig)
-        list = [...list, ev]
-      })
-    })
-
-    // Remove duplicated feeds
-    feeds = feeds.filter((val, i, list) => {
-      const existingIndex = list.findIndex(value => value.id === val.id)
-      return existingIndex === i
-    })
-
-    // Sort from newest to oldest
-    feeds.sort((a, b) => b.created_at - a.created_at)
-
-    // console.log('feeds', feeds)
-
-    setPosts(feeds)
-    return feeds
-  }, [])
-
   // Load data on component mount.
   useEffect(() => {
     const loadData = async () => {
       // Get feeds
-      const feeds = await fetchFeeds()
+      const feeds = await appData.nostrQueries.getGlobalFeeds()
+      setPosts(feeds)
       setLoaded(true)
 
       const loadedProfiles = [] // fetched profiles ( this will be used for prevent load the same profile multiple times.)
@@ -116,7 +34,7 @@ function Feeds (props) {
         const exist = loadedProfiles.find((val) => { return val === pubKey })
         if (exist) { continue }
         // Fech profile.
-        const profile = await fetchProfile(pubKey)
+        const profile = await appData.nostrQueries.getProfile(pubKey)
         loadedProfiles.push(pubKey) // mark as loaded
 
         // Update profile state
@@ -130,7 +48,7 @@ function Feeds (props) {
     if (!loaded) {
       loadData()
     }
-  }, [loaded, fetchFeeds, fetchProfile])
+  }, [loaded, appData])
 
   const onChangeTab = (tab) => {
     setActiveTab(tab)

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

@@ -9,13 +9,13 @@ import Accordion from 'react-bootstrap/Accordion'
 import { finalizeEvent } from 'nostr-tools/pure'
 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 { appData } = props
+  const { bchWalletState } = appData
   const [accordionKey, setAccordionKey] = useState(null)
   const [onFetch, setOnFetch] = useState(false)
   const [formLoaded, setFormLoaded] = useState(false)
@@ -34,40 +34,19 @@ function ProfilePost (props) {
 
   useEffect(() => {
     // Get Last post from
-    const getLastPost = () => {
-      const { nostrKeyPair } = bchWalletState
-
-      const psf = 'wss://nostr-relay.psfoundation.info'
-
-      const pool = RelayPool([psf])
-      pool.on('open', relay => {
-        relay.subscribe('subid', { limit: 1, kinds: [0], authors: [nostrKeyPair.pubHex] })
-        setFormLoaded(true)
-      })
-
-      pool.on('eose', relay => {
-        console.log('Closing Relay')
-        setFormLoaded(true)
-        relay.close()
-      })
-
-      pool.on('event', (relay, subId, ev) => {
-        console.log('Received event:', ev)
-        // setPosts(currentPosts => [...currentPosts, ev])
-        try {
-          const data = JSON.parse(ev.content)
-          console.log('data', data)
-          setFormData(data)
-        } catch (error) {
-
-        }
-      })
+    const getLastProfilePost = async () => {
+      const { nostrKeyPair } = appData.bchWalletState
+      const lastProfile = await appData.nostrQueries.getProfile(nostrKeyPair.pubHex)
+      if (lastProfile) {
+        setFormData(lastProfile)
+      }
+      setFormLoaded(true)
     }
 
     if (!formLoaded) {
-      getLastPost()
+      getLastProfilePost()
     }
-  }, [bchWalletState, formLoaded])
+  }, [appData, formLoaded])
 
   const handleInputChange = (e) => {
     const { name, value } = e.target

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

@@ -17,7 +17,7 @@ function Profile (props) {
   return (
     <>
       <Container>
-        <ProfileRead {...props} setProfile={setProfile} npub={npub} />
+        <ProfileRead {...props} onProfileRead={setProfile} npub={npub} />
         <PublicRead {...props} profile={profile} npub={npub} />
         <SlpTokensDisplay {...props} npub={npub} />
         <NFTForSale {...props} npub={npub} />

src/components/app-body/nostr/profile/nft-for-sale.js

@@ -14,6 +14,7 @@ function NFTForSale (props) {
   const [offersAreLoaded, setOffersAreLoaded] = useState(false)
   const [iconsAreLoaded, setIconsAreLoaded] = useState(false)
   const [dataAreLoaded, setDataAreLoaded] = useState(false)
+  const [startAsync, setStartAsync] = useState(false)
 
   const getAddressByNpub = useCallback(async () => {
     const url = `${config.dexServer}/sm/npub/${npub}`
@@ -24,6 +25,7 @@ function NFTForSale (props) {
 
   // Handler for refresh button
   const handleRefresh = () => {
+    console.log('handle refresh')
     loadNftOffers()
   }
 
@@ -218,9 +220,13 @@ function NFTForSale (props) {
 
   // Effect to load NFTs on component mount
   useEffect(() => {
-    console.log('loading nfts for sale')
-    loadNftOffers()
-  }, [loadNftOffers])
+    // Prevent to load data twice
+    if (!startAsync) {
+      console.log('loading nfts for sale')
+      loadNftOffers()
+      setStartAsync(true)
+    }
+  }, [loadNftOffers, startAsync])
 
   // Get Cid from url
   const parseCid = (url) => {

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

@@ -1,9 +1,6 @@
 /**
  * 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
@@ -15,45 +12,25 @@ 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'
 
 function ProfileRead (props) {
-  const { npub } = props
-  const { setProfile } = props
-  const [post, setPost] = useState({})
+  const { npub, appData } = props
+  const { onProfileRead } = props
+  const [profile, setProfile] = useState({})
   const [loaded, setLoaded] = useState(false)
   const [imageError, setImageError] = useState({ picture: false, banner: false })
 
   useEffect(() => {
-    const start = () => {
+    const start = async () => {
       const pubHexData = nip19.decode(npub)
       const pubHex = pubHexData.data
 
-      // 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)
-      })
-
-      pool.on('eose', relay => {
-        console.log('Closing Relay')
-        relay.close()
-      })
-
-      pool.on('event', (relay, subId, ev) => {
-        console.log('Received event:', ev)
-        try {
-          const profile = JSON.parse(ev.content)
-          console.log('Profile:', profile)
-          setPost(profile)
-          setProfile(profile)
-        } catch (error) {
-          console.error('Error parsing profile:', error)
-        }
-      })
+      const profile = await appData.nostrQueries.getProfile(pubHex)
+      if (profile) {
+        onProfileRead(profile)
+        setProfile(profile)
+      }
 
       setLoaded(true)
     }
@@ -61,7 +38,7 @@ function ProfileRead (props) {
     if (!loaded && npub) {
       start()
     }
-  }, [loaded, setProfile, npub])
+  }, [loaded, onProfileRead, npub, appData])
 
   const handleImageError = (type) => {
     setImageError(prev => ({ ...prev, [type]: true }))
@@ -74,10 +51,10 @@ function ProfileRead (props) {
   return (
     <Container>
       {/* Banner Section */}
-      {post.banner && !imageError.banner && (
+      {profile.banner && !imageError.banner && (
         <div className='position-relative'>
           <img
-            src={post.banner}
+            src={profile.banner}
             alt='Profile banner'
             className='w-100 rounded-4 shadow-sm'
             style={{ height: '200px', objectFit: 'cover' }}
@@ -90,10 +67,10 @@ function ProfileRead (props) {
       <div className='d-flex flex-column flex-md-row align-items-center gap-4 mb-5 p-3 p-md-5 bg-light rounded-4 shadow-sm'>
         {/* Profile Picture */}
         <div style={{ width: '120px', height: '120px' }} className='mb-3 mb-md-0'>
-          {post.picture && !imageError.picture
+          {profile.picture && !imageError.picture
             ? (
               <img
-                src={post.picture}
+                src={profile.picture}
                 alt='Profile'
                 className='rounded-circle shadow w-100 h-100'
                 style={{ objectFit: 'cover' }}
@@ -117,7 +94,7 @@ function ProfileRead (props) {
 
         {/* Profile Information */}
         <div className='flex-grow-1 text-center text-md-start mb-3 mb-md-0 d-flex flex-column align-items-center align-items-md-start'>
-          <h3 className='mb-2 fw-bold'>{post.name || 'username'}</h3>
+          <h3 className='mb-2 fw-bold'>{profile.name || 'username'}</h3>
 
           <div className='text-muted small mb-3 d-flex align-items-center flex-column flex-md-row'>
             <span className='text-truncate me-2 mb-2 mb-md-0'>
@@ -132,24 +109,24 @@ function ProfileRead (props) {
           </div>
 
           {/* About Section */}
-          {post.about && (
+          {profile.about && (
             <div className='fs-6 text-secondary'>
-              <NostrFormat content={post.about} />
+              <NostrFormat content={profile.about} />
             </div>
           )}
 
           {/* Website Link */}
-          {post.website && (
+          {profile.website && (
             <div className='mb-3 d-flex align-items-center gap-2'>
               <FontAwesomeIcon icon={faGlobe} className='text-muted' size='sm' />
               <a
-                href={post.website.startsWith('http') ? post.website : `https://${post.website}`}
+                href={profile.website.startsWith('http') ? profile.website : `https://${profile.website}`}
                 target='_blank'
                 rel='noopener noreferrer'
                 className='text-decoration-none text-muted small'
                 style={{ wordBreak: 'break-all' }}
               >
-                {post.website}
+                {profile.website}
               </a>
             </div>
           )}

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

@@ -6,49 +6,30 @@ 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 { 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 { npub, appData } = props
+  const { bchWalletState } = appData
   const [posts, setPosts] = useState([])
   const [loaded, setLoaded] = useState(false)
   const [profilePictureError, setProfilePictureError] = useState(false)
 
   useEffect(() => {
     // Get Last post from a author
-    const start = () => {
-      const pubHexData = nip19.decode(npub)
-      const pubHex = pubHexData.data
-      console.log('pubhex', pubHex)
-
-      const pool = RelayPool(config.nostrRelays)
-      pool.on('open', relay => {
-        relay.subscribe('subid', { limit: 5, kinds: [1], authors: [pubHex] })
-        setLoaded(true)
-      })
-
-      pool.on('eose', relay => {
-        console.log('Closing Relay')
-        setLoaded(true)
-        relay.close()
-      })
-
-      pool.on('event', (relay, subId, ev) => {
-        console.log('Received event:', ev)
-        setPosts(currentPosts => [...currentPosts, ev])
-      })
+    const start = async () => {
+      const pubKeyHex = appData.nostrQueries.npubToHex(npub)
+      const feeds = await appData.nostrQueries.getUserFeeds(pubKeyHex)
+      setPosts(feeds)
+      setLoaded(true)
     }
 
     if (!loaded && npub) {
       start()
     }
-  }, [bchWalletState, loaded, npub])
+  }, [bchWalletState, loaded, npub, appData])
 
   const handleProfilePictureError = () => {
     setProfilePictureError(true)

src/hooks/state.js

@@ -2,6 +2,7 @@ import { useState } from 'react'
 // import { useQueryParam, StringParam } from 'use-query-params'
 import useLocalStorageState from 'use-local-storage-state'
 import AppUtil from '../util'
+import NostrQueries from '../services/nostr-queries'
 
 import { useLocation } from 'react-router-dom'
 
@@ -156,7 +157,8 @@ function useAppState () {
     lastFeedTab,
     setLastFeedTab,
     isSingleView,
-    setIsSingleView
+    setIsSingleView,
+    nostrQueries: new NostrQueries()
   }
 }
 

src/services/nostr-queries.js

@@ -0,0 +1,235 @@
+/**
+ *  Nostr class for query into relay pools
+ *
+ */
+import config from '../config'
+import { RelayPool } from 'nostr'
+import * as nip19 from 'nostr-tools/nip19'
+
+export default class NostrQueries {
+  constructor () {
+    this.relays = config.nostrRelays
+  }
+
+  npubToHex (npub) {
+    const pubHexData = nip19.decode(npub)
+    const pubHex = pubHexData.data
+    return pubHex
+  }
+
+  // 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.
+  async getProfile (pubHex) {
+    try {
+      for (let i = 0; i < this.relays.length; i++) {
+        const profile = await new Promise((resolve) => {
+          const relay = this.relays[i]
+          // const pool = RelayPool(config.nostrRelays)
+          const pool = RelayPool([relay])
+          pool.on('open', relay => {
+            relay.subscribe('subid', { limit: 5, kinds: [0], authors: [pubHex] })
+          })
+
+          pool.on('eose', 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 ${pubHex} at ${relay.url}`)
+              resolve(profile)
+            } catch (error) {
+              resolve(false)
+            }
+            relay.close()
+          })
+        })
+        // Stop looking for profile if found
+        if (profile) {
+          return profile
+        }
+      }
+    } catch (error) {
+      console.warn(error)
+    }
+  }
+
+  // Get Feeds by user pubkey
+  async getUserFeeds (pubHex) {
+    try {
+      let feeds = await new Promise((resolve) => {
+        let list = []
+        let closedRelays = 0
+
+        const pool = RelayPool(this.relays)
+
+        pool.on('open', relay => {
+          relay.subscribe('subid', { limit: 5, kinds: [1], authors: [pubHex] })
+        })
+
+        pool.on('eose', relay => {
+          relay.close()
+          closedRelays++
+          // Resolve list if all relays are closed
+          if (closedRelays === config.nostrRelays.length) {
+            resolve(list)
+          }
+        })
+
+        pool.on('event', (relay, subId, ev) => {
+          list = [...list, ev]
+        })
+      })
+      // Remove duplicated feeds
+      feeds = feeds.filter((val, i, list) => {
+        const existingIndex = list.findIndex(value => value.id === val.id)
+        return existingIndex === i
+      })
+
+      // Sort from newest to oldest
+      feeds.sort((a, b) => b.created_at - a.created_at)
+
+      return feeds
+    } catch (error) {
+      console.warn(error)
+    }
+  }
+
+  // Get global feeds
+  async getGlobalFeeds () {
+    try {
+      let feeds = await new Promise((resolve, reject) => {
+        let list = []
+        let closedRelays = 0
+
+        const pool = RelayPool(config.nostrRelays)
+        // const pool = RelayPool([config.nostrRelay])
+        pool.on('open', relay => {
+          relay.subscribe('REQ', { limit: 10, kinds: [1], '#t': ['slpdex-socialmedia'] })
+        })
+
+        pool.on('eose', relay => {
+          relay.close()
+          closedRelays++
+          // Resolve list if all relays are closed
+          if (closedRelays === config.nostrRelays.length) {
+            resolve(list)
+          }
+        })
+
+        pool.on('event', (relay, subId, ev) => {
+          // console.log('post retrieved from ', relay.url, ev.sig)
+          list = [...list, ev]
+        })
+      })
+
+      // Remove duplicated feeds
+      feeds = feeds.filter((val, i, list) => {
+        const existingIndex = list.findIndex(value => value.id === val.id)
+        return existingIndex === i
+      })
+
+      // Sort from newest to oldest
+      feeds.sort((a, b) => b.created_at - a.created_at)
+
+      // console.log('feeds', feeds)
+
+      return feeds
+    } catch (error) {
+      console.warn(error)
+    }
+  }
+
+  // Get follow list by pubkey
+  async getFollowList (pubHex) {
+    return new Promise((resolve, reject) => {
+      let list = []
+      let closedRelays = 0
+
+      const pool = RelayPool(config.nostrRelays)
+      // const pool = RelayPool([config.nostrRelay])
+      pool.on('open', relay => {
+        relay.subscribe('subid', { limit: 1, kinds: [3], authors: [pubHex] })
+      })
+
+      pool.on('eose', relay => {
+        relay.close()
+        closedRelays++
+        // Resolve list if all relays are closed
+        if (closedRelays === this.relays.length) {
+          resolve(list)
+        }
+      })
+
+      pool.on('event', (relay, subId, ev) => {
+        // console.log('Received event:', ev)
+        // Merge list received from all relays
+        list = [...list, ...ev.tags]
+      })
+    })
+  }
+
+  // Get event likes
+  async getPostLikes (postId) {
+    try {
+      let likesRes = await new Promise((resolve) => {
+        const likes = []
+        let closedRelays = 0
+
+        const pool = RelayPool(this.relays)
+        pool.on('open', relay => {
+          relay.subscribe('subid', { kinds: [7], '#e': [postId] })
+        })
+
+        pool.on('eose', relay => {
+          relay.close()
+          closedRelays++
+          // Resolve list if all relays are closed
+          if (closedRelays === this.relays.length) {
+            resolve(likes)
+          }
+        })
+
+        pool.on('event', (relay, subId, ev) => {
+          try {
+            // Count likes
+            if (ev.content === '+' || ev.content === '-') {
+              likes.push(ev)
+            }
+          } catch (error) {
+            // skip error
+          }
+        })
+      })
+
+      // Remove duplicated events
+      likesRes = likesRes.filter((val, i, list) => {
+        const existingIndex = list.findIndex(value => value.id === val.id)
+        return existingIndex === i
+      })
+      // Get likes
+      const likesArr = likesRes.filter((val, i, list) => {
+        return val.content === '+'
+      })
+
+      // Get dislikes
+      const dislikesArr = likesRes.filter((val, i, list) => {
+        return val.content === '-'
+      })
+      // For every user dislike remove a user like from the array
+      for (let i = 0; i < dislikesArr.length; i++) {
+        const disLike = dislikesArr[i]
+        const likeExist = likesArr.findIndex(val => val.pubkey === disLike.pubkey)
+        if (likeExist >= 0) likesArr.splice(likeExist, 1)
+      }
+      // Return array of likes.
+      return likesArr
+    } catch (error) {
+      console.warn(error)
+    }
+  }
+}