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":"1000px"},400,'linear');
19 vm.prevStep = function(){
21 $(".modal-dialog").animate({"width":"6000px"},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));
63 newVNFName.vfModules = vnf.vfModules;
65 //for scale out screen
66 newVNFName.category = response.data.service.category;
67 newVNFName.groupModules = _.groupBy(newVNFName.vfModules, "customizationUuid");
70 var versions = _.uniqBy(availableVersions, 'modelInfo.modelVersion');
71 newVNFName.availableVersions = _.sortBy(_.uniq(versions, response.data.service, true),"modelInfo.modelVersion");
72 }).catch(function (error) {
81 var extractVNFModel = function (csarVNF, sdcService, selectionVNF) {
82 var versionCsarData = {
84 vnfName: csarVNF.name,
87 modelInvariantId: csarVNF.invariantUuid,
88 modelVersionId: selectionVNF.modelVersionId,
89 modelName: csarVNF.name,
90 modelVersion: csarVNF.version,
91 modelCustomizationName: csarVNF.modelCustomizationName,
92 modelCustomizationId: csarVNF.customizationUuid
95 lcpCloudRegionId: "mdt1",
96 tenantId: "88a6ca3ee0394ade9403f075db23167e"
100 suppressRollback: false,
101 requestorId: "az2016"
103 relatedInstanceList: [
106 instanceId: selectionVNF["service-instance-node"]["0"].properties['service-instance-id'],
108 modelType: "service",
109 modelInvariantId: selectionVNF["service-instance-node"]["0"].properties['model-invariant-id'],
110 modelVersionId: selectionVNF.modelVersionId,
111 modelName: sdcService.name,
112 modelVersion: sdcService.version,
113 modelCustomizationName: selectionVNF["service-instance-node"]["0"].properties['model-customization-name'], //TODO: Missing
114 modelCustomizationId: selectionVNF["service-instance-node"]["0"].properties['model-customization-id']
124 return versionCsarData;
127 vm.close = function () {
128 $uibModalInstance.close();
131 vm.uploadConfigFile = function (file) {
132 var defer = $q.defer();
134 url: "change-management/uploadConfigUpdateFile",
136 transformResponse: [function (data) {
140 .then(function (configUpdateResponse) {
141 vm.changeManagement.configUpdateFile = configUpdateResponse && JSON.parse(configUpdateResponse.data).payload;
144 .catch(function (error) {
145 defer.resolve(false);
147 return defer.promise;
151 /***converting objects to scheduler format (taken from IST) - was altered for Scale out support ***/
152 function extractChangeManagementCallbackDataStr(changeManagement) {
153 console.log(changeManagement);
155 result.requestType = changeManagement.workflow;
156 var workflowType = changeManagement.workflow;
157 result.requestDetails = [];
158 _.forEach(changeManagement.vnfNames, function (vnf) {
161 var requestInfoData ={};
162 var requestParametersData ={};
163 var moduleToScale = _.find(vnf.vfModules, function(key, item){
166 if (vnf.availableVersions && vnf.availableVersions.length!=0){
169 source: vnf.availableVersions[0].requestInfo.source,
170 suppressRollback: vnf.availableVersions[0].requestInfo.suppressRollback,
171 requestorId: vnf.availableVersions[0].requestInfo.requestorId
174 if(workflowType=='Update'){
175 requestParametersData = {
176 usePreload: vnf.availableVersions[0].requestParameters.usePreload
178 }else if(workflowType=="Replace"){
179 requestParametersData = {
180 rebuildVolumeGroups: vnf.availableVersions[0].requestParameters.usePreload
182 }else if(workflowType=="VNF In Place Software Update"){
184 'existing_software_version':changeManagement.existingSoftwareVersion,
185 'new_software_version':changeManagement.newSoftwareVersion,
186 'operations_timeout':changeManagement.operationTimeout
188 requestParametersData = {
189 controllerType: changeManagement.controllerType,
190 payload: JSON.stringify(payloadObj)
192 }else if(workflowType=="VNF Config Update"){
193 requestParametersData = {
194 payload: changeManagement.configUpdateFile
196 }else if(workflowType=="VNF Scale Out"){
198 if(moduleToScale.userParams) {
199 requestParametersData = {
200 controllerType: changeManagement.controllerType,
201 userParams: moduleToScale.userParams,
205 requestParametersData = {
206 controllerType: changeManagement.controllerType,
212 $log.info('SchedulerWidgetCtrl:extractChangeManagementCallbackDataStr info:: workflowType '+ workflowType);
213 $log.info('SchedulerWidgetCtrl:extractChangeManagementCallbackDataStr info:: requestParametersData '+ requestParametersData);
215 }else if(workflowType=="VNF In Place Software Update"){
217 'existing_software_version':changeManagement.existingSoftwareVersion,
218 'new_software_version':changeManagement.newSoftwareVersion,
219 'operations_timeout':changeManagement.operationTimeout
221 requestParametersData = {
222 payload: JSON.stringify(payloadObj)
224 }else if(workflowType=="VNF Config Update"){
225 requestParametersData = {
226 payload: changeManagement.configUpdateFile
232 if(workflowType=="VNF Scale Out") {
233 var name = moduleToScale.modelCustomizationName.split('-')[0]; //example: vSAMP12..base..module-0
234 name = name + "-" + vnf.groupModules[moduleToScale.customizationUuid].length;
238 modelType: 'vfModule',
239 modelInvariantId: moduleToScale.invariantUuid,
241 modelVersion: moduleToScale.version,
242 modelCustomizationId: moduleToScale.customizationUuid
244 cloudConfiguration: vnf.cloudConfiguration,
245 requestInfo: requestInfoData,
246 relatedInstanceList: [],
247 requestParameters:requestParametersData
252 vnfInstanceId: vnf.id,
255 modelInvariantId: vnf.properties['model-invariant-id'],
256 modelVersionId: vnf.modelVersionId,
257 modelName: vnf.properties['vnf-name'],
258 modelVersion: vnf.version,
259 modelCustomizationName: vnf.properties['model-customization-name'],
260 modelCustomizationId: vnf.properties['model-customization-id']
262 cloudConfiguration: vnf.cloudConfiguration,
263 requestInfo: requestInfoData,
264 relatedInstanceList: [],
265 requestParameters:requestParametersData
269 var serviceInstanceId = '';
270 _.forEach(vnf['service-instance-node'], function (instanceNode) {
271 if(instanceNode['node-type'] === 'service-instance'){
272 serviceInstanceId = instanceNode.properties['service-instance-id'];
276 if (vnf.availableVersions && vnf.availableVersions.length!=0){
277 _.forEach(vnf.availableVersions[0].relatedInstanceList, function (related) {
278 var rel = related.relatedInstance;
279 var relatedInstance = {
280 instanceId: serviceInstanceId,
282 modelType: rel.modelInfo.modelType,
283 modelInvariantId: rel.modelInfo.modelInvariantId,
284 modelVersionId: rel.modelInfo.modelVersionId,
285 modelName: rel.modelInfo.modelName,
286 modelVersion: rel.modelInfo.modelVersion,
287 modelCustomizationName: rel.modelInfo.modelCustomizationName,
288 modelCustomizationId: rel.modelInfo.modelCustomizationId
291 if (rel.vnfInstanceId)
292 relatedInstance.instanceId = rel.vnfInstanceId;
294 data.relatedInstanceList.push({relatedInstance: relatedInstance});
298 $log.error('SchedulerCtrl::extractChangeManagementCallbackDataStr error: ' + err);
301 result.requestDetails.push(data);
303 return JSON.stringify(result);
306 vm.openModal = function () {
307 if(vm.hasScheduler) { //scheduling supported
308 $scope.widgetParameter = ""; // needed by the scheduler?
310 // properties needed by the scheduler so it knows whether to show
311 // policy or sniro related features on the scheduler UI or not.
312 vm.changeManagement.policyYN = "Y";
313 vm.changeManagement.sniroYN = "Y";
316 widgetName: 'Portal-Common-Scheduler',
317 widgetData: vm.changeManagement,
318 widgetParameter: $scope.widgetParameter
321 window.parent.postMessage(data, VIDCONFIGURATION.SCHEDULER_PORTAL_URL);
323 //no scheduling support
324 var dataToSo = extractChangeManagementCallbackDataStr(vm.changeManagement);
326 var vnfName = vm.changeManagement.vnfNames[0].name;
327 changeManagementService.postChangeManagementNow(dataToSo, vnfName);
331 vm.loadSubscribers = function () {
333 AaiService.getSubscribers(function (response) {
334 vm.subscribers = response;
338 vm.loadServiceTypes = function () {
339 vm.serviceTypes = [];
341 AaiService.getSubscriberServiceTypes(vm.changeManagement.subscriberId)
342 .then(function (response) {
343 vm.serviceTypes = response.data;
345 .catch(function (error) {
350 vm.loadVNFTypes = function () {
352 vm.vnfTypesTemp = [];
353 vm.serviceInstances = [];
355 var instances = vm.changeManagement.serviceType["service-instances"]["service-instance"];
356 // var promiseArrOfGetVnfs = preparePromiseArrOfGetVnfs(instances);
360 AaiService.getVnfsByCustomerIdAndServiceType(
361 vm.changeManagement.subscriberId,
362 vm.changeManagement.serviceType["service-type"]
363 ).then(function (response) {
364 var vnfsData = response.data.results;
366 for (var i = 0; i < vnfsData.length; i++) {
368 const nodeType = vnfsData[i]['node-type'];
369 if (nodeType === "generic-vnf") {
370 if (_.find(vnfsData[i]['related-to'], function (node) {
371 return node['node-type'] === 'vserver'
373 vm.vnfs.push(vnfsData[i]);
375 } else if (nodeType === "service-instance") {
376 vm.serviceInstances.push(vnfsData[i]);
381 vm.vnfs = _.flattenDeep(
382 _.remove(vm.vnfs, function (vnf) {
383 var nfRole = vnf.properties['nf-role'];
384 if (nfRole !== undefined) {
385 return nfRole !== 'null' && nfRole !== '';
390 var filteredVnfs = _.uniqBy(vm.vnfs, function (vnf) {
391 return vnf.properties['nf-role'];
394 _.forEach(filteredVnfs, function (vnf) {
395 vm.vnfTypes.push(vnf.properties['nf-role'])
402 var fromVNFVersions = [];
404 vm.loadVNFVersions = function () {
405 fromVNFVersions = [];
406 vm.serviceInstancesToGetVersions = [];
408 _.forEach(vm.vnfs, function (vnf) {
409 if (vnf.properties['nf-role'] === vm.changeManagement['vnfType']) {
411 vm.serviceInstancesToGetVersions.push({
412 "model-invariant-id": vnf.properties["model-invariant-id"],
413 "model-version-id": vnf.properties["model-version-id"] }
416 versions.push(vnf.properties["model-invariant-id"]);
420 if (versions.length > 0) {
421 AaiService.getVnfVersionsByInvariantId(versions).then(function (response) {
424 $log.debug("getVnfVersionsByInvariantId: response", response);
426 fromVNFVersions = vm.serviceInstancesToGetVersions
427 .map(function (serviceInstanceToGetVersion) {
428 const model = _.find(response.data.model, {'model-invariant-id': serviceInstanceToGetVersion['model-invariant-id']});
429 $log.debug("getVnfVersionsByInvariantId: model for " + serviceInstanceToGetVersion['model-invariant-id'], model);
431 const modelVer = _.find(model["model-vers"]["model-ver"], {'model-version-id': serviceInstanceToGetVersion['model-version-id']});
432 $log.debug("getVnfVersionsByInvariantId: modelVer for " + serviceInstanceToGetVersion['model-version-id'], modelVer);
434 var modelVersionId = serviceInstanceToGetVersion["model-version-id"];
435 var modelVersion = modelVer["model-version"];
437 return {"key": modelVersionId, "value": modelVersion};
440 vm.fromVNFVersions = _.uniqBy(fromVNFVersions, 'value');
447 function getVnfs(modelInvariantId) {
448 return new Promise(function (resolve, reject) {
449 AaiService.getVnfVersionsByInvariantId(modelInvariantId)
450 .then(function (response) {
451 if (response.data.httpCode !== null &&
452 response.data.httpCode === 200) {
453 var vnfsData = response.data.t.results;
454 for (var i = 0; i < vnfsData.length; i++) {
456 if (vnfsData[i].nodeType === "generic-vnf") {
457 resolve(vnfsData[i]);
458 } else if (vnfsData[i].nodeType === "service-instance") {
459 vm.serviceInstances.push(vnfsData[i]);
467 .catch(function (error) {
473 var getVersionNameForId = function(versionId) {
474 var version = _.find(fromVNFVersions, {"key": versionId});
475 return version.value;
478 vm.loadVNFNames = function () {
480 const vnfs = vm.changeManagement.fromVNFVersion ? vm.vnfs : [];
481 _.forEach(vnfs, function (vnf) {
483 var selectedVersionNumber = getVersionNameForId(vm.changeManagement.fromVNFVersion);
485 if (vnf.properties['nf-role'] === vm.changeManagement.vnfType &&
486 selectedVersionNumber === getVersionNameForId(vnf.properties["model-version-id"])) {
489 _.forEach(vnf['related-to'], function (node) {
490 if (node['node-type'] === 'vserver') {
491 vServer = extractLcpRegionIdAndTenantId(node.url);
495 var serviceInstancesIds =
496 _.filter(vnf['related-to'], {'node-type': 'service-instance'})
497 .map(function (serviceInstance) { return serviceInstance.id });
499 var serviceInstances = _.filter(vm.serviceInstances, function(serviceInstance) {
500 return _.includes(serviceInstancesIds, serviceInstance.id);
504 if (serviceInstancesIds.length === 0) {
505 $log.error("loadVNFNames: no serviceInstancesIds for vnf", vnf);
507 $log.debug("loadVNFNames: serviceInstancesIds", serviceInstancesIds);
508 $log.debug("loadVNFNames: serviceInstances", serviceInstances);
512 "id": vnf.properties["vnf-id"],
513 "name": vnf.properties["vnf-name"],
514 "invariant-id": vnf.properties["model-invariant-id"],
515 "service-instance-node": serviceInstances,
516 "modelVersionId": vnf.properties["model-version-id"],
517 "properties": vnf.properties,
518 'cloudConfiguration': vServer,
519 "relatedTo": vnf['related-to']
525 function extractLcpRegionIdAndTenantId(url) {
527 var cloudConfiguration = {
528 lcpCloudRegionId: '',
533 e.g., in both URLs below -
534 - lcpCloudRegionId == 'rdm5b'
535 - tenantId == '0675e0709bd7444a9e13eba8b40edb3c'
537 "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"
538 "url": "/aai/v11/cloud-infrastructure/cloud-regions/cloud-region/att-aic/rdm5b/tenants/tenant/0675e0709bd7444a9e13eba8b40edb3c/vservers/vserver/932b330d-733e-427d-a519-14eebd261f70"
541 var cloudRegionMatch = url.match(/\/cloud-regions\/cloud-region\/[^\/]+\/([^\/]+)/);
542 var tenantMatch = url.match(/\/tenants\/tenant\/([^\/]+)/);
544 cloudConfiguration.lcpCloudRegionId = cloudRegionMatch[1];
545 cloudConfiguration.tenantId = tenantMatch[1];
547 return cloudConfiguration;
550 vm.loadWorkFlows = function () {
551 changeManagementService.getWorkflows(vm.changeManagement.vnfNames)
552 .then(function(response) {
553 vm.workflows = response.data.workflows;
555 .catch(function(error) {
560 //Must be $scope because we bind to the onchange of the html (cannot attached to vm variable).
561 $scope.selectFileForVNFName = function (fileInput) {
562 if (fileInput && fileInput.id) {
563 var vnfName = _.filter(vm.changeManagement.vnfNames, {"invariant-id": fileInput.id});
564 var file = fileInput.files[0];
565 var fileReader = new FileReader();
566 fileReader.onload = function (load) {
568 var lines = load.target.result;
569 vnfName[0].selectedFile = JSON.parse(lines);
574 fileReader.readAsText(file);
578 vm.selectVersionForVNFName = function (vnfName) {
579 console.log("Will add version for selected vnf name: " + vnfName.name);
582 vm.isConfigUpdate = function () {
583 return vm.changeManagement.workflow === COMPONENT.WORKFLOWS.vnfConfigUpdate;
586 vm.isScaleOut = function () {
587 return vm.changeManagement.workflow === COMPONENT.WORKFLOWS.vnfScaleOut;
590 vm.shouldShowVnfInPlaceFields = function () {
591 return vm.changeManagement.workflow === COMPONENT.WORKFLOWS.vnfInPlace;
594 vm.setPreload = function (fileEl) {
595 var files = fileEl.files;
597 var reader = new FileReader();
599 reader.onloadend = function(evt) {
600 if (evt.target.readyState === FileReader.DONE) {
601 $scope.$apply(function () {
602 $scope.moduleArr[0].userParams = JSON.parse(evt.target.result);
607 reader.readAsText(file);