feat(json-api-nestjs): Add wrapper transaction options

Author: klerick

libs/json-api/json-api-nestjs/README.md

@@ -69,6 +69,11 @@ export interface ModuleOptions {
     debug?: boolean; // Debug info in result object, like error message
     pipeForId?: Type<PipeTransform> // Nestjs pipe for validate id params, by default ParseIntPipe
     operationUrl?: string // Url for atomic operation https://jsonapi.org/ext/atomic/
+    useSoftDelete?: boolean // Use soft delete
+    runInTransaction?: <Func extends (...args: any) => any>(
+      isolationLevel: IsolationLevel,
+      fn: Func
+    ) => ReturnType<Func> // You can use cutom function for wrapping transaction in atomic operation, example: runInTransaction from https://github.com/Aliheym/typeorm-transactional
   };
 }
 ```

libs/json-api/json-api-nestjs/src/lib/mixin/interceptors/error.interceptors.ts

@@ -79,7 +79,7 @@ export class ErrorInterceptors<E extends Entity> implements NestInterceptor {
       const { errorCode, errorMsg, detail } = this.preparePostgresError(
         error.driverError
       );
-      console.log(errorCode);
+
       if (PostgresError[errorCode]) {
         return PostgresError[errorCode](
           this.repository.metadata,

libs/json-api/json-api-nestjs/src/lib/modules/atomic-operation/service/execute.service.ts

@@ -6,17 +6,25 @@ import {
   PipeTransform,
   Type,
 } from '@nestjs/common';
-import { ROUTE_ARGS_METADATA } from '@nestjs/common/constants';
+import {
+  INTERCEPTORS_METADATA,
+  ROUTE_ARGS_METADATA,
+} from '@nestjs/common/constants';
 import { Module } from '@nestjs/core/injector/module';
 import { ArgumentMetadata } from '@nestjs/common/interfaces/features/pipe-transform.interface';
 import { ModuleRef } from '@nestjs/core';
 import { DataSource } from 'typeorm';
 
 import { ParamsForExecute } from '../types';
 import { CURRENT_DATA_SOURCE_TOKEN } from '../../../constants';
-import { ASYNC_ITERATOR_FACTORY, KEY_MAIN_INPUT_SCHEMA } from '../constants';
+import {
+  ASYNC_ITERATOR_FACTORY,
+  KEY_MAIN_INPUT_SCHEMA,
+  OPTIONS,
+} from '../constants';
 import { IterateFactory } from '../factory';
 import {
+  ConfigParam,
   ResourceObject,
   ResourceObjectRelationships,
   TypeFromType,
@@ -42,11 +50,19 @@ export class ExecuteService {
   @Inject(ASYNC_ITERATOR_FACTORY) private asyncIteratorFactory!: IterateFactory<
     ExecuteService['runOneOperation']
   >;
+  @Inject(OPTIONS) private options!: ConfigParam;
 
   async run(params: ParamsForExecute[], tmpIds: (string | number)[]) {
+    if (
+      this.options.runInTransaction &&
+      typeof this.options.runInTransaction === 'function'
+    ) {
+      return this.options.runInTransaction('READ UNCOMMITTED', () => {
+        return this.executeOperations(params, tmpIds);
+      });
+    }
     const queryRunner = this.dataSource.createQueryRunner();
     await queryRunner.startTransaction('READ UNCOMMITTED');
-
     try {
       const resultArray = await this.executeOperations(params, tmpIds);
       await queryRunner.commitTransaction();

libs/json-api/json-api-nestjs/src/lib/types/module.types.ts

@@ -1,6 +1,7 @@
 import { ModuleMetadata, Type, PipeTransform } from '@nestjs/common';
 import { EntityClassOrSchema } from '@nestjs/typeorm/dist/interfaces/entity-class-or-schema.type';
 import { ObjectLiteral } from 'typeorm/common/ObjectLiteral';
+import { IsolationLevel } from 'typeorm/driver/types/IsolationLevel';
 
 export type NestController = ModuleMetadata['controllers'];
 export type NestProvider = ModuleMetadata['providers'];
@@ -24,6 +25,10 @@ export interface ConfigParam {
   pipeForId: PipeMixin;
   operationUrl?: string;
   overrideRoute?: string;
+  runInTransaction?: <Func extends (...args: any) => any>(
+    isolationLevel: IsolationLevel,
+    fn: Func
+  ) => ReturnType<Func>;
 }
 
 export interface ModuleOptions {