1 files changed, 93 insertions, 0 deletions
diff --git a/node_modules/forever/test/helpers/macros.js b/node_modules/forever/test/helpers/macros.js
new file mode 100644
index 0000000..47471f4
--- /dev/null
+++ b/node_modules/forever/test/helpers/macros.js
@@ -0,0 +1,93 @@
+/*
+ * macros.js: Test macros for the forever module
+ *
+ * (C) 2010 Nodejitsu Inc.
+ * MIT LICENCE
+ *
+ */
+ 
+var assert = require('assert'),
+    path = require('path'),
+    spawn = require('child_process').spawn,
+    nssocket = require('nssocket'),
+    forever = require('../../lib/forever'),
+    Worker = require('../../lib/forever/worker').Worker;
+ 
+var macros = exports;
+
+macros.assertTimes = function (script, times, options) {
+  options.max = times;
+  
+  return {
+    topic: function () {
+      var child = new (forever.Monitor)(script, options);
+      child.on('exit', this.callback.bind({}, null));
+      child.start();
+    },
+    "should emit 'exit' when completed": function (err, child) {
+      assert.equal(child.times, times);
+    }
+  }
+};
+
+macros.spawn = function (args, options) {
+  options.topic = function () {
+    var self = this;
+
+    args = [path.join(__dirname, '..', 'bin', 'forever')].concat(args);
+
+    var child = spawn(process.argv[0], args),
+        stdout = '',
+        stderr = '';
+
+    child.stdout.on('data', function (data) {
+      stdout += data;
+    });
+    child.stderr.on('data', function (data) {
+      stderr += data;
+    });
+    child.once('exit', function (exitCode) {
+      //
+      // Remark: We wait 200 ms because of forever boot up time (master
+      // doesn't wait for slave to start up after it's forked, it just quits)
+      //
+      setTimeout(function () {
+        self.callback(null, exitCode, stdout, stderr);
+      }, 200);
+    });
+  };
+  return options;
+};
+
+macros.list = function (options) {
+  options.topic = function () {
+    forever.list(false, this.callback)
+  };
+  return options;
+};
+
+macros.assertStartsWith = function (string, substring) {
+  assert.equal(string.slice(0, substring.length), substring);
+};
+
+macros.assertList = function (list) {
+  assert.isNotNull(list);
+  assert.lengthOf(list, 1);
+};
+
+macros.assertWorkerConnected = function (workerOptions, batch) {
+  return {
+    topic: function () {
+      var self = this,
+          reader = new nssocket.NsSocket(),
+          worker = new Worker(workerOptions);
+
+      worker.start(function (err, sock) {
+        reader.connect(sock, function () {
+          self.callback(null, reader, worker, workerOptions);
+        });
+      });
+    },
+    'worker should connect': batch
+  };
+};