ammar/backend
1
0
Fork 0
mirror of https://github.com/SyncrowIOT/backend.git synced 2025-07-15 18:27:05 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #269 from SyncrowIOT/feat/fix-delete-propagation

Browse Source
This commit is contained in:
hannathkadher
2025-02-26 16:03:44 +04:00
committed by GitHub
parent 60a4fb8ea2 2a5b35a297
commit cb6d359810
2 changed files with 2 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/space-model/handlers/propogate-space-model-deletion.handler.ts
View File

@ -22,7 +22,6 @@ export class PropogateDeleteSpaceModelHandler
const { spaceModel, queryRunner } = command.param; const { spaceModel, queryRunner } = command.param;
try { try {
await queryRunner.connect();
await queryRunner.startTransaction(); await queryRunner.startTransaction();
const spaces = await this.spaceRepository.find({ const spaces = await this.spaceRepository.find({
where: { where: {
@ -43,6 +42,7 @@ export class PropogateDeleteSpaceModelHandler
); );
} }
} }
await queryRunner.commitTransaction();
} catch (error) { } catch (error) {
await queryRunner.rollbackTransaction(); await queryRunner.rollbackTransaction();
this.logger.error( this.logger.error(

3
src/space-model/services/space-model.service.ts
View File

@ -295,6 +295,7 @@ export class SpaceModelService {
{ uuid: param.spaceModelUuid }, { uuid: param.spaceModelUuid },
{ disabled: true }, { disabled: true },
); );
await queryRunner.commitTransaction();
await this.commandBus.execute( await this.commandBus.execute(
new PropogateDeleteSpaceModelCommand({ new PropogateDeleteSpaceModelCommand({
@ -303,8 +304,6 @@ export class SpaceModelService {
}), }),
); );
await queryRunner.commitTransaction();
return new SuccessResponseDto({ return new SuccessResponseDto({
message: `SpaceModel with UUID ${param.spaceModelUuid} deleted successfully.`, message: `SpaceModel with UUID ${param.spaceModelUuid} deleted successfully.`,
statusCode: HttpStatus.OK, statusCode: HttpStatus.OK,