Auto close negentropy requests
This commit is contained in:
@@ -80,6 +80,8 @@ export class Difference extends EventEmitter {
|
|||||||
|
|
||||||
if (newMsg) {
|
if (newMsg) {
|
||||||
this._adapter.send([RelayMessageType.NegMsg, this._id, newMsg])
|
this._adapter.send([RelayMessageType.NegMsg, this._id, newMsg])
|
||||||
|
} else {
|
||||||
|
this.close()
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -89,6 +91,7 @@ export class Difference extends EventEmitter {
|
|||||||
|
|
||||||
if (negid === this._id) {
|
if (negid === this._id) {
|
||||||
this.emit(DifferenceEvent.Error, msg, url)
|
this.emit(DifferenceEvent.Error, msg, url)
|
||||||
|
this.close()
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
@@ -141,12 +144,10 @@ export const diff = async ({relays, filters, ...options}: DiffOptions) => {
|
|||||||
})
|
})
|
||||||
|
|
||||||
diff.on(DifferenceEvent.Error, (url, message) => {
|
diff.on(DifferenceEvent.Error, (url, message) => {
|
||||||
reject(message)
|
console.warn(`Negentropy error on ${url}: ${message}`)
|
||||||
diff.close()
|
|
||||||
})
|
})
|
||||||
|
|
||||||
sleep(30_000).then(() => {
|
sleep(30_000).then(() => {
|
||||||
reject("timeout")
|
|
||||||
diff.close()
|
diff.close()
|
||||||
})
|
})
|
||||||
}),
|
}),
|
||||||
|
|||||||
Reference in New Issue
Block a user