mirror of
https://github.com/nbd-wtf/nostr-tools.git
synced 2025-12-08 16:28:49 +00:00
Compare commits
1 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
4f0cae0eb8 |
@@ -1,6 +1,6 @@
|
|||||||
{
|
{
|
||||||
"name": "nostr-tools",
|
"name": "nostr-tools",
|
||||||
"version": "0.9.0",
|
"version": "0.9.1",
|
||||||
"description": "Tools for making a Nostr client.",
|
"description": "Tools for making a Nostr client.",
|
||||||
"repository": {
|
"repository": {
|
||||||
"type": "git",
|
"type": "git",
|
||||||
|
|||||||
4
pool.js
4
pool.js
@@ -21,7 +21,7 @@ export function relayPool(globalPrivateKey) {
|
|||||||
.filter(({policy}) => policy.read)
|
.filter(({policy}) => policy.read)
|
||||||
.map(({relay}) => [
|
.map(({relay}) => [
|
||||||
relay.url,
|
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]
|
return activeSubscriptions[id]
|
||||||
},
|
},
|
||||||
addRelay: relay => {
|
addRelay: relay => {
|
||||||
subControllers[relay.url] = relay.sub({cb, filter})
|
subControllers[relay.url] = relay.sub({cb, filter}, id)
|
||||||
return activeSubscriptions[id]
|
return activeSubscriptions[id]
|
||||||
},
|
},
|
||||||
removeRelay: relayURL => {
|
removeRelay: relayURL => {
|
||||||
|
|||||||
7
relay.js
7
relay.js
@@ -145,12 +145,15 @@ export function relayConnect(url, onNotice) {
|
|||||||
try {
|
try {
|
||||||
await trySend(['EVENT', event])
|
await trySend(['EVENT', event])
|
||||||
statusCallback(0)
|
statusCallback(0)
|
||||||
let {unsub} = relay.sub({
|
let {unsub} = relay.sub(
|
||||||
|
{
|
||||||
cb: () => {
|
cb: () => {
|
||||||
statusCallback(1)
|
statusCallback(1)
|
||||||
},
|
},
|
||||||
filter: {id: event.id}
|
filter: {id: event.id}
|
||||||
})
|
},
|
||||||
|
`monitor-${event.id.slice(0, 5)}`
|
||||||
|
)
|
||||||
setTimeout(unsub, 5000)
|
setTimeout(unsub, 5000)
|
||||||
} catch (err) {
|
} catch (err) {
|
||||||
statusCallback(-1)
|
statusCallback(-1)
|
||||||
|
|||||||
Reference in New Issue
Block a user