Гнездо JS: выполнить перехватчик перед фильтром исключений - PullRequest
Новая
       2

Гнездо JS: выполнить перехватчик перед фильтром исключений

0 голосов
/ 19 марта 2020

Мне нужно отслеживать события для определенных вызовов API (на основе имени обработчика), и это в основном функция, которая записывает действия.

В данный момент у меня есть перехватчик, который выполняет отслеживание событий, и он работает нормально.

Но проблема в том, что когда возникает ошибка, я ловлю ее, используя глобальный фильтр исключений, и это немедленно возвращает ответ без ввода перехватчика и моего кода отслеживания событий (мне нужно имя класса, обработчик имя и возвращаемые данные, если они доступны).

Вот мои настройки

app.module.ts 

import { Module } from '@nestjs/common';
import { ConfigModule } from '@nestjs/config';
import { MongooseModule } from '@nestjs/mongoose';
import { APP_INTERCEPTOR, APP_FILTER } from '@nestjs/core';

import { AuthModule } from './auth/auth.module';
import { MembersModule } from './members/members.module';

import { DatabaseConfigService } from './_database/database-config.service';
import { EventTrackerService } from './event-tracker/event-tracker.service';

import { LoggingInterceptor } from './_interceptors/logging.interceptor';
import { EventsTrackerInterceptor } from './_interceptors/events-tracker.interceptor';

import { AllExceptionsFilter } from './_filters/all-exception.filter';

@Module({
  imports: [
    ConfigModule.forRoot({
      isGlobal: true,
    }),
    MongooseModule.forRootAsync({
      useClass: DatabaseConfigService,
    }),
    AuthModule,
    MembersModule,
  ],
  providers: [
    {
      provide: APP_INTERCEPTOR,
      useClass: LoggingInterceptor,
    },
    {
      provide: APP_INTERCEPTOR,
      useClass: EventsTrackerInterceptor,
    },
    {
      provide: APP_FILTER,
      useClass: AllExceptionsFilter,
    },
    EventTrackerService,
  ],
})
export class AppModule {}

events-tracker .interceptor.ts 

import {
  CallHandler,
  ExecutionContext,
  Injectable,
  NestInterceptor,
} from '@nestjs/common';
import { Observable } from 'rxjs';
import { tap } from 'rxjs/operators';
import { EventTrackerService } from '../event-tracker/event-tracker.service';

@Injectable()
export class EventsTrackerInterceptor implements NestInterceptor {
  constructor(private readonly eventTrackerService: EventTrackerService) {}

  intercept(context: ExecutionContext, next: CallHandler): Observable<any> {
    const request = context.switchToHttp().getRequest();
    const response = context.switchToHttp().getResponse();
    const className = context.getClass().name;
    const handler = context.getHandler().name;

    return next.handle().pipe(
      tap(data => {
        this.eventTrackerService.handleEvent(
          request.url,
          className,
          handler,
          data,
        );
      }),
    );
  }
}

all-exception.filter.ts 

import {
  ExceptionFilter,
  Catch,
  ArgumentsHost,
  HttpException,
  HttpStatus,
  Logger,
} from '@nestjs/common';
import { EventTrackerService } from '../event-tracker/event-tracker.service';

@Catch()
export class AllExceptionsFilter implements ExceptionFilter {
  constructor(private readonly eventTrackerService: EventTrackerService) {}
  catch(exception: any, host: ArgumentsHost) {
    const ctx = host.switchToHttp();
    const response = ctx.getResponse();
    const request = ctx.getRequest();

    const status =
      exception instanceof HttpException
        ? exception.getStatus()
        : HttpStatus.FORBIDDEN;

    const message =
      typeof exception.message === 'string'
        ? exception.message
        : exception.message.message;

    const errorResponse = {
      statusCode: status,
      timestamp: new Date().toISOString(),
      path: request.url,
      message: message || 'Something went wrong',
    };
    Logger.error(
      `${request.method} ${request.url} ${status}`,
      JSON.stringify(errorResponse),
      'AllExceptionsFilter',
      true,
    );
    response.status(status).json(errorResponse);
  }
}

Мой окончательный вопрос: как мне вызвать трекер событий в перехватчике, несмотря на исключение бросить?

1 Ответ

1 голос
/ 19 марта 2020

У вас есть один из двух вариантов с перехватчиком: 1) реализовать catchError ветвь pipe, выполнить логику c и повторно выдать ошибку, или 2) tap может принять Объект похож на подписку на next, error, complete и запускает определенные функции для того, что происходит с наблюдаемой. Отвод может выглядеть как 

return next.handle().pipe(
  tap({
    next: (data) => this.eventTrackerService.handleEvent(
          request.url,
          className,
          handler,
          data,
        ),
    error: (err) => this.eventTrackerService.handleEvent(
          request.url,
          className,
          handler,
          error,
        )
  })
);

И теперь у вас есть tap, который работает при успехе и ошибке, но теперь вы также передаете ошибку вместо того, какие данные должны были возвращаться на ваш трекер.

...