codytseng
7 months ago
1 changed files with 0 additions and 303 deletions
@ -1,303 +0,0 @@ |
|||||||
import { BIG_RELAY_URLS, ExtendedKind } from '@/constants' |
|
||||||
import { isReplyNoteEvent } from '@/lib/event' |
|
||||||
import { checkAlgoRelay } from '@/lib/relay' |
|
||||||
import { isSafari } from '@/lib/utils' |
|
||||||
import { useMuteList } from '@/providers/MuteListProvider' |
|
||||||
import { useNostr } from '@/providers/NostrProvider' |
|
||||||
import { useUserTrust } from '@/providers/UserTrustProvider' |
|
||||||
import client from '@/services/client.service' |
|
||||||
import storage from '@/services/local-storage.service' |
|
||||||
import relayInfoService from '@/services/relay-info.service' |
|
||||||
import { TNoteListMode } from '@/types' |
|
||||||
import dayjs from 'dayjs' |
|
||||||
import { Event, Filter, kinds } from 'nostr-tools' |
|
||||||
import { useEffect, useMemo, useRef, useState } from 'react' |
|
||||||
import NoteList, { TNoteListRef } from '../NoteList' |
|
||||||
import Tabs from '../Tabs' |
|
||||||
|
|
||||||
const LIMIT = 100 |
|
||||||
const ALGO_LIMIT = 500 |
|
||||||
const KINDS = [ |
|
||||||
kinds.ShortTextNote, |
|
||||||
kinds.Repost, |
|
||||||
kinds.Highlights, |
|
||||||
kinds.LongFormArticle, |
|
||||||
ExtendedKind.COMMENT, |
|
||||||
ExtendedKind.POLL, |
|
||||||
ExtendedKind.VOICE, |
|
||||||
ExtendedKind.VOICE_COMMENT, |
|
||||||
ExtendedKind.PICTURE |
|
||||||
] |
|
||||||
|
|
||||||
export default function Feed({ |
|
||||||
relayUrls = [], |
|
||||||
filter = {}, |
|
||||||
author, |
|
||||||
className, |
|
||||||
filterMutedNotes = true, |
|
||||||
needCheckAlgoRelay = false, |
|
||||||
isMainFeed = false, |
|
||||||
topSpace = 0, |
|
||||||
skipTrustCheck = false |
|
||||||
}: { |
|
||||||
relayUrls?: string[] |
|
||||||
filter?: Filter |
|
||||||
author?: string |
|
||||||
className?: string |
|
||||||
filterMutedNotes?: boolean |
|
||||||
needCheckAlgoRelay?: boolean |
|
||||||
isMainFeed?: boolean |
|
||||||
topSpace?: number |
|
||||||
skipTrustCheck?: boolean |
|
||||||
}) { |
|
||||||
const { pubkey, startLogin } = useNostr() |
|
||||||
const { mutePubkeys } = useMuteList() |
|
||||||
const [refreshCount, setRefreshCount] = useState(0) |
|
||||||
const [timelineKey, setTimelineKey] = useState<string | undefined>(undefined) |
|
||||||
const [events, setEvents] = useState<Event[]>([]) |
|
||||||
const [newEvents, setNewEvents] = useState<Event[]>([]) |
|
||||||
const [hasMore, setHasMore] = useState<boolean>(true) |
|
||||||
const [loading, setLoading] = useState(true) |
|
||||||
const [listMode, setListMode] = useState<TNoteListMode>(() => |
|
||||||
isMainFeed ? storage.getNoteListMode() : 'posts' |
|
||||||
) |
|
||||||
const [filterType, setFilterType] = useState<Exclude<TNoteListMode, 'postsAndReplies'>>('posts') |
|
||||||
const noteListRef = useRef<TNoteListRef | null>(null) |
|
||||||
const { isUserTrusted, hideUntrustedNotes } = useUserTrust() |
|
||||||
const filteredNewEvents = useMemo(() => { |
|
||||||
return newEvents.filter((event: Event) => { |
|
||||||
return ( |
|
||||||
(!filterMutedNotes || !mutePubkeys.includes(event.pubkey)) && |
|
||||||
(listMode !== 'posts' || !isReplyNoteEvent(event)) && |
|
||||||
(skipTrustCheck || !hideUntrustedNotes || isUserTrusted(event.pubkey)) |
|
||||||
) |
|
||||||
}) |
|
||||||
}, [newEvents, listMode, filterMutedNotes, mutePubkeys, hideUntrustedNotes]) |
|
||||||
|
|
||||||
useEffect(() => { |
|
||||||
switch (listMode) { |
|
||||||
case 'posts': |
|
||||||
case 'postsAndReplies': |
|
||||||
setFilterType('posts') |
|
||||||
break |
|
||||||
case 'you': |
|
||||||
if (!pubkey || pubkey === author) { |
|
||||||
setFilterType('posts') |
|
||||||
} else { |
|
||||||
setFilterType('you') |
|
||||||
} |
|
||||||
break |
|
||||||
} |
|
||||||
}, [listMode, pubkey]) |
|
||||||
|
|
||||||
useEffect(() => { |
|
||||||
if (relayUrls.length === 0 && !filter.authors?.length && !author) return |
|
||||||
|
|
||||||
async function init() { |
|
||||||
setLoading(true) |
|
||||||
setEvents([]) |
|
||||||
setNewEvents([]) |
|
||||||
setHasMore(true) |
|
||||||
|
|
||||||
let areAlgoRelays = false |
|
||||||
const subRequests: { |
|
||||||
urls: string[] |
|
||||||
filter: Omit<Filter, 'since' | 'until'> & { limit: number } |
|
||||||
}[] = [] |
|
||||||
if (filterType === 'you' && author && pubkey && pubkey !== author) { |
|
||||||
const [myRelayList, targetRelayList] = await Promise.all([ |
|
||||||
client.fetchRelayList(pubkey), |
|
||||||
client.fetchRelayList(author) |
|
||||||
]) |
|
||||||
subRequests.push({ |
|
||||||
urls: myRelayList.write.concat(BIG_RELAY_URLS).slice(0, 5), |
|
||||||
filter: { |
|
||||||
kinds: KINDS, |
|
||||||
authors: [pubkey], |
|
||||||
'#p': [author], |
|
||||||
limit: LIMIT |
|
||||||
} |
|
||||||
}) |
|
||||||
subRequests.push({ |
|
||||||
urls: targetRelayList.write.concat(BIG_RELAY_URLS).slice(0, 5), |
|
||||||
filter: { |
|
||||||
kinds: KINDS, |
|
||||||
authors: [author], |
|
||||||
'#p': [pubkey], |
|
||||||
limit: LIMIT |
|
||||||
} |
|
||||||
}) |
|
||||||
} else { |
|
||||||
if (needCheckAlgoRelay) { |
|
||||||
const relayInfos = await relayInfoService.getRelayInfos(relayUrls) |
|
||||||
areAlgoRelays = relayInfos.every((relayInfo) => checkAlgoRelay(relayInfo)) |
|
||||||
} |
|
||||||
const _filter = { |
|
||||||
...filter, |
|
||||||
kinds: KINDS, |
|
||||||
limit: areAlgoRelays ? ALGO_LIMIT : LIMIT |
|
||||||
} |
|
||||||
if (relayUrls.length === 0 && (_filter.authors?.length || author)) { |
|
||||||
if (!_filter.authors?.length) { |
|
||||||
_filter.authors = [author!] |
|
||||||
} |
|
||||||
|
|
||||||
// If many websocket connections are initiated simultaneously, it will be
|
|
||||||
// very slow on Safari (for unknown reason)
|
|
||||||
if ((_filter.authors?.length ?? 0) > 5 && isSafari()) { |
|
||||||
if (!pubkey) { |
|
||||||
subRequests.push({ urls: BIG_RELAY_URLS, filter: _filter }) |
|
||||||
} else { |
|
||||||
const relayList = await client.fetchRelayList(pubkey) |
|
||||||
const urls = relayList.read.concat(BIG_RELAY_URLS).slice(0, 5) |
|
||||||
subRequests.push({ urls, filter: _filter }) |
|
||||||
} |
|
||||||
} else { |
|
||||||
const relayLists = await client.fetchRelayLists(_filter.authors) |
|
||||||
const group: Record<string, Set<string>> = {} |
|
||||||
relayLists.forEach((relayList, index) => { |
|
||||||
relayList.write.slice(0, 4).forEach((url) => { |
|
||||||
if (!group[url]) { |
|
||||||
group[url] = new Set() |
|
||||||
} |
|
||||||
group[url].add(_filter.authors![index]) |
|
||||||
}) |
|
||||||
}) |
|
||||||
|
|
||||||
const relayCount = Object.keys(group).length |
|
||||||
const coveredCount = new Map<string, number>() |
|
||||||
Object.entries(group) |
|
||||||
.sort(([, a], [, b]) => b.size - a.size) |
|
||||||
.forEach(([url, pubkeys]) => { |
|
||||||
if ( |
|
||||||
relayCount > 10 && |
|
||||||
pubkeys.size < 10 && |
|
||||||
Array.from(pubkeys).every((pubkey) => (coveredCount.get(pubkey) ?? 0) >= 2) |
|
||||||
) { |
|
||||||
delete group[url] |
|
||||||
} else { |
|
||||||
pubkeys.forEach((pubkey) => { |
|
||||||
coveredCount.set(pubkey, (coveredCount.get(pubkey) ?? 0) + 1) |
|
||||||
}) |
|
||||||
} |
|
||||||
}) |
|
||||||
|
|
||||||
subRequests.push( |
|
||||||
...Object.entries(group).map(([url, authors]) => ({ |
|
||||||
urls: [url], |
|
||||||
filter: { ..._filter, authors: Array.from(authors) } |
|
||||||
})) |
|
||||||
) |
|
||||||
} |
|
||||||
} else { |
|
||||||
subRequests.push({ urls: relayUrls, filter: _filter }) |
|
||||||
} |
|
||||||
} |
|
||||||
|
|
||||||
const { closer, timelineKey } = await client.subscribeTimeline( |
|
||||||
subRequests, |
|
||||||
{ |
|
||||||
onEvents: (events, eosed) => { |
|
||||||
if (events.length > 0) { |
|
||||||
setEvents(events) |
|
||||||
} |
|
||||||
if (areAlgoRelays) { |
|
||||||
setHasMore(false) |
|
||||||
} |
|
||||||
if (eosed) { |
|
||||||
setLoading(false) |
|
||||||
setHasMore(events.length > 0) |
|
||||||
} |
|
||||||
}, |
|
||||||
onNew: (event) => { |
|
||||||
setNewEvents((oldEvents) => |
|
||||||
[event, ...oldEvents].sort((a, b) => b.created_at - a.created_at) |
|
||||||
) |
|
||||||
} |
|
||||||
}, |
|
||||||
{ |
|
||||||
startLogin, |
|
||||||
needSort: !areAlgoRelays |
|
||||||
} |
|
||||||
) |
|
||||||
setTimelineKey(timelineKey) |
|
||||||
return closer |
|
||||||
} |
|
||||||
|
|
||||||
const promise = init() |
|
||||||
return () => { |
|
||||||
promise.then((closer) => closer()) |
|
||||||
} |
|
||||||
}, [JSON.stringify(relayUrls), filterType, refreshCount, JSON.stringify(filter)]) |
|
||||||
|
|
||||||
const loadMore = async () => { |
|
||||||
if (!timelineKey) return |
|
||||||
setLoading(true) |
|
||||||
const newEvents = await client.loadMoreTimeline( |
|
||||||
timelineKey, |
|
||||||
events.length ? events[events.length - 1].created_at - 1 : dayjs().unix(), |
|
||||||
LIMIT |
|
||||||
) |
|
||||||
setLoading(false) |
|
||||||
if (newEvents.length === 0) { |
|
||||||
setHasMore(false) |
|
||||||
return |
|
||||||
} |
|
||||||
setEvents((oldEvents) => [...oldEvents, ...newEvents]) |
|
||||||
} |
|
||||||
|
|
||||||
const showNewEvents = () => { |
|
||||||
setEvents((oldEvents) => [...newEvents, ...oldEvents]) |
|
||||||
setNewEvents([]) |
|
||||||
setTimeout(() => { |
|
||||||
noteListRef.current?.scrollToTop() |
|
||||||
}, 0) |
|
||||||
} |
|
||||||
|
|
||||||
return ( |
|
||||||
<div className={className}> |
|
||||||
<Tabs |
|
||||||
value={listMode} |
|
||||||
tabs={ |
|
||||||
pubkey && author && pubkey !== author |
|
||||||
? [ |
|
||||||
{ value: 'posts', label: 'Notes' }, |
|
||||||
{ value: 'postsAndReplies', label: 'Replies' }, |
|
||||||
{ value: 'you', label: 'YouTabName' } |
|
||||||
] |
|
||||||
: [ |
|
||||||
{ value: 'posts', label: 'Notes' }, |
|
||||||
{ value: 'postsAndReplies', label: 'Replies' } |
|
||||||
] |
|
||||||
} |
|
||||||
onTabChange={(listMode) => { |
|
||||||
setListMode(listMode as TNoteListMode) |
|
||||||
if (isMainFeed) { |
|
||||||
storage.setNoteListMode(listMode as TNoteListMode) |
|
||||||
} |
|
||||||
setTimeout(() => { |
|
||||||
noteListRef.current?.scrollToTop() |
|
||||||
}, 0) |
|
||||||
}} |
|
||||||
threshold={Math.max(800, topSpace)} |
|
||||||
/> |
|
||||||
<NoteList |
|
||||||
ref={noteListRef} |
|
||||||
events={events.filter( |
|
||||||
(event: Event) => |
|
||||||
(listMode !== 'posts' || !isReplyNoteEvent(event)) && |
|
||||||
(skipTrustCheck || !hideUntrustedNotes || isUserTrusted(event.pubkey)) |
|
||||||
)} |
|
||||||
hasMore={hasMore} |
|
||||||
loading={loading} |
|
||||||
loadMore={loadMore} |
|
||||||
filterMutedNotes={filterMutedNotes} |
|
||||||
onRefresh={() => { |
|
||||||
setRefreshCount((count) => count + 1) |
|
||||||
}} |
|
||||||
newEvents={filteredNewEvents} |
|
||||||
showNewEvents={showNewEvents} |
|
||||||
/> |
|
||||||
</div> |
|
||||||
) |
|
||||||
} |
|
||||||
Loading…
Reference in new issue