forEachSeries

gistfile1.txt

  
function checkUserTags(user) {
  var tags = user.tags
  var newTags = [];
 
  
  console.log( "Checking user", user._id)   
  if (tags.length > 0) {
    tags.forEach(function (tagName, i) {
      console.log("user", user._id, tagName, i);
        Tag
          .where('name', tagName)
          .findOne(function(err, tag)  {
           if (!tag) {
             var newtag = { name : tagName, type : 'award'}
             Tag.create(newtag, function(err, newtag) {
               console.log(user);
               if (err) {
                 console.log("error", err)
                 doneCheckingTags(i)
               } else {
                 console.log("tag created", newtag.name)
                 newTags.push(newtag._id);
                 doneCheckingTags(i)
               }                
             });
           } else {
             doneCheckingTags(i);
             newTags.push(tag._id);
           }
         });
      });  
  } else {
    console.log("User has no tags");
  }
  
  
    
  function doneCheckingTags(i) {
    if (i+1 >= tags.length) {
      updateUserTag(user._id, newTags);
      }
   }
  
  
}

  
  OldUser
    .find(function (err, users) {
      async.forEachSeries(users, checkUserTags, function (err) {
         console.log("done", err);
      });
    });