nostr/coracle
1
0
Fork 0
mirror of https://github.com/coracle-social/coracle.git synced 2024-09-18 19:23:40 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix subscription completion condition

Browse Source
This commit is contained in:
Jonathan Staab 2023-02-04 14:22:40 -06:00
parent 9cc50e1894
commit 658911ce9f
1 changed files with 11 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/agent/pool.ts
View File

@ -189,7 +189,17 @@ const request = (relays, filters, {threshold = 1} = {}): Promise<Record<string,
const eose = []
const attemptToComplete = () => {
if (eose.length >= threshold || Date.now() - now >= 5000) {
const done = (
eose.length === relays.length
|| eose.filter(url => relaysWithEvents.has(url)).length >= threshold
|| (
Date.now() - now >= 1000
&& eose.length > relays.length - Math.round(relays.length / 10)
)
|| Date.now() - now >= 5000
)
if (done) {
agg.unsub()
resolve(events)
}