26b1819bfca6bbfe9401be95eaf26f670d8fb0f0
[vid.git] / vid-app-common / src / main / webapp / app / vid / scripts / modals / new-change-management / new-change-management.controller.js
1 (function () {
2     'use strict';
3
4     appDS2.controller("newChangeManagementModalController", ["$uibModalInstance", "$uibModal",'$q', "AaiService", "changeManagementService", "Upload",
5         "$log", "$scope", "_", "COMPONENT", "VIDCONFIGURATION", newChangeManagementModalController]);
6
7     function newChangeManagementModalController($uibModalInstance, $uibModal,$q, AaiService, changeManagementService, Upload, $log, $scope, _, COMPONENT, VIDCONFIGURATION) {
8
9         var vm = this;
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;
14         vm.wizardStep = 1;
15         vm.nextStep = function(){
16             vm.wizardStep++;
17             $(".modal-dialog").animate({"width":"1000px"},400,'linear');
18         };
19         vm.prevStep = function(){
20             vm.wizardStep--;
21             $(".modal-dialog").animate({"width":"6000px"},400,'linear');
22         };
23
24         vm.softwareVersionRegex = "[-a-zA-Z0-9\.]+";
25
26         var init = function () {
27             vm.changeManagement = {};
28
29             loadServicesCatalog();
30             registerVNFNamesWatcher();
31             vm.loadSubscribers();
32         };
33
34         var loadServicesCatalog = function () {
35             changeManagementService.getAllSDCServices()
36                 .then(function (response) {
37                     vm.SDCServicesCatalog = response.data;
38                 })
39                 .catch(function (error) {
40                     $log.error(error);
41                 })
42         };
43
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);
48                     if (oldVal) {
49                         vm.changeManagement.vnfNames = oldVal;
50                         vm.changeManagement.vnfNames.push(newVNFName);
51                     }
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"]});
56
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;
64
65                                             //for scale out screen
66                                             newVNFName.category = response.data.service.category;
67                                             newVNFName.groupModules = _.groupBy(newVNFName.vfModules, "customizationUuid");
68                                         }
69                                     });
70                                     var versions = _.uniqBy(availableVersions, 'modelInfo.modelVersion');
71                                     newVNFName.availableVersions = _.sortBy(_.uniq(versions, response.data.service, true),"modelInfo.modelVersion");
72                                 }).catch(function (error) {
73                                 $log.error(error);
74                             });
75                         });
76                     }
77                 }
78             }, true);
79         };
80
81         var extractVNFModel = function (csarVNF, sdcService, selectionVNF) {
82             var versionCsarData = {
83                 vnfInstanceId: "",
84                 vnfName: csarVNF.name,
85                 modelInfo: {
86                     modelType: "vnf",
87                     modelInvariantId: csarVNF.invariantUuid,
88                     modelVersionId: selectionVNF.modelVersionId,
89                     modelName: csarVNF.name,
90                     modelVersion: csarVNF.version,
91                     modelCustomizationName: csarVNF.modelCustomizationName,
92                     modelCustomizationId: csarVNF.customizationUuid
93                 },
94                 cloudConfiguration: {
95                     lcpCloudRegionId: "mdt1",
96                     tenantId: "88a6ca3ee0394ade9403f075db23167e"
97                 },
98                 requestInfo: {
99                     source: "VID",
100                     suppressRollback: false,
101                     requestorId: "az2016"
102                 },
103                 relatedInstanceList: [
104                     {
105                         relatedInstance: {
106                             instanceId: selectionVNF["service-instance-node"]["0"].properties['service-instance-id'],
107                             modelInfo: {
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']
115                             }
116                         }
117                     }
118                 ],
119                 requestParameters: {
120                     usePreload: true
121                 }
122             };
123
124             return versionCsarData;
125         };
126
127         vm.close = function () {
128             $uibModalInstance.close();
129         };
130
131         vm.uploadConfigFile = function (file) {
132             var defer = $q.defer();
133             Upload.upload({
134                 url: "change-management/uploadConfigUpdateFile",
135                 file: file,
136                 transformResponse: [function (data) {
137                     return data;
138                 }]
139             })
140             .then(function (configUpdateResponse) {
141                 vm.changeManagement.configUpdateFile = configUpdateResponse && JSON.parse(configUpdateResponse.data).payload;
142                 defer.resolve(true);
143             })
144             .catch(function (error) {
145                 defer.resolve(false);
146             });
147             return defer.promise;
148         };
149
150
151                 /***converting objects to scheduler format (taken from IST) - was altered for Scale out support ***/
152                 function extractChangeManagementCallbackDataStr(changeManagement) {
153                         console.log(changeManagement);
154                         var result = {};
155                         result.requestType = changeManagement.workflow;
156                         var workflowType = changeManagement.workflow;
157                         result.requestDetails = [];
158                         _.forEach(changeManagement.vnfNames, function (vnf) {
159                                 
160                                 try{
161                                 var requestInfoData ={};
162                                 var requestParametersData ={};
163                 var moduleToScale = _.find(vnf.vfModules, function(key, item){
164                     return !item.scale;
165                 });
166                                 if (vnf.availableVersions && vnf.availableVersions.length!=0){
167                                         
168                                         requestInfoData ={
169                                                 source: vnf.availableVersions[0].requestInfo.source,
170                                                 suppressRollback: vnf.availableVersions[0].requestInfo.suppressRollback,
171                                                 requestorId: vnf.availableVersions[0].requestInfo.requestorId
172                                         }
173                                         
174                                         if(workflowType=='Update'){
175                                                 requestParametersData = {
176                                                         usePreload: vnf.availableVersions[0].requestParameters.usePreload
177                                                 }
178                                         }else if(workflowType=="Replace"){
179                                                 requestParametersData = {
180                                                         rebuildVolumeGroups: vnf.availableVersions[0].requestParameters.usePreload
181                                                 }
182                                         }else if(workflowType=="VNF In Place Software Update"){
183                                                 var payloadObj = {
184                                                         'existing_software_version':changeManagement.existingSoftwareVersion,
185                                                         'new_software_version':changeManagement.newSoftwareVersion,
186                                                         'operations_timeout':changeManagement.operationTimeout
187                                                 };
188                                                 requestParametersData = {
189                             controllerType: changeManagement.controllerType,
190                             payload: JSON.stringify(payloadObj)
191                                                 }
192                                         }else if(workflowType=="VNF Config Update"){
193                                                 requestParametersData = {
194                                                         payload: changeManagement.configUpdateFile
195                                                 }
196                     }else if(workflowType=="VNF Scale Out"){
197
198                         if(moduleToScale.userParams) {
199                             requestParametersData = {
200                                 controllerType: changeManagement.controllerType,
201                                 userParams: moduleToScale.userParams,
202                                 usePreload: true
203                             }
204                         }else{
205                             requestParametersData = {
206                                 controllerType: changeManagement.controllerType,
207                                 userParams: [],
208                                 usePreload: false
209                             }
210                         }
211                     }
212                                         $log.info('SchedulerWidgetCtrl:extractChangeManagementCallbackDataStr info:: workflowType '+ workflowType);
213                                         $log.info('SchedulerWidgetCtrl:extractChangeManagementCallbackDataStr info:: requestParametersData '+ requestParametersData);
214
215                                 }else if(workflowType=="VNF In Place Software Update"){
216                                         var payloadObj = {
217                                                 'existing_software_version':changeManagement.existingSoftwareVersion,
218                                                 'new_software_version':changeManagement.newSoftwareVersion,
219                                                 'operations_timeout':changeManagement.operationTimeout
220                                         };
221                                         requestParametersData = {
222                                                 payload: JSON.stringify(payloadObj)
223                                         }
224                                 }else if(workflowType=="VNF Config Update"){
225                                         requestParametersData = {
226                                                 payload: changeManagement.configUpdateFile
227                                         }
228                                 }
229
230
231                                 var data;
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;
235
236                     data = {
237                         modelInfo: {
238                             modelType: 'vfModule',
239                             modelInvariantId: moduleToScale.invariantUuid,
240                             modelName: name,
241                             modelVersion: moduleToScale.version,
242                             modelCustomizationId: moduleToScale.customizationUuid
243                         },
244                         cloudConfiguration: vnf.cloudConfiguration,
245                         requestInfo: requestInfoData,
246                         relatedInstanceList: [],
247                         requestParameters:requestParametersData
248                     }
249                 }else{
250                     data = {
251                         vnfName: vnf.name,
252                         vnfInstanceId: vnf.id,
253                         modelInfo: {
254                             modelType: 'vnf',
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']
261                         },
262                         cloudConfiguration: vnf.cloudConfiguration,
263                         requestInfo: requestInfoData,
264                         relatedInstanceList: [],
265                         requestParameters:requestParametersData
266                     }
267                 }
268
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'];
273                                         }
274                                 });
275
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,
281                                                         modelInfo: {
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
289                                                         }
290                                                 };
291                                                 if (rel.vnfInstanceId)
292                                                         relatedInstance.instanceId = rel.vnfInstanceId;
293
294                                                 data.relatedInstanceList.push({relatedInstance: relatedInstance});
295                                         });
296                                 }
297                                 }catch(err){
298                                         $log.error('SchedulerCtrl::extractChangeManagementCallbackDataStr error: ' + err);
299                                 }
300
301                                 result.requestDetails.push(data);
302                         });
303                         return JSON.stringify(result);
304                 }
305                 
306         vm.openModal = function () {
307             if(vm.hasScheduler) { //scheduling supported
308                                 $scope.widgetParameter = ""; // needed by the scheduler?
309
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";
314
315                                 var data = {
316                                         widgetName: 'Portal-Common-Scheduler',
317                                         widgetData: vm.changeManagement,
318                                         widgetParameter: $scope.widgetParameter
319                                 };
320                         
321                                 window.parent.postMessage(data, VIDCONFIGURATION.SCHEDULER_PORTAL_URL);
322                         } else {
323                                 //no scheduling support
324                                 var dataToSo = extractChangeManagementCallbackDataStr(vm.changeManagement);
325                                 //TODO: foreach
326                 var vnfName = vm.changeManagement.vnfNames[0].name;
327                                 changeManagementService.postChangeManagementNow(dataToSo, vnfName);
328                         }
329         };
330
331         vm.loadSubscribers = function () {
332             vm.subscribers = [];
333             AaiService.getSubscribers(function (response) {
334                 vm.subscribers = response;
335             });
336         };
337
338         vm.loadServiceTypes = function () {
339             vm.serviceTypes = [];
340
341             AaiService.getSubscriberServiceTypes(vm.changeManagement.subscriberId)
342                 .then(function (response) {
343                     vm.serviceTypes = response.data;
344                 })
345                 .catch(function (error) {
346                     $log.error(error);
347                 });
348         };
349
350         vm.loadVNFTypes = function () {
351             vm.vnfTypes = [];
352             vm.vnfTypesTemp = [];
353             vm.serviceInstances = [];
354
355             var instances = vm.changeManagement.serviceType["service-instances"]["service-instance"];
356             // var promiseArrOfGetVnfs = preparePromiseArrOfGetVnfs(instances);
357
358             vm.vnfs = [];
359
360             AaiService.getVnfsByCustomerIdAndServiceType(
361                 vm.changeManagement.subscriberId,
362                 vm.changeManagement.serviceType["service-type"]
363             ).then(function (response) {
364                     var vnfsData = response.data.results;
365                     if (vnfsData) {
366                         for (var i = 0; i < vnfsData.length; i++) {
367                             if (vnfsData[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'
372                                         }) !== undefined) {
373                                         vm.vnfs.push(vnfsData[i]);
374                                     }
375                                 } else if (nodeType === "service-instance") {
376                                     vm.serviceInstances.push(vnfsData[i]);
377                                 }
378                             }
379                         }
380
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 !== '';
386                                 }
387                             })
388                         );
389
390                         var filteredVnfs = _.uniqBy(vm.vnfs, function (vnf) {
391                             return vnf.properties['nf-role'];
392                         });
393
394                         _.forEach(filteredVnfs, function (vnf) {
395                             vm.vnfTypes.push(vnf.properties['nf-role'])
396                         });
397                     }
398                 }
399             );
400         };
401
402         var fromVNFVersions = [];
403
404         vm.loadVNFVersions = function () {
405             fromVNFVersions = [];
406             vm.serviceInstancesToGetVersions = [];
407             var versions = [];
408             _.forEach(vm.vnfs, function (vnf) {
409                 if (vnf.properties['nf-role'] === vm.changeManagement['vnfType']) {
410
411                     vm.serviceInstancesToGetVersions.push({
412                         "model-invariant-id": vnf.properties["model-invariant-id"],
413                         "model-version-id": vnf.properties["model-version-id"] }
414                     );
415
416                     versions.push(vnf.properties["model-invariant-id"]);
417                 }
418             });
419
420             if (versions.length > 0) {
421                 AaiService.getVnfVersionsByInvariantId(versions).then(function (response) {
422                     if (response.data) {
423
424                         $log.debug("getVnfVersionsByInvariantId: response", response);
425
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);
430
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);
433
434                                 var modelVersionId = serviceInstanceToGetVersion["model-version-id"];
435                                 var modelVersion = modelVer["model-version"];
436
437                                 return {"key": modelVersionId, "value": modelVersion};
438                             });
439
440                         vm.fromVNFVersions = _.uniqBy(fromVNFVersions, 'value');
441                     }
442                 })
443             }
444         };
445
446
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++) {
455                                 if (vnfsData[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]);
460                                     }
461                                 }
462                             }
463                             resolve(null);
464                         }
465                         resolve(null);
466                     })
467                     .catch(function (error) {
468                         reject(error);
469                     });
470             });
471         }
472
473         var getVersionNameForId = function(versionId) {
474             var version = _.find(fromVNFVersions, {"key": versionId});
475             return version.value;
476         };
477
478         vm.loadVNFNames = function () {
479             vm.vnfNames = [];
480             const vnfs = vm.changeManagement.fromVNFVersion ? vm.vnfs : [];
481             _.forEach(vnfs, function (vnf) {
482
483                 var selectedVersionNumber = getVersionNameForId(vm.changeManagement.fromVNFVersion);
484
485                 if (vnf.properties['nf-role'] === vm.changeManagement.vnfType &&
486                     selectedVersionNumber === getVersionNameForId(vnf.properties["model-version-id"])) {
487                     var vServer = {};
488
489                     _.forEach(vnf['related-to'], function (node) {
490                         if (node['node-type'] === 'vserver') {
491                             vServer = extractLcpRegionIdAndTenantId(node.url);
492                         }
493                     });
494
495                     var serviceInstancesIds =
496                         _.filter(vnf['related-to'], {'node-type': 'service-instance'})
497                             .map(function (serviceInstance) { return serviceInstance.id });
498
499                     var serviceInstances = _.filter(vm.serviceInstances, function(serviceInstance) {
500                         return _.includes(serviceInstancesIds, serviceInstance.id);
501                     });
502
503                     // logging only
504                     if (serviceInstancesIds.length === 0) {
505                         $log.error("loadVNFNames: no serviceInstancesIds for vnf", vnf);
506                     } else {
507                         $log.debug("loadVNFNames: serviceInstancesIds", serviceInstancesIds);
508                         $log.debug("loadVNFNames: serviceInstances", serviceInstances);
509                     }
510
511                     vm.vnfNames.push({
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']
520                     });
521                 }
522             });
523         };
524
525         function extractLcpRegionIdAndTenantId(url) {
526
527             var cloudConfiguration = {
528                 lcpCloudRegionId: '',
529                 tenantId: ''
530             };
531
532             /*
533              e.g., in both URLs below -
534                - lcpCloudRegionId == 'rdm5b'
535                - tenantId == '0675e0709bd7444a9e13eba8b40edb3c'
536
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"
539              */
540
541             var cloudRegionMatch = url.match(/\/cloud-regions\/cloud-region\/[^\/]+\/([^\/]+)/);
542             var tenantMatch = url.match(/\/tenants\/tenant\/([^\/]+)/);
543
544             cloudConfiguration.lcpCloudRegionId = cloudRegionMatch[1];
545             cloudConfiguration.tenantId = tenantMatch[1];
546
547             return cloudConfiguration;
548         };
549
550         vm.loadWorkFlows = function () {
551             changeManagementService.getWorkflows(vm.changeManagement.vnfNames)
552                 .then(function(response) {
553                     vm.workflows = response.data.workflows;
554                 })
555                 .catch(function(error) {
556                     $log.error(error);
557                 });
558         };
559
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) {
567                     try {
568                         var lines = load.target.result;
569                         vnfName[0].selectedFile = JSON.parse(lines);
570                     } catch (error) {
571                         $log.error(error);
572                     }
573                 };
574                 fileReader.readAsText(file);
575             }
576         };
577
578         vm.selectVersionForVNFName = function (vnfName) {
579             console.log("Will add version for selected vnf name: " + vnfName.name);
580         };
581
582         vm.isConfigUpdate = function () {
583             return vm.changeManagement.workflow === COMPONENT.WORKFLOWS.vnfConfigUpdate;
584         }
585                 
586         vm.isScaleOut = function () {
587             return vm.changeManagement.workflow === COMPONENT.WORKFLOWS.vnfScaleOut;
588         }
589
590         vm.shouldShowVnfInPlaceFields = function () {
591             return vm.changeManagement.workflow === COMPONENT.WORKFLOWS.vnfInPlace;
592         };
593
594         vm.setPreload = function (fileEl) {
595             var files = fileEl.files;
596             var file = files[0];
597             var reader = new FileReader();
598
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);
603                     });
604                 }
605             };
606
607             reader.readAsText(file);
608         };
609
610         init();
611     }
612 })();