MongoDB
 sql >> Database >  >> NoSQL >> MongoDB

Come gestire i callback in un ciclo for (Node.JS)

Questo problema è definito come "callback hell" .Ci sono molti altri approcci come l'utilizzo di Promise e Async biblioteche che troverai.

Sono più entusiasta del nativo async ES7 porterà, che puoi effettivamente iniziare a utilizzare oggi con la libreria transpiler Babel .

Ma di gran lunga l'approccio più semplice che ho trovato è il seguente:elimini le lunghe funzioni di callback e le definisci all'esterno.

router.route('/report') // the REST api address
    .post(calling_a_POST)

function calling_a_POST(req, res) {
    ...
    var data = "";
    https.get(url, function callback(response) {
        ...
        response.on("end", response_on_end_callback); // --> take out
        response.on("error", console.error);
    });
}

function response_on_end_callback() {                 // <-- define here
    ...
    for (var i = 0; i < length; i++) {
        var report = new Report(array.pop());
        ...
        Report.find({ id: report['id'] })
              .count(Report_find_count_callback);     // --> take out
    };
    res.json({
        message: 'Grabbed Report'
    });
}

function Report_find_count_callback(err, count) {     // <-- define here
    ...
    if (count == 0) {
        report.save(function(err) {                   // !! report is undefined here
            console.log('saved');
            if (err)
                res.send(err);                        // !! res is undefined here
        });
    }
}

Un avvertimento è che non sarai in grado di accedere a tutte le variabili all'interno di quella che era la callback, perché le hai tolte dall'ambito.

Questo potrebbe essere risolto con una sorta di wrapper di "iniezione di dipendenza" per passare le variabili richieste.

router.route('/report') // the REST api address
    .post(calling_a_POST)

function calling_a_POST(req, res) {
    ...
    var data = "";
    https.get(url, function callback(response) {
        ...
        response.on("end", function(err, data){       // take these arguments
            response_on_end(err, data, res);          // plus the needed variables
        });
        response.on("error", console.error);
    });
}

function response_on_end(err, data, res) {  // and pass them to function defined outside
    ...
    for (var i = 0; i < length; i++) {
        var report = new Report(array.pop());
        ...
        Report.find({ id: report['id'] })
            .count(function(err, count){
                Report_find_count(err, count, report, res);  // same here
            });
    };
    res.json({                                        // res is now available
        message: 'Grabbed Report'
    });
}

function Report_find_count(err, count, report, res) {        // same here
    ...
    if (count == 0) {
        report.save(function(err) {                   // report is now available
            console.log('saved');
            if (err)
                res.send(err);                        // res is now available
        });
    }
}

Mi rendo conto di aver commesso un errore qui:

function calling_a_POST(req, res) {
    ...
    var data = "";
    https.get(url, function callback(response) {
        ...
        //sponse.on("end", function(err, data){
        response.on("end", function(err){ // data shouldn't be here
            response_on_end(err, data, res);
        });
        response.on("error", console.error);
    });
}

Un altro problema che potevo prevedere, che in realtà potrebbe non sorgere qui ma sarebbe comunque meglio parlarne comunque. I data variabile, poiché è una stringa che è un tipo primitivo a differenza di un oggetto, è "passata per valore". Maggiori informazioni

È meglio racchiudere la variabile in un oggetto e passare l'oggetto, perché gli oggetti in javascript sono sempre "passati per riferimento".

function calling_a_POST(req, res) {
    ...
    // var data = ""; // 
    var data_wrapper = {};
    data_wrapper.data = {};                                // wrap it in an object
    https.get(url, function callback(response) {
        ...
        response.on("data", function(chunk){
            data_wrapper.data += chunk.toString() + "";   // use the dot notation to reference
        });
        response.on("end", function(err){ 
            response_on_end(err, data_wrapper, res);      // and pass that object
        });
        response.on("error", console.error);
    });
}

function response_on_end_callback(err, data_wrapper, res) {
    var data = data_wrapper.data;                         // later redefine the variable
    ...
    for (var i = 0; i < length; i++) {
        var report = new Report(array.pop());
        ...