neerajsonii

import { Injectable, NestInterceptor, ExecutionContext, CallHandler, HttpException } from '@nestjs/common';
import { Observable, throwError } from 'rxjs';
import { catchError, map } from 'rxjs/operators';

export interface Response<T> {
  data: T;
}

@Injectable()
export class TransformInterceptor<T> implements NestInterceptor<T, Response<T>> {

neerajsonii

/* Repository method  */

  saveWithTransactions(data, transactionManager): Promise<Entity> {
    if (transactionManager) return transactionManager.save(Entity, data);
    return this.repository.save(data);
 }

neerajsonii

/* 1. Using DataSource or EntityManager: */

await myDataSource.manager.transaction(async (transactionalEntityManager) => {
  await transactionalEntityManager.save(users)
  await transactionalEntityManager.save(photos)
  // ...
});

/* 2. Using a QueryRunner: */