En attente de tâches asynchrones pour terminer nodejs

Question

Je crée une application dans laquelle un utilisateur peut avoir de nombreuses chambres et chaque chambre peut avoir plusieurs canaux, voici mon code lors de la récupération des chambres et des canaux correspondants:

getRooms: function (req, res) { 
      User.find({id: req.cookies.claver_id}).exec(function (err, result) { 
       if (err) { 
        return res.send(400); 
       } 
       rooms = result[0].rooms; 
       if (rooms.length === 1) {//No room defaults to [''] 
        return res.send(400); 
       } 

       var roomsObj = {}; 
       var roomsArr = [];//we will place the roomsObj inside the roomsArr 

       var chansObj = {}; 
       var chansArr = []; 

       async.each(rooms, function (roomId, cb){ 
        roomsObj = {}; 
        if (roomId !== '') { 
        Rooms.findOne({id: roomId}).exec(function (err, room){ 
         roomName = room.name; 
         inviteLink = room.inviteLink; 
         roomsObj.name = roomName; 
         roomsObj.id = roomId; 
         roomsObj.inviteLink = inviteLink; 

         var channels = room.channels; 
         async.each(channels, function (channelId, cb) { 
          chansObj = {}; 
          Channels.findOne({id: channelId}).exec(function (err, channel){ 
          chansObj.name = channel.channelName; 
          chansObj.id = channelId; 
          chansObj.type = channel.channelType; 
          chansArr.push(chansObj); 
          cb(); 
         }); 
         }, 
         function (err) { 

         }); 


        }); 
       } 
       cb(); 

       }, function (err) { 
        roomsObj.channels = chansArr; 
        roomsArr.push(roomsObj); 
        sails.log(roomsArr); 

       }); 



      }); 
     } 

Il est supposé retourner un objet javascript avec la structure suivante:

[ { name: "Room Name", 
    roomId: "Room Id", 
    inviteLink: "Room Invite Link", 
    channels: [ 
       { 
       name: "Channel Name", 
       id: "channel Id" 
       } 
       ] 
    } 

] 

Mais je reçois toujours un tableau vide parce que async.each(rooms, function (roomId, cb){ }) n'attend pas async.each(channels, function (channelId, cb) {}) pour terminer, j'ai donc objet chambre vide. S'il vous plaît comment puis-je résoudre ce problème?

Answer 1

Vous devez appeler votre boucle rooms's callback après avoir terminé la boucle channels.

Vous devriez faire quelque chose comme ceci:

getRooms: function (req, res) { 
      User.find({id: req.cookies.claver_id}).exec(function (err, result) { 
       if (err) { 
        return res.send(400); 
       } 
       rooms = result[0].rooms; 
       if (rooms.length === 1) {//No room defaults to [''] 
        return res.send(400); 
       } 

       var roomsObj = {}; 
       var roomsArr = [];//we will place the roomsObj inside the roomsArr 

       var chansObj = {}; 
       var chansArr = []; 

       async.each(rooms, function (roomId, callback1){ 
        roomsObj = {}; 
        if (roomId !== '') { 
        Rooms.findOne({id: roomId}).exec(function (err, room){ 
         roomName = room.name; 
         inviteLink = room.inviteLink; 
         roomsObj.name = roomName; 
         roomsObj.id = roomId; 
         roomsObj.inviteLink = inviteLink; 

         var channels = room.channels; 
         var i=0; 
         async.each(channels, function (channelId, callback2) { 
          chansObj = {}; 
          Channels.findOne({id: channelId}).exec(function (err, channel){ 
          chansObj.name = channel.channelName; 
          chansObj.id = channelId; 
          chansObj.type = channel.channelType; 
          chansArr.push(chansObj); 
          i++; 
          if(i===(channels.length-1)){ 
           i=0; 
           callback1(); 
          }else{ 
          callback2(); 
          } 
         }); 
         }, 
         function (err) { 
         }); 
        }); 
       } 

       }, function (err) { 
        roomsObj.channels = chansArr; 
        roomsArr.push(roomsObj); 
        sails.log(roomsArr); 
       }); 
      }); 
     } 

Answer 2

Je l'ai résolu, il était vraiment un cas de promesses, je promesse Bluebird combinée avec async - le code modifié:

getRooms: function (req, res) { 
      User.find({id: req.cookies.claver_id}).exec(function (err, result) { 
       if (err) { 
        return res.send(400); 
       } 
       rooms = result[0].rooms; 
       if (rooms.length === 1) {//No room defaults to [''] 
        return res.send(400); 
       } 

       var roomsObj = {}; 
       var roomsArr = [];//we will place the roomsObj inside the roomsArr 

       var chansObj = {}; 
       var chansArr = []; 
       Promise.each(rooms, function (roomId, callback1){ 
        roomsObj = {}; 
        if (roomId !== '') { 
        async.series ([ 
         function() { 
          Rooms.findOne({id: roomId}).then(function (room){ 
         roomName = room.name; 
         inviteLink = room.inviteLink; 
         roomsObj.name = roomName; 
         roomsObj.id = roomId; 
         roomsObj.inviteLink = inviteLink; 
         channels = room.channels; 
         sails.log(roomName); 
         }) 
        } 
        ]); 
         return Promise.each(channels, function (channelId) { 
          return Promise.all([ 
          Channels.findOne({id: channelId}).then(function (channel){ 
          chansObj = {}; 
          chansObj.name = channel.channelName; 
          chansObj.id = channelId; 
          chansObj.type = channel.channelType; 
          chansArr.push(chansObj); 
          sails.log(chansObj); 
          }) 
          ]).then(function() { 
           sails.log('done one'); 

          }); 
         }).then(function() { 
          roomsObj.channels = chansArr; 
          roomsArr.push(roomsObj); 
          sails.log('done all'); 
          chansArr = []; 

         }); 
       } 
       }).then(function() { 
         sails.log(roomsArr); 
         sails.log("grand finish"); 
        }); 

      }); 
     } 

Merci à tous ceux qui ont contribué.