fix some important bugs so it is actually usable.
This commit is contained in:
parent
fc4ddad068
commit
d3d120cd7c
|
@ -1,6 +1,6 @@
|
|||
{
|
||||
"name": "nostr-tools",
|
||||
"version": "0.4.4",
|
||||
"version": "0.4.5",
|
||||
"description": "Tools for making a Nostr client.",
|
||||
"main": "index.js",
|
||||
"repository": {
|
||||
|
|
7
pool.js
7
pool.js
|
@ -25,11 +25,14 @@ export function relayPool(globalPrivateKey) {
|
|||
])
|
||||
)
|
||||
|
||||
const activeCallback = cb
|
||||
const activeFilters = filter
|
||||
|
||||
activeSubscriptions[id] = {
|
||||
sub: ({cb = cb, filter = filter}) =>
|
||||
sub: ({cb = activeCallback, filter = activeFilters}) =>
|
||||
Object.entries(subControllers).map(([relayURL, sub]) => [
|
||||
relayURL,
|
||||
sub({cb, filter}, id)
|
||||
sub.sub({cb, filter}, id)
|
||||
]),
|
||||
addRelay: relay => {
|
||||
subControllers[relay.url] = relay.sub({cb, filter})
|
||||
|
|
6
relay.js
6
relay.js
|
@ -118,8 +118,12 @@ export function relayConnect(url, onNotice) {
|
|||
channels[channel] = cb
|
||||
openSubs[channel] = filters
|
||||
|
||||
const activeCallback = cb
|
||||
const activeFilters = filters
|
||||
|
||||
return {
|
||||
sub: ({cb = cb, filter = filter}) => sub({cb, filter}, channel),
|
||||
sub: ({cb = activeCallback, filter = activeFilters}) =>
|
||||
sub({cb, filter}, channel),
|
||||
unsub: () => {
|
||||
delete openSubs[channel]
|
||||
delete channels[channel]
|
||||
|
|
Loading…
Reference in New Issue