4 appDS2.controller("newChangeManagementModalController", ["$uibModalInstance", "$uibModal",'$q', "AaiService", "changeManagementService", "Upload",
5 "$log", "$scope", "_", "COMPONENT", "VIDCONFIGURATION", newChangeManagementModalController]);
7 function newChangeManagementModalController($uibModalInstance, $uibModal,$q, AaiService, changeManagementService, Upload, $log, $scope, _, COMPONENT, VIDCONFIGURATION) {
10 vm.hasScheduler = !!VIDCONFIGURATION.SCHEDULER_PORTAL_URL;
11 vm.configUpdatePatternError = "Invalid file type. Please select a file with a CSV extension.";
12 vm.configUpdateContentError = "Invalid file structure.";
13 vm.controllers = VIDCONFIGURATION.SCALE_OUT_CONTROLLERS;
15 vm.nextStep = function(){
17 $(".modal-dialog").animate({"width":"1200px"},400,'linear');
19 vm.prevStep = function(){
21 $(".modal-dialog").animate({"width":"600px"},400,'linear');
24 vm.softwareVersionRegex = "[-a-zA-Z0-9\.]+";
26 var init = function () {
27 vm.changeManagement = {};
29 loadServicesCatalog();
30 registerVNFNamesWatcher();
34 var loadServicesCatalog = function () {
35 changeManagementService.getAllSDCServices()
36 .then(function (response) {
37 vm.SDCServicesCatalog = response.data;
39 .catch(function (error) {
44 var registerVNFNamesWatcher = function () {
45 $scope.$watch('vm.changeManagement.vnfNames', function (newVal, oldVal) {
46 if (!oldVal || newVal && newVal.length > oldVal.length) { //JUST THE LAST ONE ADDED
47 var newVNFName = _.last(vm.changeManagement.vnfNames);
49 vm.changeManagement.vnfNames = oldVal;
50 vm.changeManagement.vnfNames.push(newVNFName);
52 if (newVNFName && newVNFName["service-instance-node"]) {
53 var availableVersions = [];
54 var services = _.filter(vm.SDCServicesCatalog.services,
55 {"invariantUUID": newVNFName["service-instance-node"][0].properties["model-invariant-id"]});
57 _.each(services, function (service) {
58 changeManagementService.getSDCService(service.uuid)
59 .then(function (response) {
60 _.each(response.data.vnfs, function (vnf) {
61 if (newVNFName["invariant-id"] === vnf.invariantUuid) {
62 availableVersions.push(extractVNFModel(vnf, response.data.service, newVNFName));
64 //for scale out screen
65 if(service.uuid === newVNFName["service-instance-node"][0].properties["model-version-id"]) {
66 newVNFName.vfModules = vnf.vfModules;
67 newVNFName.category = response.data.service.category;
68 newVNFName.groupModules = _.groupBy(newVNFName.vfModules, "customizationUuid");
70 //list vfmodules ids in AAI that belong to that vnf instance
71 var modulesAaiIds = _.filter(newVNFName.relatedTo, function(item){
72 return item["node-type"] === "vf-module";
73 }).map(function(item){
77 _.forEach(newVNFName.vfModules, function (mdl, key) {
78 mdl.scale = false; //defaults to not scale unless user changes it
79 if(mdl.properties && mdl.properties.max_vf_module_instances) {
81 //how many vf modules of the same customizationId belong to that vnf instance
82 mdl.currentCount = _.filter(vm.vfModules, function(item){
83 return modulesAaiIds.indexOf(item.id) > -1 && item.properties["model-customization-id"] === mdl.customizationUuid;
86 mdl.scalable = mdl.properties.max_vf_module_instances.value - mdl.currentCount > 0;
94 var versions = _.uniqBy(availableVersions, 'modelInfo.modelVersion');
95 newVNFName.availableVersions = _.sortBy(_.uniq(versions, response.data.service, true),"modelInfo.modelVersion");
96 }).catch(function (error) {
105 var extractVNFModel = function (csarVNF, sdcService, selectionVNF) {
106 var versionCsarData = {
108 vnfName: csarVNF.name,
111 modelInvariantId: csarVNF.invariantUuid,
112 modelVersionId: selectionVNF.modelVersionId,
113 modelName: csarVNF.name,
114 modelVersion: csarVNF.version,
115 modelCustomizationName: csarVNF.modelCustomizationName,
116 modelCustomizationId: csarVNF.customizationUuid
118 cloudConfiguration: {
119 lcpCloudRegionId: "mdt1",
120 tenantId: "88a6ca3ee0394ade9403f075db23167e"
124 suppressRollback: false,
125 requestorId: "az2016"
127 relatedInstanceList: [
130 instanceId: selectionVNF["service-instance-node"]["0"].properties['service-instance-id'],
132 modelType: "service",
133 modelInvariantId: selectionVNF["service-instance-node"]["0"].properties['model-invariant-id'],
134 modelVersionId: selectionVNF.modelVersionId,
135 modelName: sdcService.name,
136 modelVersion: sdcService.version,
137 modelCustomizationName: selectionVNF["service-instance-node"]["0"].properties['model-customization-name'], //TODO: Missing
138 modelCustomizationId: selectionVNF["service-instance-node"]["0"].properties['model-customization-id']
148 return versionCsarData;
151 vm.close = function () {
152 $uibModalInstance.close();
155 vm.uploadConfigFile = function (file) {
156 var defer = $q.defer();
158 url: "change-management/uploadConfigUpdateFile",
160 transformResponse: [function (data) {
164 .then(function (configUpdateResponse) {
165 vm.changeManagement.configUpdateFile = configUpdateResponse && JSON.parse(configUpdateResponse.data).payload;
168 .catch(function (error) {
169 defer.resolve(false);
171 return defer.promise;
175 /***converting objects to scheduler format (taken from IST) - was altered for Scale out support ***/
176 function extractChangeManagementCallbackDataStr(changeManagement) {
177 console.log(changeManagement);
179 result.requestType = changeManagement.workflow;
180 var workflowType = changeManagement.workflow;
181 result.requestDetails = [];
182 _.forEach(changeManagement.vnfNames, function (vnf) {
185 var requestInfoData ={};
186 var requestParametersData ={};
187 var moduleToScale = _.find(vnf.vfModules, function(key, item){
190 if (vnf.availableVersions && vnf.availableVersions.length!=0){
193 source: vnf.availableVersions[0].requestInfo.source,
194 suppressRollback: vnf.availableVersions[0].requestInfo.suppressRollback,
195 requestorId: vnf.availableVersions[0].requestInfo.requestorId
198 if(workflowType=='Update'){
199 requestParametersData = {
200 usePreload: vnf.availableVersions[0].requestParameters.usePreload
202 }else if(workflowType=="Replace"){
203 requestParametersData = {
204 rebuildVolumeGroups: vnf.availableVersions[0].requestParameters.usePreload
206 }else if(workflowType=="VNF In Place Software Update"){
208 'existing_software_version':changeManagement.existingSoftwareVersion,
209 'new_software_version':changeManagement.newSoftwareVersion,
210 'operations_timeout':changeManagement.operationTimeout
212 requestParametersData = {
213 controllerType: changeManagement.controllerType,
214 payload: JSON.stringify(payloadObj)
216 }else if(workflowType=="VNF Config Update"){
217 requestParametersData = {
218 payload: changeManagement.configUpdateFile
220 }else if(workflowType=="VNF Scale Out"){
221 if(!moduleToScale) return null;
223 if(moduleToScale.userParams) {
224 requestParametersData = {
225 controllerType: changeManagement.controllerType,
226 userParams: moduleToScale.userParams
230 requestParametersData = {
231 controllerType: changeManagement.controllerType,
237 $log.info('SchedulerWidgetCtrl:extractChangeManagementCallbackDataStr info:: workflowType '+ workflowType);
238 $log.info('SchedulerWidgetCtrl:extractChangeManagementCallbackDataStr info:: requestParametersData '+ requestParametersData);
240 }else if(workflowType=="VNF In Place Software Update"){
242 'existing_software_version':changeManagement.existingSoftwareVersion,
243 'new_software_version':changeManagement.newSoftwareVersion,
244 'operations_timeout':changeManagement.operationTimeout
246 requestParametersData = {
247 payload: JSON.stringify(payloadObj)
249 }else if(workflowType=="VNF Config Update"){
250 requestParametersData = {
251 payload: changeManagement.configUpdateFile
257 if(workflowType=="VNF Scale Out") {
260 modelType: 'vfModule',
261 modelInvariantId: moduleToScale.invariantUuid,
262 modelName: moduleToScale.modelCustomizationName,
263 modelVersion: moduleToScale.version,
264 modelVersionId: moduleToScale.uuid
266 cloudConfiguration: vnf.cloudConfiguration,
267 requestInfo: requestInfoData,
268 relatedInstanceList: [],
269 requestParameters:requestParametersData
271 requestInfoData.instanceName = vnf.name + "_" + (moduleToScale.currentCount + 1);
275 vnfInstanceId: vnf.id,
278 modelInvariantId: vnf.properties['model-invariant-id'],
279 modelVersionId: vnf.modelVersionId,
280 modelName: vnf.properties['vnf-name'],
281 modelVersion: vnf.version,
282 modelCustomizationName: vnf.properties['model-customization-name'],
283 modelCustomizationId: vnf.properties['model-customization-id']
285 cloudConfiguration: vnf.cloudConfiguration,
286 requestInfo: requestInfoData,
287 relatedInstanceList: [],
288 requestParameters:requestParametersData
292 var serviceInstanceId = '';
293 _.forEach(vnf['service-instance-node'], function (instanceNode) {
294 if(instanceNode['node-type'] === 'service-instance'){
295 serviceInstanceId = instanceNode.properties['service-instance-id'];
299 if (vnf.availableVersions && vnf.availableVersions.length!=0){
300 _.forEach(vnf.availableVersions[0].relatedInstanceList, function (related) {
301 var rel = related.relatedInstance;
302 var relatedInstance = {
303 instanceId: serviceInstanceId,
305 modelType: rel.modelInfo.modelType,
306 modelInvariantId: rel.modelInfo.modelInvariantId,
307 modelVersionId: rel.modelInfo.modelVersionId,
308 modelName: rel.modelInfo.modelName,
309 modelVersion: rel.modelInfo.modelVersion,
310 modelCustomizationName: rel.modelInfo.modelCustomizationName,
311 modelCustomizationId: rel.modelInfo.modelCustomizationId
314 if (rel.vnfInstanceId)
315 relatedInstance.instanceId = rel.vnfInstanceId;
317 data.relatedInstanceList.push({relatedInstance: relatedInstance});
319 if(workflowType=="VNF Scale Out") {
320 //push vnf to related as well as the service instance
321 var relatedInstance = {
324 modelCustomizationName: vnf.availableVersions[0].modelInfo.modelCustomizationName,
325 modelInvariantId: vnf.availableVersions[0].modelInfo.modelInvariantId,
326 modelName: vnf.availableVersions[0].modelInfo.modelName,
327 modelType: vnf.availableVersions[0].modelInfo.modelType,
328 modelVersion: vnf.availableVersions[0].modelInfo.modelVersion,
329 modelVersionId: vnf.availableVersions[0].modelInfo.modelVersionId
332 data.relatedInstanceList.push({relatedInstance: relatedInstance});
336 $log.error('SchedulerCtrl::extractChangeManagementCallbackDataStr error: ' + err);
339 result.requestDetails.push(data);
341 return JSON.stringify(result);
344 vm.openModal = function () {
345 if(vm.hasScheduler) { //scheduling supported
346 $scope.widgetParameter = ""; // needed by the scheduler?
348 // properties needed by the scheduler so it knows whether to show
349 // policy or sniro related features on the scheduler UI or not.
350 vm.changeManagement.policyYN = "Y";
351 vm.changeManagement.sniroYN = "Y";
354 widgetName: 'Portal-Common-Scheduler',
355 widgetData: vm.changeManagement,
356 widgetParameter: $scope.widgetParameter
359 window.parent.postMessage(data, VIDCONFIGURATION.SCHEDULER_PORTAL_URL);
361 //no scheduling support
362 var dataToSo = extractChangeManagementCallbackDataStr(vm.changeManagement);
365 if(vm.changeManagement.workflow==="VNF Scale Out") {
366 dataToSo = JSON.parse(dataToSo);
367 dataToSo = {requestDetails: dataToSo.requestDetails[0]};
368 changeManagementService.postChangeManagementScaleOutNow(dataToSo, vm.changeManagement.vnfNames[0]["service-instance-node"][0].properties["service-instance-id"], vm.changeManagement.vnfNames[0].id);
371 var vnfName = vm.changeManagement.vnfNames[0].name;
372 changeManagementService.postChangeManagementNow(dataToSo, vnfName);
378 vm.loadSubscribers = function () {
380 AaiService.getSubscribers(function (response) {
381 vm.subscribers = response;
385 vm.loadServiceTypes = function () {
386 vm.serviceTypes = [];
388 AaiService.getSubscriberServiceTypes(vm.changeManagement.subscriberId)
389 .then(function (response) {
390 vm.serviceTypes = response.data;
392 .catch(function (error) {
397 vm.loadVNFTypes = function () {
399 vm.vnfTypesTemp = [];
400 vm.serviceInstances = [];
402 var instances = vm.changeManagement.serviceType["service-instances"]["service-instance"];
403 // var promiseArrOfGetVnfs = preparePromiseArrOfGetVnfs(instances);
408 AaiService.getVnfsByCustomerIdAndServiceType(
409 vm.changeManagement.subscriberId,
410 vm.changeManagement.serviceType["service-type"]
411 ).then(function (response) {
412 var vnfsData = response.data.results;
414 for (var i = 0; i < vnfsData.length; i++) {
416 const nodeType = vnfsData[i]['node-type'];
417 if (nodeType === "generic-vnf") {
418 if (_.find(vnfsData[i]['related-to'], function (node) {
419 return node['node-type'] === 'vserver'
421 vm.vnfs.push(vnfsData[i]);
423 } else if (nodeType === "service-instance") {
424 vm.serviceInstances.push(vnfsData[i]);
425 } else if (nodeType === "vf-module") {
426 vm.vfModules.push(vnfsData[i]);
431 vm.vnfs = _.flattenDeep(
432 _.remove(vm.vnfs, function (vnf) {
433 var nfRole = vnf.properties['nf-role'];
434 if (nfRole !== undefined) {
435 return nfRole !== 'null' && nfRole !== '';
440 var filteredVnfs = _.uniqBy(vm.vnfs, function (vnf) {
441 return vnf.properties['nf-role'];
444 _.forEach(filteredVnfs, function (vnf) {
445 vm.vnfTypes.push(vnf.properties['nf-role'])
452 var fromVNFVersions = [];
454 vm.loadVNFVersions = function () {
455 fromVNFVersions = [];
456 vm.serviceInstancesToGetVersions = [];
458 _.forEach(vm.vnfs, function (vnf) {
459 if (vnf.properties['nf-role'] === vm.changeManagement['vnfType']) {
461 vm.serviceInstancesToGetVersions.push({
462 "model-invariant-id": vnf.properties["model-invariant-id"],
463 "model-version-id": vnf.properties["model-version-id"] }
466 versions.push(vnf.properties["model-invariant-id"]);
470 if (versions.length > 0) {
471 AaiService.getVnfVersionsByInvariantId(versions).then(function (response) {
474 $log.debug("getVnfVersionsByInvariantId: response", response);
476 fromVNFVersions = vm.serviceInstancesToGetVersions
477 .map(function (serviceInstanceToGetVersion) {
478 const model = _.find(response.data.model, {'model-invariant-id': serviceInstanceToGetVersion['model-invariant-id']});
479 $log.debug("getVnfVersionsByInvariantId: model for " + serviceInstanceToGetVersion['model-invariant-id'], model);
481 const modelVer = _.find(model["model-vers"]["model-ver"], {'model-version-id': serviceInstanceToGetVersion['model-version-id']});
482 $log.debug("getVnfVersionsByInvariantId: modelVer for " + serviceInstanceToGetVersion['model-version-id'], modelVer);
484 var modelVersionId = serviceInstanceToGetVersion["model-version-id"];
485 var modelVersion = modelVer["model-version"];
487 return {"key": modelVersionId, "value": modelVersion};
490 vm.fromVNFVersions = _.uniqBy(fromVNFVersions, 'value');
497 function getVnfs(modelInvariantId) {
498 return new Promise(function (resolve, reject) {
499 AaiService.getVnfVersionsByInvariantId(modelInvariantId)
500 .then(function (response) {
501 if (response.data.httpCode !== null &&
502 response.data.httpCode === 200) {
503 var vnfsData = response.data.t.results;
504 for (var i = 0; i < vnfsData.length; i++) {
506 if (vnfsData[i].nodeType === "generic-vnf") {
507 resolve(vnfsData[i]);
508 } else if (vnfsData[i].nodeType === "service-instance") {
509 vm.serviceInstances.push(vnfsData[i]);
517 .catch(function (error) {
523 var getVersionNameForId = function(versionId) {
524 var version = _.find(fromVNFVersions, {"key": versionId});
525 return version.value;
528 vm.loadVNFNames = function () {
530 const vnfs = vm.changeManagement.fromVNFVersion ? vm.vnfs : [];
531 _.forEach(vnfs, function (vnf) {
533 var selectedVersionNumber = getVersionNameForId(vm.changeManagement.fromVNFVersion);
535 if (vnf.properties['nf-role'] === vm.changeManagement.vnfType &&
536 selectedVersionNumber === getVersionNameForId(vnf.properties["model-version-id"])) {
539 _.forEach(vnf['related-to'], function (node) {
540 if (node['node-type'] === 'vserver') {
541 vServer = extractLcpRegionIdAndTenantId(node.url);
545 var serviceInstancesIds =
546 _.filter(vnf['related-to'], {'node-type': 'service-instance'})
547 .map(function (serviceInstance) { return serviceInstance.id });
549 var serviceInstances = _.filter(vm.serviceInstances, function(serviceInstance) {
550 return _.includes(serviceInstancesIds, serviceInstance.id);
554 if (serviceInstancesIds.length === 0) {
555 $log.error("loadVNFNames: no serviceInstancesIds for vnf", vnf);
557 $log.debug("loadVNFNames: serviceInstancesIds", serviceInstancesIds);
558 $log.debug("loadVNFNames: serviceInstances", serviceInstances);
562 "id": vnf.properties["vnf-id"],
563 "name": vnf.properties["vnf-name"],
564 "invariant-id": vnf.properties["model-invariant-id"],
565 "service-instance-node": serviceInstances,
566 "modelVersionId": vnf.properties["model-version-id"],
567 "properties": vnf.properties,
568 'cloudConfiguration': vServer,
569 "relatedTo": vnf['related-to']
575 function extractLcpRegionIdAndTenantId(url) {
577 var cloudConfiguration = {
578 lcpCloudRegionId: '',
583 e.g., in both URLs below -
584 - lcpCloudRegionId == 'rdm5b'
585 - tenantId == '0675e0709bd7444a9e13eba8b40edb3c'
587 "url": "https://aai-conexus-e2e.ecomp.cci.att.com:8443/aai/v10/cloud-infrastructure/cloud-regions/cloud-region/att-aic/rdm5b/tenants/tenant/0675e0709bd7444a9e13eba8b40edb3c/vservers/vserver/932b330d-733e-427d-a519-14eebd261f70"
588 "url": "/aai/v11/cloud-infrastructure/cloud-regions/cloud-region/att-aic/rdm5b/tenants/tenant/0675e0709bd7444a9e13eba8b40edb3c/vservers/vserver/932b330d-733e-427d-a519-14eebd261f70"
591 var cloudRegionMatch = url.match(/\/cloud-regions\/cloud-region\/[^\/]+\/([^\/]+)/);
592 var tenantMatch = url.match(/\/tenants\/tenant\/([^\/]+)/);
594 cloudConfiguration.lcpCloudRegionId = cloudRegionMatch[1];
595 cloudConfiguration.tenantId = tenantMatch[1];
597 return cloudConfiguration;
600 vm.loadWorkFlows = function () {
601 changeManagementService.getWorkflows(vm.changeManagement.vnfNames)
602 .then(function(response) {
603 vm.workflows = response.data.workflows;
605 .catch(function(error) {
610 //Must be $scope because we bind to the onchange of the html (cannot attached to vm variable).
611 $scope.selectFileForVNFName = function (fileInput) {
612 if (fileInput && fileInput.id) {
613 var vnfName = _.filter(vm.changeManagement.vnfNames, {"invariant-id": fileInput.id});
614 var file = fileInput.files[0];
615 var fileReader = new FileReader();
616 fileReader.onload = function (load) {
618 var lines = load.target.result;
619 vnfName[0].selectedFile = JSON.parse(lines);
624 fileReader.readAsText(file);
628 vm.selectVersionForVNFName = function (vnfName) {
629 console.log("Will add version for selected vnf name: " + vnfName.name);
632 vm.isConfigUpdate = function () {
633 return vm.changeManagement.workflow === COMPONENT.WORKFLOWS.vnfConfigUpdate;
636 vm.isScaleOut = function () {
637 return vm.changeManagement.workflow === COMPONENT.WORKFLOWS.vnfScaleOut;
640 vm.shouldShowVnfInPlaceFields = function () {
641 return vm.changeManagement.workflow === COMPONENT.WORKFLOWS.vnfInPlace;
644 vm.setPreload = function (fileEl) {
645 var files = fileEl.files;
647 var reader = new FileReader();
649 reader.onloadend = function(evt) {
650 if (evt.target.readyState === FileReader.DONE) {
651 $scope.$apply(function () {
652 $scope.moduleArr[0].userParams = JSON.parse(evt.target.result);
657 reader.readAsText(file);