Merge pull request #94 from sarangjo/manual-restart

Add manual restart option

Author: wclr

lib/index.js

@@ -7,6 +7,7 @@ var fs = require('fs')
 var tsNodeVersion = require('ts-node').VERSION
 var tsVersion = require('typescript').version
 var kill = require('tree-kill')
+var readline = require('readline')
 
 module.exports = function(script, scriptArgs, nodeArgs, opts) {
   if (typeof script !== 'string' || script.length === 0) {
@@ -44,34 +45,7 @@ module.exports = function(script, scriptArgs, nodeArgs, opts) {
     recursive: true
   })
   var starting = false
-  watcher.on('change', function(file) {
-    if (file === compiler.tsConfigPath) {
-      notify('Reinitializing TS compilation')
-      compiler.init(opts)
-    }
-    /* eslint-disable no-octal-escape */
-
-    if (cfg.clear || cfg.cls) {
-      process.stdout.write('\033[2J\033[H')
-    }
-    notify('Restarting', file + ' has been modified')
-    compiler.compileChanged(file)
-    if (starting) {
-      log.debug('Already starting')
-      return
-    }
-    log.debug('Removing all watchers from files')
-    watcher.removeAll()
-    starting = true
-    if (child) {
-      log.debug('Child is still running, restart upon exit')
-      child.on('exit', start)
-      stop()
-    } else {
-      log.debug('Child is already stopped, probably due to a previous error')
-      start()
-    }
-  })
+  watcher.on('change', restart)
 
   watcher.on('fallback', function(limit) {
     log.warn('node-dev ran out of file handles after watching %s files.', limit)
@@ -80,6 +54,19 @@ module.exports = function(script, scriptArgs, nodeArgs, opts) {
     if (cfg.deps) log.info('... or add `--no-deps` to use less file handles.')
   })
 
+  // Read for "rs" from command line
+  const rl = readline.createInterface({
+    input: process.stdin,
+    output: process.stdout,
+    terminal: false
+  })
+  rl.on('line', function(line) {
+    if (line.trim() === 'rs') {
+      log.debug('User entered `rs`')
+      restart('', true)
+    }
+  })
+
   /**
    * Run the wrapped script.
    */
@@ -192,6 +179,36 @@ module.exports = function(script, scriptArgs, nodeArgs, opts) {
     }
   }
 
+  function restart(file, isManualRestart) {
+    if (file === compiler.tsConfigPath) {
+      notify('Reinitializing TS compilation')
+      compiler.init(opts)
+    }
+    /* eslint-disable no-octal-escape */
+    if (cfg.clear) process.stdout.write('\033[2J\033[H')
+    if (isManualRestart) {
+      notify('Restarting', 'manual restart from user')
+    } else {
+      notify('Restarting', file + ' has been modified')
+    }
+    compiler.compileChanged(file)
+    if (starting) {
+      log.debug('Already starting')
+      return
+    }
+    log.debug('Removing all watchers from files')
+    watcher.removeAll()
+    starting = true
+    if (child) {
+      log.debug('Child is still running, restart upon exit')
+      child.on('exit', start)
+      stop()
+    } else {
+      log.debug('Child is already stopped, probably due to a previous error')
+      start()
+    }
+  }
+
   // Relay SIGTERM
   process.on('SIGTERM', function() {
     log.debug('Process got SIGTERM')