Блог

Я подозреваю, что есть какая-то проблема с кодом, и это, скорее всего, в части catch, которая в целом приводит к сбою серверного приложения.

Цель: В основном проверка типа ошибки, которая может быть обработана, например, если объект не существует, для всех других ошибок корректно отклоните их обратно вызывающему без сбоя приложения.

 const Article = require("Article");

function upload(row) {
    return new Promise(function(resolve, reject){

        Article.requestData(row.schema) // if exists
            .then(Article.upload.bind(null, row.article)) //may throw error
            .then(resolve) // done if OK
            .catch(function(error){
                if(error.code == "NotFoundException") { // entity doesn't exists
                    Article.create(row.schema) // create entity
                        .then(Article.upload.bind(null, row.article)) // upload
                        .then(resolve, reject); // reject upload error
                } else { // upload errors
                    // reject(error); // tried reject
                    throw error; // trying re-throw
                }
            });
    });
}
  

Код сначала пытается получить информацию о сущности, и если она не найдена, он создает ее.

Теперь часть загрузки может выдавать ошибку, которую мне нужно корректно отправить обратно вызывающему.

Ошибка, которую я получаю, это UnhandledPromiseRejectionWarning

Тот же код, но переписанный.

 function upload(row) {

   return Article.requestData(row.schema) // if exists
     .then(Article.upload.bind(null, row.article)) //may throw error
     .catch(function(error){
        if(error.code == "NotFoundException") { // entity doesn't exists
           return Article.create(row.schema) // create entity
             .then(Article.upload.bind(null, row.article)) // upload
        } else {
            throw error;
     });
}
  

Запуск new Promise() часто называют антишаблоном. Иногда вы не можете легко обойти это, но это типичный случай, когда это совершенно не нужно.

Каждый раз, когда вы вызываете .then() or .catch() , возвращается новое обещание, и это то же самое обещание, которое вы хотите вернуть из своей функции.

Вот версия async / await, просто для удовольствия:

 async function upload(row) {

  try {
    await Article.requestData(row.schema) // if exists
    await Article.upload.bind(row.article);
  } catch (error) {

    if(error.code == "NotFoundException") { // entity doesn't exists
       await Article.create(row.schema) // create entity
       await Article.upload(row.article);
    } else {
       throw error;
    }
  }
}