diff --git a/packages/revisions/src/Infra/TypeORM/SQL/SQLRevisionRepository.ts b/packages/revisions/src/Infra/TypeORM/SQL/SQLRevisionRepository.ts index a1d32fb8b..f59d526ee 100644 --- a/packages/revisions/src/Infra/TypeORM/SQL/SQLRevisionRepository.ts +++ b/packages/revisions/src/Infra/TypeORM/SQL/SQLRevisionRepository.ts @@ -17,6 +17,27 @@ export class SQLRevisionRepository extends SQLLegacyRevisionRepository { super(ormRepository, revisionMetadataMapper, revisionMapper, logger) } + override async removeByUserUuid(userUuid: Uuid): Promise { + await this.ormRepository + .createQueryBuilder() + .delete() + .from('revisions_revisions') + .where('user_uuid = :userUuid', { userUuid: userUuid.value }) + .execute() + } + + override async removeOneByUuid(revisionUuid: Uuid, userUuid: Uuid): Promise { + await this.ormRepository + .createQueryBuilder() + .delete() + .from('revisions_revisions') + .where('uuid = :revisionUuid AND user_uuid = :userUuid', { + userUuid: userUuid.value, + revisionUuid: revisionUuid.value, + }) + .execute() + } + override async findOneByUuid(revisionUuid: Uuid, userUuid: Uuid, sharedVaultUuids: Uuid[]): Promise { const queryBuilder = this.ormRepository.createQueryBuilder()