support timeout option in in-process strategy

lib/in-process.js

@@ -1,4 +1,6 @@
 var ScriptsManager = module.exports = function (options) {
+  this.options = options
+  this.options.timeout = this.options.timeout || 10000
 }
 
 ScriptsManager.prototype.start = function (cb) {
@@ -10,7 +12,24 @@ ScriptsManager.prototype.ensureStarted = function (cb) {
 }
 
 ScriptsManager.prototype.execute = function (inputs, options, cb) {
-  require(options.execModulePath)(inputs, options.callback, cb)
+  var resolved = false
+
+  var timeout = setTimeout(function () {
+    cb(new Error('Timeout error during executing script'))
+  }, options.timeout || this.options.timeout)
+
+  timeout.unref()
+
+  require(options.execModulePath)(inputs, options.callback, function (err, res) {
+    if (resolved) {
+      return
+    }
+
+    resolved = true
+    clearTimeout(timeout)
+
+    cb(err, res)
+  })
 }
 
 ScriptsManager.prototype.kill = function () {

test/test.js

@@ -154,7 +154,7 @@ describe('scripts manager', function () {
   })
 
   describe('in process', function () {
-    var scriptsManager = new ScriptManagerInProcess()
+    var scriptsManager = new ScriptManagerInProcess({})
 
     beforeEach(function (done) {
       scriptsManager.ensureStarted(done)
@@ -165,6 +165,27 @@ describe('scripts manager', function () {
     })
 
     common(scriptsManager)
+
+    it('should handle timeouts', function (done) {
+      var timeouted = false
+
+      scriptsManager.execute({ foo: 'foo' },
+        {
+          execModulePath: path.join(__dirname, 'scripts', 'timeout.js'),
+          timeout: 10
+        }, function (err) {
+          if (err) {
+            timeouted = true
+            done()
+          }
+        })
+
+      setTimeout(function () {
+        if (!timeouted) {
+          done(new Error('It should timeout'))
+        }
+      }, 500)
+    })
   })
 
   function commonForSafeExecution (scriptsManager) {