Add force option to upsert identity and log warning when enabled

Author: tacxou

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

@@ -65,6 +65,7 @@ export class IdentitiesUpsertController extends AbstractController {
     filtersQuery: {
       [key: string]: string;
     }[] = [],
+    @Query('force') forceString: string,
     @Query('errorOnNotFound') errorOnNotFound: string = 'false',
     @Query('upsert') upsert: string = 'true',
   ): Promise<
@@ -75,6 +76,10 @@ export class IdentitiesUpsertController extends AbstractController {
       validations?: MixedValue;
     }>
   > {
+    const force = /true|on|yes|1/i.test(forceString);
+    if (force) {
+      this.logger.warn('Upserting with force mode enabled.');
+    }
     const filters = {};
     if (filtersQuery.length === 0) {
       throw new BadRequestException('Missing filters array');
@@ -88,7 +93,7 @@ export class IdentitiesUpsertController extends AbstractController {
     const [code, data] = await this._service.upsertWithFingerprint<Identities>(filters, body, {
       errorOnNotFound: /true|on|yes|1/i.test(errorOnNotFound),
       upsert: /true|on|yes|1/i.test(upsert),
-    });
+    }, {force});
 
     // If the state is TO_COMPLETE, the identity is created but additional fields are missing or invalid
     // Else the state is TO_VALIDATE, we return a 201 status code

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

@@ -13,7 +13,12 @@ export class IdentitiesUpsertService extends AbstractIdentitiesService {
     filters: FilterQuery<T>,
     data?: IdentitiesUpsertDto,
     options?: QueryOptions<T>,
+    extra?: { force?: boolean },
   ): Promise<[HttpStatus.OK | HttpStatus.CREATED, ModifyResult<Query<T, T, any, T>>]> {
+    extra = {
+      force: false,
+      ...extra,
+    }
     data = this.transformNullsToString(data);
     const identity = await this.model.findOne<Identities>(filters).exec();
     this.logger.log(`Upserting identity with filters ${JSON.stringify(filters)}`);
@@ -65,7 +70,7 @@ export class IdentitiesUpsertService extends AbstractIdentitiesService {
       }),
     );
 
-    await this.checkFingerprint(filters, fingerprint);
+    await this.checkFingerprint(filters, fingerprint, extra);
 
     this.logger.verbose('identities upsert data: ' + JSON.stringify({
       $setOnInsert: {
@@ -103,7 +108,11 @@ export class IdentitiesUpsertService extends AbstractIdentitiesService {
   public async checkFingerprint<T extends AbstractSchema | Document>(
     filters: FilterQuery<T>,
     fingerprint: string,
+    extra: { force?: boolean } = { force: false },
   ): Promise<void> {
+    if (extra.force) {
+      return;
+    }
     const identity = await this.model
       .findOne(
         { ...filters, fingerprint },