adds closed reply

This commit is contained in:
Vitor Pamplona 2024-01-28 14:21:39 -05:00
parent ffe7776345
commit 5ce8fe83d2

View File

@ -213,7 +213,6 @@ const fetchFromRelay = async (relay, filters, pubkey, events, relayStatus) =>
signNostrAuthEvent(relay, subscriptionId).then( signNostrAuthEvent(relay, subscriptionId).then(
(event) => { (event) => {
if (event) { if (event) {
console.log("AUTH", JSON.stringify(['EVENT', event]))
ws.send(JSON.stringify(['EVENT', event])) ws.send(JSON.stringify(['EVENT', event]))
} else { } else {
updateRelayStatus(relay, "AUTH Req", 0, undefined, relayStatus) updateRelayStatus(relay, "AUTH Req", 0, undefined, relayStatus)
@ -229,6 +228,17 @@ const fetchFromRelay = async (relay, filters, pubkey, events, relayStatus) =>
) )
} }
if (msgType === 'CLOSED') {
subscriptions[subscriptionId].done = true
let alldone = Object.values(subscriptions).every(filter => filter.done === true);
if (alldone) {
updateRelayStatus(relay, "Done", 0, undefined, relayStatus)
ws.close()
resolve(relay)
}
}
if (msgType === 'OK') { if (msgType === 'OK') {
// auth ok. // auth ok.
for (const [key, sub] of Object.entries(subscriptions)) { for (const [key, sub] of Object.entries(subscriptions)) {