浏览代码

fix(revisions): add more verbose logs to the transition

Karol Sójko 1 年之前
父节点
当前提交
df20dd46db

+ 6 - 0
packages/revisions/src/Domain/UseCase/Transition/TransitionRevisionsFromPrimaryToSecondaryDatabaseForUser/TransitionRevisionsFromPrimaryToSecondaryDatabaseForUser.ts

@@ -90,6 +90,12 @@ export class TransitionRevisionsFromPrimaryToSecondaryDatabaseForUser implements
 
 
         for (const revision of revisions) {
         for (const revision of revisions) {
           try {
           try {
+            this.logger.info(
+              `Transitioning revision #${
+                totalRevisionsCountTransitionedToSecondary + 1
+              }: ${revision.id.toString()} to secondary database`,
+            )
+
             const didSave = await (this.secondRevisionsRepository as RevisionRepositoryInterface).insert(revision)
             const didSave = await (this.secondRevisionsRepository as RevisionRepositoryInterface).insert(revision)
             if (!didSave) {
             if (!didSave) {
               return Result.fail(`Failed to save revision ${revision.id.toString()} to secondary database`)
               return Result.fail(`Failed to save revision ${revision.id.toString()} to secondary database`)

+ 3 - 3
packages/revisions/src/Infra/TypeORM/SQL/SQLRevisionRepository.ts

@@ -24,9 +24,9 @@ export class SQLRevisionRepository implements RevisionRepositoryInterface {
 
 
   async findByUserUuid(dto: { userUuid: Uuid; offset?: number; limit?: number }): Promise<Revision[]> {
   async findByUserUuid(dto: { userUuid: Uuid; offset?: number; limit?: number }): Promise<Revision[]> {
     const queryBuilder = this.ormRepository
     const queryBuilder = this.ormRepository
-      .createQueryBuilder()
-      .where('user_uuid = :userUuid', { userUuid: dto.userUuid.value })
-      .orderBy('created_at', 'ASC')
+      .createQueryBuilder('revision')
+      .where('revision.user_uuid = :userUuid', { userUuid: dto.userUuid.value })
+      .orderBy('revision.created_at', 'ASC')
 
 
     if (dto.offset !== undefined) {
     if (dto.offset !== undefined) {
       queryBuilder.skip(dto.offset)
       queryBuilder.skip(dto.offset)