Knoten Rückkehr BluebirdJS Versprechen

Question

ich habe ein kleines Problem, dieses Skript funktioniert perfekt, mit einem Problem, das „runTenant“ Methode ist nicht ein Versprechen der Rückkehr (die von „all()“ muss die Lösung

Dieser Code.:

Promise.resolve(runTenant(latest)).then(function() { 
    end(); 
}); 

fordert diesen Code:

function runTenant(cb) { 
    return new Promise(function() { 
    //global var 
    if (!Tenant) { 
     loadCoreModels(); 
     Tenant = bookshelf.core.bs.model('Tenant'); 
    } 

    new Tenant().fetchAll() 
     .then(function(tenants) { 

     if (tenants.models.length == 0) { 
      return; 
     } else { 
      async.eachSeries(tenants.models, function(tenant, next) { 

      var account = tenant.attributes; 
      Promise.resolve(db_tenant.config(account)).then(function(knex_tenant_config) { 
       if (knex_tenant_config) { 
       db_tenant.invalidateRequireCacheForFile('knex'); 
       var knex_tenant = require('knex')(knex_tenant_config); 
       var knex_pending = cb(knex_tenant); 
       Promise.resolve(knex_pending).then(function() { 
        next(null, null); 
       }); 
       } else { 
       next(null, null); 
       } 
      }); 

      }); 
     }; 
     }); 
    }); 
} 

der Code von runTenant richtig funktioniert aber es Stände und können nicht zum "end()", weil das Versprechen von "runTenant (spätestens)" isn‘ t sein gelöst werden.

Als ob es nicht offensichtlich wäre, bin ich schrecklich bei Versprechungen. Arbeitet immer noch daran, meinen Kopf um sie herum zu bekommen.

Vielen Dank für jede Hilfe/Richtung!

Answer 1

Sie nicht den Promise Konstruktor überhaupt hier verwenden sollten (und im Grunde auch nicht anderswo), selbst wenn Sie es zum Laufen gebracht hätten, wäre es ein antipattern. Sie haben dieses Versprechen nie gelöst - beachten Sie, dass die resolve argument zu Promise Konstruktor Rückruf ist eine sehr unterschiedliche Funktion als Promise.resolve.

Und Sie sollten nicht die async Bibliothek verwenden, wenn Sie eine leistungsstarke Versprechen Bibliothek wie Bluebird zur Hand haben.

Als ob es nicht offensichtlich wäre, bin ich schrecklich bei Versprechungen.

Vielleicht wollen Sie einen Blick auf meine rules of thumb zum Schreiben von Versprechen Funktionen.

Hier ist, was Ihre Funktion sollte wie folgt aussehen:

function runTenant(cb) { 
    //global var 
    if (!Tenant) { 
    loadCoreModels(); 
    Tenant = bookshelf.core.bs.model('Tenant'); 
    } 
    return new Tenant().fetchAll().then(function(tenants) { 
    // if (tenants.models.length == 0) { 
    // return; 
    // } else 
    // In case there are no models, the loop iterates zero times, which makes no difference 
    return Promise.each(tenants.models, function(tenant) { 
     var account = tenant.attributes; 
     return db_tenant.config(account).then(function(knex_tenant_config) { 
     if (knex_tenant_config) { 
      db_tenant.invalidateRequireCacheForFile('knex'); 
      var knex_tenant = require('knex')(knex_tenant_config); 
      return cb(knex_tenant); // can return a promise 
     } 
     }); 
    }); 
    }); 
} 

Answer 2

Sie müssen alle verschachtelten Versprechen zurückgeben. Ich kann diesen Code nicht ausführen, also ist das kein Problem. Aber hoffentlich hilft es Ihnen zu verstehen, was fehlt.

function runTenant(cb) { 
    //global var 
    if (!Tenant) { 
     loadCoreModels(); 
     Tenant = bookshelf.core.bs.model('Tenant'); 
    } 

    return new Tenant().fetchAll() //added return 
     .then(function (tenants) { 

      if (tenants.models.length == 0) { 
       return; 
      } else { 
       var promises = []; //got to collect the promises 
       tenants.models.each(function (tenant, next) { 

        var account = tenant.attributes; 
        var promise = Promise.resolve(db_tenant.config(account)).then(function (knex_tenant_config) { 
         if (knex_tenant_config) { 
          db_tenant.invalidateRequireCacheForFile('knex'); 
          var knex_tenant = require('knex')(knex_tenant_config); 
          var knex_pending = cb(knex_tenant); 
          return knex_pending; //return value that you want the whole chain to resolve to 
         } 
        }); 
        promises.push(promise); //add promise to collection 
       }); 
       return Promise.all(promises); //make promise from all promises 
      } 
     }); 
} 

Answer 3

Ihre Versprechen in runTenant Funktion wird nie gelöst. Sie müssen resolve oder reject Funktion aufrufen Versprechen zu beheben:

function runTenant() { 
    return new Promise(function(resolve, reject) { 
    // somewhere in your code 
    if (err) { 
     reject(err); 
    } else { 
     resolve(); 
    } 
    }); 
}); 

Und Sie sollten nicht cb in runTenant Funktion übergeben, verwenden Versprechen Kette:

runTenant() 
.then(latest) 
.then(end) 
.catch(function(err) { 
    console.log(err); 
});