Compare commits
No commits in common. "bc782c775a036894a8d1404611d9290d54dcf398" and "8ee6f98654c87c4a59ac4a0c58d01c48e79e1220" have entirely different histories.
bc782c775a
...
8ee6f98654
@ -8,7 +8,7 @@ import {
|
|||||||
} from '@nostr-dev-kit/ndk'
|
} from '@nostr-dev-kit/ndk'
|
||||||
import { useEffect, useState } from 'react'
|
import { useEffect, useState } from 'react'
|
||||||
import { CommentEvent, ModDetails, UserRelaysType } from 'types'
|
import { CommentEvent, ModDetails, UserRelaysType } from 'types'
|
||||||
import { log, LogType, timeout } from 'utils'
|
import { log, LogType } from 'utils'
|
||||||
import { useNDKContext } from './useNDKContext'
|
import { useNDKContext } from './useNDKContext'
|
||||||
|
|
||||||
export const useComments = (mod: ModDetails) => {
|
export const useComments = (mod: ModDetails) => {
|
||||||
@ -20,11 +20,7 @@ export const useComments = (mod: ModDetails) => {
|
|||||||
|
|
||||||
const setupSubscription = async () => {
|
const setupSubscription = async () => {
|
||||||
// Find the mod author's relays.
|
// Find the mod author's relays.
|
||||||
|
const authorReadRelays = await getRelayListForUser(mod.author, ndk)
|
||||||
const authorReadRelays = await Promise.race([
|
|
||||||
getRelayListForUser(mod.author, ndk),
|
|
||||||
timeout(10 * 1000) // add a 10 sec timeout
|
|
||||||
])
|
|
||||||
.then((ndkRelayList) => {
|
.then((ndkRelayList) => {
|
||||||
if (ndkRelayList) return ndkRelayList[UserRelaysType.Read]
|
if (ndkRelayList) return ndkRelayList[UserRelaysType.Read]
|
||||||
return [] // Return an empty array if ndkRelayList is undefined
|
return [] // Return an empty array if ndkRelayList is undefined
|
||||||
@ -44,21 +40,13 @@ export const useComments = (mod: ModDetails) => {
|
|||||||
'#a': [mod.aTag]
|
'#a': [mod.aTag]
|
||||||
}
|
}
|
||||||
|
|
||||||
const relayUrls = new Set<string>()
|
|
||||||
|
|
||||||
ndk.pool.urls().forEach((relayUrl) => {
|
|
||||||
relayUrls.add(relayUrl)
|
|
||||||
})
|
|
||||||
|
|
||||||
authorReadRelays.forEach((relayUrl) => relayUrls.add(relayUrl))
|
|
||||||
|
|
||||||
subscription = ndk.subscribe(
|
subscription = ndk.subscribe(
|
||||||
filter,
|
filter,
|
||||||
{
|
{
|
||||||
closeOnEose: false,
|
closeOnEose: false,
|
||||||
cacheUsage: NDKSubscriptionCacheUsage.CACHE_FIRST
|
cacheUsage: NDKSubscriptionCacheUsage.CACHE_FIRST
|
||||||
},
|
},
|
||||||
NDKRelaySet.fromRelayUrls(Array.from(relayUrls), ndk)
|
NDKRelaySet.fromRelayUrls(authorReadRelays, ndk, true)
|
||||||
)
|
)
|
||||||
|
|
||||||
subscription.on('event', (ndkEvent) => {
|
subscription.on('event', (ndkEvent) => {
|
||||||
|
Loading…
Reference in New Issue
Block a user