From 2a5b35a29727786bc335bb94c22f7dd8629f545d Mon Sep 17 00:00:00 2001 From: hannathkadher Date: Wed, 26 Feb 2025 16:02:58 +0400 Subject: [PATCH] fixed query commit --- .../handlers/propogate-space-model-deletion.handler.ts | 2 +- src/space-model/services/space-model.service.ts | 3 +-- 2 files changed, 2 insertions(+), 3 deletions(-) diff --git a/src/space-model/handlers/propogate-space-model-deletion.handler.ts b/src/space-model/handlers/propogate-space-model-deletion.handler.ts index 0e29222..31efeba 100644 --- a/src/space-model/handlers/propogate-space-model-deletion.handler.ts +++ b/src/space-model/handlers/propogate-space-model-deletion.handler.ts @@ -22,7 +22,6 @@ export class PropogateDeleteSpaceModelHandler const { spaceModel, queryRunner } = command.param; try { - await queryRunner.connect(); await queryRunner.startTransaction(); const spaces = await this.spaceRepository.find({ where: { @@ -43,6 +42,7 @@ export class PropogateDeleteSpaceModelHandler ); } } + await queryRunner.commitTransaction(); } catch (error) { await queryRunner.rollbackTransaction(); this.logger.error( diff --git a/src/space-model/services/space-model.service.ts b/src/space-model/services/space-model.service.ts index d70565d..1f435b9 100644 --- a/src/space-model/services/space-model.service.ts +++ b/src/space-model/services/space-model.service.ts @@ -295,6 +295,7 @@ export class SpaceModelService { { uuid: param.spaceModelUuid }, { disabled: true }, ); + await queryRunner.commitTransaction(); await this.commandBus.execute( new PropogateDeleteSpaceModelCommand({ @@ -303,8 +304,6 @@ export class SpaceModelService { }), ); - await queryRunner.commitTransaction(); - return new SuccessResponseDto({ message: `SpaceModel with UUID ${param.spaceModelUuid} deleted successfully.`, statusCode: HttpStatus.OK,