highperfocused/nostr-react
1
0
Fork 0
mirror of https://github.com/t4t5/nostr-react.git synced 2025-09-17 21:20:29 +02:00
Code Issues Packages Projects Releases Wiki Activity

Working unsubscribe function

Browse Source
This commit is contained in:
Tristan Edwards
2022-12-26 13:52:27 +01:00
parent 54e611e362
commit 1f5db629b8
1 changed files with 7 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
src/index.tsx
View File

@@ -123,6 +123,9 @@ export function useNostr() {
export function useNostrEvents({ filter }: { filter: Filter }) { export function useNostrEvents({ filter }: { filter: Filter }) {
const { isLoading, onConnect, debug, connectedRelays } = useNostr() const { isLoading, onConnect, debug, connectedRelays } = useNostr()
const [events, setEvents] = useState<NostrEvent[]>([]) const [events, setEvents] = useState<NostrEvent[]>([])
const [unsubscribe, setUnsubscribe] = useState(() => {
return
})
let onEventCallback: null | OnEventFunc = null let onEventCallback: null | OnEventFunc = null
@@ -130,19 +133,17 @@ export function useNostrEvents({ filter }: { filter: Filter }) {
const filterBase64 = const filterBase64 =
typeof window !== "undefined" ? window.btoa(JSON.stringify(filter)) : null typeof window !== "undefined" ? window.btoa(JSON.stringify(filter)) : null
let unsubscribe = () => {
return
}
const subscribe = (relay: Relay) => { const subscribe = (relay: Relay) => {
log(debug, "info", "⬆️ nostr: Subscribing to filter:", filter) log(debug, "info", "⬆️ nostr: Subscribing to filter:", filter)
const sub = relay.sub([filter]) const sub = relay.sub([filter])
unsubscribe = () => { const unsubscribeFunc = () => {
log(debug, "info", "✌️ nostr: Unsubscribing from filter:", filter) log(debug, "info", "🚪 nostr: Unsubscribing from filter:", filter)
return sub.unsub() return sub.unsub()
} }
setUnsubscribe(() => unsubscribeFunc)
sub.on("event", (event: NostrEvent) => { sub.on("event", (event: NostrEvent) => {
log(debug, "info", "⬇️ nostr: Received event:", event) log(debug, "info", "⬇️ nostr: Received event:", event)
onEventCallback?.(event) onEventCallback?.(event)