Implemented flag --watch-delay with tests

bin/pm2

@@ -75,6 +75,7 @@ commander.version(pkg.version)
   .option('--merge-logs', 'merge logs from different instances but keep error and out separated')
   .option('--watch [paths]', 'watch application folder for changes', function(v, m) { m.push(v); return m;}, [])
   .option('--ignore-watch <folders|files>', 'List of paths to ignore (name or regex)')
+  .option('--watch-delay <delay>', 'specify a restart delay after changing files (--watch-delay 4 (in sec) or 4000ms)')
   .option('--no-color', 'skip colors')
   .option('--no-vizion', 'start an app without vizion feature (versioning control)')
   .option('--no-autorestart', 'start an app without automatic restart')

lib/API.js

@@ -659,6 +659,14 @@ class API {
       }
     }
 
+    if (opts.watchDelay) {
+      if (typeof opts.watchDelay === "string" && opts.watchDelay.indexOf("ms") !== -1)
+        app_conf.watch_delay = parseInt(opts.watchDelay);
+      else {
+        app_conf.watch_delay = parseFloat(opts.watchDelay) * 1000;
+      }
+    }
+
     /**
      * If -w option, write configuration to configuration.json file
      */

lib/Watcher.js

@@ -64,16 +64,18 @@ module.exports = function ClusterMode(God) {
 
       console.error('Change detected on path %s for app %s - restarting', path, pm2_env.name);
 
-      God.restartProcessName(pm2_env.name, function(err, list) {
-        self.restarting = false;
-
-        if (err) {
-          log('Error while restarting', err);
-          return false;
-        }
-
-        return log('Process restarted');
-      });
+      setTimeout(function() {
+        God.restartProcessName(pm2_env.name, function(err, list) {
+          self.restarting = false;
+
+          if (err) {
+            log('Error while restarting', err);
+            return false;
+          }
+
+          return log('Process restarted');
+        });
+      }, (pm2_env.watch_delay || 0));
 
       return false;
     });

test/programmatic/flagWatch.mocha.js

@@ -52,4 +52,4 @@ describe('Flag --ignore-watch', function() {
         f_w.handleFolders('./node_modules', res);
         should(res).be.empty();
     });
-});
+});

test/programmatic/watcher.js

@@ -178,6 +178,16 @@ describe('Watcher', function() {
     })
   })
 
+  it('should work with watch_delay', function(cb) {
+    testPM2Env('server-watch:online')({watch: true, watch_delay: 4000}, cb);
+    pm2.start(extend(json, {watch: true, watch_delay: 4000}), errShouldBeNull);
+  })
+
+  it('should not crash with watch_delay without watch', function(cb) {
+    testPM2Env('server-watch:online')({watch_delay: 4000}, cb);
+    pm2.start(extend(json, {watch_delay: 4000}), errShouldBeNull);
+  })
+
   /**
    * Test #1668
    */