From 225e0aaf88a396bf308c2e5eed0bb6e130cb2d64 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Karol=20S=C3=B3jko?= Date: Tue, 13 Dec 2022 12:12:36 +0100 Subject: [PATCH] fix(syncing-server): logs on revisions procedure --- packages/syncing-server/bin/revisions.ts | 16 +++++++++++++--- 1 file changed, 13 insertions(+), 3 deletions(-) diff --git a/packages/syncing-server/bin/revisions.ts b/packages/syncing-server/bin/revisions.ts index 069677989..6d1d759d9 100644 --- a/packages/syncing-server/bin/revisions.ts +++ b/packages/syncing-server/bin/revisions.ts @@ -24,7 +24,7 @@ const fixRevisionsOwnership = async ( const createdAfter = new Date(`${year}-${month}-1`) const createdBefore = new Date(`${month !== 12 ? year : year + 1}-${month !== 12 ? month + 1 : 1}-1`) - logger.info(`Processing items between ${createdAfter.toISOString} and ${createdBefore.toISOString}`) + logger.info(`Processing items between ${createdAfter.toISOString()} and ${createdBefore.toISOString()}`) const stream = await itemRepository.streamAll({ createdBetween: [createdAfter, createdBefore], @@ -60,11 +60,21 @@ const fixRevisionsOwnership = async ( }), ) .on('finish', () => { - logger.info(`Finished processing items between ${createdAfter.toISOString} and ${createdBefore.toISOString}`) + logger.info( + `Finished processing items between ${createdAfter.toISOString()} and ${createdBefore.toISOString()}`, + ) resolve() }) - .on('error', reject) + .on('error', (error) => { + logger.error( + `Could not process items between ${createdAfter.toISOString()} and ${createdBefore.toISOString()}: ${JSON.stringify( + error, + )}`, + ) + + reject() + }) }) }