mirror of
https://github.com/SyncrowIOT/backend.git
synced 2025-07-15 18:27:05 +00:00
fixed delete propagation
This commit is contained in:
@ -49,6 +49,8 @@ export class PropogateUpdateSpaceModelHandler
|
|||||||
await this.addSubspaceModel(subspaceModel, spaces);
|
await this.addSubspaceModel(subspaceModel, spaces);
|
||||||
} else if (subspaceModel.action === ModifyAction.DELETE) {
|
} else if (subspaceModel.action === ModifyAction.DELETE) {
|
||||||
await this.deleteSubspaceModel(subspaceModel, spaces);
|
await this.deleteSubspaceModel(subspaceModel, spaces);
|
||||||
|
} else if (subspaceModel.action === ModifyAction.UPDATE) {
|
||||||
|
await this.updateSubspaceModel(subspaceModel);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@ -152,6 +154,15 @@ export class PropogateUpdateSpaceModelHandler
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
async updateSubspaceModel(subspaceModel: ISingleSubspaceModel) {
|
||||||
|
return this.subspaceRepository.update(
|
||||||
|
{
|
||||||
|
subSpaceModel: { uuid: subspaceModel.subspaceModel.uuid },
|
||||||
|
disabled: false,
|
||||||
|
},
|
||||||
|
{ subspaceName: subspaceModel.subspaceModel.subspaceName },
|
||||||
|
);
|
||||||
|
}
|
||||||
async updateSubspaceModels(
|
async updateSubspaceModels(
|
||||||
subspaceModels: UpdatedSubspaceModelPayload[],
|
subspaceModels: UpdatedSubspaceModelPayload[],
|
||||||
queryRunner: QueryRunner,
|
queryRunner: QueryRunner,
|
||||||
|
@ -36,6 +36,13 @@ export class PropogateDeleteSpaceModelHandler
|
|||||||
|
|
||||||
for (const space of spaces) {
|
for (const space of spaces) {
|
||||||
try {
|
try {
|
||||||
|
await queryRunner.manager.update(
|
||||||
|
this.spaceRepository.target,
|
||||||
|
{ uuid: space.uuid },
|
||||||
|
{
|
||||||
|
spaceModel: null,
|
||||||
|
},
|
||||||
|
);
|
||||||
await this.spaceService.unlinkSpaceFromModel(space, queryRunner);
|
await this.spaceService.unlinkSpaceFromModel(space, queryRunner);
|
||||||
} catch (innerError) {
|
} catch (innerError) {
|
||||||
this.logger.error(
|
this.logger.error(
|
||||||
|
Reference in New Issue
Block a user