aiolabs/lightning-pub
2
0
Fork 0
Code Issues 9 Pull requests 4 Projects Releases Packages Wiki Activity Actions

parallel

Browse source
This commit is contained in:
Daniel Lugo 2020-01-28 22:16:47 -04:00
parent b72604075f
commit 2eac1eaaf7
1 changed files with 51 additions and 49 deletions
Download patch file Download diff file Expand all files Collapse all files

100
services/gunDB/contact-api/actions.js
View file

@ -1061,59 +1061,61 @@ const disconnect = async pub => {
pub pub
)) ))
await new Promise((res, rej) => { await Promise.all([
user new Promise((res, rej) => {
.get(Key.USER_TO_INCOMING) user
.get(pub) .get(Key.USER_TO_INCOMING)
.put(null, ack => { .get(pub)
if (ack.err) { .put(null, ack => {
rej(new Error(ack.err)) if (ack.err) {
} else { rej(new Error(ack.err))
res() } else {
} res()
}) }
}) })
}),
await new Promise((res, rej) => { new Promise((res, rej) => {
user user
.get(Key.RECIPIENT_TO_OUTGOING) .get(Key.RECIPIENT_TO_OUTGOING)
.get(pub) .get(pub)
.put(null, ack => { .put(null, ack => {
if (ack.err) { if (ack.err) {
rej(new Error(ack.err)) rej(new Error(ack.err))
} else { } else {
res() res()
} }
}) })
}) }),
await new Promise((res, rej) => { new Promise((res, rej) => {
user user
.get(Key.USER_TO_LAST_REQUEST_SENT) .get(Key.USER_TO_LAST_REQUEST_SENT)
.get(pub) .get(pub)
.put(null, ack => { .put(null, ack => {
if (ack.err) { if (ack.err) {
rej(new Error(ack.err)) rej(new Error(ack.err))
} else { } else {
res() res()
} }
}) })
}) }),
await new Promise((res, rej) => { new Promise((res, rej) => {
user user
.get(Key.OUTGOINGS) .get(Key.OUTGOINGS)
.get(outGoingID) .get(outGoingID)
.put(null, ack => { .put(null, ack => {
if (ack.err) { if (ack.err) {
rej(new Error(ack.err)) rej(new Error(ack.err))
} else { } else {
res() res()
} }
}) })
}) }),
await generateHandshakeAddress(require('../Mediator').getUser()) await generateHandshakeAddress(require('../Mediator').getUser())
])
} }
module.exports = { module.exports = {