|
1 | 1 | import { |
2 | 2 | BadRequestException, |
3 | | - HttpStatus, |
4 | 3 | HttpException, |
| 4 | + HttpStatus, |
5 | 5 | Injectable, |
6 | 6 | RequestTimeoutException, |
7 | 7 | UnprocessableEntityException, |
8 | 8 | } from '@nestjs/common'; |
9 | | -import { ModuleRef } from '@nestjs/core'; |
10 | | -import { Document, ModifyResult, Query, Types } from 'mongoose'; |
11 | | -import { AbstractQueueProcessor } from '~/_common/abstracts/abstract.queue.processor'; |
12 | | -import { IdentityState } from '~/management/identities/_enums/states.enum'; |
13 | | -import { Identities } from '~/management/identities/_schemas/identities.schema'; |
14 | | -import { IdentitiesCrudService } from '~/management/identities/identities-crud.service'; |
15 | | -import { JobState } from '../jobs/_enums/state.enum'; |
16 | | -import { Jobs } from '../jobs/_schemas/jobs.schema'; |
17 | | -import { JobsService } from '../jobs/jobs.service'; |
18 | | -import { Tasks } from '../tasks/_schemas/tasks.schema'; |
19 | | -import { TasksService } from '../tasks/tasks.service'; |
20 | | -import { ActionType } from './_enum/action-type.enum'; |
21 | | -import { ExecuteJobOptions } from './_interfaces/execute-job-options.interface'; |
22 | | -import { WorkerResultInterface } from '~/core/backends/_interfaces/worker-result.interface'; |
23 | | -import { DataStatusEnum } from '~/management/identities/_enums/data-status'; |
| 9 | +import {ModuleRef} from '@nestjs/core'; |
| 10 | +import {Document, ModifyResult, Query, Types} from 'mongoose'; |
| 11 | +import {AbstractQueueProcessor} from '~/_common/abstracts/abstract.queue.processor'; |
| 12 | +import {IdentityState} from '~/management/identities/_enums/states.enum'; |
| 13 | +import {Identities} from '~/management/identities/_schemas/identities.schema'; |
| 14 | +import {IdentitiesCrudService} from '~/management/identities/identities-crud.service'; |
| 15 | +import {JobState} from '../jobs/_enums/state.enum'; |
| 16 | +import {Jobs} from '../jobs/_schemas/jobs.schema'; |
| 17 | +import {JobsService} from '../jobs/jobs.service'; |
| 18 | +import {Tasks} from '../tasks/_schemas/tasks.schema'; |
| 19 | +import {TasksService} from '../tasks/tasks.service'; |
| 20 | +import {ActionType} from './_enum/action-type.enum'; |
| 21 | +import {ExecuteJobOptions} from './_interfaces/execute-job-options.interface'; |
| 22 | +import {WorkerResultInterface} from '~/core/backends/_interfaces/worker-result.interface'; |
| 23 | +import {DataStatusEnum} from '~/management/identities/_enums/data-status'; |
24 | 24 |
|
25 | 25 | const DEFAULT_SYNC_TIMEOUT = 30_000; |
26 | 26 |
|
@@ -432,7 +432,13 @@ export class BackendsService extends AbstractQueueProcessor { |
432 | 432 | optionals['processedAt'] = new Date(); |
433 | 433 | optionals['state'] = JobState.IN_PROGRESS; |
434 | 434 | } |
435 | | - |
| 435 | + //anonymisation payload sur reset et changement de mdp |
| 436 | + if (actionType === ActionType.IDENTITY_PASSWORD_RESET || actionType === ActionType.IDENTITY_PASSWORD_CHANGE) { |
| 437 | + payload['params']['newPassword'] ='**********'; |
| 438 | + } |
| 439 | + if (actionType === ActionType.IDENTITY_PASSWORD_CHANGE) { |
| 440 | + payload['params']['oldPassword'] ='**********'; |
| 441 | + } |
436 | 442 | let jobStore: Document<Jobs> = null; |
437 | 443 | if (!options?.disableLogs) { |
438 | 444 | const identity = concernedTo ? await this.identitiesService.findById<Identities>(concernedTo) : null; |
|
0 commit comments