pipeline: Promise.all -> Promise.allSettled

This commit is contained in:
Alex Gleason 2024-10-15 16:27:48 -05:00
parent 45cf74c168
commit 8bf0a443db
No known key found for this signature in database
GPG key ID: 7211D1F99744FBB7

View file

@ -69,19 +69,18 @@ async function handleEvent(event: DittoEvent, signal: AbortSignal): Promise<void
await storeEvent(purifyEvent(event), signal);
} finally {
// This needs to run in steps, and should not block the API from responding.
Promise.all([
Promise.allSettled([
handleZaps(kysely, event),
parseMetadata(event, signal),
setLanguage(event),
generateSetEvents(event),
])
.then(() =>
Promise.all([
Promise.allSettled([
streamOut(event),
webPush(event),
])
)
.catch(console.warn);
);
}
}