Почему перехватчик nestjs возвращает неопределенное значение? - PullRequest
Новая
       27

Почему перехватчик nestjs возвращает неопределенное значение?

0 голосов
/ 17 марта 2019

Я пытаюсь реализовать перехватчик ведения журнала в nestjs таким образом, чтобы он захватывал все запросы и ответы и регистрировал его.

Следовательно, я реализовал LoggingInterceptor, подобный этому 

import { logger } from './../utils/logger';
import { ExecutionContext, Injectable, NestInterceptor } from '@nestjs/common';
import { Observable, BehaviorSubject, from } from 'rxjs';
import { map, tap, refCount, publish, publishLast } from 'rxjs/operators';

    @Injectable()
    export class LoggingInterceptorInterceptor implements NestInterceptor {
      intercept(context: ExecutionContext, call$: Observable<any>): Observable<any> {
        const reqHeaders = context.switchToHttp().getRequest().headers;
        const reqBody = context.switchToHttp().getRequest().body;
        logger.info('Logging the incoming request:',reqHeaders);
        logger.info('Logging the incoming req body:', reqBody);
        const now = Date.now();
        logger.info('Time of request call is', now);

        const serviceBehaviorSubj = new BehaviorSubject<any>(null);

    // response will be available only in the call$ observable stream
    // so use tap to get a clone of the observable and print the data sent

        // this pipe call transforms the response object to start with something called data
        // so a default response like "Done", "test" looks now as a json string 
        // {data : Done}  {data: test}
        // const anotherrespObs: Observable<any> = call$.pipe(publishLast(), refCount());
        // anotherrespObs.pipe(publishLast(), refCount()).subscribe(data => {
        //   logger.info('Logging the outgoing response', data);
        // });

        return call$.pipe(map(data => {
          console.log('data here is', data);
          return ({ dottted: data });
        }));
        //oo.then(return new Pro)
        // return call$.pipe(tap(() => {
        //   logger.info(`Time of completion is ${Date.now() -now}`);
        // }), map(data => {
        //   console.log('ccccccc', data);
        //   return data;
        // }));
      }
}

Я понимаю, что оператор call $ ведет себя как Observable, и он будет подписан внутренне nestjs для отправки ответа клиенту, но я хотелзарегистрировать информацию перед отправкой и, возможно, преобразовать ответ

Поэтому я использую оператор map () для rxjs.Это работает правильно, если набор ответов имеет тип, отличный от 'application / json'.Если Content-Type имеет тип «plain / text», операция map применяется и преобразуется в требуемый объект json и отправляется клиенту, но не в случае, если ответ уже имеет тип application / json, то есть jsonобъект.Я не могу применить объект преобразования.При регистрации значения, отправленного в map (), я вижу, что оно регистрируется как неопределенное для объектов json.Итак, как мне получить ответ (даже если это объект json) и, возможно, зарегистрировать его и преобразовать перед отправкой клиенту в перехватчике

Примечание: я опасаюсь, что ответ может содержать конфиденциальную информацию,но я, вероятно, использовал бы маскирование журналов, чтобы просто замаскировать данные ответа, но это в настоящее время для целей тестирования

Вот пример контроллера, для которого я могу записать ответ в перехватчике 

@ApiOperation({ title: 'Get - With Params', description: 'Test Method with parms' })
@Get('/getTest/:id1/:id2')
@ApiOkResponse({ description: 'Sample string is emitted' })
@ApiResponse({ status: 404, description: 'The endpoint is unavailable' })
@ApiResponse({ status: 503, description: 'The endpoint cannot be processed' })
// @Header('sampleHeaderKey', 'sampleHeaderValue')
// NOte if you send params in the URL and do not use @param then the URL will
// result in NO such end point
public getConfigDataInResponse(@Param('id1') id1: number, @Param('id2') id2: number,  @Req() req) {
  logger.info('request headers', req.headers);
  logger.info('reqiest params', req.params);
  logger.info('reqiest query params', req.query);
  logger.info('reqiest body ', req.body);
  return 'TEST';
}

А вот метод, для которого ответ не может быть зарегистрирован, он переходит как «неопределенный» в перехватчике 

public getConfigDataInResponse(@Param('id1') id1: number, @Param('id2') id2: number,  @Req() req, @Res() res) {
  logger.info('request headers', req.headers);
  logger.info('reqiest params', req.params);
  logger.info('reqiest query params', req.query);
  logger.info('reqiest body ', req.body);
  res.set('SampeHeader', 'saomevaluie');
  res.status(HttpStatus.OK).send('some data');
}

1 Ответ

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

Когда вы вводите @Res() в методе вашего контроллера, многие функции, которые делают гнездо таким замечательным, как перехватчики, не будут работать.

В большинстве случаев вам не нужно вводить@Res() потому что вместо этого вы можете использовать выделенные декораторы.В вашем примере это будет: 

// Sets the http response code (default for POST is 201, for anything else 200)
@HttpCode(204)
// Sets a custom header
@Header('SampleHeader', 'somevalue')
@Get('/getTest/:id1/:id2')
public getConfigDataInResponse(@Param('id1') id1: number, @Param('id2') id2: number) {
  return 'some data';
}
...