add missing id arguments.

This commit is contained in:
fiatjaf
2021-12-13 21:21:26 -03:00
parent 06e867b675
commit 4f0cae0eb8
3 changed files with 11 additions and 8 deletions

View File

@@ -21,7 +21,7 @@ export function relayPool(globalPrivateKey) {
.filter(({policy}) => policy.read)
.map(({relay}) => [
relay.url,
relay.sub({filter, cb: event => cb(event, relay.url)})
relay.sub({filter, cb: event => cb(event, relay.url)}, id)
])
)
@@ -37,7 +37,7 @@ export function relayPool(globalPrivateKey) {
return activeSubscriptions[id]
},
addRelay: relay => {
subControllers[relay.url] = relay.sub({cb, filter})
subControllers[relay.url] = relay.sub({cb, filter}, id)
return activeSubscriptions[id]
},
removeRelay: relayURL => {