молекулярный веб-шлюз API. onError никогда не ударил - PullRequest
0 голосов
/ 07 февраля 2020

Мы использовали пример с сайта молекулярной системы в качестве основы для нашего API-шлюза, и у нас возникают проблемы, когда маршруты выдают ошибки - обработчик onError никогда не срабатывает, исключение не обрабатывается, и узел вылетает в приложение. Не идея!

Я понимаю, что это НЕ полный пример, но быстрый взгляд, если мы допустили какие-либо грубые ошибки в концепции или ожидаем, что обработчик onError будет удачным ...

const OpenApiMixin = require('./openapi.mixin')
const { MoleculerError } = require('moleculer').Errors

class BadRequestError extends MoleculerError {
  constructor (message) {
    message = message || 'Bad request'
    super(message, 400, 'Bad request')
  }
}

...
const functionThatCanThrowError = async (req, res)=>{
    if (!req.body.email) {
      throw new BadRequestError('No email transferred.')
    }
    ...
}

module.exports = {
  name: 'api-gateway',
  mixins: [ApiGateway, OpenApiMixin()],
  settings: {
    ...
    path: '/',
    routes: [
    {
      path: '/api',
      ...
      aliases: {
            'POST /route-can-throw-error': functionThatCanThrowError
      },

      // Route error handler
      onError (req, res, err) {
        let { type, code, message, data, name } = err
        res.writeHead(Number(code) || 500, { 'Content-Type': 'application/json' })
        res.end(JSON.stringify({ type, code, message, data, name }))
      }
    }
 ]
}``

Ответы [ 2 ]

3 голосов
/ 07 февраля 2020

Определенный functionThatCanThrowError является промежуточным программным обеспечением. Это должно быть Express -подобное промежуточное ПО, где вы не можете выдать ошибку. Для этого вам следует позвонить next(err).

Например:

const functionThatCanThrowError = async (req, res, next)=>{
    if (!req.body.email) {
      next(new BadRequestError('No email transferred.'))
    }
    ...
}

Дополнительная информация: https://expressjs.com/en/guide/error-handling.html

2 голосов
/ 07 февраля 2020

Что сказал @icebob + пример


    module.exports = {
        name: "api",
        mixins: [ApiGateway],
        settings: {
            port: process.env.PORT || 3000,
            routes: [
                {
                    path: "/api",

                    whitelist: ["**"],

                    aliases: {
                        "GET /req-res-error": [
                            (req, res, next) => {
                                next(new MoleculerError("Req-Res Error"));
                            }
                        ],
                        "GET /action-error": "api.actionError"
                    },

                    onError(req, res, err) {
                        this.logger.error("An Error Occurred!");
                        res.end("Global error: " + err.message);
                    }
                }
            ]
        },

        actions: {
            async actionError() {
                throw new MoleculerError("ACTION ERROR");
            }
        }
    };

...