4 appDS2.controller("newChangeManagementModalController", ["$uibModalInstance", "$uibModal",'$q', "AaiService", "changeManagementService", "Upload",
5 "$log", "$scope", "_", "COMPONENT", "VIDCONFIGURATION","DataService","featureFlags", newChangeManagementModalController]);
7 function newChangeManagementModalController($uibModalInstance, $uibModal,$q, AaiService, changeManagementService, Upload, $log, $scope, _, COMPONENT, VIDCONFIGURATION, DataService, featureFlags) {
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.";
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\.]+";
28 function fetchAttUid() {
29 var defer = $q.defer();
31 defer.resolve(attuid);
33 AaiService.getLoggedInUserID(function (response) {
34 attuid = response.data;
35 defer.resolve(attuid);
44 var init = function () {
45 vm.changeManagement = {};
47 loadServicesCatalog();
48 fetchAttUid().then(registerVNFNamesWatcher);
52 var loadServicesCatalog = function () {
53 changeManagementService.getAllSDCServices()
54 .then(function (response) {
55 vm.SDCServicesCatalog = response.data;
57 .catch(function (error) {
62 var registerVNFNamesWatcher = function () {
63 $scope.$watch('vm.changeManagement.vnfNames', function (newVal, oldVal) {
64 if (!oldVal || newVal && newVal.length > oldVal.length) { //JUST THE LAST ONE ADDED
65 var newVNFName = _.last(vm.changeManagement.vnfNames);
67 vm.changeManagement.vnfNames = oldVal;
68 vm.changeManagement.vnfNames.push(newVNFName);
70 if (newVNFName && newVNFName["service-instance-node"]) {
71 var availableVersions = [];
72 var services = _.filter(vm.SDCServicesCatalog.services,
73 {"invariantUUID": newVNFName["service-instance-node"][0].properties["model-invariant-id"]});
75 _.each(services, function (service) {
76 changeManagementService.getSDCService(service.uuid)
77 .then(function (response) {
78 _.each(response.data.vnfs, function (vnf) {
79 if (newVNFName["invariant-id"] === vnf.invariantUuid) {
80 availableVersions.push(extractVNFModel(vnf, response.data.service, newVNFName));
82 //for scale out screen
83 if(service.uuid === newVNFName["service-instance-node"][0].properties["model-version-id"]) {
84 newVNFName.vfModules = vnf.vfModules;
85 newVNFName.category = response.data.service.category;
86 newVNFName.groupModules = _.groupBy(newVNFName.vfModules, "customizationUuid");
88 //list vfmodules ids in AAI that belong to that vnf instance
89 var modulesAaiIds = _.filter(newVNFName.relatedTo, function(item){
90 return item["node-type"] === "vf-module";
91 }).map(function(item){
95 _.forEach(newVNFName.vfModules, function (mdl, key) {
96 mdl.scale = false; //defaults to not scale unless user changes it
97 if(mdl.properties && mdl.properties.maxCountInstances) {
99 //how many vf modules of the same customizationId belong to that vnf instance
100 mdl.currentCount = _.filter(vm.vfModules, function(item){
101 return modulesAaiIds.indexOf(item.id) > -1 && item.properties["model-customization-id"] === mdl.customizationUuid;
104 mdl.scalable = mdl.properties.maxCountInstances - mdl.currentCount > 0;
106 mdl.scalable = false;
112 var versions = _.uniqBy(availableVersions, 'modelInfo.modelVersion');
113 newVNFName.availableVersions = _.sortBy(_.uniq(versions, response.data.service, true),"modelInfo.modelVersion");
114 }).catch(function (error) {
123 var extractVNFModel = function (csarVNF, sdcService, selectionVNF) {
125 @param selectionVNF A vnf *instance* selected in "available VNF" drop-down box
126 @param csarVNF A VNF *MODEL* that has an invariantUuid same as selectionVNF (might be
127 a different version; i.e. selectionVNF.modelVersionId <> csarVNF.uuid)
128 @param sdcService The Service *MODEL* which has the related VNF `csarVNF`.
130 var versionCsarData = {
132 vnfName: csarVNF.name,
135 modelInvariantId: csarVNF.invariantUuid,
136 modelVersionId: csarVNF.uuid,
137 modelName: csarVNF.name,
138 modelVersion: csarVNF.version,
139 modelCustomizationName: csarVNF.modelCustomizationName,
140 modelCustomizationId: csarVNF.customizationUuid
142 cloudConfiguration: selectionVNF.cloudConfiguration || {},
145 suppressRollback: false,
148 relatedInstanceList: [
151 instanceId: selectionVNF["service-instance-node"]["0"].properties['service-instance-id'],
153 modelType: "service",
154 modelInvariantId: sdcService.invariantUuid,
155 modelVersionId: sdcService.uuid,
156 modelName: sdcService.name,
157 modelVersion: sdcService.version
167 return versionCsarData;
170 vm.close = function () {
171 $uibModalInstance.close();
174 vm.uploadConfigFile = function (file) {
175 var defer = $q.defer();
177 url: "change-management/uploadConfigUpdateFile",
179 transformResponse: [function (data) {
183 .then(function (configUpdateResponse) {
184 vm.changeManagement.configUpdateFile = configUpdateResponse && JSON.parse(configUpdateResponse.data).payload;
187 .catch(function (error) {
188 defer.resolve(false);
190 return defer.promise;
194 /***converting objects to scheduler format (taken from IST) - was altered for Scale out support ***/
195 function extractChangeManagementCallbackDataStr(changeManagement) {
196 console.log(changeManagement);
198 result.requestType = changeManagement.workflow;
199 var workflowType = changeManagement.workflow;
200 var configurationParameters = changeManagement.configurationParameters;
201 result.requestDetails = [];
202 _.forEach(changeManagement.vnfNames, function (vnf) {
205 var requestInfoData ={};
206 var requestParametersData ={};
207 var moduleToScale = _.find(vnf.vfModules, function(key, item){
210 if (vnf.availableVersions && vnf.availableVersions.length!=0){
213 source: vnf.availableVersions[0].requestInfo.source,
214 suppressRollback: vnf.availableVersions[0].requestInfo.suppressRollback,
215 requestorId: vnf.availableVersions[0].requestInfo.requestorId
218 if(workflowType=='Update'){
219 requestParametersData = {
220 usePreload: vnf.availableVersions[0].requestParameters.usePreload
222 }else if(workflowType=="Replace"){
223 requestParametersData = {
224 rebuildVolumeGroups: vnf.availableVersions[0].requestParameters.usePreload
226 }else if(workflowType=="VNF In Place Software Update"){
228 'existing_software_version':changeManagement.existingSoftwareVersion,
229 'new_software_version':changeManagement.newSoftwareVersion,
230 'operations_timeout':changeManagement.operationTimeout
232 requestParametersData = {
233 payload: JSON.stringify(payloadObj)
235 }else if(workflowType=="VNF Config Update"){
236 requestParametersData = {
237 payload: changeManagement.configUpdateFile
239 }else if(workflowType=="VNF Scale Out"){
240 if(!moduleToScale) return null;
242 if(moduleToScale.userParams) {
243 requestParametersData = {
244 userParams: moduleToScale.userParams
248 requestParametersData = {
254 $log.info('SchedulerWidgetCtrl:extractChangeManagementCallbackDataStr info:: workflowType '+ workflowType);
255 $log.info('SchedulerWidgetCtrl:extractChangeManagementCallbackDataStr info:: requestParametersData '+ requestParametersData);
257 }else if(workflowType=="VNF In Place Software Update"){
259 'existing_software_version':changeManagement.existingSoftwareVersion,
260 'new_software_version':changeManagement.newSoftwareVersion,
261 'operations_timeout':changeManagement.operationTimeout
263 requestParametersData = {
264 payload: JSON.stringify(payloadObj)
266 }else if(workflowType=="VNF Config Update"){
267 requestParametersData = {
268 payload: changeManagement.configUpdateFile
274 if(workflowType=="VNF Scale Out") {
277 vnfInstanceId: vnf.id,
279 modelType: 'vfModule',
280 modelInvariantId: moduleToScale.invariantUuid,
281 modelName: moduleToScale.modelCustomizationName,
282 modelVersion: moduleToScale.version,
283 modelCustomizationName: moduleToScale.modelCustomizationName,
284 modelCustomizationId: moduleToScale.customizationUuid,
285 modelVersionId: moduleToScale.uuid
287 cloudConfiguration: vnf.cloudConfiguration,
288 requestInfo: requestInfoData,
289 relatedInstanceList: [],
290 requestParameters:requestParametersData,
291 configurationParameters: JSON.parse(configurationParameters)
293 requestInfoData.instanceName = vnf.name + "_" + (moduleToScale.currentCount + 1);
297 vnfInstanceId: vnf.id,
300 modelInvariantId: vnf.properties['model-invariant-id'],
301 modelVersionId: vnf.modelVersionId,
302 modelName: vnf.properties['vnf-name'],
303 modelVersion: vnf.version,
304 modelCustomizationName: vnf.properties['model-customization-name'],
305 modelCustomizationId: vnf.properties['model-customization-id']
307 cloudConfiguration: vnf.cloudConfiguration,
308 requestInfo: requestInfoData,
309 relatedInstanceList: [],
310 requestParameters:requestParametersData
314 var serviceInstanceId = '';
315 _.forEach(vnf['service-instance-node'], function (instanceNode) {
316 if(instanceNode['node-type'] === 'service-instance'){
317 serviceInstanceId = instanceNode.properties['service-instance-id'];
321 if (vnf.availableVersions && vnf.availableVersions.length!=0){
322 _.forEach(vnf.availableVersions[0].relatedInstanceList, function (related) {
323 var rel = related.relatedInstance;
324 var relatedInstance = {
325 instanceId: serviceInstanceId,
327 modelType: rel.modelInfo.modelType,
328 modelInvariantId: rel.modelInfo.modelInvariantId,
329 modelVersionId: rel.modelInfo.modelVersionId,
330 modelName: rel.modelInfo.modelName,
331 modelVersion: rel.modelInfo.modelVersion,
332 modelCustomizationName: rel.modelInfo.modelCustomizationName,
333 modelCustomizationId: rel.modelInfo.modelCustomizationId
336 if (rel.vnfInstanceId)
337 relatedInstance.instanceId = rel.vnfInstanceId;
339 data.relatedInstanceList.push({relatedInstance: relatedInstance});
341 if(workflowType=="VNF Scale Out") {
342 //push vnf to related as well as the service instance
343 var relatedInstance = {
346 modelCustomizationId: vnf.availableVersions[0].modelInfo.modelCustomizationId,
347 modelCustomizationName: vnf.availableVersions[0].modelInfo.modelCustomizationName,
348 modelInvariantId: vnf.availableVersions[0].modelInfo.modelInvariantId,
349 modelName: vnf.availableVersions[0].modelInfo.modelName,
350 modelType: vnf.availableVersions[0].modelInfo.modelType,
351 modelVersion: vnf.availableVersions[0].modelInfo.modelVersion,
352 modelVersionId: vnf.availableVersions[0].modelInfo.modelVersionId
355 data.relatedInstanceList.push({relatedInstance: relatedInstance});
359 $log.error('SchedulerCtrl::extractChangeManagementCallbackDataStr error: ' + err);
362 result.requestDetails.push(data);
364 return JSON.stringify(result);
366 vm.openModal = function () {
367 if(vm.hasScheduler) { //scheduling supported
368 $scope.widgetParameter = ""; // needed by the scheduler?
370 // properties needed by the scheduler so it knows whether to show
371 // policy or sniro related features on the scheduler UI or not.
372 vm.changeManagement.policyYN = "Y";
373 vm.changeManagement.sniroYN = "Y";
375 if (featureFlags.isOn(COMPONENT.FEATURE_FLAGS.FLAG_ADD_MSO_TESTAPI_FIELD)) {
376 vm.changeManagement.testApi = DataService.getMsoRequestParametersTestApi();
379 widgetName: 'Portal-Common-Scheduler',
380 widgetData: vm.changeManagement,
381 widgetParameter: $scope.widgetParameter
384 window.parent.postMessage(data, VIDCONFIGURATION.SCHEDULER_PORTAL_URL);
386 //no scheduling support
387 var dataToSo = extractChangeManagementCallbackDataStr(vm.changeManagement);
389 var vnfName = vm.changeManagement.vnfNames[0].name;
390 changeManagementService.postChangeManagementNow(dataToSo, vnfName);
395 vm.loadSubscribers = function () {
397 AaiService.getSubscribers(function (response) {
398 vm.subscribers = response;
402 vm.loadServiceTypes = function () {
403 vm.serviceTypes = [];
405 AaiService.getSubscriberServiceTypes(vm.changeManagement.subscriberId)
406 .then(function (response) {
407 vm.serviceTypes = response.data;
409 .catch(function (error) {
414 vm.loadVNFTypes = function () {
416 vm.vnfTypesTemp = [];
417 vm.serviceInstances = [];
419 var instances = vm.changeManagement.serviceType["service-instances"]["service-instance"];
420 // var promiseArrOfGetVnfs = preparePromiseArrOfGetVnfs(instances);
425 AaiService.getVnfsByCustomerIdAndServiceType(
426 vm.changeManagement.subscriberId,
427 vm.changeManagement.serviceType["service-type"]
428 ).then(function (response) {
429 var vnfsData = response.data.results;
431 for (var i = 0; i < vnfsData.length; i++) {
433 const nodeType = vnfsData[i]['node-type'];
434 if (nodeType === "generic-vnf") {
435 if (_.find(vnfsData[i]['related-to'], function (node) {
436 return node['node-type'] === 'vserver'
438 vm.vnfs.push(vnfsData[i]);
440 } else if (nodeType === "service-instance") {
441 vm.serviceInstances.push(vnfsData[i]);
442 } else if (nodeType === "vf-module") {
443 vm.vfModules.push(vnfsData[i]);
448 vm.vnfs = _.flattenDeep(
449 _.remove(vm.vnfs, function (vnf) {
450 var nfRole = vnf.properties['nf-role'];
451 if (nfRole !== undefined) {
452 return nfRole !== 'null' && nfRole !== '';
457 var filteredVnfs = _.uniqBy(vm.vnfs, function (vnf) {
458 return vnf.properties['nf-role'];
461 _.forEach(filteredVnfs, function (vnf) {
462 vm.vnfTypes.push(vnf.properties['nf-role'])
469 var fromVNFVersions = [];
471 vm.loadVNFVersions = function () {
472 fromVNFVersions = [];
473 vm.serviceInstancesToGetVersions = [];
475 _.forEach(vm.vnfs, function (vnf) {
476 if (vnf.properties['nf-role'] === vm.changeManagement['vnfType']
477 && vnf.properties["model-invariant-id"]
478 && vnf.properties["model-version-id"]) {
479 vm.serviceInstancesToGetVersions.push({
480 "model-invariant-id": vnf.properties["model-invariant-id"],
481 "model-version-id": vnf.properties["model-version-id"]
485 versions.push(vnf.properties["model-invariant-id"]);
489 if (versions.length > 0) {
490 AaiService.getVnfVersionsByInvariantId(versions).then(function (response) {
493 $log.debug("getVnfVersionsByInvariantId: response", response);
495 fromVNFVersions = vm.serviceInstancesToGetVersions
496 .map(function (serviceInstanceToGetVersion) {
497 const model = _.find(response.data.model, {'model-invariant-id': serviceInstanceToGetVersion['model-invariant-id']});
498 $log.debug("getVnfVersionsByInvariantId: model for " + serviceInstanceToGetVersion['model-invariant-id'], model);
500 const modelVer = _.find(model["model-vers"]["model-ver"], {'model-version-id': serviceInstanceToGetVersion['model-version-id']});
501 $log.debug("getVnfVersionsByInvariantId: modelVer for " + serviceInstanceToGetVersion['model-version-id'], modelVer);
503 var modelVersionId = serviceInstanceToGetVersion["model-version-id"];
504 var modelVersion = modelVer["model-version"];
506 return {"key": modelVersionId, "value": modelVersion};
509 vm.fromVNFVersions = _.uniqBy(fromVNFVersions, 'value');
516 function getVnfs(modelInvariantId) {
517 return new Promise(function (resolve, reject) {
518 AaiService.getVnfVersionsByInvariantId(modelInvariantId)
519 .then(function (response) {
520 if (response.data.httpCode !== null &&
521 response.data.httpCode === 200) {
522 var vnfsData = response.data.t.results;
523 for (var i = 0; i < vnfsData.length; i++) {
525 if (vnfsData[i].nodeType === "generic-vnf") {
526 resolve(vnfsData[i]);
527 } else if (vnfsData[i].nodeType === "service-instance") {
528 vm.serviceInstances.push(vnfsData[i]);
536 .catch(function (error) {
542 var getVersionNameForId = function(versionId) {
543 var version = _.find(fromVNFVersions, {"key": versionId});
544 return version.value;
547 vm.loadVNFNames = function () {
549 const vnfs = vm.changeManagement.fromVNFVersion ? vm.vnfs : [];
550 _.forEach(vnfs, function (vnf) {
552 var selectedVersionNumber = getVersionNameForId(vm.changeManagement.fromVNFVersion);
554 if (vnf.properties['nf-role'] === vm.changeManagement.vnfType &&
555 selectedVersionNumber === getVersionNameForId(vnf.properties["model-version-id"])) {
558 _.forEach(vnf['related-to'], function (node) {
559 if (node['node-type'] === 'vserver') {
560 vServer = extractLcpRegionIdAndTenantId(node.url);
564 var serviceInstancesIds =
565 _.filter(vnf['related-to'], {'node-type': 'service-instance'})
566 .map(function (serviceInstance) { return serviceInstance.id });
568 var serviceInstances = _.filter(vm.serviceInstances, function(serviceInstance) {
569 return _.includes(serviceInstancesIds, serviceInstance.id);
573 if (serviceInstancesIds.length === 0) {
574 $log.error("loadVNFNames: no serviceInstancesIds for vnf", vnf);
576 $log.debug("loadVNFNames: serviceInstancesIds", serviceInstancesIds);
577 $log.debug("loadVNFNames: serviceInstances", serviceInstances);
581 "id": vnf.properties["vnf-id"],
582 "name": vnf.properties["vnf-name"],
583 "invariant-id": vnf.properties["model-invariant-id"],
584 "service-instance-node": serviceInstances,
585 "modelVersionId": vnf.properties["model-version-id"],
586 "properties": vnf.properties,
587 'cloudConfiguration': vServer,
588 "relatedTo": vnf['related-to']
594 function extractLcpRegionIdAndTenantId(url) {
596 var cloudConfiguration = {
597 lcpCloudRegionId: '',
602 e.g., in both URLs below -
603 - lcpCloudRegionId == 'rdm5b'
604 - tenantId == '0675e0709bd7444a9e13eba8b40edb3c'
606 "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"
607 "url": "/aai/v11/cloud-infrastructure/cloud-regions/cloud-region/att-aic/rdm5b/tenants/tenant/0675e0709bd7444a9e13eba8b40edb3c/vservers/vserver/932b330d-733e-427d-a519-14eebd261f70"
610 var cloudRegionMatch = url.match(/\/cloud-regions\/cloud-region\/[^\/]+\/([^\/]+)/);
611 var tenantMatch = url.match(/\/tenants\/tenant\/([^\/]+)/);
613 cloudConfiguration.lcpCloudRegionId = cloudRegionMatch[1];
614 cloudConfiguration.tenantId = tenantMatch[1];
616 return cloudConfiguration;
619 vm.loadWorkFlows = function () {
620 // Should be corrected when VID-397 will be closed. At the moment there is a need
621 // to merge local and remote workflows not to broke current functionality.
622 return vm.loadLocalWorkFlows()
623 .then(vm.loadRemoteWorkFlows)
625 vm.workflows = vm.localWorkflows.concat(vm.remoteWorkflows.map(item => item.name));
629 vm.loadLocalWorkFlows = function () {
630 return changeManagementService.getWorkflows(vm.changeManagement.vnfNames)
631 .then(function (response) {
632 vm.localWorkflows = response.data.workflows || [];
633 }).catch(function (error) {
638 vm.loadRemoteWorkFlows = function () {
639 let vnfNames = vm.changeManagement.vnfNames.map(vnfName => vnfName.name);
640 return changeManagementService.getSOWorkflows(vnfNames)
641 .then(function (response) {
642 vm.remoteWorkflows = response.data || [];
643 }).catch(function (error) {
648 //Must be $scope because we bind to the onchange of the html (cannot attached to vm variable).
649 $scope.selectFileForVNFName = function (fileInput) {
650 if (fileInput && fileInput.id) {
651 var vnfName = _.filter(vm.changeManagement.vnfNames, {"invariant-id": fileInput.id});
652 var file = fileInput.files[0];
653 var fileReader = new FileReader();
654 fileReader.onload = function (load) {
656 var lines = load.target.result;
657 vnfName[0].selectedFile = JSON.parse(lines);
662 fileReader.readAsText(file);
666 vm.selectVersionForVNFName = function (vnfName) {
667 console.log("Will add version for selected vnf name: " + vnfName.name);
670 vm.isConfigUpdate = function () {
671 return vm.changeManagement.workflow === COMPONENT.WORKFLOWS.vnfConfigUpdate;
674 vm.isScaleOut = function () {
675 return vm.changeManagement.workflow === COMPONENT.WORKFLOWS.vnfScaleOut;
678 vm.shouldShowVnfInPlaceFields = function () {
679 return vm.changeManagement.workflow === COMPONENT.WORKFLOWS.vnfInPlace;
682 vm.setPreload = function (fileEl) {
683 var files = fileEl.files;
685 var reader = new FileReader();
687 reader.onloadend = function(evt) {
688 if (evt.target.readyState === FileReader.DONE) {
689 $scope.$apply(function () {
690 $scope.moduleArr[0].userParams = JSON.parse(evt.target.result);
695 reader.readAsText(file);