change migration script to use async.whilst

Author: podviaznikov

scripts/update-github-webhooks-event.js

@@ -19,35 +19,39 @@ function findAllRepos(cb) {
 
 var allErrors = [];
 
+
+function findUser (users, cb) {
+  var user;
+  var count = 0;
+  async.whilst(
+    function () { return !user || count < users.length; },
+    function (callback) {
+      var u = users[count];
+      count++;
+      User.findByGithubId(user, function (err, gitHubUser) {
+        if (gitHubUser) {
+          user = gitHubUser;
+        }
+        callback();
+      });
+    },
+    function (err) {
+      if (err) {
+        return cb(err);
+      }
+      cb(null, user);
+    }
+  );
+}
+
+
 function findUsersForRepos(repos, cb) {
   debug('findUsersForRepos', 'total repos num:', repos.length);
   async.map(repos, function (repo, callback) {
-    User.findByGithubId(repo.creators[0], function (err, user) {
+    findUser(repo.creators, function (err, user) {
       if (err) { return callback(err); }
       repo.user = user;
-      if (!user) {
-        if (!repo.creators[1]) {
-          return callback(null, repo);
-        }
-        User.findByGithubId(repo.creators[1], function (err, user) {
-          if (err) { return callback(err); }
-          repo.user = user;
-          if (!user) {
-            if (!repo.creators[2]) {
-              return callback(null, repo);
-            }
-            User.findByGithubId(repo.creators[2], function (err, user) {
-              if (err) { return callback(err); }
-              repo.user = user;
-              callback(null, repo);
-            });
-          } else {
-            callback(null, repo);
-          }
-        });
-      } else {
-        callback(null, repo);
-      }
+      callback(null, repo);
     });
   }, cb);
 }
@@ -56,9 +60,9 @@ function findUsersForRepos(repos, cb) {
 function updateHooksEvents(repos, cb) {
   debug('updateHooksEvents', 'total repos num:', repos.length);
   async.mapLimit(repos, 50, function(repo, callback) {
-    console.log('processing repo', repo);
+    debug('processing repo', repo);
     if (!repo.user) {
-      console.log('user not found for the repo', repo);
+      debug('user not found for the repo', repo);
       return callback();
     }
     var github = new GitHub({token: repo.user.accounts.github.accessToken});
@@ -67,12 +71,14 @@ function updateHooksEvents(repos, cb) {
       if (err) {
         allErrors.push(err);
         if(err.output.statusCode === 404) {
-          console.log('repos not found. just skip it', repo);
+          debug('repos not found. just skip it', repo);
           callback(null);
-        } else if(err.output.statusCode === 502) {
-          console.log('access token removed. just skip it', repo);
+        }
+        else if(err.output.statusCode === 502) {
+          debug('access token removed. just skip it', repo);
           callback(null);
-        } else {
+        }
+        else {
           callback(err);
         }
       }