add ssl support

to use ssl, there are a few new arguments in the object passed to the
Stomp constructor:

- ssl: `{boolean}`, use ssl for the connection
- ssl_validate: `{boolean}`, disconnect if the certificate does not
  validate
- ssl_options: `{object}`, passed into the tls.connect method as the
  `options` parameter, see <http://nodejs.org/docs/v0.4.8/api/tls.html>

Signed-off-by: Joshua Rubin <jrubin@zvelo.com>

Author: Joshua Rubin

lib/stomp.js

@@ -21,6 +21,7 @@
 */
 
 var net = require('net'),
+    tls = require('tls'),
     sys = require('sys'),
     frame = require('./frame'),
     stomp_utils = require('./stomp-utils'),
@@ -91,21 +92,41 @@ function parse_frame(chunk) {
 };
 
 function _connect(stomp) {
-    var socket = stomp.socket = net.Stream();
     log = stomp.log;
-    log.debug('Connecting to ' + stomp.host + ':' + stomp.port);
-    socket.connect(stomp.port, stomp.host);
 
-    socket.on('connect', function() {
+    if (stomp.ssl) {
+      log.debug('Connecting to ' + stomp.host + ':' + stomp.port + ' using SSL');
+      stomp.socket = tls.connect(stomp.port, stomp.host, stomp.ssl_options, function() {
+          log.debug('SSL connection complete');
+          if (!stomp.socket.authorized) {
+              log.error('SSL is not authorized: '+stomp.socket.authorizationError);
+              if (stomp.ssl_validate) {
+                  _disconnect(stomp);
+                  return;
+              }
+          }
+          _setupListeners(stomp);
+      });
+    } else {
+        log.debug('Connecting to ' + stomp.host + ':' + stomp.port);
+        stomp.socket = new net.Socket();
+        stomp.socket.connect(stomp.port, stomp.host);
+        _setupListeners(stomp);
+    }
+}
+
+function _setupListeners(stomp) {
+    function _connected() {
         log.debug('Connected to socket');
         if (utils.really_defined(stomp.login) &&
             utils.really_defined(stomp.passcode)) {
             stomp_connect(stomp, {login: stomp.login, passcode: stomp.passcode});
-        }
-        else {
+        } else {
             stomp_connect(stomp);
         }
-    });
+    }
+
+    var socket = stomp.socket;
 
     socket.on('drain', function(data) {
         log.debug('draining');
@@ -122,10 +143,9 @@ function _connect(stomp) {
         var parsed_frame = null;
         var _frame = null;
         while (_frame = frames.shift()) {
-            parsed_frame = parse_frame(_frame)
+            parsed_frame = parse_frame(_frame);
             stomp.handle_new_frame(parsed_frame);
         }
-
     });
 
     socket.on('end', function() {
@@ -142,6 +162,12 @@ function _connect(stomp) {
             log.error('Disconnected with error: ' + error);
         stomp.emit("disconnected");
     });
+
+    if (stomp.ssl) {
+        _connected();
+    } else {
+        socket.on('connect', _connected);
+    }
 };
 
 function stomp_connect(stomp, headers) {
@@ -155,7 +181,6 @@ function stomp_connect(stomp, headers) {
     var frame_to_send = _frame.build_frame(args);
 
     send_frame(stomp, frame_to_send);
-    log.debug('Connected to STOMP');
 };
 
 function _disconnect(stomp) {
@@ -208,6 +233,9 @@ function Stomp(args) {
     this.log = new StompLogging(this.debug);
     this._subscribed_to = {};
     this.session = null;
+    this.ssl = args['ssl'] ? true : false;
+    this.ssl_validate = args['ssl_validate'] ? true : false;
+    this.ssl_options = args['ssl_options'] || [];
 };
 
 Stomp.prototype = new process.EventEmitter();
@@ -234,6 +262,7 @@ Stomp.prototype.handle_new_frame = function(this_frame) {
                 self.emit('message', this_frame);
             break;
         case "CONNECTED":
+            log.debug('Connected to STOMP');
             self.session = this_frame.headers['session'];
             self.emit('connected');
             break;