highperfocused/nostrudel
1
0
Fork 0
mirror of https://github.com/hzrd149/nostrudel.git synced 2025-09-22 23:22:27 +02:00
Code Issues Packages Projects Releases Wiki Activity

fix showing duplicate streams

Browse Source
This commit is contained in:
hzrd149
2023-07-04 13:09:13 -05:00
parent e9685035b6
commit 5a20698f87
1 changed files with 8 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
src/views/streams/index.tsx
View File

@@ -6,7 +6,7 @@ import IntersectionObserverProvider from "../../providers/intersection-observer"
import { useTimelineCurserIntersectionCallback } from "../../hooks/use-timeline-cursor-intersection-callback"; import { useTimelineCurserIntersectionCallback } from "../../hooks/use-timeline-cursor-intersection-callback";
import useSubject from "../../hooks/use-subject"; import useSubject from "../../hooks/use-subject";
import StreamCard from "./components/stream-card"; import StreamCard from "./components/stream-card";
import { ParsedStream, parseStreamEvent } from "../../helpers/nostr/stream"; import { ParsedStream, getATag, parseStreamEvent } from "../../helpers/nostr/stream";
import { NostrEvent } from "../../types/nostr-event"; import { NostrEvent } from "../../types/nostr-event";
export default function LiveStreamsTab() { export default function LiveStreamsTab() {
@@ -29,13 +29,17 @@ export default function LiveStreamsTab() {
const events = useSubject(timeline.timeline); const events = useSubject(timeline.timeline);
const streams = useMemo(() => { const streams = useMemo(() => {
const parsed: ParsedStream[] = []; const parsedStreams: Record<string, ParsedStream> = {};
for (const event of events) { for (const event of events) {
try { try {
parsed.push(parseStreamEvent(event)); const parsed = parseStreamEvent(event);
const aTag = getATag(parsed);
if (!parsedStreams[aTag] || parsed.event.created_at > parsedStreams[aTag].event.created_at) {
parsedStreams[aTag] = parsed;
}
} catch (e) {} } catch (e) {}
} }
return parsed.sort((a, b) => b.updated - a.updated); return Array.from(Object.values(parsedStreams)).sort((a, b) => b.updated - a.updated);
}, [events]); }, [events]);
return ( return (