diff --git a/src/agent/pool.ts b/src/agent/pool.ts index 89e1c3e9..a8048a1e 100644 --- a/src/agent/pool.ts +++ b/src/agent/pool.ts @@ -181,10 +181,10 @@ const subscribe = async (relays, filters, {onEvent, onEose}: Record[]> => { +const request = (relays, filters, {threshold = 0.5} = {}): Promise[]> => { return new Promise(async resolve => { relays = uniqBy(prop('url'), relays.filter(r => isRelay(r.url))) - threshold = Math.min(relays.length, threshold) + threshold = relays.length * threshold const now = Date.now() const relaysWithEvents = new Set() diff --git a/src/app/alerts.js b/src/app/alerts.js index 9c1d32d7..ac1b255d 100644 --- a/src/app/alerts.js +++ b/src/app/alerts.js @@ -37,7 +37,7 @@ const load = async (relays, pubkey) => { const events = await _load( relays, {kinds: [1, 7], '#p': [pubkey], since, limit: 1000}, - {threshold: 10} + {threshold: 0.9} ) onChunk(relays, pubkey, events) @@ -53,8 +53,7 @@ const listen = async (relays, pubkey) => { {kinds: [1, 7], '#p': [pubkey], since: now()}, batch(300, events => { onChunk(relays, pubkey, events) - }), - {threshold: 2} + }) ) }