From 29e8de32383e911bbb431d3fd0da68faefa32d3d Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Karol=20S=C3=B3jko?= Date: Mon, 9 Oct 2023 08:26:18 +0200 Subject: [PATCH] fix: logs in transition --- ...onRevisionsFromPrimaryToSecondaryDatabaseForUser.ts | 10 +++++----- ...sitionItemsFromPrimaryToSecondaryDatabaseForUser.ts | 4 ++-- 2 files changed, 7 insertions(+), 7 deletions(-) diff --git a/packages/revisions/src/Domain/UseCase/Transition/TransitionRevisionsFromPrimaryToSecondaryDatabaseForUser/TransitionRevisionsFromPrimaryToSecondaryDatabaseForUser.ts b/packages/revisions/src/Domain/UseCase/Transition/TransitionRevisionsFromPrimaryToSecondaryDatabaseForUser/TransitionRevisionsFromPrimaryToSecondaryDatabaseForUser.ts index ceec63bf8..8e7881644 100644 --- a/packages/revisions/src/Domain/UseCase/Transition/TransitionRevisionsFromPrimaryToSecondaryDatabaseForUser/TransitionRevisionsFromPrimaryToSecondaryDatabaseForUser.ts +++ b/packages/revisions/src/Domain/UseCase/Transition/TransitionRevisionsFromPrimaryToSecondaryDatabaseForUser/TransitionRevisionsFromPrimaryToSecondaryDatabaseForUser.ts @@ -159,9 +159,9 @@ export class TransitionRevisionsFromPrimaryToSecondaryDatabaseForUser implements } this.logger.info( - `[${ - userUuid.value - }] Removing revision ${revision.id.toString()} in primary database as it is not identical to revision in secondary database`, + `[${userUuid.value}] Removing revision ${revision.id.toString()} in primary database: ${JSON.stringify( + revisionInPrimary, + )} as it is not identical to revision in secondary database: ${JSON.stringify(revision)}`, ) await this.primaryRevisionsRepository.removeOneByUuid( @@ -205,8 +205,8 @@ export class TransitionRevisionsFromPrimaryToSecondaryDatabaseForUser implements } private async allowForPrimaryDatabaseToCatchUp(): Promise { - const twoSecondsInMilliseconds = 2_000 - await this.timer.sleep(twoSecondsInMilliseconds) + const delay = 1_000 + await this.timer.sleep(delay) } private async checkIntegrityBetweenPrimaryAndSecondaryDatabase(userUuid: Uuid): Promise> { diff --git a/packages/syncing-server/src/Domain/UseCase/Transition/TransitionItemsFromPrimaryToSecondaryDatabaseForUser/TransitionItemsFromPrimaryToSecondaryDatabaseForUser.ts b/packages/syncing-server/src/Domain/UseCase/Transition/TransitionItemsFromPrimaryToSecondaryDatabaseForUser/TransitionItemsFromPrimaryToSecondaryDatabaseForUser.ts index 27c9fe43b..22acacaff 100644 --- a/packages/syncing-server/src/Domain/UseCase/Transition/TransitionItemsFromPrimaryToSecondaryDatabaseForUser/TransitionItemsFromPrimaryToSecondaryDatabaseForUser.ts +++ b/packages/syncing-server/src/Domain/UseCase/Transition/TransitionItemsFromPrimaryToSecondaryDatabaseForUser/TransitionItemsFromPrimaryToSecondaryDatabaseForUser.ts @@ -99,8 +99,8 @@ export class TransitionItemsFromPrimaryToSecondaryDatabaseForUser implements Use } private async allowForPrimaryDatabaseToCatchUp(): Promise { - const twoSecondsInMilliseconds = 2_000 - await this.timer.sleep(twoSecondsInMilliseconds) + const delay = 1_000 + await this.timer.sleep(delay) } private async migrateItemsForUser(userUuid: Uuid, timestamp: number): Promise> {