skyquake/plugins/launchpad/api/launchpad.js

   1 /*
   2  *
   3  *   Copyright 2016 RIFT.IO Inc
   4  *
   5  *   Licensed under the Apache License, Version 2.0 (the "License");
   6  *   you may not use this file except in compliance with the License.
   7  *   You may obtain a copy of the License at
   8  *
   9  *       http://www.apache.org/licenses/LICENSE-2.0
  10  *
  11  *   Unless required by applicable law or agreed to in writing, software
  12  *   distributed under the License is distributed on an "AS IS" BASIS,
  13  *   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  14  *   See the License for the specific language governing permissions and
  15  *   limitations under the License.
  16  *
  17  */
  18
  19 var request = require('request');
  20 var Promise = require('bluebird');
  21 var rp = require('request-promise');
  22 var utils = require('../../../framework/core/api_utils/utils.js');
  23 var constants = require('../../../framework/core/api_utils/constants.js');
  24 var APIVersion = '/v1';
  25 var _ = require('underscore');
  26 var epa_aggregator = require('./epa_aggregator.js');
  27 var transforms = require('./transforms.js');
  28 var uuid = require('node-uuid');
  29
  30 // Revealing module pattern objects
  31 var Catalog = {};
  32 var Config = {};
  33 var NSR = {};
  34 var VNFR = {};
  35 var VLR = {};
  36 var RIFT = {};
  37 var ComputeTopology = {};
  38 var NetworkTopology = {};
  39 var VDUR = {};
  40 var CloudAccount = {};
  41 var ConfigAgentAccount = {};
  42 var RPC = {};
  43 var SSHkey = {};
  44 // API Configuration Info
  45 var APIConfig = {}
  46 APIConfig.NfviMetrics = ['vcpu', 'memory'];
  47
  48 RPC.executeNSServicePrimitive = function(req) {
  49     var api_server = req.query['api_server'];
  50     return new Promise(function(resolve, reject) {
  51         var uri = utils.projectContextUrl(req, utils.confdPort(api_server) + APIVersion + '/api/operations/exec-ns-service-primitive');
  52         var jsonData = {
  53             "input": utils.addProjectContextToRPCPayload(req, uri, req.body)
  54         };
  55
  56         var headers = _.extend({},
  57             constants.HTTP_HEADERS.accept.data,
  58             constants.HTTP_HEADERS.content_type.data, {
  59                 'Authorization': req.session && req.session.authorization
  60             }
  61         );
  62         request({
  63             url: uri,
  64             method: 'POST',
  65             headers: headers,
  66             forever: constants.FOREVER_ON,
  67             rejectUnauthorized: false,
  68             json: jsonData
  69         }, function(error, response, body) {
  70             if (utils.validateResponse('RPC.executeNSServicePrimitive', error, response, body, resolve, reject)) {
  71                 return resolve({
  72                     statusCode: response.statusCode,
  73                     data: JSON.stringify(response.body)
  74                 });
  75             }
  76         })
  77     });
  78 };
  79
  80 RPC.getNSServicePrimitiveValues = function(req) {
  81     var api_server = req.query['api_server'];
  82     // var nsr_id = req.body['nsr_id_ref'];
  83     // var nsConfigPrimitiveName = req.body['name'];
  84     return new Promise(function(resolve, reject) {
  85         var uri = utils.projectContextUrl(req, utils.confdPort(api_server) + APIVersion + '/api/operations/get-ns-service-primitive-values');
  86
  87         var jsonData = {
  88             "input": utils.addProjectContextToRPCPayload(req, uri, req.body)
  89         };
  90
  91         var headers = _.extend({},
  92             constants.HTTP_HEADERS.accept.data,
  93             constants.HTTP_HEADERS.content_type.data, {
  94                 'Authorization': req.session && req.session.authorization
  95             }
  96         );
  97         request({
  98             uri: uri,
  99             method: 'POST',
 100             headers: headers,
 101             forever: constants.FOREVER_ON,
 102             rejectUnauthorized: false,
 103             json: jsonData
 104         }, function(error, response, body) {
 105             if (utils.validateResponse('RPC.getNSServicePrimitiveValues', error, response, body, resolve, reject)) {
 106
 107                 resolve({
 108                     statusCode: response.statusCode,
 109                     data: JSON.parse(body)
 110                 });
 111             }
 112         });
 113     }).catch(function(error) {
 114         console.log('error getting primitive values');
 115     });
 116 };
 117 RPC.refreshAccountConnectionStatus = function(req) {
 118     var api_server = req.query['api_server'];
 119     var Name = req.params.name;
 120     var Type = req.params.type;
 121     var jsonData = {
 122         input: {}
 123     };
 124     var rpcInfo = {
 125         sdn: {
 126             label: 'sdn-account',
 127             rpc: 'update-sdn-status'
 128         },
 129         config: {
 130             label: 'cfg-agent-account',
 131             rpc: 'update-cfg-agent-status'
 132         },
 133         cloud: {
 134             label: 'cloud-account',
 135             rpc: 'update-cloud-status'
 136         }
 137     }
 138     jsonData.input[rpcInfo[Type].label] = Name;
 139
 140     var uri = utils.projectContextUrl(req, utils.confdPort(api_server) + APIVersion + '/api/operations/' + rpcInfo[Type].rpc);
 141
 142     jsonData.input = utils.addProjectContextToRPCPayload(req, uri, jsonData.input);
 143
 144     var headers = _.extend({},
 145         constants.HTTP_HEADERS.accept.data,
 146         constants.HTTP_HEADERS.content_type.data, {
 147             'Authorization': req.session && req.session.authorization
 148         }
 149     );
 150     return new Promise(function(resolve, reject) {
 151         request({
 152             uri: uri,
 153             method: 'POST',
 154             headers: headers,
 155             forever: constants.FOREVER_ON,
 156             rejectUnauthorized: false,
 157             json: jsonData
 158         }, function(error, response, body) {
 159             if (utils.validateResponse('RPC.refreshAccountConnectionStatus', error, response, body, resolve, reject)) {
 160
 161                 resolve({
 162                     statusCode: response.statusCode,
 163                     data: body
 164                 });
 165             }
 166         });
 167     }).catch(function(error) {
 168         console.log('Error refreshing account info');
 169     });
 170 };
 171
 172
 173 var DataCenters = {};
 174 // Catalog module methods
 175 Catalog.get = function(req) {
 176     var api_server = req.query['api_server'];
 177     var results = {}
 178     var projectPrefix = req.session.projectId ? "project-" : "";
 179     return new Promise(function(resolve, reject) {
 180         Promise.all([
 181             rp({
 182                 uri: utils.projectContextUrl(req, utils.confdPort(api_server) + APIVersion + '/api/config/nsd-catalog/nsd?deep'),
 183                 method: 'GET',
 184                 headers: _.extend({}, constants.HTTP_HEADERS.accept.collection, {
 185                     'Authorization': req.session && req.session.authorization
 186                 }),
 187                 forever: constants.FOREVER_ON,
 188                 rejectUnauthorized: false,
 189                 resolveWithFullResponse: true
 190             }),
 191             rp({
 192                 uri: utils.projectContextUrl(req, utils.confdPort(api_server) + APIVersion + '/api/config/vnfd-catalog/vnfd?deep'),
 193                 method: 'GET',
 194                 headers: _.extend({}, constants.HTTP_HEADERS.accept.collection, {
 195                     'Authorization': req.session && req.session.authorization
 196                 }),
 197                 forever: constants.FOREVER_ON,
 198                 rejectUnauthorized: false,
 199                 resolveWithFullResponse: true
 200             }),
 201             rp({
 202                 uri: utils.projectContextUrl(req, utils.confdPort(api_server) + APIVersion + '/api/operational/ns-instance-opdata?deep'),
 203                 method: 'GET',
 204                 headers: _.extend({}, constants.HTTP_HEADERS.accept.data, {
 205                     'Authorization': req.session && req.session.authorization
 206                 }),
 207                 forever: constants.FOREVER_ON,
 208                 rejectUnauthorized: false,
 209                 resolveWithFullResponse: true
 210             })
 211             // Not enabled for now
 212             // rp({
 213             //   uri: utils.confdPort(api_server) + APIVersion + '/api/config/pnfd-catalog/pnfd?deep',
 214             //   method: 'GET',
 215             //   headers: _.extend({},
 216             //     constants.HTTP_HEADERS.accept.collection,
 217             //     {
 218             //       'Authorization': req.session && req.session.authorization
 219             //     }),
 220             //   forever: constants.FOREVER_ON,
 221             // rejectUnauthorized: false,
 222             //   resolveWithFullResponse: true
 223             // })
 224         ]).then(function(result) {
 225             console.log('Resolved all request promises (NSD, VNFD) successfully');
 226             var response = [{
 227                 "id": "GUID-1",
 228                 "name": "RIFT.ware™ NS Descriptors Catalog",
 229                 "short-name": "rift.ware-nsd-cat",
 230                 "description": "RIFT.ware™, an open source NFV development and deployment software platform that makes it simple to create, deploy and manage hyper-scale Virtual network functions and applications.",
 231                 "vendor": "RIFT.io",
 232                 "version": "",
 233                 "created-on": "",
 234                 "type": "nsd",
 235                 "meta": {
 236                     "icon-svg": "data:image/svg+xml,%3C%3Fxml%20version%3D%221.0%22%20encoding%3D%22iso-8859-1%22%3F%3E%0A%3C!--%20Generator%3A%20Adobe%20Illustrator%2018.0.0%2C%20SVG%20Export%20Plug-In%20.%20SVG%20Version%3A%206.00%20Build%200)%20%20--%3E%0A%3C!DOCTYPE%20svg%20PUBLIC%20%22-%2F%2FW3C%2F%2FDTD%20SVG%201.1%2F%2FEN%22%20%22http%3A%2F%2Fwww.w3.org%2FGraphics%2FSVG%2F1.1%2FDTD%2Fsvg11.dtd%22%3E%0A%3Csvg%20version%3D%221.1%22%20id%3D%22connection-icon-1%22%20xmlns%3D%22http%3A%2F%2Fwww.w3.org%2F2000%2Fsvg%22%20xmlns%3Axlink%3D%22http%3A%2F%2Fwww.w3.org%2F1999%2Fxlink%22%20x%3D%220px%22%20y%3D%220px%22%0A%09%20viewBox%3D%220%200%2050%2050%22%20style%3D%22enable-background%3Anew%200%200%2050%2050%3B%22%20xml%3Aspace%3D%22preserve%22%3E%0A%09%3Cpath%20d%3D%22M15%2030c-2.8%200-5-2.2-5-5s2.2-5%205-5%205%202.2%205%205-2.2%205-5%205zm0-8c-1.7%200-3%201.3-3%203s1.3%203%203%203%203-1.3%203-3-1.3-3-3-3z%22%2F%3E%3Cpath%20d%3D%22M35%2020c-2.8%200-5-2.2-5-5s2.2-5%205-5%205%202.2%205%205-2.2%205-5%205zm0-8c-1.7%200-3%201.3-3%203s1.3%203%203%203%203-1.3%203-3-1.3-3-3-3z%22%2F%3E%3Cpath%20d%3D%22M35%2040c-2.8%200-5-2.2-5-5s2.2-5%205-5%205%202.2%205%205-2.2%205-5%205zm0-8c-1.7%200-3%201.3-3%203s1.3%203%203%203%203-1.3%203-3-1.3-3-3-3z%22%2F%3E%3Cpath%20d%3D%22M19.007%2025.885l12.88%206.44-.895%201.788-12.88-6.44z%22%2F%3E%3Cpath%20d%3D%22M30.993%2015.885l.894%201.79-12.88%206.438-.894-1.79z%22%2F%3E%3C%2Fsvg%3E"
 237                 },
 238                 "descriptors": []
 239             }, {
 240                 "id": "GUID-2",
 241                 "name": "RIFT.ware™ VNF Descriptors Catalog",
 242                 "short-name": "rift.ware-vnfd-cat",
 243                 "description": "RIFT.ware™, an open source NFV development and deployment software platform that makes it simple to create, deploy and manage hyper-scale Virtual network functions and applications.",
 244                 "vendor": "RIFT.io",
 245                 "version": "",
 246                 "created-on": "",
 247                 "type": "vnfd",
 248                 "meta": {
 249                     "icon-svg": "data:image/svg+xml,<?xml version=\"1.0\" encoding=\"utf-8\"?> <!-- Generator: Adobe Illustrator 16.0.0, SVG Export Plug-In . SVG Version: 6.00 Build 0) --> <!DOCTYPE svg PUBLIC \"-//W3C//DTD SVG 1.1//EN\" \"http://www.w3.org/Graphics/SVG/1.1/DTD/svg11.dtd\"> <svg version=\"1.1\" id=\"Layer_3\" xmlns=\"http://www.w3.org/2000/svg\" xmlns:xlink=\"http://www.w3.org/1999/xlink\" x=\"0px\" y=\"0px\" width=\"100px\" height=\"100px\" viewBox=\"0 0 100 100\" enable-background=\"new 0 0 100 100\" xml:space=\"preserve\"> <g> <path d=\"M58.852,62.447l-4.662-1.033c-0.047-3.138-0.719-6.168-1.996-9.007l3.606-2.92c0.858-0.695,0.99-1.954,0.296-2.813 l-4.521-5.584c-0.334-0.413-0.818-0.675-1.346-0.731c-0.525-0.057-1.056,0.102-1.468,0.435L45.25,43.64v0 c-2.486-1.907-5.277-3.259-8.297-4.019v-4.458c0-1.104-0.896-2-2-2H27.77c-1.104,0-2,0.896-2,2v4.461 c-3.08,0.777-5.922,2.171-8.447,4.144l-3.545-2.82c-0.415-0.33-0.94-0.479-1.472-0.422c-0.527,0.06-1.009,0.327-1.339,0.743 l-4.472,5.623c-0.688,0.864-0.544,2.123,0.32,2.81l3.642,2.896v0c-1.25,2.848-1.895,5.88-1.916,9.011l-4.666,1.078 c-1.076,0.249-1.747,1.322-1.499,2.398l1.616,7.001c0.249,1.077,1.325,1.747,2.399,1.499l4.813-1.111v0 c1.429,2.681,3.344,5.017,5.691,6.943l-2.17,4.55c-0.476,0.997-0.054,2.19,0.943,2.666l6.484,3.094 c0.271,0.129,0.566,0.195,0.861,0.195c0.226,0,0.451-0.038,0.668-0.115c0.5-0.177,0.909-0.545,1.138-1.024l2.198-4.611 c2.923,0.563,5.966,0.554,8.879-0.033l2.236,4.585c0.484,0.994,1.685,1.403,2.675,0.921l6.456-3.148 c0.992-0.484,1.405-1.682,0.921-2.674l-2.206-4.524c2.335-1.946,4.231-4.301,5.639-6.999l4.812,1.067 c1.076,0.237,2.146-0.441,2.385-1.52l1.556-7.014c0.115-0.518,0.02-1.06-0.266-1.508C59.82,62.878,59.369,62.562,58.852,62.447z M40.18,61.761c0,4.859-3.953,8.812-8.813,8.812c-4.858,0-8.811-3.953-8.811-8.812s3.952-8.812,8.811-8.812 C36.227,52.949,40.18,56.902,40.18,61.761z\"/> <path d=\"M64.268,45.324c0.746,0,1.463-0.42,1.806-1.139l1.054-2.208c1.826,0.353,3.736,0.345,5.551-0.021l1.07,2.195 c0.484,0.992,1.682,1.405,2.675,0.921l2.691-1.313c0.477-0.233,0.842-0.646,1.015-1.147c0.172-0.501,0.139-1.051-0.095-1.528 l-1.052-2.155c1.458-1.214,2.645-2.686,3.527-4.377l2.278,0.504c1.075,0.238,2.146-0.442,2.386-1.52l0.647-2.923 c0.238-1.078-0.442-2.146-1.521-2.385l-2.184-0.484c-0.028-1.962-0.449-3.857-1.248-5.632l1.673-1.355 c0.412-0.334,0.675-0.818,0.73-1.345s-0.102-1.056-0.436-1.468l-1.884-2.327c-0.697-0.859-1.957-0.99-2.813-0.295l-1.614,1.307 c-1.554-1.193-3.299-2.038-5.188-2.513v-2.039c0-1.104-0.896-2-2-2h-2.994c-1.104,0-2,0.896-2,2v2.04 c-1.927,0.486-3.703,1.358-5.28,2.592l-1.634-1.298c-0.862-0.687-2.12-0.543-2.81,0.32l-1.864,2.344 c-0.33,0.416-0.481,0.945-0.422,1.472c0.061,0.527,0.327,1.009,0.743,1.339l1.69,1.345c-0.78,1.779-1.184,3.676-1.197,5.636 l-2.189,0.505c-0.517,0.119-0.965,0.439-1.246,0.889c-0.281,0.45-0.372,0.993-0.252,1.51l0.675,2.918 c0.249,1.076,1.323,1.747,2.398,1.498l2.28-0.527c0.892,1.676,2.089,3.137,3.559,4.343l-1.035,2.17 c-0.228,0.479-0.257,1.028-0.08,1.528c0.178,0.5,0.546,0.91,1.024,1.138l2.703,1.289C63.686,45.261,63.979,45.324,64.268,45.324z M64.334,27.961c0-3.039,2.473-5.51,5.512-5.51c3.038,0,5.51,2.472,5.51,5.51c0,3.039-2.472,5.511-5.51,5.511 C66.807,33.472,64.334,31,64.334,27.961z\"/> <path d=\"M96.107,66.441l-2.182-0.484c-0.028-1.961-0.449-3.856-1.25-5.632l1.675-1.355c0.412-0.334,0.675-0.818,0.73-1.346 c0.056-0.527-0.102-1.056-0.436-1.468l-1.885-2.327c-0.695-0.859-1.956-0.99-2.813-0.295l-1.614,1.307 c-1.555-1.193-3.3-2.038-5.188-2.513v-2.039c0-1.104-0.896-2-2-2h-2.994c-1.104,0-2,0.896-2,2v2.041 c-1.929,0.486-3.706,1.358-5.282,2.592l-0.001,0l-1.631-1.298c-0.415-0.331-0.938-0.482-1.472-0.422 c-0.527,0.06-1.009,0.327-1.339,0.742l-1.863,2.343c-0.688,0.865-0.544,2.123,0.32,2.811l1.691,1.345 c-0.782,1.784-1.186,3.68-1.199,5.636l-2.188,0.505c-0.517,0.12-0.965,0.439-1.246,0.889c-0.281,0.45-0.372,0.993-0.252,1.51 l0.675,2.918c0.249,1.076,1.327,1.744,2.397,1.498l2.281-0.526c0.893,1.677,2.09,3.138,3.558,4.343h0.001l-1.035,2.168 c-0.229,0.479-0.258,1.029-0.081,1.529c0.178,0.5,0.546,0.909,1.024,1.138l2.702,1.289c0.278,0.132,0.571,0.195,0.86,0.195 c0.746,0,1.463-0.42,1.806-1.139l1.054-2.208c1.828,0.353,3.739,0.347,5.552-0.021l1.071,2.194 c0.484,0.992,1.682,1.405,2.675,0.921l2.69-1.312c0.477-0.233,0.842-0.645,1.014-1.147c0.173-0.501,0.14-1.051-0.093-1.528 l-1.052-2.155c1.459-1.215,2.645-2.688,3.525-4.377l2.278,0.505c0.52,0.116,1.061,0.02,1.508-0.266 c0.447-0.285,0.763-0.736,0.878-1.254l0.647-2.923C97.866,67.748,97.186,66.681,96.107,66.441z M85.162,66.174 c0,3.039-2.471,5.511-5.508,5.511c-3.039,0-5.512-2.472-5.512-5.511c0-3.039,2.473-5.511,5.512-5.511 C82.691,60.664,85.162,63.136,85.162,66.174z\"/> </g> </svg> "
 250                 },
 251                 "descriptors": []
 252             }, {
 253                 "id": "GUID-3",
 254                 "name": "RIFT.ware™ PNF Descriptors Catalog",
 255                 "short-name": "rift.ware-pnfd-cat",
 256                 "description": "RIFT.ware™, an open source NFV development and deployment software platform that makes it simple to create, deploy and manage hyper-scale Virtual network functions and applications.",
 257                 "vendor": "RIFT.io",
 258                 "version": "",
 259                 "created-on": "",
 260                 "type": "pnfd",
 261                 "meta": {
 262                     "icon-svg": "data:image/svg+xml,<?xml version=\"1.0\" encoding=\"utf-8\"?> <!-- Generator: Adobe Illustrator 16.0.0, SVG Export Plug-In . SVG Version: 6.00 Build 0) --> <!DOCTYPE svg PUBLIC \"-//W3C//DTD SVG 1.1//EN\" \"http://www.w3.org/Graphics/SVG/1.1/DTD/svg11.dtd\"> <svg version=\"1.1\" id=\"Layer_4\" xmlns=\"http://www.w3.org/2000/svg\" xmlns:xlink=\"http://www.w3.org/1999/xlink\" x=\"0px\" y=\"0px\" width=\"100px\" height=\"100px\" viewBox=\"0 0 100 100\" enable-background=\"new 0 0 100 100\" xml:space=\"preserve\"> <path d=\"M86.334,47.444V35.759H13.666v11.686h3.561v5.111h-3.561v11.686h72.668V52.556h-4.108v-5.111H86.334z M26.628,59.454h-5.051 v-4.941h5.051V59.454z M26.628,52.404h-5.051v-4.941h5.051V52.404z M26.628,45.486h-5.051v-4.941h5.051V45.486z M34.094,59.454 h-5.051v-4.941h5.051V59.454z M34.094,52.404h-5.051v-4.941h5.051V52.404z M34.094,45.486h-5.051v-4.941h5.051V45.486z M41.452,59.454h-5.051v-4.941h5.051V59.454z M41.452,52.404h-5.051v-4.941h5.051V52.404z M41.452,45.486h-5.051v-4.941h5.051 V45.486z M48.733,59.454h-5.051v-4.941h5.051V59.454z M48.733,52.404h-5.051v-4.941h5.051V52.404z M48.733,45.486h-5.051v-4.941 h5.051V45.486z M56.2,59.454h-5.051v-4.941H56.2V59.454z M56.2,52.404h-5.051v-4.941H56.2V52.404z M56.2,45.486h-5.051v-4.941H56.2 V45.486z M63.558,59.454h-5.05v-4.941h5.05V59.454z M63.558,52.404h-5.05v-4.941h5.05V52.404z M63.558,45.486h-5.05v-4.941h5.05 V45.486z M74.858,59.312h-6.521v-3.013h6.521V59.312z M71.572,50.854c-2.875,0-5.204-2.33-5.204-5.203s2.329-5.203,5.204-5.203 s5.204,2.33,5.204,5.203S74.446,50.854,71.572,50.854z M74.858,45.618c0,1.801-1.46,3.261-3.261,3.261 c-1.8,0-3.261-1.46-3.261-3.261s1.46-3.26,3.261-3.26C73.398,42.358,74.858,43.817,74.858,45.618z\"/> </svg>"
 263                 },
 264                 "descriptors": []
 265             }];
 266             var vnfdCatalog = null;
 267             var vnfdDict = {};
 268             if (result[1].body) {
 269                 vnfdCatalog = JSON.parse(result[1].body).collection[projectPrefix + 'vnfd:vnfd'].map(function(v, i) {
 270                     vnfdDict[v.id] = v['short-name'] || v.name;
 271                 })
 272             }
 273             if (result[0].body) {
 274                 response[0].descriptors = JSON.parse(result[0].body).collection[projectPrefix + 'nsd:nsd'];
 275                 if (result[2].body) {
 276                     var data = JSON.parse(result[2].body);
 277                     if (data && data["nsr:ns-instance-opdata"] && data["nsr:ns-instance-opdata"]["rw-nsr:nsd-ref-count"]) {
 278                         var nsdRefCountCollection = data["nsr:ns-instance-opdata"]["rw-nsr:nsd-ref-count"];
 279                         response[0].descriptors.map(function(nsd) {
 280                             if (!nsd["meta"]) {
 281                                 nsd["meta"] = {};
 282                             }
 283                             if (typeof nsd['meta'] == 'string') {
 284                                 nsd['meta'] = JSON.parse(nsd['meta']);
 285                             }
 286                             nsd["meta"]["instance-ref-count"] = _.findWhere(nsdRefCountCollection, {
 287                                 "nsd-id-ref": nsd.id
 288                             })["instance-ref-count"];
 289                             nsd["constituent-vnfd"] && nsd["constituent-vnfd"].map(function(v) {
 290                                 v.name = vnfdDict[v["vnfd-id-ref"]];
 291                             })
 292                         });
 293                     }
 294                 }
 295             };
 296             if (result[1].body) {
 297                 response[1].descriptors = JSON.parse(result[1].body).collection[projectPrefix + 'vnfd:vnfd'];
 298             };
 299             // if (result[2].body) {
 300             //   response[2].descriptors = JSON.parse(result[2].body).collection[projectPrefix + 'pnfd:pnfd'];
 301             // };
 302             resolve({
 303                 statusCode: response.statusCode || 200,
 304                 data: JSON.stringify(response)
 305             });
 306         }).catch(function(error) {
 307             // Todo: Need better logic than all or nothing.
 308             // Right now even if one of the southbound APIs fails - all fail
 309             var res = {};
 310             console.log('Problem with Catalog.get', error);
 311             res.statusCode = error.statusCode || 500;
 312             res.errorMessage = {
 313                 error: 'Failed to get catalogs' + error
 314             };
 315             reject(res);
 316         });
 317     });
 318 };
 319 Catalog.delete = function(req) {
 320     var api_server = req.query['api_server'];
 321     var catalogType = req.params.catalogType;
 322     var id = req.params.id;
 323     console.log('Deleting', catalogType, id, 'from', api_server);
 324     return new Promise(function(resolve, reject) {
 325         request({
 326             uri: utils.projectContextUrl(req, utils.confdPort(api_server) + APIVersion + '/api/config/' + catalogType + '-catalog/' + catalogType + '/' + id),
 327             method: 'DELETE',
 328             headers: _.extend({}, constants.HTTP_HEADERS.accept.data, {
 329                 'Authorization': req.session && req.session.authorization
 330             }),
 331             forever: constants.FOREVER_ON,
 332             rejectUnauthorized: false,
 333         }, function(error, response, body) {
 334             if (utils.validateResponse('Catalog.delete', error, response, body, resolve, reject)) {
 335                 resolve({
 336                     statusCode: response.statusCode
 337                 });
 338             }
 339         });
 340     });
 341 };
 342 Catalog.getVNFD = function(req) {
 343     var api_server = req.query['api_server'];
 344     var vnfdID = req.body.data;
 345     var authorization = req.session && req.session.authorization;
 346     var VNFDs = [];
 347     if (typeof(vnfdID) == "object" && vnfdID.constructor.name == "Array") {
 348         vnfdID.map(function(id) {
 349             VNFDs.push(requestVNFD(id));
 350         });
 351     } else {
 352         VNFDs.push(requestVNFD(vnfdID));
 353     }
 354     return new Promise(function(resolve, reject) {
 355         Promise.all(VNFDs).then(function(data) {
 356             resolve(data)
 357         }).catch(function(error) {
 358             // Todo: Need better logic than all or nothing.
 359             // Right now even if one of the southbound APIs fails - all fail
 360             var res = {};
 361             console.log('Problem with Catalog.getVNFD', error);
 362             res.statusCode = 404;
 363             res.errorMessage = {
 364                 error: 'Failed to get VNFDs' + error
 365             };
 366             reject(res);
 367         });
 368     });
 369
 370     function requestVNFD(id) {
 371         return new Promise(function(resolve, reject) {
 372             var url = utils.confdPort(api_server) + APIVersion + '/api/config/vnfd-catalog/vnfd' + (id ? '/' + id : '') + '?deep';
 373             request({
 374                 uri: utils.projectContextUrl(req, url),
 375                 method: 'GET',
 376                 headers: _.extend({}, constants.HTTP_HEADERS.accept.data, {
 377                     'Authorization': authorization
 378                 }),
 379                 forever: constants.FOREVER_ON,
 380                 rejectUnauthorized: false,
 381             }, function(error, response, body) {
 382                 if (utils.validateResponse('Catalog.getVNFD', error, response, body, resolve, reject)) {
 383                     var data;
 384                     //Is this still needed?
 385                     try {
 386                         data = JSON.parse(response.body)
 387                     } catch (e) {
 388                         reject({
 389                             statusCode: response ? response.statusCode : 400,
 390                             errorMessage: 'Issue parsing VNFD ' + id + 'from ' + utils.confdPort(api_server) + APIVersion + '/api/config/vnfd-catalog/vnfd/' + id + '?deep'
 391                         });
 392                     }
 393                     resolve(data);
 394                 }
 395             });
 396         });
 397     }
 398 };
 399 Catalog.create = function(req) {
 400     var api_server = req.query['api_server'];
 401     var catalogType = req.params.catalogType;
 402     var data = req.body;
 403     console.log('Creating', catalogType, 'on', api_server);
 404     var jsonData = {};
 405     jsonData[catalogType] = [];
 406     jsonData[catalogType].push(data);
 407     return new Promise(function(resolve, reject) {
 408         var requestHeaders = {};
 409         _.extend(requestHeaders, constants.HTTP_HEADERS.accept.data, constants.HTTP_HEADERS.content_type.data, {
 410             'Authorization': req.session && req.session.authorization
 411         });
 412         request({
 413             uri: utils.projectContextUrl(req, utils.confdPort(api_server) + APIVersion + '/api/config/' + catalogType + '-catalog'),
 414             method: 'POST',
 415             headers: requestHeaders,
 416             forever: constants.FOREVER_ON,
 417             rejectUnauthorized: false,
 418             json: jsonData
 419         }, function(error, response, body) {
 420             if (utils.validateResponse('Catalog.create', error, response, body, resolve, reject)) {
 421                 resolve({
 422                     statusCode: response.statusCode
 423                 });
 424             }
 425         });
 426     });
 427 };
 428 Catalog.update = function(req) {
 429     var api_server = req.query['api_server'];
 430     var catalogType = req.params.catalogType;
 431     var id = req.params.id;
 432     var data = req.body;
 433     console.log('Updating', catalogType, 'id', id, 'on', api_server);
 434     var jsonData = {};
 435     jsonData[catalogType] = {};
 436     jsonData[catalogType] = data;
 437     return new Promise(function(resolve, reject) {
 438         var requestHeaders = {};
 439         _.extend(requestHeaders, constants.HTTP_HEADERS.accept.data, constants.HTTP_HEADERS.content_type.data, {
 440             'Authorization': req.session && req.session.authorization
 441         });
 442         request({
 443             uri: utils.projectContextUrl(req, utils.confdPort(api_server) + APIVersion + '/api/config/' + catalogType + '-catalog' + '/' + catalogType + '/' + id),
 444             method: 'PUT',
 445             headers: requestHeaders,
 446             forever: constants.FOREVER_ON,
 447             rejectUnauthorized: false,
 448             json: jsonData
 449         }, function(error, response, body) {
 450             if (utils.validateResponse('Catalog.update', error, response, body, resolve, reject)) {
 451                 resolve({
 452                     statusCode: response.statusCode
 453                 });
 454             }
 455         });
 456     });
 457 };
 458
 459 Catalog.decorateNsdCatalogWithPlacementGroups = function decorateNsdCatalogWithPlacementGroups(catalog) {
 460     var newData = catalog;
 461     var parsedCatalog = JSON.parse(catalog.data);
 462     var nsds = parsedCatalog[0].descriptors;
 463     var vnfds = parsedCatalog[1].descriptors;
 464     var vnfdDict = (function(){
 465         var dict = {};
 466         vnfds.map(function(v, i) {
 467             dict[v.id] = v;
 468         })
 469         return dict;
 470     })(vnfds);
 471
 472     nsds.map(function(c, i) {
 473         //Rename and decorate NSD placement groups
 474         c['ns-placement-groups'] = c['placement-groups'] && c['placement-groups'].map(function(p, i) {
 475             //Adds vnfd name to member-vnfd entry
 476             p['member-vnfd'] = p['member-vnfd'].map(function(v) {
 477                 v.name = vnfdDict[v['vnfd-id-ref']].name;
 478                 return v;
 479             });
 480             p['host-aggregate'] = [];
 481             return p;
 482         });
 483
 484         //Adds vnf placement groups to nsd object for UI
 485         c['vnf-placement-groups'] = [];
 486         c['constituent-vnfd'] && c['constituent-vnfd'].map(function(v) {
 487             var vnf = vnfdDict[v['vnfd-id-ref']];
 488             // var vnfPg = {
 489             //     name: vnf.name,
 490             //     'placement-groups': vnf['placement-groups'].map(function(vp){
 491             //         vp['host-aggregate'] = [{}];
 492             //         return vp;
 493             //     })
 494             // };
 495             v['vnf-name'] = vnf.name;
 496             vnf['placement-groups'] && vnf['placement-groups'].map(function(vp) {
 497                 vp['host-aggregate'] = [];
 498                 vp['vnf-name'] = vnf.name;
 499                 vp['vnfd-id-ref'] = v['vnfd-id-ref'];
 500                 vp['member-vnf-index'] = v['member-vnf-index'];
 501                 c['vnf-placement-groups'].push(vp);
 502             })
 503         })
 504         return c;
 505     })
 506     // parsedCatalog[0].descriptors = nsds;
 507     newData.data = JSON.stringify(parsedCatalog);
 508     return newData;
 509 }
 510
 511 // NSR module methods
 512 // Spend some time refactoring this
 513 // refactor to accept only request object
 514 NSR.get = function(req) {
 515     var self = this;
 516     var nsrPromises = [];
 517     var api_server = req.query["api_server"];
 518     var id = req.params.id;
 519     var projectPrefix = req.session.projectId ? "project-" : "";
 520     var nsdInfo = new Promise(function(resolve, reject) {
 521         request({
 522             uri: utils.projectContextUrl(req, utils.confdPort(api_server) + APIVersion + '/api/config/nsd-catalog/nsd?deep'),
 523             method: 'GET',
 524             headers: _.extend({}, constants.HTTP_HEADERS.accept.collection, {
 525                 'Authorization': req.session && req.session.authorization
 526             }),
 527             forever: constants.FOREVER_ON,
 528             rejectUnauthorized: false,
 529         }, function(error, response, body) {
 530             if (utils.validateResponse('NSR.get nsd-catalog', error, response, body, resolve, reject)) {
 531                 var data;
 532                 var isString = typeof(response.body) == "string";
 533                 if (isString && response.body == '') return resolve('empty');
 534                 data = isString ? JSON.parse(response.body) : response.body;
 535                 var nsdData = data.collection[projectPrefix + "nsd:nsd"];
 536                 if (nsdData.constructor.name == "Object") {
 537                     nsdData = [nsdData];
 538                 }
 539                 resolve(nsdData);
 540             };
 541         })
 542     })
 543     var config = new Promise(function(resolve, reject) {
 544         request({
 545             uri: utils.projectContextUrl(req, utils.confdPort(api_server) + APIVersion + '/api/operational/ns-instance-config/nsr' + (id ? '/' + id : '') + '?deep'),
 546             method: 'GET',
 547             headers: _.extend({}, id ? constants.HTTP_HEADERS.accept.data : constants.HTTP_HEADERS.accept.collection, {
 548                 'Authorization': req.session && req.session.authorization
 549             }),
 550             forever: constants.FOREVER_ON,
 551             rejectUnauthorized: false,
 552         }, function(error, response, body) {
 553             if (utils.validateResponse('NSR.get ns-instance-config', error, response, body, resolve, reject)) {
 554                 var data;
 555                 var isString = typeof(response.body) == "string";
 556                 if (isString && response.body == '') return resolve();
 557                 data = isString ? JSON.parse(response.body) : response.body;
 558                 data = id ? data : data.collection;
 559                 var nsrData = data["nsr:nsr"];
 560                 if (nsrData.constructor.name == "Object") {
 561                     nsrData = [nsrData];
 562                 }
 563                 resolve(nsrData);
 564             };
 565         });
 566     });
 567     var opData = new Promise(function(resolve, reject) {
 568         request({
 569             uri: utils.projectContextUrl(req, utils.confdPort(api_server) + APIVersion + '/api/operational/ns-instance-opdata/nsr' + (id ? '/' + id : '') + '?deep'),
 570             method: 'GET',
 571             headers: _.extend({}, id ? constants.HTTP_HEADERS.accept.data : constants.HTTP_HEADERS.accept.collection, {
 572                 'Authorization': req.session && req.session.authorization
 573             }),
 574             forever: constants.FOREVER_ON,
 575             rejectUnauthorized: false,
 576         }, function(error, response, body) {
 577             if (utils.validateResponse('NSR.get ns-instance-opdata', error, response, body, resolve, reject)) {
 578                 var data;
 579                 var isString = typeof(response.body) == "string";
 580                 if (isString && response.body == '') return resolve();
 581                 data = isString ? JSON.parse(response.body) : response.body;
 582                 data = id ? data : data.collection;
 583                 var nsrData = data["nsr:nsr"];
 584                 if (nsrData.constructor.name == "Object") {
 585                     nsrData = [nsrData];
 586                 }
 587                 nsrData.forEach(self.decorateWithScalingGroupDict);
 588                 nsrData.forEach(self.decorateAndTransformNFVI);
 589                 nsrData.forEach(self.decorateAndTransformWithControls);
 590                 Promise.all(self.addVnfrDataPromise(req, nsrData)).then(function() {
 591                     Promise.all(self.addVlrDataPromise(req, nsrData)).then(function() {
 592                         resolve(nsrData);
 593                     });
 594                 });
 595             };
 596         });
 597     }).catch(function(error) {
 598         console.log('error getting aggregated NS opdata', error)
 599         //note this will actually trigger the success callback
 600     });
 601     return new Promise(function(resolve, reject) {
 602         //Need smarter error handling here
 603         Promise.all([config, opData]).then(function(resolves) {
 604             var aggregate = {};
 605             // resolves[0] ==> ns-instance-config
 606             // resolves[1] ==> ns-instance-opdata
 607
 608             var nsInstanceConfig = resolves[0] && resolves[0];
 609             var nsInstanceOpdata = resolves[1] && resolves[1];
 610
 611             if (!nsInstanceConfig && !nsInstanceOpdata) {
 612                 return resolve({
 613                     nsrs: []
 614                 });
 615             }
 616
 617             nsInstanceConfig.forEach(function(v, k) {
 618                 v.nsd_name = v['nsd'] && v['nsd']['name'];
 619                 var scaling_group_descriptor = null;
 620
 621                 scaling_group_descriptor = v['nsd'] && v['nsd']['scaling-group-descriptor'];
 622
 623                 if (scaling_group_descriptor) {
 624                     scaling_group_descriptor.map(function(sgd, sgdi) {
 625                         sgd['vnfd-member'] && sgd['vnfd-member'].map(function(vnfd, vnfdi) {
 626                             var vnfrObj = _.findWhere(_.findWhere(nsInstanceOpdata, {
 627                                     'ns-instance-config-ref': v.id
 628                                 }).vnfrs, {
 629                                 'member-vnf-index-ref': vnfd['member-vnf-index-ref']
 630                             });
 631                             if (vnfrObj) {
 632                                 vnfd['short-name'] = vnfrObj['short-name'];
 633                             }
 634                         })
 635                     })
 636                     v['scaling-group-descriptor'] = scaling_group_descriptor;
 637                 }
 638
 639                 if (nsInstanceOpdata && nsInstanceOpdata.constructor.name == "Array") {
 640                     nsInstanceOpdata.forEach(function(w, l) {
 641                         if (v.id == w["ns-instance-config-ref"]) {
 642                             for (prop in w) {
 643                                 if (prop != "ns-instance-config-ref" && !v.hasOwnProperty(prop)) {
 644                                     v[prop] = w[prop];
 645                                 }
 646                             }
 647                         }
 648                     });
 649                 }
 650
 651                 v['scaling-group-record'] && v['scaling-group-record'].map(function(sgr) {
 652                     var scalingGroupName = sgr['scaling-group-name-ref'];
 653                     sgr['instance'] && sgr['instance'].map(function(instance) {
 654                         var scalingGroupInstanceId = instance['instance-id'];
 655                         instance['vnfrs'] && instance['vnfrs'].map(function(vnfr) {
 656                             var vnfrObj = _.findWhere(v['vnfrs'], {id: vnfr});
 657                             if (vnfrObj) {
 658                                 vnfrObj['scaling-group-name'] = scalingGroupName;
 659                                 vnfrObj['scaling-group-instance-id'] = scalingGroupInstanceId;
 660                             }
 661                         });
 662                     });
 663                 })
 664             });
 665             var nsrsData = nsInstanceConfig;
 666             nsrsData.sort(function(a, b) {
 667                 return a["create-time"] - b["create-time"];
 668             });
 669             resolve({
 670                 nsrs: nsrsData
 671             });
 672         }).catch(function(error) {
 673             reject({
 674                 statusCode: 404,
 675                 errorMessage: error
 676             })
 677         })
 678     });
 679 };
 680 // Static VNFR Cache bu VNFR ID
 681 var staticVNFRCache = {};
 682
 683 /**
 684  * [decorateWithScalingGroupDict description]
 685  * @param  {[type]} nsr [description]
 686  * @return {[type]}
 687 {vnfr-id} : {
 688     "scaling-group-name-ref": "sg1",
 689     "instance-id": 0,
 690     "op-status": "running",
 691     "is-default": "true",
 692     "create-time": 1463593760,
 693     "config-status": "configuring",
 694     "vnfrs": [
 695         "432154e3-164e-4c05-83ee-3b56e4c898e7"
 696     ]
 697 }
 698  */
 699 NSR.decorateWithScalingGroupDict = function(nsr) {
 700     var sg = nsr["scaling-group-record"];
 701     var dict = {};
 702     if(sg) {
 703         sg.map(function(s) {
 704             var sgRef = s['scaling-group-name-ref'];
 705             s.instance && s.instance.map(function(si) {
 706                 si.vnfrs && si.vnfrs.map(function(v) {
 707                     dict[v] = si;
 708                     dict[v]["scaling-group-name-ref"] = sgRef;
 709                 })
 710             })
 711         })
 712     }
 713     return nsr['vnfr-scaling-groups'] = dict;
 714 }
 715
 716
 717 NSR.addVlrDataPromise = function(req, nsrs) {
 718     var api_server = req.query['api_server'];
 719     var promises = [];
 720     nsrs.map(function(nsr) {
 721         var vlrPromises = [];
 722         var vlr = nsr['vlr'];
 723         nsr['decorated-vlrs'] = [];
 724         if (!vlr) {
 725             console.log('No VL\'s found in NS');
 726         }
 727         vlr && vlr.map(function(vlrObject) {
 728             req.params.id = vlrObject['vlr-ref'];
 729             var vlrPromise = VLR.get(req).then(function(vlr) {
 730                 try {
 731                     var vlrItem = vlr['data'][0];
 732                     decorateNSRWithVLR(nsr, vlrObject, vlrItem);
 733                 } catch (e) {
 734                     console.log('Expection caught getting VLRs and adding to NSR:', e);
 735                 }
 736             })
 737             vlrPromises.push(vlrPromise);
 738         });
 739         var NSR_Promise = new Promise(function(resolve, reject) {
 740             Promise.all(vlrPromises).then(function() {
 741                 resolve();
 742             })
 743         });
 744         promises.push(NSR_Promise);
 745     });
 746     return promises;
 747
 748     function decorateNSRWithVLR(nsr, nsrVLRObject, vlr) {
 749         var vlrObject = _.extend(nsrVLRObject, vlr);
 750         vlrObject['vnfr-connection-point-ref'] && vlrObject['vnfr-connection-point-ref'].map(function(vnfrCP) {
 751             var vnfrName = nsr['vnfrs'] && _.find(nsr['vnfrs'], {id: vnfrCP['vnfr-id']})['name'];
 752             vnfrName && (vnfrCP['vnfr-name'] = vnfrName);
 753         });
 754         nsr['decorated-vlrs'].splice(_.sortedIndex(nsr['decorated-vlrs'], vlrObject, 'name'), 0, vlrObject);
 755         // nsr['decorated-vlrs'].splice(_.sortedIndex(nsr['decorated-vlrs'], vlrObject, 'create-time'), 0, vlrObject);
 756     }
 757 }
 758
 759
 760 NSR.addVnfrDataPromise = function(req, nsrs) {
 761     var api_server = req.query['api_server'];
 762     var promises = [];
 763     nsrs.map(function(nsr) {
 764         var epa_params = {};
 765         var constituent_vnfr_ref = nsr["constituent-vnfr-ref"];
 766         var vnfrPromises = [];
 767         nsr["vnfrs"] = [];
 768         nsr["dashboard-urls"] = [];
 769         nsr['nfvi-metrics'] = [];
 770         if (!constituent_vnfr_ref) {
 771             console.log('Something is wrong, there are no constituent-vnfr-refs');
 772             constituent_vnfr_ref = [];
 773         }
 774         //Get VNFR Static Data
 775         constituent_vnfr_ref && constituent_vnfr_ref.map(function(constituentVnfrObj) {
 776             req.params.id = constituentVnfrObj['vnfr-id'];
 777             var vnfrPromise;
 778             vnfrPromise = VNFR.get(req).then(function(vnfr) {
 779                 try {
 780                     var vnfrItem = vnfr[0];
 781                     decorateNSRWithVNFR(nsr, vnfrItem)
 782                     staticVNFRCache[vnfrItem.id] = vnfrItem;
 783                 } catch (e) {
 784                     console.log('Exception caught:', e);
 785                 }
 786             });
 787             vnfrPromises.push(vnfrPromise);
 788         });
 789         var NSR_Promise = new Promise(function(resolve, reject) {
 790             Promise.all(vnfrPromises).then(function() {
 791                 var vnfrs = staticVNFRCache;
 792                 //Aggregate EPA Params
 793                 constituent_vnfr_ref && constituent_vnfr_ref.map(function(k) {
 794                         if (vnfrs[k['vnfr-id']]) {
 795                             epa_params = epa_aggregator(vnfrs[k['vnfr-id']].vdur, epa_params);
 796                         }
 797                     })
 798                 //Add VNFR Name to monitoring params
 799                 try {
 800                     if (nsr["monitoring-param"]) {
 801                         nsr["monitoring-param"].map(function(m) {
 802                             var vnfr = vnfrs[m["vnfr-id"]] || {};
 803                             m["vnfr-name"] = vnfr['name'] ? vnfr['name'] : (vnfr['short-name'] ? vnfr['short-name'] : 'VNFR');
 804                         });
 805                     }
 806                 } catch (e) {
 807                     console.log('Exception caught:', e);
 808                 }
 809                 resolve();
 810             })
 811         })
 812         nsr["epa-params"] = epa_params;
 813         promises.push(NSR_Promise);
 814     })
 815     return promises;
 816
 817     function decorateNSRWithVDURConsoleUrls(nsr, vnfr) {
 818         nsr['console-urls'] = nsr['console-urls'] ? nsr['console-urls'] : [];
 819
 820         vnfr && vnfr['vdur'] && vnfr['vdur'].map(function(vdur) {
 821             // This console-url is what front-end will hit to generate a real console-url
 822             vdur['console-url'] = 'api/vnfr/' + vnfr.id + '/vdur/' + vdur.id + '/console-url';
 823             nsr['console-urls'].push({
 824                 id: vdur.id,
 825                 name: vnfr.name,
 826                 'console-url': vdur['console-url']
 827             });
 828         });
 829     }
 830
 831     function decorateNSRWithVNFR(nsr, vnfr) {
 832         var vnfrObj = {
 833             id: vnfr.id,
 834             "member-vnf-index-ref": vnfr["member-vnf-index-ref"],
 835             "short-name": vnfr["short-name"],
 836             "vnf-configuration": vnfr["vnf-configuration"],
 837             "nsr-id": nsr['ns-instance-config-ref'],
 838             "name": vnfr['name'],
 839             "vdur": vnfr["vdur"],
 840             "cloud-account": vnfr["cloud-account"]
 841         };
 842         var vnfrSg = nsr['vnfr-scaling-groups'];
 843         var vnfrName = vnfr["name"];
 844         if(vnfrSg) {
 845             if(vnfrSg[vnfr.id]) {
 846                 vnfrName = vnfrSg[vnfr.id]["scaling-group-name-ref"] + ':' + vnfrSg[vnfr.id][ "instance-id"] + ':' + vnfrName;
 847             }
 848         }
 849         var vnfrNfviMetrics = buildNfviGraphs(vnfr.vdur, vnfrName);
 850         if (vnfr['vnf-configuration'] && vnfr['vnf-configuration']['service-primitive'] && vnfr['vnf-configuration']['service-primitive'].length > 0) {
 851             vnfrObj['service-primitives-present'] = true;
 852         } else {
 853             vnfrObj['service-primitives-present'] = false;
 854         }
 855                 transforms.mergeVnfrNfviMetrics(vnfrNfviMetrics, nsr["nfvi-metrics"]);
 856         //TODO: Should be sorted by create-time when it becomes available instead of id
 857         // nsr["vnfrs"].splice(_.sortedIndex(nsr['vnfrs'], vnfrObj, 'create-time'), 0, vnfrObj);
 858         nsr["vnfrs"].splice(_.sortedIndex(nsr['vnfrs'], vnfrObj, 'id'), 0, vnfrObj);
 859         vnfrObj["dashboard-url"] = vnfr["dashboard-url"];
 860         nsr["dashboard-urls"].push(vnfrObj);
 861
 862         decorateNSRWithVDURConsoleUrls(nsr, vnfr);
 863     }
 864 }
 865 NSR.create = function(req) {
 866     var api_server = req.query['api_server'];
 867     var data = req.body.data;
 868     console.log('Instantiating NSR on ', api_server);
 869     return new Promise(function(resolve, reject) {
 870         var requestHeaders = {};
 871         _.extend(requestHeaders, constants.HTTP_HEADERS.accept.data, constants.HTTP_HEADERS.content_type.data, {
 872             'Authorization': req.session && req.session.authorization
 873         });
 874         request({
 875             uri: utils.projectContextUrl(req, utils.confdPort(api_server) + APIVersion + '/api/config/ns-instance-config'),
 876             method: 'POST',
 877             headers: requestHeaders,
 878             forever: constants.FOREVER_ON,
 879             rejectUnauthorized: false,
 880             json: data
 881         }, function(error, response, body) {
 882             if (utils.validateResponse('NSR.create', error, response, body, resolve, reject)) {
 883                 var nsr_id = null;
 884                 try {
 885                     nsr_id = data.nsr[0].id;
 886                 } catch (e) {
 887                     console.log("NSR.create unable to get nsr_id. Error: %s",
 888                     e.toString());
 889                 }
 890                 resolve({
 891                     statusCode: response.statusCode,
 892                     data: { nsr_id: nsr_id }
 893                  });
 894             };
 895         });
 896     });
 897 };
 898 NSR.delete = function(req) {
 899     var api_server = req.query["api_server"];
 900     var id = req.params.id;
 901     if (!id || !api_server) {
 902         return new Promise(function(resolve, reject) {
 903             console.log('Must specifiy api_server and id to delete NSR');
 904             return reject({
 905                 statusCode: 500,
 906                 errorMessage: {
 907                     error: 'Must specifiy api_server and id to delete NSR'
 908                 }
 909             });
 910         });
 911     };
 912     console.log('Deleting NSR with id: ' + id + 'on server: ' + api_server);
 913     return new Promise(function(resolve, reject) {
 914         var requestHeaders = {};
 915         _.extend(requestHeaders, constants.HTTP_HEADERS.accept.data, {
 916             'Authorization': req.session && req.session.authorization
 917         });
 918         request({
 919             uri: utils.projectContextUrl(req, utils.confdPort(api_server) + APIVersion + '/api/config/ns-instance-config/nsr/' + id),
 920             method: 'DELETE',
 921             headers: requestHeaders,
 922             forever: constants.FOREVER_ON,
 923             rejectUnauthorized: false,
 924         }, function(error, response, body) {
 925             if (utils.validateResponse('NSR.delete', error, response, body, resolve, reject)) {
 926                 resolve({
 927                     statusCode: response.statusCode,
 928                     data: JSON.stringify(response.body)
 929                 });
 930             };
 931         });
 932     });
 933 };
 934 NSR.decorateAndTransformNFVI = function(nsr) {
 935         var toDecorate = [];
 936         // var metricsToUse = ["vcpu", "memory", "storage", "network"];
 937         var metricsToUse = ["vcpu", "memory"];
 938         try {
 939             var nfviMetrics = nsr["rw-nsr:nfvi-metrics"];
 940             if (nfviMetrics) {
 941                 metricsToUse.map(function(name) {
 942                     toDecorate.push(nfviMetrics[name])
 943                 });
 944             }
 945             nsr["nfvi-metrics"] = toDecorate;
 946             delete nsr["rw-nsr:nfvi-metrics"];
 947         } catch (e) {}
 948         return nsr;
 949     }
 950     //Not a great pattern, Need a better way of handling logging;
 951     //Refactor and move to the logging/logging.js
 952 var logCache = {
 953     decorateAndTransformWithControls: {}
 954 }
 955 NSR.decorateAndTransformWithControls = function(nsr) {
 956     var controlTypes = ["action-param", "control-param"];
 957     var nsControls = [];
 958     var Groups = {};
 959     controlTypes.map(function(control) {
 960         try {
 961             var controls = nsr["rw-nsr:" + control];
 962             // nsControls.push(controls);
 963             controls.map(function(item) {
 964                 if (!Groups[item["group-tag"]]) {
 965                     Groups[item["group-tag"]] = {};
 966                     Groups[item["group-tag"]]["action-param"] = []
 967                     Groups[item["group-tag"]]["control-param"] = []
 968                 }
 969                 Groups[item["group-tag"]][control].push(item);
 970             });
 971             delete nsr["rw-nsr:" + control];
 972         } catch (e) {
 973             var id = nsr["ns-instance-config-ref"];
 974             if (!logCache.decorateAndTransformWithControls[id]) {
 975                 logCache.decorateAndTransformWithControls[id] = {};
 976             }
 977             var log = logCache.decorateAndTransformWithControls[id];
 978             if (!log[control]) {
 979                 log[control] = true;
 980                 console.log('No controls exist for ' + control + ' at ' + nsr["ns-instance-config-ref"]);
 981             }
 982         }
 983     });
 984     for (k in Groups) {
 985         var obj = {}
 986         obj[k] = Groups[k];
 987         nsControls.push(obj)
 988     }
 989     nsr.nsControls = nsControls;
 990     return nsr;
 991 };
 992 NSR.setStatus = function(req) {
 993     var api_server = req.query['api_server'];
 994     var id = req.params.id;
 995     var status = req.body.status;
 996     console.log('Setting NSR (id: ' + id + ') status, on ' + api_server + ', to be: ' + status);
 997     return new Promise(function(resolve, reject) {
 998         var command;
 999         if (typeof(status) != "string") {
1000             reject({
1001                 'ERROR': 'NSR.setStatus Error: status is not a string type'
1002             });
1003         }
1004         command = status.toUpperCase();
1005         if (command != "ENABLED" && command != "DISABLED") {
1006             reject({
1007                 'ERROR': 'NSR.setStatus Error: status is: ' + command + '. It should be ENABLED or DISABLED'
1008             });
1009         }
1010         var requestHeaders = {};
1011         _.extend(requestHeaders, constants.HTTP_HEADERS.accept.data, constants.HTTP_HEADERS.content_type.data, {
1012             'Authorization': req.session && req.session.authorization
1013         });
1014         request({
1015             uri: utils.projectContextUrl(req, utils.confdPort(api_server) + APIVersion + '/api/config/ns-instance-config/nsr/' + id + '/admin-status/'),
1016             method: 'PUT',
1017             headers: requestHeaders,
1018             json: {
1019                 "nsr:admin-status": command
1020             },
1021             forever: constants.FOREVER_ON,
1022             rejectUnauthorized: false,
1023         }, function(error, response, body) {
1024             if (utils.validateResponse('NSR.setStatus', error, response, body, resolve, reject)) {
1025                 resolve({
1026                     statusCode: response.statusCode
1027                 });
1028             };
1029         });
1030     });
1031 };
1032
1033 NSR.createScalingGroupInstance = function(req) {
1034     var api_server = req.query['api_server'];
1035     var id = req.params.id;
1036     var scaling_group_id = req.params.scaling_group_id;
1037     if (!api_server || !id || !scaling_group_id) {
1038         return new Promise(function(resolve, reject) {
1039             return reject({
1040                 statusCode: 500,
1041                 errorMessage: {
1042                     error: 'API server/NSR id/Scaling group not provided'
1043                 }
1044             });
1045         });
1046     }
1047
1048     var instance_id = Math.floor(Math.random() * 65535);
1049
1050     var jsonData = {
1051         instance: [{
1052             // id: uuid.v1()
1053             id: instance_id
1054         }]
1055     };
1056
1057     console.log('Creating scaling group instance for NSR ', id, ', scaling group ', scaling_group_id, ' with instance id ', instance_id);
1058
1059     return new Promise(function(resolve, reject) {
1060         var requestHeaders = {};
1061         _.extend(requestHeaders,
1062             constants.HTTP_HEADERS.accept.data,
1063             constants.HTTP_HEADERS.content_type.data,
1064             {
1065                 'Authorization': req.session && req.session.authorization
1066             }
1067         );
1068
1069         request({
1070             uri: utils.projectContextUrl(req, utils.confdPort(api_server) + APIVersion + '/api/config/ns-instance-config/nsr/' + id + '/scaling-group/' + scaling_group_id + '/instance'),
1071             method: 'POST',
1072             headers: requestHeaders,
1073             json: jsonData,
1074             forever: constants.FOREVER_ON,
1075             rejectUnauthorized: false
1076         }, function (error, response, body) {
1077             if (utils.validateResponse('NSR.createScalingGroupInstance', error, response, body, resolve, reject)) {
1078                 resolve({
1079                     statusCode: response.statusCode,
1080                     data: typeof response.body == 'string' ? JSON.parse(response.body):response.body
1081                 })
1082             }
1083         });
1084     });
1085 };
1086
1087 NSR.deleteScalingGroupInstance = function(req) {
1088     var api_server=req.query['api_server'];
1089     var id = req.params.id;
1090     var scaling_group_id = req.params.scaling_group_id;
1091     var scaling_instance_id = req.params.scaling_instance_id;
1092
1093     if (!api_server || !id || !scaling_group_id || !scaling_instance_id) {
1094         return new Promise(function(resolve, reject) {
1095             return reject({
1096                 statusCode: 500,
1097                 errorMessage: {
1098                     error: 'API server/NSR id/Scaling group/Scaling instance id not provided'
1099                 }
1100             });
1101         });
1102     }
1103
1104     console.log('Deleting scaling group instance id ', scaling_instance_id,
1105         ' for scaling group ', scaling_group_id,
1106         ', under NSR ', id);
1107
1108     return new Promise(function(resolve, reject) {
1109         var requestHeaders = {};
1110         _.extend(requestHeaders,
1111             constants.HTTP_HEADERS.accept.data,
1112             constants.HTTP_HEADERS.content_type.data,
1113             {
1114                 'Authorization': req.session && req.session.authorization
1115             }
1116         );
1117
1118         request({
1119             uri: utils.projectContextUrl(req, utils.confdPort(api_server) + APIVersion + '/api/config/ns-instance-config/nsr/' + id + '/scaling-group/' + scaling_group_id + '/instance/' + scaling_instance_id),
1120             method: 'DELETE',
1121             headers: requestHeaders,
1122             forever: constants.FOREVER_ON,
1123             rejectUnauthorized: false
1124         }, function (error, response, body) {
1125             if (utils.validateResponse('NSR.deleteScalingGroupInstance', error, response, body, resolve, reject)) {
1126                 resolve({
1127                     statusCode: response.statusCode,
1128                     data: typeof response.body == 'string' ? JSON.parse(response.body):response.body
1129                 })
1130             }
1131         });
1132     });
1133 };
1134
1135 NSR.nsd = {};
1136 NSR.nsd.vld = {};
1137
1138 NSR.nsd.vld.get = function(req) {
1139     var api_server = req.query['api_server'];
1140     var nsr_id = req.params.nsr_id;
1141     var vld_id = req.params.vld_id;
1142
1143     if (!api_server || !nsr_id) {
1144         return new Promise(function(resolve, reject) {
1145             return reject({
1146                 statusCode: constants.HTTPS_RESPONSE_CODES.ERROR.INTERNAL_SERVER_ERROR,
1147                 errorMessage: 'API server/NSR id not provided'
1148             });
1149         })
1150     }
1151     console.log('Getting VLD', vld_id ? (' ' + vld_id) : ('\'s'), ' for NSR id', nsr_id);
1152
1153     return new Promise(function(resolve, reject) {
1154         var requestHeaders = {};
1155         _.extend(requestHeaders,
1156             vld_id ? constants.HTTP_HEADERS.accept.data : constants.HTTP_HEADERS.accept.collection,
1157             {
1158                 'Authorization': req.session && req.session.authorization
1159             }
1160         );
1161
1162         request({
1163             uri: utils.projectContextUrl(req, utils.confdPort(api_server) + APIVersion + '/api/config/ns-instance-config/nsr/' + nsr_id + '/nsd/vld' + (vld_id ? '/' + vld_id : '')  +'?deep'),
1164             method: 'GET',
1165             headers: requestHeaders,
1166             forever: constants.FOREVER_ON,
1167             rejectUnauthorized: false
1168         }, function (error, response, body) {
1169             if (utils.validateResponse('NSR.nsd.vld.get', error, response, body, resolve, reject)) {
1170                 resolve({
1171                     statusCode: response.statusCode,
1172                     data: typeof response.body == 'string' ? JSON.parse(response.body):response.body
1173                 });
1174             }
1175         });
1176     });
1177 };
1178
1179 NSR.nsd.vld.create = function(req) {
1180     var api_server = req.query['api_server'];
1181     var nsr_id = req.params.nsr_id;
1182     var vld_id = req.params.vld_id;
1183     var data = req.body;
1184
1185     if (!api_server || !nsr_id) {
1186         return new Promise(function(resolve, reject) {
1187             return reject({
1188                 statusCode: constants.HTTPS_RESPONSE_CODES.ERROR.INTERNAL_SERVER_ERROR,
1189                 errorMessage: 'API server/NSR id not provided'
1190             });
1191         });
1192     }
1193
1194     console.log((vld_id ? 'Updating VLD ' + vld_id : 'Creating VLD') + ' under NSR', nsr_id);
1195
1196     var jsonData = {
1197         vld: typeof(data) == 'string' ? JSON.parse(data) : data
1198     };
1199
1200     return new Promise(function(resolve, reject) {
1201         var requestHeaders = {};
1202         _.extend(requestHeaders, constants.HTTP_HEADERS.accept.data, constants.HTTP_HEADERS.content_type.data, {
1203             'Authorization': req.session && req.session.authorization
1204         });
1205         request({
1206             uri: utils.projectContextUrl(req, utils.confdPort(api_server) + '/api/config/ns-instance-config/nsr/' + nsr_id + '/nsd/vld' + (vld_id ? '/' + vld_id : '')),
1207             method: vld_id ? 'PUT' : 'POST',
1208             headers: requestHeaders,
1209             forever: constants.FOREVER_ON,
1210             rejectUnauthorized: false,
1211             json: jsonData
1212         }, function(error, response, body) {
1213             if (utils.validateResponse('NSR.nsd.vld.create/update', error, response, body, resolve, reject)) {
1214                 resolve({
1215                     statusCode: response.statusCode,
1216                     data: (typeof(response.body) == 'string') ? JSON.parse(response.body) : response.body
1217                 });
1218             }
1219         });
1220     });
1221 };
1222
1223 NSR.nsd.vld.update = NSR.nsd.vld.create;
1224
1225 NSR.nsd.vld.delete = function(req) {
1226     var api_server = req.query['api_server'];
1227     var nsr_id = req.params.nsr_id;
1228     var vld_id = req.params.vld_id;
1229
1230     if (!api_server || !nsr_id || !vld_id) {
1231         return new Promise(function(resolve, reject) {
1232             return reject({
1233                 statusCode: constants.HTTPS_RESPONSE_CODES.ERROR.INTERNAL_SERVER_ERROR,
1234                 errorMessage: 'API server/NSR id/VLD id not provided'
1235             });
1236         })
1237     }
1238     console.log('Deleting VLD', vld_id, 'for NSR id', nsr_id);
1239
1240     return new Promise(function(resolve, reject) {
1241         var requestHeaders = {};
1242         _.extend(requestHeaders,
1243             constants.HTTP_HEADERS.accept.data,
1244             {
1245                 'Authorization': req.session && req.session.authorization
1246             }
1247         );
1248
1249         request({
1250             uri: utils.projectContextUrl(req, utils.confdPort(api_server) + APIVersion + '/api/config/ns-instance-config/nsr/' + nsr_id + '/nsd/vld/' + vld_id),
1251             method: 'DELETE',
1252             headers: requestHeaders,
1253             forever: constants.FOREVER_ON,
1254             rejectUnauthorized: false
1255         }, function (error, response, body) {
1256             if (utils.validateResponse('NSR.nsd.vld.delete', error, response, body, resolve, reject)) {
1257                 resolve({
1258                     statusCode: response.statusCode,
1259                     data: typeof response.body == 'string' ? JSON.parse(response.body):response.body
1260                 });
1261             }
1262         });
1263     });
1264 }
1265
1266 VNFR.get = function(req) {
1267     var api_server = req.query["api_server"];
1268     var id = req.params.id;
1269     var uri = utils.confdPort(api_server);
1270     uri += APIVersion + '/api/operational/vnfr-catalog/vnfr' + (id ? '/' + id : '') + '?deep';
1271     var headers = _.extend({}, id ? constants.HTTP_HEADERS.accept.data : constants.HTTP_HEADERS.accept.collection, {
1272         'Authorization': req.session && req.session.authorization
1273     });
1274     return new Promise(function(resolve, reject) {
1275         request({
1276             url: utils.projectContextUrl(req, uri),
1277             method: 'GET',
1278             headers: headers,
1279             forever: constants.FOREVER_ON,
1280             rejectUnauthorized: false,
1281         }, function(error, response, body) {
1282             if (utils.validateResponse('VNFR.get', error, response, body, resolve, reject)) {
1283                 var data = JSON.parse(response.body);
1284                 var returnData = id ? [data["vnfr:vnfr"]] : data.collection["vnfr:vnfr"];
1285                 returnData.forEach(function(vnfr) {
1286                     vnfr['nfvi-metrics'] = buildNfviGraphs(vnfr.vdur);
1287                     vnfr['epa-params'] = epa_aggregator(vnfr.vdur);
1288                     vnfr['service-primitives-present'] = (vnfr['vnf-configuration'] && vnfr['vnf-configuration']['service-primitive'] && vnfr['vnf-configuration']['service-primitive'].length > 0) ? true : false;
1289                     vnfr['vdur'] && vnfr['vdur'].map(function(vdur, vdurIndex) {
1290                         // This console-url is what front-end will hit to generate a real console-url
1291                         vdur['console-url'] = 'api/vnfr/' + vnfr.id + '/vdur/' + vdur.id + '/console-url';
1292                     });
1293                 });
1294                 return resolve(returnData);
1295             };
1296         });
1297     });
1298 }
1299
1300 function buildNfviGraphs(VDURs, vnfrName){
1301         var temp = {};
1302         var toReturn = [];
1303         APIConfig.NfviMetrics.map(function(k) {
1304
1305             VDURs && VDURs.map(function(v,i) {
1306                 //Check for RIFT-12699: VDUR NFVI Metrics not fully populated
1307                 if (v["rw-vnfr:nfvi-metrics"] && v["rw-vnfr:nfvi-metrics"][k] && v["rw-vnfr:nfvi-metrics"][k].hasOwnProperty('utilization')) {
1308                     if(!temp[k]) {
1309                         temp[k] = {
1310                             title: '',
1311                             data: []
1312                         };
1313                     };
1314                     try {
1315                         var data = v["rw-vnfr:nfvi-metrics"][k];
1316                         var newData = {};
1317                         newData.name = v.name ? v.name : v.id.substring(0,6);
1318                         newData.name = vnfrName ? vnfrName + ': ' + newData.name : newData.name;
1319                         newData.id = v.id;
1320                         //converts to perentage
1321                         newData.utilization = data.utilization * 0.01;
1322                         temp[k].data.push(newData);
1323                         temp[k].title = v["rw-vnfr:nfvi-metrics"][k].label;
1324                     } catch (e) {
1325                         console.log('Something went wrong with the VNFR NFVI Metrics. Check that the data is being properly returned. ERROR: ', e);
1326                     }
1327                 }
1328             });
1329             if(temp[k]) {
1330                 toReturn.push(temp[k]);
1331             }
1332         });
1333         return toReturn;
1334     }
1335
1336
1337 //Cache NSR reference for VNFR
1338 VNFR.cachedNSR = {};
1339 VNFR.getByNSR = function(req) {
1340     var api_server = req.query["api_server"];
1341     var id = req.params.nsr_id;
1342     var uri = utils.confdPort(api_server);
1343     var reqClone = _.clone(req);
1344     delete reqClone.params.id;
1345     uri += APIVersion + '/api/operational/ns-instance-opdata/nsr/' + id + '?deep';
1346     var headers = _.extend({}, id ? constants.HTTP_HEADERS.accept.data : constants.HTTP_HEADERS.accept.collection, {
1347         'Authorization': req.session && req.session.authorization
1348     });
1349     return new Promise(function(resolve, reject) {
1350         if (VNFR.cachedNSR[id]) {
1351             var data = VNFR.cachedNSR[id];
1352             var vnfrList = _.pluck(data["constituent-vnfr-ref"], 'vnfr-id');
1353             VNFR.get(reqClone).then(function(vnfrData) {
1354                 resolve(filterVnfrByList(vnfrList, vnfrData));
1355             });
1356         } else {
1357             request({
1358                 url: utils.projectContextUrl(req, uri),
1359                 method: 'GET',
1360                 headers: headers,
1361                 forever: constants.FOREVER_ON,
1362                 rejectUnauthorized: false,
1363             }, function(error, response, body) {
1364                 if (utils.validateResponse('VNFR.getByNSR', error, response, body, resolve, reject)) {
1365                     var data = JSON.parse(response.body);
1366                     data = data["nsr:nsr"];
1367                     //Cache NSR data with NSR-ID as
1368                     VNFR.cachedNSR[id] = data;
1369                     var vnfrList = _.pluck(data["constituent-vnfr-ref"], 'vnfr-id');
1370                     var returnData = [];
1371                     VNFR.get(reqClone).then(function(vnfrData) {
1372                         resolve(filterVnfrByList(vnfrList, vnfrData));
1373                     });
1374                 };
1375             });
1376         }
1377     });
1378 };
1379
1380 function filterVnfrByList(vnfrList, vnfrData) {
1381     return vnfrData.map(function(vnfr) {
1382         if (vnfrList.indexOf(vnfr.id) > -1) {
1383             return vnfr;
1384         }
1385     })
1386 };
1387
1388 VLR.get = function(req) {
1389     var api_server = req.query["api_server"];
1390     var id = req.params.id;
1391     var uri = utils.confdPort(api_server);
1392     uri += APIVersion + '/api/operational/vlr-catalog/vlr' + (id ? '/' + id : '') + '?deep';
1393     var headers = _.extend({}, id ? constants.HTTP_HEADERS.accept.data : constants.HTTP_HEADERS.accept.collection, {
1394         'Authorization': req.session && req.session.authorization
1395     });
1396     return new Promise(function(resolve, reject) {
1397         request({
1398             url: utils.projectContextUrl(req, uri),
1399             method: 'GET',
1400             headers: headers,
1401             forever: constants.FOREVER_ON,
1402             rejectUnauthorized: false,
1403         }, function(error, response, body) {
1404             if (utils.validateResponse('VLR.get', error, response, body, resolve, reject)) {
1405                 var data = JSON.parse(response.body);
1406                 var returnData = id ? [data["vlr:vlr"]] : data.collection["vlr:vlr"];
1407                 return resolve({
1408                     data: returnData,
1409                     statusCode: response.statusCode
1410                 });
1411             };
1412         });
1413     });
1414 }
1415
1416 RIFT.api = function(req) {
1417     var api_server = req.query["api_server"];
1418     var uri = utils.confdPort(api_server);
1419     var url = req.path;
1420     return new Promise(function(resolve, reject) {
1421         request({
1422             url: utils.projectContextUrl(req, uri + url + '?deep'),
1423             method: 'GET',
1424             headers: _.extend({}, constants.HTTP_HEADERS.accept.data, {
1425                 'Authorization': req.session && req.session.authorization
1426             }),
1427             forever: constants.FOREVER_ON,
1428             rejectUnauthorized: false,
1429         }, function(error, response, body) {
1430             if (utils.validateResponse('RIFT.api', error, response, body, resolve, reject)) {
1431                 resolve(JSON.parse(response.body))
1432             };
1433         })
1434     })
1435 };
1436
1437 ComputeTopology.get = function(req) {
1438     var api_server = req.query['api_server'];
1439     var nsr_id = req.params.id;
1440     var result = {
1441         id: nsr_id, // node id
1442         name: nsr_id, // node name to display
1443         parameters: {}, // the parameters that can be used to determine size/color, etc. for the node
1444         type: 'nsr',
1445         children: [] // children for the node
1446     };
1447     return new Promise(function(resolve, reject) {
1448         var nsrPromise = new Promise(function(success, failure) {
1449             request({
1450                 uri: utils.projectContextUrl(req, utils.confdPort(api_server) + APIVersion + '/api/operational/ns-instance-opdata/nsr/' + nsr_id + '?deep'),
1451                 method: 'GET',
1452                 headers: _.extend({},
1453                     constants.HTTP_HEADERS.accept.data, {
1454                         'Authorization': req.session && req.session.authorization
1455                     }),
1456                 forever: constants.FOREVER_ON,
1457                 rejectUnauthorized: false,
1458             }, function(error, response, body) {
1459                 if (utils.validateResponse('ComputeTopology.get ns-instance-opdata/nsr/:id', error, response, body, success, failure)) {
1460                     var data;
1461                     var isString = typeof(response.body) == "string";
1462                     if (isString && response.body == '') {
1463                         return success({});
1464                     }
1465                     try {
1466                         data = isString ? JSON.parse(response.body) : response.body;
1467
1468                         var nsrNFVIMetricData = data["nsr:nsr"]["rw-nsr:nfvi-metrics"];
1469                         result.parameters = nsrNFVIMetricData;
1470
1471                         result.name = data["nsr:nsr"]["name-ref"];
1472
1473                         var nsrData = data["nsr:nsr"]["constituent-vnfr-ref"];
1474                         success(nsrData);
1475                     } catch (e) {
1476                         console.log('Error parsing ns-instance-opdata for NSR ID', nsr_id, 'Exception:', e);
1477                         return failure()
1478                     }
1479                 };
1480             });
1481         }).then(function(data) {
1482
1483             try {
1484                 // got NSR data
1485                 // now get VNFR data and populate the structure
1486                 var vnfrPromises = [];
1487
1488                 // Run separately to confirm that primary structure is populated before promise resolution takes over
1489                 // and starts modifying the data
1490                 data.forEach(function(vnfrObj) {
1491
1492                     var vnfrId = vnfrObj['vnfr-id'];
1493
1494                     // If anything needs to be added to result for each vnfrId, do it here
1495
1496                     vnfrPromises.push(
1497                         new Promise(function(success, failure) {
1498                             rp({
1499                                 uri: utils.projectContextUrl(req, utils.confdPort(api_server) + APIVersion + '/api/operational/vnfr-catalog/vnfr/' + vnfrId + '?deep'),
1500                                 method: 'GET',
1501                                 headers: _.extend({}, constants.HTTP_HEADERS.accept.data, {
1502                                     'Authorization': req.session && req.session.authorization
1503                                 }),
1504                                 forever: constants.FOREVER_ON,
1505                                 rejectUnauthorized: false,
1506                                 resolveWithFullResponse: true
1507                             }, function(error, response, body) {
1508                                 if (utils.validateResponse('ComputeTopology.get vnfr-catalaog/vnfr/:id', error, response, body, success, failure)) {
1509                                     try {
1510                                         var data = JSON.parse(response.body);
1511                                         var returnData = data["vnfr:vnfr"];
1512
1513                                         // Push VNFRs in result
1514                                         result.children.push({
1515                                             id: vnfrId,
1516                                             name: returnData.name,
1517                                             parameters: {}, // nfvi metrics here
1518                                             children: [],
1519                                             type: 'vnfr'
1520                                         });
1521
1522                                         // Push VDURs in result
1523                                         returnData.vdur.forEach(function(vdur) {
1524                                             result.children[result.children.length - 1].children.push({
1525                                                 id: vdur.id,
1526                                                 name: vdur.id,
1527                                                 parameters: {},
1528                                                 type: 'vdur'
1529                                                     // children: []
1530                                             });
1531                                         });
1532
1533                                         return success(returnData.vdur);
1534                                     } catch (e) {
1535                                         console.log('Error parsing vnfr-catalog for VNFR ID', vnfrId, 'Exception:', e);
1536                                         return failure();
1537                                     }
1538                                 };
1539                             });
1540                         })
1541                     );
1542                 });
1543
1544                 Promise.all(vnfrPromises).then(function(output) {
1545                     console.log('Resolved all VNFR requests successfully');
1546                     // By now result must be completely populated. output is moot
1547
1548                     // Sort the results as there's no order to them from RIFT-REST
1549                     result.children.sort(sortByName);
1550
1551                     result.children.forEach(function(vnfr) {
1552                         vnfr.children.sort(sortByName);
1553                     });
1554
1555                     resolve({
1556                         statusCode: 200,
1557                         data: result
1558                     });
1559                 }).catch(function(error) {
1560                     // Todo: Can this be made better?
1561                     // Right now if one of the southbound APIs fails - we just return what's populated so far in result
1562                     console.log('Problem with ComputeTopology.get vnfr-catalog/vnfr/:id', error, 'Resolving with partial data', result);
1563                     resolve({
1564                         statusCode: 200,
1565                         data: result
1566                     });
1567                 });
1568             } catch (e) {
1569                 // API came back with empty ns-instance-opdata response for NSR ID
1570                 // bail
1571                 console.log('Error iterating through ns-instance-opdata response for NSR ID', nsr_id, 'Exception:', e);
1572                 resolve({
1573                     statusCode: 200,
1574                     data: result
1575                 })
1576             }
1577         }, function(error) {
1578             // failed to get NSR data.
1579             // bail
1580             resolve({
1581                 statusCode: 200,
1582                 data: result
1583             });
1584         });
1585     });
1586 };
1587
1588 NetworkTopology.get = function(req) {
1589     var api_server = req.query["api_server"];
1590     var uri = utils.confdPort(api_server);
1591     uri += APIVersion + '/api/operational/network?deep';
1592     var headers = _.extend({}, constants.HTTP_HEADERS.accept.data, {
1593         'Authorization': req.session && req.session.authorization
1594     });
1595     return new Promise(function(resolve, reject) {
1596         request({
1597             url: utils.projectContextUrl(req, uri),
1598             method: 'GET',
1599             headers: headers,
1600             forever: constants.FOREVER_ON,
1601             rejectUnauthorized: false
1602         }, function(error, response, body) {
1603             if (utils.validateResponse('NetworkTopology.get', error, response, body, resolve, reject)) {
1604                 var data = JSON.parse(response.body);
1605                 var returnData = transforms.transformNetworkTopology(
1606                     data["ietf-network:network"]
1607                 );
1608                 resolve({
1609                     statusCode: 200,
1610                     data: returnData
1611                 });
1612             };
1613         });
1614     })
1615 }
1616
1617 VDUR.get = function(req) {
1618     var api_server = req.query["api_server"];
1619     var vnfrID = req.params.vnfr_id;
1620     var vdurID = req.params.vdur_id;
1621     var uri = utils.confdPort(api_server);
1622     uri += APIVersion + '/api/operational/vnfr-catalog/vnfr/' + vnfrID + '/vdur/' + vdurID + '?deep';
1623     var headers = _.extend({}, constants.HTTP_HEADERS.accept.data, {
1624         'Authorization': req.session && req.session.authorization
1625     });
1626     return new Promise(function(resolve, reject) {
1627         request({
1628             url: utils.projectContextUrl(req, uri),
1629             method: 'GET',
1630             headers: headers,
1631             forever: constants.FOREVER_ON,
1632             rejectUnauthorized: false,
1633         }, function(error, response, body) {
1634             if (utils.validateResponse('VDUR.get', error, response, body, resolve, reject)) {
1635                 var data = JSON.parse(response.body);
1636                 var returnData = data["vdur:vdur"];
1637                 return resolve(returnData);
1638             };
1639         });
1640     })
1641 }
1642
1643 VDUR.consoleUrl = {};
1644 VDUR.consoleUrl.get = function(req) {
1645     var api_server = req.query["api_server"];
1646     var vnfrID = req.params.vnfr_id;
1647     var vdurID = req.params.vdur_id;
1648     var uri = utils.confdPort(api_server);
1649     uri += APIVersion + '/api/operational/vnfr-console/vnfr/' + vnfrID + '/vdur/' + vdurID + '/console-url' + '?deep';
1650     var headers = _.extend({}, constants.HTTP_HEADERS.accept.data, {
1651         'Authorization': req.session && req.session.authorization
1652     });
1653     return new Promise(function(resolve, reject) {
1654         request({
1655             url: utils.projectContextUrl(req, uri),
1656             method: 'GET',
1657             headers: headers,
1658             forever: constants.FOREVER_ON,
1659             rejectUnauthorized: false,
1660         }, function(error, response, body) {
1661             if (utils.validateResponse('VDUR.consoleUrl.get', error, response, body, resolve, reject)) {
1662                 var data = JSON.parse(response.body);
1663                 var returnData = data;
1664                 return resolve({
1665                     data: returnData,
1666                     statusCode: response.statusCode
1667                 });
1668             };
1669         });
1670     })
1671 }
1672
1673 CloudAccount.get = function(req) {
1674     var api_server = req.query["api_server"];
1675     var uri = utils.confdPort(api_server);
1676     uri += APIVersion + '/api/operational/cloud/account?deep';
1677     var headers = _.extend({}, constants.HTTP_HEADERS.accept.collection, {
1678         'Authorization': req.session && req.session.authorization
1679     });
1680     return new Promise(function(resolve, reject) {
1681         request({
1682             url: utils.projectContextUrl(req, uri),
1683             method: 'GET',
1684             headers: headers,
1685             forever: constants.FOREVER_ON,
1686             rejectUnauthorized: false,
1687         }, function(error, response, body) {
1688             if (utils.validateResponse('CloudAccount.get', error, response, body, resolve, reject)) {
1689                 var data = JSON.parse(response.body);
1690                 var returnData = data["collection"]["rw-cloud:account"];
1691                 resolve({
1692                     statusCode: 200,
1693                     data: returnData
1694                 });
1695             };
1696         });
1697     });
1698 }
1699
1700
1701 // Config-Agent Account APIs
1702 ConfigAgentAccount.get = function(req) {
1703     var self = this;
1704
1705     var api_server = req.query["api_server"];
1706     var id = req.params.id;
1707
1708     if (!id) {
1709         // Get all config accounts
1710         return new Promise(function(resolve, reject) {
1711
1712             var requestHeaders = {};
1713             _.extend(requestHeaders,
1714                 constants.HTTP_HEADERS.accept.collection, {
1715                     'Authorization': req.session && req.session.authorization
1716                 });
1717
1718             request({
1719                     url: utils.projectContextUrl(req, utils.confdPort(api_server) + APIVersion + '/api/operational/config-agent/account'),
1720                     type: 'GET',
1721                     headers: requestHeaders,
1722                     forever: constants.FOREVER_ON,
1723                     rejectUnauthorized: false,
1724                 },
1725                 function(error, response, body) {
1726                     var data;
1727                     var statusCode;
1728                     if (utils.validateResponse('ConfigAgentAccount.get', error, response, body, resolve, reject)) {
1729                         try {
1730                             data = JSON.parse(response.body).collection['rw-config-agent:account'];
1731                             statusCode = response.statusCode;
1732                         } catch (e) {
1733                             console.log('Problem with "ConfigAgentAccount.get"', e);
1734                             var err = {};
1735                             err.statusCode = 500;
1736                             err.errorMessage = {
1737                                 error: 'Problem with "ConfigAgentAccount.get": ' + e.toString()
1738                             }
1739                             return reject(err);
1740                         }
1741
1742                         return resolve({
1743                             statusCode: statusCode,
1744                             data: data
1745                         });
1746                     };
1747                 });
1748         });
1749     } else {
1750         //Get a specific config account
1751         return new Promise(function(resolve, reject) {
1752             var requestHeaders = {};
1753             _.extend(requestHeaders,
1754                 constants.HTTP_HEADERS.accept.data, {
1755                     'Authorization': req.session && req.session.authorization
1756                 });
1757
1758             request({
1759                     url: utils.projectContextUrl(req, utils.confdPort(api_server) + APIVersion + '/api/operational/config-agent/account/' + id),
1760                     type: 'GET',
1761                     headers: requestHeaders,
1762                     forever: constants.FOREVER_ON,
1763                     rejectUnauthorized: false,
1764                 },
1765                 function(error, response, body) {
1766                     var data;
1767                     var statusCode;
1768                     if (utils.validateResponse('ConfigAgentAccount.get', error, response, body, resolve, reject)) {
1769                         try {
1770                             data = JSON.parse(response.body)['rw-config-agent:account'];
1771                             statusCode = response.statusCode;
1772                         } catch (e) {
1773                             console.log('Problem with "ConfigAgentAccount.get"', e);
1774                             var err = {};
1775                             err.statusCode = 500;
1776                             err.errorMessage = {
1777                                 error: 'Problem with "ConfigAgentAccount.get": ' + e.toString()
1778                             }
1779                             return reject(err);
1780                         }
1781
1782                         return resolve({
1783                             statusCode: statusCode,
1784                             data: data
1785                         });
1786                     }
1787                 });
1788         });
1789     }
1790 };
1791
1792 ConfigAgentAccount.create = function(req) {
1793
1794     var api_server = req.query["api_server"];
1795     var data = req.body;
1796
1797     return new Promise(function(resolve, reject) {
1798         var jsonData = {
1799             "account": Array.isArray(data) ? data : [data]
1800         };
1801
1802         console.log('Creating with', JSON.stringify(jsonData));
1803
1804         var requestHeaders = {};
1805         _.extend(requestHeaders,
1806             constants.HTTP_HEADERS.accept.data,
1807             constants.HTTP_HEADERS.content_type.data, {
1808                 'Authorization': req.session && req.session.authorization
1809             });
1810
1811         request({
1812             url: utils.projectContextUrl(req, utils.confdPort(api_server) + APIVersion + '/api/config/config-agent'),
1813             method: 'POST',
1814             headers: requestHeaders,
1815             forever: constants.FOREVER_ON,
1816             rejectUnauthorized: false,
1817             json: jsonData,
1818         }, function(error, response, body) {
1819             if (utils.validateResponse('ConfigAgentAccount.create', error, response, body, resolve, reject)) {
1820                 return resolve({
1821                     statusCode: response.statusCode,
1822                     data: JSON.stringify(response.body),
1823                     body:response.body.body
1824                 });
1825             };
1826         });
1827     });
1828 };
1829
1830 ConfigAgentAccount.update = function(req) {
1831
1832     var api_server = req.query["api_server"];
1833     var id = req.params.id;
1834     var data = req.body;
1835
1836     return new Promise(function(resolve, reject) {
1837         var jsonData = {
1838             "rw-config-agent:account": data
1839         };
1840
1841         console.log('Updating config-agent', id, ' with', JSON.stringify(jsonData));
1842
1843         var requestHeaders = {};
1844         _.extend(requestHeaders,
1845             constants.HTTP_HEADERS.accept.data,
1846             constants.HTTP_HEADERS.content_type.data, {
1847                 'Authorization': req.session && req.session.authorization
1848             });
1849
1850         request({
1851             url: utils.projectContextUrl(req, utils.confdPort(api_server) + APIVersion + '/api/config/config-agent/account/' + id),
1852             method: 'PUT',
1853             headers: requestHeaders,
1854             forever: constants.FOREVER_ON,
1855             rejectUnauthorized: false,
1856             json: jsonData,
1857         }, function(error, response, body) {
1858             if (utils.validateResponse('ConfigAgentAccount.update', error, response, body, resolve, reject)) {
1859                 return resolve({
1860                     statusCode: response.statusCode,
1861                     data: JSON.stringify(response.body)
1862                 });
1863             };
1864         });
1865     });
1866 };
1867
1868 ConfigAgentAccount.delete = function(req) {
1869
1870     var api_server = req.query["api_server"];
1871     var id = req.params.id;
1872
1873     if (!id || !api_server) {
1874         return new Promise(function(resolve, reject) {
1875             console.log('Must specifiy api_server and id to delete config-agent account');
1876             return reject({
1877                 statusCode: 500,
1878                 errorMessage: {
1879                     error: 'Must specifiy api_server and id to delete config agent account'
1880                 }
1881             });
1882         });
1883     };
1884
1885     return new Promise(function(resolve, reject) {
1886         var requestHeaders = {};
1887         _.extend(requestHeaders,
1888             constants.HTTP_HEADERS.accept.data, {
1889                 'Authorization': req.session && req.session.authorization
1890             });
1891         request({
1892             url: utils.projectContextUrl(req, utils.confdPort(api_server) + APIVersion + '/api/config/config-agent/account/' + id),
1893             method: 'DELETE',
1894             headers: requestHeaders,
1895             forever: constants.FOREVER_ON,
1896             rejectUnauthorized: false,
1897         }, function(error, response, body) {
1898             if (utils.validateResponse('ConfigAgentAccount.delete', error, response, body, resolve, reject)) {
1899                 return resolve({
1900                     statusCode: response.statusCode,
1901                     data: JSON.stringify(response.body)
1902                 });
1903             };
1904         });
1905     });
1906 };
1907
1908
1909 DataCenters.get = function(req) {
1910     var api_server = req.query["api_server"];
1911     return new Promise(function(resolve, reject) {
1912         var requestHeaders = {};
1913         _.extend(requestHeaders,
1914             constants.HTTP_HEADERS.accept.data, {
1915                 'Authorization': req.session && req.session.authorization
1916             });
1917         request({
1918             url: utils.projectContextUrl(req, utils.confdPort(api_server) + APIVersion + '/api/operational/datacenters?deep'),
1919             method: 'GET',
1920             headers: requestHeaders,
1921             forever: constants.FOREVER_ON,
1922             rejectUnauthorized: false,
1923         }, function(error, response, body) {
1924             if (utils.validateResponse('DataCenters.get', error, response, body, resolve, reject)) {
1925                 var returnData = {};
1926                 try {
1927                     data = JSON.parse(response.body)["rw-launchpad:datacenters"]["ro-accounts"];
1928                     data.map(function(c) {
1929                         returnData[c.name] = c.datacenters;
1930                     })
1931                     statusCode = response.statusCode;
1932                 } catch (e) {
1933                     console.log('Problem with "DataCenters.get"', e);
1934                     var err = {};
1935                     err.statusCode = 500;
1936                     err.errorMessage = {
1937                         error: 'Problem with "DataCenters.get": ' + e.toString()
1938                     }
1939                     return reject(err);
1940                 }
1941                 return resolve({
1942                     statusCode: response.statusCode,
1943                     data: returnData
1944                 });
1945             };
1946         });
1947     });
1948 }
1949
1950 SSHkey.get  = function(req) {
1951     var api_server = req.query["api_server"];
1952     return new Promise(function(resolve, reject) {
1953         var requestHeaders = {};
1954         _.extend(requestHeaders,
1955             constants.HTTP_HEADERS.accept.data, {
1956                 'Authorization': req.session && req.session.authorization
1957             });
1958         request({
1959             url: utils.projectContextUrl(req, utils.confdPort(api_server) + APIVersion + '/api/config/key-pair?deep'),
1960             method: 'GET',
1961             headers: requestHeaders,
1962             forever: constants.FOREVER_ON,
1963             rejectUnauthorized: false,
1964         }, function(error, response, body) {
1965             if (utils.validateResponse('SSHkey.get', error, response, body, resolve, reject)) {
1966                 var returnData = {};
1967                 try {
1968                     returnData = JSON.parse(response.body)['nsr:key-pair'];
1969                     statusCode = response.statusCode;
1970                 } catch (e) {
1971                     console.log('Problem with "SSHkey.get"', e);
1972                     var err = {};
1973                     err.statusCode = 500;
1974                     err.errorMessage = {
1975                         error: 'Problem with "SSHkey.get": ' + e.toString()
1976                     }
1977                     return reject(err);
1978                 }
1979                 return resolve({
1980                     statusCode: response.statusCode,
1981                     data: returnData
1982                 });
1983             };
1984         });
1985     });
1986 }
1987 SSHkey.delete = function(req) {
1988     var api_server = req.query['api_server'];
1989     var id = decodeURI(req.params.name);
1990     console.log('Deleting ssk-key', id);
1991     return new Promise(function(resolve, reject) {
1992         request({
1993             uri: utils.projectContextUrl(req, utils.confdPort(api_server) + APIVersion + '/api/config/key-pair/' + id),
1994             method: 'DELETE',
1995             headers: _.extend({}, constants.HTTP_HEADERS.accept.data, {
1996                 'Authorization': req.session && req.session.authorization
1997             }),
1998             forever: constants.FOREVER_ON,
1999             rejectUnauthorized: false,
2000         }, function(error, response, body) {
2001             if (utils.validateResponse('SSHkey.delete', error, response, body, resolve, reject)) {
2002                 resolve({
2003                     statusCode: response.statusCode
2004                 });
2005             }
2006         });
2007     });
2008 };
2009 SSHkey.post = function(req) {
2010     var api_server = req.query['api_server'];
2011     var data = req.body;
2012     return new Promise(function(resolve, reject) {
2013         request({
2014             uri: utils.projectContextUrl(req, utils.confdPort(api_server) + APIVersion + '/api/config/key-pair/'),
2015             method: 'POST',
2016             headers: _.extend({}, constants.HTTP_HEADERS.accept.data, {
2017                 'Authorization': req.session && req.session.authorization
2018             }),
2019             json: data,
2020             forever: constants.FOREVER_ON,
2021             rejectUnauthorized: false,
2022         }, function(error, response, body) {
2023             if (utils.validateResponse('SSHkey.post', error, response, body, resolve, reject)) {
2024                 resolve({
2025                     data: 'success',
2026                     statusCode: response.statusCode
2027                 });
2028             }
2029         });
2030     });
2031 };
2032 SSHkey.put = function(req) {
2033     var api_server = req.query['api_server'];
2034     var data = req.body;
2035     return new Promise(function(resolve, reject) {
2036         request({
2037             uri: utils.projectContextUrl(req, utils.confdPort(api_server) + APIVersion + '/api/config/key-pair/'),
2038             method: 'PUT',
2039             headers: _.extend({}, constants.HTTP_HEADERS.accept.data, {
2040                 'Authorization': req.session && req.session.authorization
2041             }),
2042             json: data,
2043             forever: constants.FOREVER_ON,
2044             rejectUnauthorized: false,
2045         }, function(error, response, body) {
2046             if (utils.validateResponse('SSHkey.put', error, response, body, resolve, reject)) {
2047                 resolve({
2048                     statusCode: response.statusCode
2049                 });
2050             }
2051         });
2052     });
2053 };
2054
2055 function sortByName(a, b) {
2056     return a.name > b.name;
2057 }
2058
2059 module.exports.catalog = Catalog;
2060 module.exports.nsr = NSR;
2061 module.exports.vnfr = VNFR;
2062 module.exports.vlr = VLR;
2063 module.exports.vdur = VDUR;
2064 module.exports.rift = RIFT;
2065 module.exports.computeTopology = ComputeTopology;
2066 module.exports.networkTopology = NetworkTopology;
2067 module.exports.config = Config;
2068 module.exports.cloud_account = CloudAccount;
2069 module.exports['config-agent-account'] = ConfigAgentAccount;
2070 module.exports.rpc = RPC;
2071 module.exports.data_centers = DataCenters;
2072 module.exports.SSHkey = SSHkey;