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

wait ack

Browse source
This commit is contained in:
hatim boufnichel 2021-07-31 19:30:04 +02:00
parent 7696450896
commit 812e03b135
1 changed files with 34 additions and 15 deletions
Download patch file Download diff file Expand all files Collapse all files

29
services/gunDB/contact-api/jobs/lastSeenNode.js
View file

@ -29,24 +29,43 @@ const lastSeenNode = user => {
logger.warn('onOrders() -> tried to sub without authing') logger.warn('onOrders() -> tried to sub without authing')
throw new Error(ErrorCode.NOT_AUTH) throw new Error(ErrorCode.NOT_AUTH)
} }
let gotLatestUserAck = true
let gotLatestProfileAck = true
setInterval(() => { setInterval(() => {
if (user.is) { if (!user.is) {
return
}
if (!gotLatestUserAck) {
logger.error(`lastSeenNode user job: didnt get latest ack`)
return
}
gotLatestUserAck = false
user.get(Key.LAST_SEEN_NODE).put(Date.now(), ack => { user.get(Key.LAST_SEEN_NODE).put(Date.now(), ack => {
if (ack.err && typeof ack.err !== 'number') { if (ack.err && typeof ack.err !== 'number') {
logger.error(`Error inside lastSeenNode job: ${ack.err}`) logger.error(`Error inside lastSeenNode user job: ${ack.err}`)
} }
gotLatestUserAck = true
}) })
}, LAST_SEEN_NODE_INTERVAL)
setInterval(() => {
if (!user.is) {
return
}
if (!gotLatestProfileAck) {
logger.error(`lastSeenNode profile job: didnt get latest ack`)
return
}
gotLatestProfileAck = false
user user
.get(Key.PROFILE) .get(Key.PROFILE)
.get(Key.LAST_SEEN_NODE) .get(Key.LAST_SEEN_NODE)
.put(Date.now(), ack => { .put(Date.now(), ack => {
if (ack.err && typeof ack.err !== 'number') { if (ack.err && typeof ack.err !== 'number') {
logger.error(`Error inside lastSeenNode job: ${ack.err}`) logger.error(`Error inside lastSeenNode profile job: ${ack.err}`)
} }
gotLatestProfileAck = true
}) })
}
}, LAST_SEEN_NODE_INTERVAL) }, LAST_SEEN_NODE_INTERVAL)
} }