save + activation

Author: alainabbas

src/core/backends/backends.service.ts

@@ -287,7 +287,7 @@ export class BackendsService extends AbstractQueueProcessor {
       if (!identity.lastBackendSync) {
         throw new BadRequestException({
           status: HttpStatus.BAD_REQUEST,
-          message: `Identity ${key} is not in state TO_DELETE`,
+          message: `Identity ${key}  has never been synched`,
           identity,
         });
       }
@@ -330,7 +330,7 @@ export class BackendsService extends AbstractQueueProcessor {
       if (!identity.lastBackendSync) {
         throw new BadRequestException({
           status: HttpStatus.BAD_REQUEST,
-          message: `Identity ${key} is not in state TO_DELETE`,
+          message: `Identity ${key}  has never been synched`,
           identity,
         });
       }
@@ -359,7 +359,15 @@ export class BackendsService extends AbstractQueueProcessor {
     }
     return result;
   }
-
+  public async activationIdentity(payload: string, status: boolean, options?: ExecuteJobOptions) {
+    let result = null;
+    if (status === true) {
+      result = await this.enableIdentities([payload], options );
+    } else {
+      result = await this.disableIdentities([payload], options);
+    }
+    return result[0];
+  }
   public async executeJob(
     actionType: ActionType,
     concernedTo?: Types.ObjectId,

src/management/identities/_dto/_parts/activation-dto.ts

@@ -0,0 +1,12 @@
+import { ApiProperty } from '@nestjs/swagger';
+import { IsBoolean, IsString } from 'class-validator';
+
+export class ActivationDto {
+  @IsString()
+  @ApiProperty({ example: '66d80ab41821baca9bf965b2', description: 'Id of identity', type: String })
+  public id: string;
+
+  @IsBoolean()
+  @ApiProperty({ example: 'true', description: 'true or false to enable or disable the identity', type: String })
+  public status: boolean;
+}

src/management/identities/_dto/identities.dto.ts

@@ -8,6 +8,7 @@ import { additionalFieldsPartDto } from './_parts/additionalFields.dto';
 import { MetadataDto } from '~/_common/abstracts/dto/metadata.dto';
 import { InitStatesEnum } from '~/management/identities/_enums/init-state.enum';
 import { CustomFieldsDto } from '~/_common/abstracts/dto/custom-fields.dto';
+import {DataStatusEnum} from "~/management/identities/_enums/data-status";
 
 export class IdentitiesCreateDto extends IntersectionType(CustomFieldsDto, MetadataDto) {
   @IsNumber()
@@ -20,6 +21,11 @@ export class IdentitiesCreateDto extends IntersectionType(CustomFieldsDto, Metad
   @ApiProperty({ enum: InitStatesEnum })
   public initState: InitStatesEnum;
 
+  @IsNumber()
+  @IsEnum(DataStatusEnum)
+  @ApiProperty({ enum: DataStatusEnum })
+  public dataStatus: DataStatusEnum;
+
   @IsNumber()
   @IsOptional()
   @IsEnum(IdentityLifecycle)

src/management/identities/_stubs/identities.dto.stub.ts

@@ -5,6 +5,7 @@ import { IdentityState } from '~/management/identities/_enums/states.enum';
 import { additionalFieldsPartDtoStub } from './_parts/addtionalFields.dto.stub';
 import { inetOrgPersonDtoStub } from './_parts/inetOrgPerson.dto.stub';
 import { InitStatesEnum } from '~/management/identities/_enums/init-state.enum';
+import { DataStatusEnum } from '~/management/identities/_enums/data-status';
 
 export const IdentitiesDtoStub = (): IdentitiesDto => {
   return {
@@ -13,6 +14,7 @@ export const IdentitiesDtoStub = (): IdentitiesDto => {
     inetOrgPerson: inetOrgPersonDtoStub(),
     additionalFields: additionalFieldsPartDtoStub(),
     initState: InitStatesEnum.NOSENT,
+    dataStatus: DataStatusEnum.ACTIVE,
   };
 };
 
@@ -23,6 +25,7 @@ export const IdentitiesUpdateDtoStub = (): IdentitiesUpdateDto => {
     state: IdentityState.TO_COMPLETE,
     lifecycle: IdentityLifecycle.INACTIVE,
     initState: InitStatesEnum.NOSENT,
+    dataStatus: DataStatusEnum.ACTIVE,
     inetOrgPerson,
     additionalFields: additionalFieldsPartDtoStub(),
   };

src/management/identities/identities-activation.controller.ts

@@ -0,0 +1,25 @@
+import { AbstractController } from '~/_common/abstracts/abstract.controller';
+import { IdentitiesActivationService } from '~/management/identities/identities-activation.service';
+import { ApiOperation, ApiResponse, ApiTags} from '@nestjs/swagger';
+import { Body, Controller, HttpStatus, Post, Res} from '@nestjs/common';
+import { Response } from 'express';
+import { ActivationDto } from '~/management/identities/_dto/_parts/activation-dto';
+
+@ApiTags('management/identities')
+@Controller('identities')
+export class IdentitiesActivationController extends AbstractController {
+  public constructor(protected readonly _service: IdentitiesActivationService) {
+    super();
+  }
+
+  @Post('activation')
+  @ApiOperation({ summary: 'active/desactive l identité' })
+  @ApiResponse({ status: HttpStatus.OK })
+  public async activation(@Res() res: Response,@Body() body:ActivationDto): Promise<Response> {
+    const data = this._service.activation(body.id, body.status)
+    return res.status(HttpStatus.OK).json({
+      statusCode: HttpStatus.OK,
+      data,
+    });
+  }
+}

src/management/identities/identities-activation.service.ts

@@ -0,0 +1,43 @@
+import { AbstractIdentitiesService } from '~/management/identities/abstract-identities.service';
+import { Identities } from '~/management/identities/_schemas/identities.schema';
+import { BadRequestException } from '@nestjs/common';
+import { DataStatusEnum } from '~/management/identities/_enums/data-status';
+import { JobState } from '~/core/jobs/_enums/state.enum';
+
+export class IdentitiesActivationService extends AbstractIdentitiesService {
+  public async activation(id: string, status: boolean) {
+    //recherche de l'identité
+    let identity: Identities = null;
+    let statusChanged = false;
+    try {
+      identity = await this.findById<Identities>(id);
+    } catch (error) {
+      throw new BadRequestException('Id1 not found');
+    }
+    if (identity.dataStatus !== DataStatusEnum.DELETED) {
+      if (status) {
+        if (identity.dataStatus !== DataStatusEnum.ACTIVE) {
+          identity.dataStatus = DataStatusEnum.ACTIVE;
+          statusChanged = true;
+        }
+      } else {
+        if (identity.dataStatus !== DataStatusEnum.INACTIVE) {
+          identity.dataStatus = DataStatusEnum.INACTIVE;
+          statusChanged = true;
+        }
+      }
+    } else {
+      throw new BadRequestException('Identity is in status deleted');
+    }
+    //sauvegarde de l'identité
+    if (statusChanged) {
+      // le dataStaus à changé on envoye l info aux backend et on enregistre l identité
+      const result = await this.backends.activationIdentity(identity._id.toString(), status);
+      if (result.state === JobState.COMPLETED){
+        await super.update(identity._id, identity);
+      } else {
+        throw new BadRequestException('Backend failed');
+      }
+    }
+  }
+}

src/management/identities/identities-crud.controller.ts

@@ -54,6 +54,7 @@ export class IdentitiesCrudController extends AbstractController {
     inetOrgPerson: 1,
     additionalFields: 1,
     metadata: 1,
+    dataStatus: 1,
   };
 
   @Post()

src/management/identities/identities-doublon.controller.ts

@@ -9,6 +9,7 @@ import { IdentitiesDoublonService } from '~/management/identities/identities-dou
 
 @ApiTags('management/identities')
 @Controller('identities')
+
 export class IdentitiesDoublonController extends AbstractController {
   public constructor(protected readonly _service: IdentitiesDoublonService) {
     super();

src/management/identities/identities.module.ts

@@ -15,6 +15,9 @@ import { IdentitiesDoublonService } from '~/management/identities/identities-dou
 import { IdentitiesCrudController } from '~/management/identities/identities-crud.controller';
 import { IdentitiesUpsertController } from '~/management/identities/identities-upsert.controller';
 import { IdentitiesPhotoController } from '~/management/identities/identities-photo.controller';
+import { IdentitiesActivationController } from '~/management/identities/identities-activation.controller';
+import { IdentitiesActivationService } from '~/management/identities/identities-activation.service';
+import { IdentitiesDoublonController } from '~/management/identities/identities-doublon.controller';
 
 @Module({
   imports: [
@@ -34,13 +37,20 @@ import { IdentitiesPhotoController } from '~/management/identities/identities-ph
     IdentitiesCrudService,
     IdentitiesDoublonService,
     IdentitiesValidationService,
+    IdentitiesActivationService,
     {
       provide: APP_FILTER,
       useClass: IdentitiesValidationFilter,
     },
     IdentitiesJsonformsService,
   ],
-  controllers: [IdentitiesCrudController, IdentitiesUpsertController, IdentitiesPhotoController],
+  controllers: [
+    IdentitiesCrudController,
+    IdentitiesUpsertController,
+    IdentitiesPhotoController,
+    IdentitiesDoublonController,
+    IdentitiesActivationController,
+  ],
   exports: [IdentitiesCrudService],
 })
 export class IdentitiesModule {}