Add tests for TLS connections

test/lib/stunnel-process.js

@@ -0,0 +1,83 @@
+'use strict';
+
+// helper to start and stop the stunnel process.
+var spawn = require('child_process').spawn;
+var EventEmitter = require('events').EventEmitter;
+var fs = require('fs');
+var path = require('path');
+var util = require('util');
+
+function once(cb) {
+    var called = false;
+    return function() {
+        if(called) return;
+        called = true;
+        cb.apply(this, arguments);
+    };
+}
+
+function StunnelProcess(conf_dir) {
+    EventEmitter.call(this);
+
+    // set up an stunnel to redis; edit the conf file to include required absolute paths
+    var conf_file = path.resolve(conf_dir, 'stunnel.conf');
+    var conf_text = fs.readFileSync(conf_file + '.template').toString().replace(/__dirname/g, conf_dir);
+
+    fs.writeFileSync(conf_file, conf_text);
+    var stunnel = this.stunnel = spawn('stunnel', [conf_file]);
+
+    // handle child process events, and failure to set up tunnel
+    var self = this;
+    this.timer = setTimeout(function() {
+        self.emit('error', new Error('Timeout waiting for stunnel to start'));
+    }, 8000);
+
+    stunnel.on('error', function(err) {
+        self.clear();
+        self.emit('error', err);
+    });
+
+    stunnel.on('exit', function(code) {
+        self.clear();
+        if(code === 0) {
+            self.emit('stopped');
+        } else {
+            self.emit('error', new Error('Stunnel exited unexpectedly; code = ' + code));
+        }
+    });
+
+    // wait to stunnel to start
+    stunnel.stderr.on("data", function(data) {
+        if(data.toString().match(/Service.+redis.+bound/)) {
+            clearTimeout(this.timer);
+            self.emit('started');
+        }
+    });
+}
+util.inherits(StunnelProcess, EventEmitter);
+
+StunnelProcess.prototype.clear = function() {
+    this.stunnel = null;
+    clearTimeout(this.timer);
+};
+
+StunnelProcess.prototype.stop = function(done) {
+	if(this.stunnel) {
+	    this.stunnel.kill();
+	}
+};
+
+module.exports = {
+    start: function(done, conf_dir) {
+        done = once(done);
+        var stunnel = new StunnelProcess(conf_dir);
+        stunnel.once('error', done.bind(done));
+        stunnel.once('started', done.bind(done, null, stunnel));
+    },
+    stop: function(stunnel, done) {
+        stunnel.removeAllListeners();
+        stunnel.stop();
+        stunnel.once('error', done.bind(done));
+        stunnel.once('stopped', done.bind(done, null));
+    }
+};