如何儘早打破承諾鏈，在Express中發送錯誤？

Question

我有這樣的要求處理程序，它看起來像這樣：

router.post('/', function(req,res) { 
    var screencast; 
    var channel; 

    youtube.get(req.body.videoId).then(function(data) { 
    screencast = data.screencast; 
    channel = data.channel; 
    }).then(function() { 
    return connection.beginTransactionAsync(); 
    }).then(function() { 
    return connection.queryAsync('INSERT IGNORE INTO Channels SET ?', channel); 
    }).then(function() { 
    return connection.queryAsync('INSERT INTO Screencasts SET ?', screencast) 
    }).then(function() { 
    return connection.commit(); 
    }).error(function(e) { 
    connection.rollback(); 
    }); 
}); 

有時候我想打破諾言鏈早期併發送一個錯誤。這裏是我的嘗試：

router.post('/', function(req,res) { 
    var screencast; 
    var channel; 

    youtube.get(req.body.videoId).then(function(data) { 
    if (data === null) { 
     res.send('error: video does not exist.'); 
     return; 
    } 
    screencast = data.screencast; 
    channel = data.channel; 
    }).then(function() { 
    console.log('trace: starting transaction'); 
    return connection.beginTransactionAsync(); 
    }).then(function() { 
    return connection.queryAsync('INSERT IGNORE INTO Channels SET ?', channel); 
    }).then(function() { 
    return connection.queryAsync('INSERT INTO Screencasts SET ?', screencast) 
    }).then(function() { 
    return connection.commit(); 
    }).error(function(e) { 
    connection.rollback(); 
    }); 
}); 

雖然顯示錯誤，許鏈demonstrably不破;下一個函數被調用。

我的問題是，我該如何早點破壞承諾鏈發送錯誤？

東西，我試過是引入一個多個級別的縮進：

youtube.get(req.body.videoId).then(function(data) { 
    if (data === null) { 
    res.send('error: video does not exist.'); 
    return; 
    } 
    connection.beginTransactionAsync().then(function() { 
    return connection.queryAsync('INSERT IGNORE INTO Channels SET ?', channel); 
    }).then(... 

我發現這個工作然而，我擔心使用更多的嵌套，因爲我還需要檢查視頻是否已經存儲在數據庫中，在處理之前，需要兩個的縮進級別，也許更多。

我發現了另外兩個答案（one），但它們對我沒有幫助。我的問題特別與Bluebird和Express有關。

Answer 1

我想你只需要在你的承諾鏈上添加一個.catch的回調函數，當你遇到一個應該違背承諾的問題時，你需要添加一個.catch回調函數和throw。

router.post('/', function(req,res) { 
    var screencast; 
    var channel; 

    youtube.get(req.body.videoId).then(function(data) { 
    if (data === null) { 
     throw new Error('video does not exist.'); 
    } 
    screencast = data.screencast; 
    channel = data.channel; 
    }).then(function() { 
    console.log('trace: starting transaction'); 
    return connection.beginTransactionAsync(); 
    }).then(function() { 
    return connection.queryAsync('INSERT IGNORE INTO Channels SET ?', channel); 
    }).then(function() { 
    return connection.queryAsync('INSERT INTO Screencasts SET ?', screencast) 
    }).then(function() { 
    return connection.commit(); 
    }).error(function(e) { 
    connection.rollback(); 
    }).catch(function(err){ 
    res.send("error: " + err); 
    }); 
});