Merge branch 'main' of https://github.com/Libertech-FR/sesame-orchestrator

Author: tacxou

src/management/identities/identities.controller.ts

@@ -177,19 +177,33 @@ export class IdentitiesController extends AbstractController {
     @Body() body: IdentitiesUpdateDto,
     @Res() res: Response,
   ): Promise<Response> {
-    try {
-      const data = await this._service.update(_id, body);
-      return res.status(HttpStatus.OK).json({
-        statusCode: HttpStatus.OK,
-        data,
-      });
-    } catch (error) {
-      return res.status(HttpStatus.BAD_REQUEST).json({
-        statusCode: HttpStatus.BAD_REQUEST,
-        message: error.message,
-        validations: error.validations,
-      });
+    const data = await this._service.update(_id, body);
+    return res.status(HttpStatus.OK).json({
+      statusCode: HttpStatus.OK,
+      data,
+    });
+  }
+
+  @Patch(':_id([0-9a-fA-F]{24})/state')
+  @ApiParam({ name: '_id', type: String })
+  @ApiUpdateDecorator(IdentitiesUpdateDto, IdentitiesDto)
+  public async updateState(
+    @Param('_id', ObjectIdValidationPipe) _id: Types.ObjectId,
+    @Body() body: IdentitiesUpdateDto,
+    @Res() res: Response,
+  ): Promise<Response> {
+    const identity = await this._service.findById(_id);
+    if (!identity) {
+      throw new BadRequestException('Identity not found');
     }
+    if (identity.state !== IdentityState.TO_VALIDATE) {
+      throw new BadRequestException("La validation de l'identité est déjà complétée.");
+    }
+    const data = await this._service.updateState(_id, body.state);
+    return res.status(HttpStatus.OK).json({
+      statusCode: HttpStatus.OK,
+      data,
+    });
   }
 
   @Delete(':_id([0-9a-fA-F]{24})')

src/management/identities/identities.service.ts

@@ -92,12 +92,25 @@ export class IdentitiesService extends AbstractServiceSchema {
         throw error; // Rethrow the original error if it's not one of the handled types.
       }
     }
+    if (update.state === IdentityState.TO_COMPLETE) {
+      update = { ...update, state: IdentityState.TO_VALIDATE };
+    }
+    console.log(update);
     //update.state = IdentityState.TO_VALIDATE;
     const updated = await super.update(_id, update, options);
     //TODO: add backends service logic here (TO_SYNC)
     return updated;
   }
 
+  public async updateState<T extends AbstractSchema | Document>(
+    _id: Types.ObjectId | any,
+    state: IdentityState,
+    options?: QueryOptions<T> & { rawResult: true },
+  ): Promise<ModifyResult<Query<T, T, any, T>>> {
+    const updated = await super.update(_id, { state }, options);
+    return updated;
+  }
+
   public async delete<T extends AbstractSchema | Document>(
     _id: Types.ObjectId | any,
     options?: QueryOptions<T> | null | undefined,