1 files changed, 33 insertions, 26 deletions

diff --git a/lib/cloudify.js b/lib/cloudify.js
index 0832dc7..2db460a 100644
--- a/lib/cloudify.js
+++ b/lib/cloudify.js
@@ -22,9 +22,7 @@ const CLOUDIFY = "cloudify-manager";
 const FINISHED = [ "terminated", "cancelled", "failed" ];
 const RETRY_INTERVAL = 5000;   // Every 5 seconds
 const MAX_TRIES = 720;        // Up to 1 hour
-
-const TENANT = "default_tenant";  // Tenant name for Cloudify 4.x
-
+const DEFAULT_TENANT = "default_tenant";
 const doRequest = require('./promise_request').doRequest;
 const repeat = require('./repeat');
 const admzip = require('adm-zip');
@@ -83,7 +81,9 @@ const getExecutionStatus = function(req, execution_id) {
         method : "GET",
         uri : cfyAPI + "/executions/" + execution_id
     };
-    addAuthToOptions(reqOptions);
+
+    addAuthToOptions(reqOptions, req);
+
     return doRequest(req, reqOptions, null, CLOUDIFY);
 };
 
@@ -174,7 +174,9 @@ const startWorkflowExecution = function(mainReq, deployment_id, workflow_id, par
             "Accept" : "*/*"
         }
     };
-    addAuthToOptions(reqOptions);
+
+    addAuthToOptions(reqOptions, mainReq);
+
     var body = {
         "deployment_id" : deployment_id,
         "workflow_id" : workflow_id
@@ -212,14 +214,14 @@ exports.uploadBlueprint = function(req, bpid, blueprint) {
 
     // Set up the HTTP PUT request
     const reqOptions = {
-            method : "PUT",
-            uri : cfyAPI + "/blueprints/" + bpid,
-            headers : {
-                "Content-Type" : "application/octet-stream",
-                "Accept" : "*/*"
-            }
+        method : "PUT",
+        uri : cfyAPI + "/blueprints/" + bpid,
+        headers : {
+            "Content-Type" : "application/octet-stream",
+            "Accept" : "*/*"
+        }
     };
-    addAuthToOptions(reqOptions);
+    addAuthToOptions(reqOptions, req);
 
     // Initiate PUT request and return the promise for a result
     return doRequest(req, reqOptions, zip_buffer, CLOUDIFY);
@@ -237,7 +239,7 @@ exports.createDeployment = function(req, dpid, bpid, inputs) {
             "Accept" : "*/*"
         }
     };
-    addAuthToOptions(reqOptions);
+    addAuthToOptions(reqOptions, req);
 
     var body = {
         blueprint_id : bpid
@@ -280,7 +282,8 @@ exports.getOutputs = function(req, dpid) {
             "Accept" : "*/*"
         }
     };
-    addAuthToOptions(reqOptions);
+
+    addAuthToOptions(reqOptions, req);
 
     return doRequest(req, reqOptions, null, CLOUDIFY);
 };
@@ -294,7 +297,8 @@ exports.getOutputDescriptions = function(req, dpid) {
             "Accept" : "*/*"
         }
     };
-    addAuthToOptions(reqOptions);
+
+    addAuthToOptions(reqOptions, req);
 
     return doRequest(req, reqOptions, null, CLOUDIFY);
 };
@@ -305,7 +309,8 @@ exports.deleteDeployment = function(req, dpid) {
         method : "DELETE",
         uri : cfyAPI + "/deployments/" + dpid
     };
-    addAuthToOptions(reqOptions);
+
+    addAuthToOptions(reqOptions, req);
 
     return doRequest(req, reqOptions, null, CLOUDIFY);
 };
@@ -316,7 +321,8 @@ exports.deleteBlueprint = function(req, bpid) {
         method : "DELETE",
         uri : cfyAPI + "/blueprints/" + bpid
     };
-    addAuthToOptions(reqOptions);
+
+    addAuthToOptions(reqOptions, req);
 
     return doRequest(req, reqOptions, null, CLOUDIFY);
 };
@@ -331,16 +337,16 @@ exports.setCredentials = function(user, password) {
     cfyAuth = cfyAuth || (user + ':' + password);
 };
 
-function addAuthToOptions(reqOptions) {
+function addAuthToOptions(reqOptions, req) {
+
     if (!!cfyAuth && cfyAuth !== "undefined:undefined") {
         reqOptions.auth = cfyAuth;
     }
-    if (reqOptions.headers) {
-        reqOptions.headers.Tenant = TENANT;
-    }
-    else {
-        reqOptions.headers = {"Tenant" : TENANT};
-    }
+    reqOptions.headers = reqOptions.headers || {};
+    reqOptions.headers.Tenant = req.query.cfy_tenant_name || DEFAULT_TENANT;
+
+    logger.debug(req.dcaeReqId, "Calling " + reqOptions.uri + " with Tenant: " + reqOptions.headers.Tenant );
+
 }
 
 // Set a logger
@@ -352,9 +358,10 @@ exports.getNodeInstances = function (mainReq, on_next_node_instances, offset) {
     offset = offset || 0;
     var reqOptions = {
         method : "GET",
-        uri : cfyAPI + "/node-instances?_include=id,deployment_id,runtime_properties&_size=1000&_offset=" + offset
+        uri : cfyAPI + "/node-instances?_include=id,deployment_id,runtime_properties&_offset=" + offset
     };
-    addAuthToOptions(reqOptions);
+
+    addAuthToOptions(reqOptions, mainReq);
 
     logger.info(mainReq.dcaeReqId, "getNodeInstances: " + JSON.stringify(reqOptions));
     return doRequest(mainReq, reqOptions, null, CLOUDIFY)