Utilizzo di loop e promesse nelle transazioni in Sequenza

Question

Attualmente sto creando un'app Nodejs, Express, Sequelize (w. PostgreSQL) e ho incontrato alcuni problemi nell'usare promesse insieme a transazioni e loop.

Sto cercando di capire come utilizzare un ciclo for in una transazione. Sto cercando di scorrere un elenco di membri e creare un nuovo utente nel database per ciascuno di essi.

So che il seguente codice è errato ma mostra ciò che sto cercando di fare.

Qualcuno può indicarmi la giusta direzione?

 var members = req.body.members; 
     models.sequelize.transaction(function (t) { 
      for (var i = 0; i < members.length; i++) { 
       return models.User.create({'firstname':members[i], 'email':members[i], 'pending':true}, {transaction: t}).then(function(user) { 
        return user.addInvitations([group], {transaction: t}).then(function(){}).catch(function(err){return next(err);}); 
       }) 
      }; 
     }).then(function (result) { 
      console.log("YAY"); 
     }).catch(function (err) { 
      console.log("NO!!!"); 
      return next(err); 
     }); 

Answer 1

È necessario utilizzare un Promise.all

var members = req.body.members; 
    models.sequelize.transaction(function (t) { 
     var promises = [] 
     for (var i = 0; i < members.length; i++) { 
      var newPromise = models.User.create({'firstname':members[i], 'email':members[i], 'pending':true}, {transaction: t}); 
      promises.push(newPromise); 
     }; 
     return Promise.all(promises).then(function(users) { 
      var userPromises = []; 
      for (var i = 0; i < users.length; i++) { 
       userPromises.push(users[i].addInvitations([group], {transaction: t}); 
      } 
      return Promise.all(userPromises); 
     }); 
    }).then(function (result) { 
     console.log("YAY"); 
    }).catch(function (err) { 
     console.log("NO!!!"); 
     return next(err); 
    }); 

non credo è necessario catch all'interno di transazioni sequelize come penso che salta fuori per il fermo sulla transazione

Siamo spiacenti per la formattazione . Sul cellulare.

Promise.all attenderà tutte le promette di tornare (o non riescono) prima di eseguire l'.then, e il callback .then sarà tutti i dati promessa da parte ogni array

Answer 2

È necessario utilizzare il costruito nel loop costrutti di Bluebird fornito con sequelize:

var members = req.body.members; 
models.sequelize.transaction(t => 
    Promise.map(members, m => // create all users 
    models.User.create({firstname: m, email: m, 'pending':true}, {transaction: t}) 
).map(user => // then for each user add the invitation 
    user.addInvitations([group], {transaction: t}) // add invitations 
)).nodeify(err); // convert to node err-back syntax for express 

Answer 3

primo: https://caolan.github.io/async/docs.html

Così, facilmente:

// requiring... 
const async = require('async'); 

// exports... 
createAllAsync: (array, transaction) => { 
    return new Promise((resolve, reject) => { 
    var results = []; 
    async.forEachOf(array, (elem, index, callback) => { 
     results.push(models.Model.create(elem, {transaction})); 
     callback(); 
    }, err => { 
     if (err) { 
     reject(err); 
     } 
     else { 
     resolve(results); 
     } 
    }); 
    }); 
}