Adding SSL Termination to RS LB config

lib/client/cloudloadbalancers.js

@@ -73,7 +73,8 @@ exports.CloudLoadBalancers = {
         var lb = {
             name: details.name,
             nodes: details.nodes,
-            protocol: details.protocol,
+            protocol: details.protocol.name,
+            port: details.protocol.port,
             virtualIps: details.virtualIps
         };
 
@@ -101,10 +102,6 @@ exports.CloudLoadBalancers = {
             lb.metadata = details.metadata;
         }
 
-        if (details.port) {
-            lb.port = details.port;
-        }
-
         if (details.timeout) {
             lb.timeout = details.timeout;
         }
@@ -123,13 +120,16 @@ exports.CloudLoadBalancers = {
         var requestOptions = {
             uri: '/loadbalancers',
             method: 'POST',
-            data: lb,
+            data: {
+                loadBalancer: lb
+            },
             endpoint: rackspace.Endpoints.CloudLoadBalancer
         };
 
+        console.log(require('util').inspect(requestOptions, false, null, true));
         self.authorizedRequest(requestOptions, function(err, res, body) {
             if (err || !body.loadBalancer) {
-                callback(err);
+                callback(err ? err : body);
                 return;
             }
 
@@ -198,7 +198,7 @@ exports.CloudLoadBalancers = {
         });
 
         var requestOptions = {
-            uri: '/loadbalancers/' + self.id,
+            uri: '/loadbalancers',
             method: 'DELETE',
             qs: {
                 id: lbIds
@@ -208,7 +208,7 @@ exports.CloudLoadBalancers = {
 
         self.authorizedRequest(requestOptions, function(err, res, body) {
             if (err || res.statusCode !== 202) {
-                callback(err);
+                callback(err ? err : body);
                 return;
             }
 
@@ -357,6 +357,10 @@ validateLbInputs = function(inputs) {
         errors.requiredParametersMissing.push('protocol');
     }
 
+    if (!inputs.port) {
+        errors.requiredParametersMissing.push('port');
+    }
+
     if (!inputs.virtualIps) {
         errors.requiredParametersMissing.push('virtualIps');
     }
@@ -374,16 +378,11 @@ validateLbInputs = function(inputs) {
     }
 
     if (!inputs.protocol ||
-        typeof(inputs.protocol) !== 'object' ||
-        !rackspace.Protocols[inputs.protocol.name]) {
+        typeof(inputs.protocol) !== 'string' ||
+        !rackspace.Protocols[inputs.protocol]) {
         errors.invalidInputs.push('please specify a valid protocol');
     }
 
-    if (!inputs.virtualIps !== rackspace.VirtualIpTypes.PUBLIC ||
-        !inputs.virtualIps !== rackspace.VirtualIpTypes.SERVICENET) {
-        errors.invalidInputs.push('virtualIps must be PUBLIC or SERVICENET');
-    }
-
     // TODO Node validation
 
     if (errors.requiredParametersMissing.length) {

lib/cloudloadbalancers/loadbalancer.js

@@ -88,6 +88,94 @@ LoadBalancer.prototype = {
         });
     },
 
+    /**
+     * @name LoadBalancer.getSSLConfig
+     * @description Get the SSL Termintation configuration for this LB
+     * @param {Function}    callback    handles the callback of your api call
+     */
+    getSSLConfig: function(callback) {
+        var self = this,
+            requestOptions = {
+                uri: '/loadbalancers/' + self.id + '/ssltermination',
+                endpoint: rackspace.Endpoints.CloudLoadBalancer
+            };
+
+        self.client.authorizedRequest(requestOptions, function(err, res, body) {
+            if (err || res.statusCode !== 200) {
+                callback(err ? err : body);
+                return;
+            }
+
+            self.sslTermination = body.sslTermination;
+            callback(err, body.sslTermination);
+        });
+    },
+
+    /**
+     * @name LoadBalancer.disableSSLTermination
+     * @description Disable and remove the connection throttle
+     * @param {Function}    callback    handles the callback of your api call
+     */
+    disableSSLTermination: function(callback) {
+        var self = this,
+            requestOptions = {
+                uri: '/loadbalancers/' + self.id + '/ssltermination',
+                method: 'DELETE',
+                endpoint: rackspace.Endpoints.CloudLoadBalancer
+            };
+
+        self.client.authorizedRequest(requestOptions, function(err, res, body) {
+            if (err || res.statusCode !== 202) {
+                callback(err ? err : body);
+                return;
+            }
+
+            delete(self.sslTermination);
+            callback(err, self);
+        });
+    },
+
+    /**
+     * @name LoadBalancer.enableSSLTermination
+     * @description Enable the ssl termination for your LB
+     * @param {Object}      details     details for the new load balancer
+     * @param {Function}    callback    handles the callback of your api call
+     */
+    enableSSLTermination: function(details, callback) {
+        var self = this,
+            sslConfig = {
+                certificate: details.certificate,
+                enabled: typeof(details.enabled) === 'boolean' ? details.enabled : true,
+                secureTrafficOnly: typeof(details.secureTrafficOnly) === 'boolean' ?
+                    details.secureTrafficOnly : false,
+                privatekey: details.privatekey,
+                securePort: details.securePort
+            },
+            requestOptions = {
+                uri: '/loadbalancers/' + self.id + '/ssltermination',
+                method: 'PUT',
+                endpoint: rackspace.Endpoints.CloudLoadBalancer
+            };
+
+        if (details.intermediateCertificate) {
+            sslConfig.intermediateCertificate = details.intermediateCertificate;
+        }
+
+        requestOptions.data = {
+            sslTermination: sslConfig
+        };
+
+        self.client.authorizedRequest(requestOptions, function(err, res, body) {
+            if (err || res.statusCode !== 202) {
+                callback(err ? err : body);
+                return;
+            }
+
+            self.connectionThrottle = requestOptions.data.connectionThrottle;
+            callback(err, self);
+        });
+    },
+
     /**
      * @name LoadBalancer.getAccessList
      * @description Gets the access list for your load balancer