From 5539e5cf896d7aad0849e2ac8b002def6f513750 Mon Sep 17 00:00:00 2001 From: BilligsterUser Date: Mon, 6 Mar 2023 17:16:16 +0100 Subject: [PATCH] Pool: Sub use provided alreadyHaveEvent Fn --- pool.ts | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/pool.ts b/pool.ts index 18a9edb..e724845 100644 --- a/pool.ts +++ b/pool.ts @@ -30,7 +30,7 @@ export class SimplePool { if (existing && existing.status === 1) return existing if (existing) { - await existing.connect(); + await existing.connect() return existing } @@ -47,8 +47,9 @@ export class SimplePool { sub(relays: string[], filters: Filter[], opts?: SubscriptionOptions): Sub { let _knownIds: Set = new Set() - let modifiedOpts = opts || {} - modifiedOpts.alreadyHaveEvent = (id, url) => { + let modifiedOpts = {...opts || {}} + modifiedOpts.alreadyHaveEvent = (id, url) => { + if (opts?.alreadyHaveEvent?.(id, url)) { return true } let set = this._seenOn[id] || new Set() set.add(url) this._seenOn[id] = set