Блог

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

 router.route('/addSomething').post(async (req,res,next) => {
  await Document.findOne(
    {name: req.body.name}, // search parameter
    (error,doc) = { // callback
      if(error) return next(error) // pass system generated error to next() and exit route
      else if (doc) return next(new Error("This name already exists")) // pass my own error to next() and exit route
    })

  // everything from now on shouldn't happen

  await Document.save() etc...
 

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

Я ищу элегантный способ обработки ошибок mongoose/mongodb и выхода из функции в момент ошибки, не помещая блоки try/catch повсюду.

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

 router.route('/addSomething').post(async (req, res, next) => {
    await Document.findOne(
        { name: req.body.name }, // search parameter
        (error, doc) => { // callback
            if (error) return next(error) // pass system generated error to next() and exit route
            else if (doc) return next(new Error("This name already exists")) // pass my own error to next() and exit route

            continue(); // Call the continue function if function isn't already returned
        }
    );
    function continue() { // Add a continue function
        // Continue your code
        await Document.save();
        // ...
    }
});
 

Рассмотрите возможность использования util.promisify , чтобы избавиться от обратного вызова:

 router.route('/addSomething').post(async (req, res, next) => {
  try {
    var doc = await util.promisify(Document.findOne)(
      { name: req.body.name } // search parameter
    );
  } catch(error) {
    return next(error); // pass system generated error to next() and exit route
  }
  if (doc) return next(new Error("This name already exists")); // pass my own error to next() and exit route
  // everything from now on shouldn't happen
  await Document.save() etc...
});