nostr/coracle
1
0
Fork 0
mirror of https://github.com/coracle-social/coracle.git synced 2024-09-15 17:53:36 +00:00
Code Issues Packages Projects Releases Wiki Activity

optimize deduplication.

Browse Source
This commit is contained in:
fiatjaf 2023-03-01 16:39:18 -03:00 committed by Jonathan Staab
parent 1188dc55be
commit 1e270b52aa
1 changed files with 10 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
src/agent/pool.ts
View File

@ -263,17 +263,20 @@ const subscribe = async (
return
}
const sub = conn.nostr.sub(filter, {id})
const sub = conn.nostr.sub(filter, {
id,
alreadyHaveEvent: (id) => {
conn.stats.eventsCount += 1
let has = false
if (seen.has(id)) has = true
seen.add(id)
return has
}
})
sub.on('event', e => {
conn.stats.eventsCount += 1
if (!seen.has(e.id)) {
seen.add(e.id)
// Normalize events here, annotate with relay url
onEvent({...e, seen_on: relay.url, content: e.content || ''})
}
})
sub.on('eose', () => {