NestJS 全局身份验证全局守卫与 RabbitMQ 订阅者发生冲突

Question

我正在使用 @golevelup/nestjs-rabbitmq 来处理来自队列的 RabbitMQ 消息，全局防护正在拦截来自队列的请求。有什么办法可以阻止全局警卫收到这些请求吗？

Auth Guard

@Injectable()
export default class GqlAuthGuard extends AuthGuard(AuthStrategy.Jwt) {
  constructor(private reflector: Reflector) {
    super();
  }

  getRequest(context: ExecutionContext) {
    const ctx = GqlExecutionContext.create(context);

    return ctx.getContext();
  }

  canActivate(context: ExecutionContext) {
    const isPublic = this.reflector.getAllAndOverride<boolean>(IS_PUBLIC_KEY, [
      context.getHandler(),
      context.getClass(),
    ]);

    if (isPublic) {
      return true;
    }

    return super.canActivate(context);
  }
}

RabbitMQ Subscriber

@SubscribeToEvent({
    queue: Topic.SendSurvey,
  })
  async handler({ surveyId, schedulingEventId }: HandlerParams) {
    this.logger.info('Handling message', surveyId, schedulingEventId);

    this.surveysService.dispatch(surveyId, schedulingEventId);
  }

我遇到的错误

[22-03-24 02:52:31] [error] [app] TypeError: Cannot read properties of undefined (reading 'req') {"0":"MotivatoExceptionsHandler"}
[22-03-24 02:52:31] [error] [app] TypeError: Cannot read properties of undefined (reading 'req') {"0":"MotivatoExceptionsHandler"}
[22-03-24 02:52:31] [error] [app] TypeError: Cannot read properties of undefined (reading 'req') {"0":"MotivatoExceptionsHandler"}
[22-03-24 02:52:31] [error] [app] TypeError: Cannot read properties of undefined (reading 'req') {"0":"MotivatoExceptionsHandler"}

我尝试更改 getRequest 但它不起作用

Answer 1

async canActivate(context: ExecutionContext): Promise<boolean> {
  const type = context.getType<'rmq'>()
  if (type === 'rmq') {
    return true
  }
  ...
}

以这种方式添加时有效