insert/rubberguppe
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

set delivery request timeout, handle rejections in startDelivery

Browse source
This commit is contained in:
Will Murphy 2022-11-09 10:40:43 -06:00
parent 725346186b
commit 1ad8ee1397
1 changed files with 14 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
deliveryWorker.js
View file

@ -28,6 +28,7 @@ const apex = ActivitypubExpress({
actorParam: 'actor', actorParam: 'actor',
objectParam: 'id', objectParam: 'id',
itemsPerPage: 100, itemsPerPage: 100,
requestTimeout: 500,
routes routes
}) })
@ -37,16 +38,26 @@ client.connect()
let resumeDeliveryTimer let resumeDeliveryTimer
function deliver () { function deliver () {
apex.startDelivery() apex.startDelivery()
.catch(err => {
console.error('Error starting delivery', err)
})
.finally(() => {
// delivery will stop if the queue empties, ensure it keeps running when new work is available // delivery will stop if the queue empties, ensure it keeps running when new work is available
// no effect if called while already running // no effect if called while already running
resumeDeliveryTimer = setTimeout(deliver, 5000) resumeDeliveryTimer = setTimeout(deliver, 5000)
})
} }
deliver() deliver()
onShutdown(async () => { onShutdown(async () => {
clearTimeout(resumeDeliveryTimer) clearTimeout(resumeDeliveryTimer)
apex.offlineMode = true
// time for last delivery to finish (need to fix in apex) // time for last delivery to finish (need to fix in apex)
await new Promise(resolve => setTimeout(resolve, 3000)) await new Promise(resolve => setTimeout(resolve, 3000))
await client.close() await client.close()
console.log('Guppe delivery worker closed') console.log('Guppe delivery worker closed')
}) })
}) })
.catch(err => {
console.error('Error starting delivery worker', err)
process.exit(1)
})