Bluebird.Promisify - Как правильно создать цепочку обещаний?

Question

Этот вопрос следует этому вопросу: node.js: how to return a value of a callback function?

Я решил написать код в предыдущем вопросе, используя Bluebird.promisify. Это то, что я писал:

var express = require('express') 
var app = express() 
var MongoClient = require('mongodb').MongoClient; 
var db = require('./db.js') 
var Promise = require('bluebird'); 

app.get('/', function(req, res){ 
    var result = Promise.promisify(db.get_document); 
    result().then(function(doc) { 
     res.send(doc); 
     console.log("end"); 
    }); 
}); 

app.listen(3000, function(req, res) { 
    console.log("Listening on port 3000"); 
}); 

function get_document() { 
    var connect = Promise.promisify(MongoClient.connect); 
    connect(url).then(function(err,db) { 
    var col = db.collection('myinterviews'); // !!! ERROR!!! 'db' undefined 
    return col.find().toArray 
    }).then(function (err, docs) { 
    db.close(); 
    return docs[0].name; 
    }); 
}; 

Линия:

var col = db.collection('myinterviews');

выдает сообщение об ошибке:

"Unhandled rejection TypeError: Cannot read property 'collection' of undefined."

Функция MongoClient.connect принимает функцию обратного вызова с двумя аргументами, так почему 'db' undefined?

Answer 1

Обещание не передает ошибки и результат к тому же методу. Вы должны добавить catch, чтобы получить ошибку.

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

var express = require('express') 
var app = express() 
var MongoClient = require('mongodb').MongoClient; 
var Promise = require('bluebird'); 

app.get('/', function(req, res){ 

    var result = Promise.promisify(get_document); 
    result().then(function(doc) { 
     res.send(doc); 
     console.log("end"); 
    }).catch(function(err){ 
     console.log(err); 
     res.status(500).send(err.toString()); 
    }); 
}); 

app.listen(3000, function(req, res) { 
    console.log("Listening on port 3000"); 
}); 

function get_document (callback) { 
    return Promise.promisify(MongoClient.connect)(YOUR_URL) 
    .then(function(db){ 
     return db.collection(YOUR_COLLECTION).find().toArray(); 
    }) 
    .then(function (docs) { 
     return callback(null, docs[0].name); 
    }).catch(function(err){ 
     return callback(err); 
    }); 
};