2 * ============LICENSE_START=======================================================
4 * ================================================================================
5 * Copyright (C) 2017 - 2019 AT&T Intellectual Property. All rights reserved.
6 * ================================================================================
7 * Licensed under the Apache License, Version 2.0 (the "License");
8 * you may not use this file except in compliance with the License.
9 * You may obtain a copy of the License at
11 * http://www.apache.org/licenses/LICENSE-2.0
13 * Unless required by applicable law or agreed to in writing, software
14 * distributed under the License is distributed on an "AS IS" BASIS,
15 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
16 * See the License for the specific language governing permissions and
17 * limitations under the License.
18 * ============LICENSE_END=========================================================
24 appDS2.controller("newChangeManagementModalController", ["$uibModalInstance", "$uibModal",'$q', "AaiService", "changeManagementService", "Upload",
25 "$log", "$scope", "_", "COMPONENT", "VIDCONFIGURATION","DataService","featureFlags", newChangeManagementModalController]);
27 function newChangeManagementModalController($uibModalInstance, $uibModal,$q, AaiService, changeManagementService, Upload, $log, $scope, _, COMPONENT, VIDCONFIGURATION, DataService, featureFlags) {
31 vm.hasScheduler = !!VIDCONFIGURATION.SCHEDULER_PORTAL_URL;
35 vm.nextStep = function(){
37 $(".modal-dialog").animate({"width":"1200px"},400,'linear');
39 vm.prevStep = function(){
41 $(".modal-dialog").animate({"width":"600px"},400,'linear');
44 vm.softwareVersionRegex = "[-a-zA-Z0-9\.]+";
48 $scope.showReportWindow = function() {
49 const modalWindow = $uibModal.open({
50 templateUrl: 'app/vid/scripts/modals/report-modal/report-modal.html',
51 controller: 'reportModalController',
54 errorMsg: function () {
55 return vm.errorMsg.message;
62 $scope.isShowErrorReport = function() {
63 return featureFlags.isOn(COMPONENT.FEATURE_FLAGS.FLAG_CREATE_ERROR_REPORTS);
66 function fetchAttUid() {
67 var defer = $q.defer();
69 defer.resolve(attuid);
71 AaiService.getLoggedInUserID(function (response) {
72 attuid = response.data;
73 defer.resolve(attuid);
83 var init = function () {
84 vm.changeManagement = {};
85 vm.changeManagement.workflowParameters = new Map();
87 loadServicesCatalog();
88 fetchAttUid().then(registerVNFNamesWatcher);
92 var loadServicesCatalog = function () {
93 changeManagementService.getAllSDCServices()
94 .then(function (response) {
95 vm.SDCServicesCatalog = response.data;
97 .catch(function (error) {
103 var registerVNFNamesWatcher = function () {
104 $scope.$watch('vm.changeManagement.vnfNames', function (newVal, oldVal) {
105 if (!oldVal || newVal && newVal.length > oldVal.length) { //JUST THE LAST ONE ADDED
106 var newVNFName = _.last(vm.changeManagement.vnfNames);
108 vm.changeManagement.vnfNames = oldVal;
109 vm.changeManagement.vnfNames.push(newVNFName);
111 if (newVNFName && newVNFName["service-instance-node"]) {
112 var availableVersions = [];
113 var services = _.filter(vm.SDCServicesCatalog.services,
114 {"invariantUUID": newVNFName["service-instance-node"][0].properties["model-invariant-id"]});
116 _.each(services, function (service) {
117 changeManagementService.getSDCService(service.uuid)
118 .then(function (response) {
119 _.each(response.data.vnfs, function (vnf) {
120 if (newVNFName["invariant-id"] === vnf.invariantUuid) {
121 availableVersions.push(extractVNFModel(vnf, response.data.service, newVNFName));
123 //for scale out screen
124 if(service.uuid === newVNFName["service-instance-node"][0].properties["model-version-id"]) {
125 newVNFName.vfModules = vnf.vfModules;
126 newVNFName.category = response.data.service.category;
127 newVNFName.groupModules = _.groupBy(newVNFName.vfModules, "customizationUuid");
129 //list vfmodules ids in AAI that belong to that vnf instance
130 var modulesAaiIds = _.filter(newVNFName.relatedTo, function(item){
131 return item["node-type"] === "vf-module";
132 }).map(function(item){
136 _.forEach(newVNFName.vfModules, function (mdl, key) {
137 mdl.scale = false; //defaults to not scale unless user changes it
138 if(mdl.properties && mdl.properties.maxCountInstances) {
140 //how many vf modules of the same customizationId belong to that vnf instance
141 mdl.currentCount = _.filter(vm.vfModules, function(item){
142 return modulesAaiIds.indexOf(item.id) > -1 && item.properties["model-customization-id"] === mdl.customizationUuid;
145 mdl.scalable = mdl.properties.maxCountInstances - mdl.currentCount > 0;
147 mdl.scalable = false;
153 var versions = _.uniqBy(availableVersions, 'modelInfo.modelVersion');
154 newVNFName.availableVersions = _.sortBy(_.uniq(versions, response.data.service, true),"modelInfo.modelVersion");
155 }).catch(function (error) {
165 var extractVNFModel = function (csarVNF, sdcService, selectionVNF) {
167 @param selectionVNF A vnf *instance* selected in "available VNF" drop-down box
168 @param csarVNF A VNF *MODEL* that has an invariantUuid same as selectionVNF (might be
169 a different version; i.e. selectionVNF.modelVersionId <> csarVNF.uuid)
170 @param sdcService The Service *MODEL* which has the related VNF `csarVNF`.
172 var versionCsarData = {
174 vnfName: csarVNF.name,
177 modelInvariantId: csarVNF.invariantUuid,
178 modelVersionId: csarVNF.uuid,
179 modelName: csarVNF.name,
180 modelVersion: csarVNF.version,
181 modelCustomizationName: csarVNF.modelCustomizationName,
182 modelCustomizationId: csarVNF.customizationUuid
184 cloudConfiguration: selectionVNF.cloudConfiguration || {},
187 suppressRollback: false,
190 relatedInstanceList: [
193 instanceId: selectionVNF["service-instance-node"]["0"].properties['service-instance-id'],
195 modelType: "service",
196 modelInvariantId: sdcService.invariantUuid,
197 modelVersionId: sdcService.uuid,
198 modelName: sdcService.name,
199 modelVersion: sdcService.version
209 return versionCsarData;
212 vm.close = function () {
213 $uibModalInstance.close();
216 vm.uploadConfigFile = function (file) {
217 var defer = $q.defer();
219 url: "change-management/uploadConfigUpdateFile",
221 transformResponse: [function (data) {
225 .then(function (configUpdateResponse) {
226 vm.getInternalWorkFlowParameter("VNF Config Update", "FILE", "Attach configuration file").value = configUpdateResponse && JSON.parse(configUpdateResponse.data).payload;
229 .catch(function (error) {
230 defer.resolve(false);
232 return defer.promise;
236 /***converting objects to scheduler format (taken from IST) - was altered for Scale out support ***/
237 function extractChangeManagementCallbackDataStr(changeManagement) {
238 console.log(changeManagement);
240 result.requestType = changeManagement.workflow;
241 var workflowType = changeManagement.workflow;
242 result.requestDetails = [];
243 _.forEach(changeManagement.vnfNames, function (vnf) {
246 var requestInfoData ={};
247 var requestParametersData ={};
248 var moduleToScale = _.find(vnf.vfModules, {"scale": true});
249 if (vnf.availableVersions && vnf.availableVersions.length!=0){
252 source: vnf.availableVersions[0].requestInfo.source,
253 suppressRollback: vnf.availableVersions[0].requestInfo.suppressRollback,
254 requestorId: vnf.availableVersions[0].requestInfo.requestorId
257 if(workflowType=='Update'){
258 requestParametersData = {
259 usePreload: vnf.availableVersions[0].requestParameters.usePreload
261 }else if(workflowType=="Replace"){
262 requestParametersData = {
263 rebuildVolumeGroups: vnf.availableVersions[0].requestParameters.usePreload
265 }else if(workflowType=="VNF In Place Software Update"){
267 'existing_software_version':vm.getInternalWorkFlowParameter(workflowType, 'text', 'Existing software version').value,
268 'new_software_version':vm.getInternalWorkFlowParameter(workflowType, 'text', 'New software version').value,
269 'operations_timeout':vm.getInternalWorkFlowParameter(workflowType, 'text', 'Operations timeout').value
271 requestParametersData = {
272 payload: JSON.stringify(payloadObj)
274 }else if(workflowType=="VNF Config Update"){
275 requestParametersData = {
276 payload: vm.getInternalWorkFlowParameter("VNF Config Update", "FILE", "Attach configuration file").value
278 }else if(workflowType=="VNF Scale Out"){
279 if(!moduleToScale) return null;
281 if(moduleToScale.userParams) {
282 requestParametersData = {
283 userParams: moduleToScale.userParams
287 requestParametersData = {
293 $log.info('SchedulerWidgetCtrl:extractChangeManagementCallbackDataStr info:: workflowType '+ workflowType);
294 $log.info('SchedulerWidgetCtrl:extractChangeManagementCallbackDataStr info:: requestParametersData '+ requestParametersData);
296 }else if(workflowType=="VNF In Place Software Update"){
298 'existing_software_version':vm.getInternalWorkFlowParameter(workflowType, 'text', 'Existing software version').value,
299 'new_software_version':vm.getInternalWorkFlowParameter(workflowType, 'text', 'New software version').value,
300 'operations_timeout':vm.getInternalWorkFlowParameter(workflowType, 'text', 'Operations timeout').value
302 requestParametersData = {
303 payload: JSON.stringify(payloadObj)
305 }else if(workflowType=="VNF Config Update"){
306 requestParametersData = {
307 payload: vm.getInternalWorkFlowParameter("VNF Config Update", "FILE", "Attach configuration file").value
312 if(workflowType=="VNF Scale Out") {
315 vnfInstanceId: vnf.id,
317 modelType: 'vfModule',
318 modelInvariantId: moduleToScale.invariantUuid,
319 modelName: moduleToScale.modelCustomizationName,
320 modelVersion: moduleToScale.version,
321 modelCustomizationName: moduleToScale.modelCustomizationName,
322 modelCustomizationId: moduleToScale.customizationUuid,
323 modelVersionId: moduleToScale.uuid
325 cloudConfiguration: vnf.cloudConfiguration,
326 requestInfo: requestInfoData,
327 relatedInstanceList: [],
328 requestParameters:requestParametersData,
329 configurationParameters: JSON.parse(vm.getInternalWorkFlowParameter("VNF Scale Out", "text", "Configuration Parameters").value)
331 requestInfoData.instanceName = vnf.name + "_" + (moduleToScale.currentCount + 1);
335 vnfInstanceId: vnf.id,
338 modelInvariantId: vnf.properties['model-invariant-id'],
339 modelVersionId: vnf.modelVersionId,
340 modelName: vnf.properties['vnf-name'],
341 modelVersion: vnf.version,
342 modelCustomizationName: vnf.properties['model-customization-name'],
343 modelCustomizationId: vnf.properties['model-customization-id']
345 cloudConfiguration: vnf.cloudConfiguration,
346 requestInfo: requestInfoData,
347 relatedInstanceList: [],
348 requestParameters:requestParametersData
352 var serviceInstanceId = '';
353 _.forEach(vnf['service-instance-node'], function (instanceNode) {
354 if(instanceNode['node-type'] === 'service-instance'){
355 serviceInstanceId = instanceNode.properties['service-instance-id'];
359 if (vnf.availableVersions && vnf.availableVersions.length!=0){
360 _.forEach(vnf.availableVersions[0].relatedInstanceList, function (related) {
361 var rel = related.relatedInstance;
362 var relatedInstance = {
363 instanceId: serviceInstanceId,
365 modelType: rel.modelInfo.modelType,
366 modelInvariantId: rel.modelInfo.modelInvariantId,
367 modelVersionId: rel.modelInfo.modelVersionId,
368 modelName: rel.modelInfo.modelName,
369 modelVersion: rel.modelInfo.modelVersion,
370 modelCustomizationName: rel.modelInfo.modelCustomizationName,
371 modelCustomizationId: rel.modelInfo.modelCustomizationId
374 if (rel.vnfInstanceId)
375 relatedInstance.instanceId = rel.vnfInstanceId;
377 data.relatedInstanceList.push({relatedInstance: relatedInstance});
379 if(workflowType=="VNF Scale Out") {
380 //push vnf to related as well as the service instance
381 var relatedInstance = {
384 modelCustomizationId: vnf.availableVersions[0].modelInfo.modelCustomizationId,
385 modelCustomizationName: vnf.availableVersions[0].modelInfo.modelCustomizationName,
386 modelInvariantId: vnf.availableVersions[0].modelInfo.modelInvariantId,
387 modelName: vnf.availableVersions[0].modelInfo.modelName,
388 modelType: vnf.availableVersions[0].modelInfo.modelType,
389 modelVersion: vnf.availableVersions[0].modelInfo.modelVersion,
390 modelVersionId: vnf.availableVersions[0].modelInfo.modelVersionId
393 data.relatedInstanceList.push({relatedInstance: relatedInstance});
397 $log.error('SchedulerCtrl::extractChangeManagementCallbackDataStr error: ' + err);
401 result.requestDetails.push(data);
403 return JSON.stringify(result);
406 function getWorkflowParametersFromForm() {
407 let workflowParameters =
409 cloudConfiguration:{},
410 requestParameters:{userParams:[{}]}
412 workflowParameters.requestDetails.cloudConfiguration = vm.changeManagement.vnfNames[0].cloudConfiguration;
414 let parameters = vm.getRemoteWorkFlowParameters(vm.changeManagement.workflow);
415 parameters.forEach((parameter)=>{
416 let inputField = document.getElementById('so-workflow-parameter-'+parameter.soFieldName);
417 workflowParameters.requestDetails.requestParameters.userParams[0][parameter.soFieldName]=inputField.value;
420 return workflowParameters;
423 vm.openModal = function () {
424 if(vm.hasScheduler) { //scheduling supported
425 vm.scheduleWorkflow();
427 //no scheduling support
428 vm.executeWorkflow();
432 vm.scheduleWorkflow = function () {
433 $scope.widgetParameter = ""; // needed by the scheduler?
435 // properties needed by the scheduler so it knows whether to show
436 // policy or sniro related features on the scheduler UI or not.
437 vm.changeManagement.policyYN = "Y";
438 vm.changeManagement.sniroYN = "Y";
440 if (featureFlags.isOn(COMPONENT.FEATURE_FLAGS.FLAG_ADD_MSO_TESTAPI_FIELD)) {
441 vm.changeManagement.testApi = DataService.getMsoRequestParametersTestApi();
444 widgetName: 'Portal-Common-Scheduler',
445 widgetData: vm.changeManagement,
446 widgetParameter: $scope.widgetParameter
449 window.parent.postMessage(data, VIDCONFIGURATION.SCHEDULER_PORTAL_URL);
452 vm.executeWorkflow = function () {
453 if ( vm.localWorkflows && vm.localWorkflows.length > 0 ) {
454 vm.triggerLocalWorkflow();
456 let source = vm.getRemoteWorkflowSource(vm.changeManagement.workflow);
457 if( source === "NATIVE"){
458 vm.triggerLocalWorkflow();
460 vm.triggerRemoteWorkflow();
465 vm.triggerLocalWorkflow = function () {
466 var dataToSo = extractChangeManagementCallbackDataStr(vm.changeManagement);
468 var vnfName = vm.changeManagement.vnfNames[0].name;
469 changeManagementService.postChangeManagementNow(dataToSo, vnfName);
473 vm.triggerRemoteWorkflow = function () {
474 let cachedWorkflowDetails = vm.getCachedWorkflowDetails(vm.changeManagement.workflow);
475 if (cachedWorkflowDetails.length > 0) {
476 let workflowParameters = getWorkflowParametersFromForm();
477 if (workflowParameters) {
478 let servieInstanceId = vm.changeManagement.vnfNames[0]['service-instance-node'][0].properties['service-instance-id'];
479 let vnfInstanceId = vm.changeManagement.vnfNames[0].id;
480 let workflow_UUID = cachedWorkflowDetails[0].id;
481 changeManagementService.postWorkflowsParametersNow(servieInstanceId, vnfInstanceId, workflow_UUID, workflowParameters);
486 vm.loadSubscribers = function () {
488 AaiService.getSubscribers(function (response) {
489 vm.subscribers = response;
493 vm.loadServiceTypes = function () {
494 vm.serviceTypes = [];
496 AaiService.getSubscriberServiceTypes(vm.changeManagement.subscriberId)
497 .then(function (response) {
498 vm.serviceTypes = response.data;
500 .catch(function (error) {
506 vm.loadVNFTypes = function () {
508 vm.vnfTypesTemp = [];
509 vm.serviceInstances = [];
511 var instances = vm.changeManagement.serviceType["service-instances"]["service-instance"];
512 // var promiseArrOfGetVnfs = preparePromiseArrOfGetVnfs(instances);
517 AaiService.getVnfsByCustomerIdAndServiceType(
518 vm.changeManagement.subscriberId,
519 vm.changeManagement.serviceType["service-type"]
520 ).then(function (response) {
521 var vnfsData = response.data.results;
523 for (var i = 0; i < vnfsData.length; i++) {
525 const nodeType = vnfsData[i]['node-type'];
526 if (nodeType === "generic-vnf") {
527 if (_.find(vnfsData[i]['related-to'], function (node) {
528 return node['node-type'] === 'vserver'
530 vm.vnfs.push(vnfsData[i]);
532 } else if (nodeType === "service-instance") {
533 vm.serviceInstances.push(vnfsData[i]);
534 } else if (nodeType === "vf-module") {
535 vm.vfModules.push(vnfsData[i]);
540 vm.vnfs = _.flattenDeep(
541 _.remove(vm.vnfs, function (vnf) {
542 var nfRole = vnf.properties['nf-role'];
543 if (nfRole !== undefined) {
544 return nfRole !== 'null' && nfRole !== '';
549 var filteredVnfs = _.uniqBy(vm.vnfs, function (vnf) {
550 return vnf.properties['nf-role'];
553 _.forEach(filteredVnfs, function (vnf) {
554 vm.vnfTypes.push(vnf.properties['nf-role'])
561 var fromVNFVersions = [];
563 vm.loadVNFVersions = function () {
564 fromVNFVersions = [];
565 vm.serviceInstancesToGetVersions = [];
567 _.forEach(vm.vnfs, function (vnf) {
568 if (vnf.properties['nf-role'] === vm.changeManagement['vnfType']
569 && vnf.properties["model-invariant-id"]
570 && vnf.properties["model-version-id"]) {
571 vm.serviceInstancesToGetVersions.push({
572 "model-invariant-id": vnf.properties["model-invariant-id"],
573 "model-version-id": vnf.properties["model-version-id"]
577 versions.push(vnf.properties["model-invariant-id"]);
581 if (versions.length > 0) {
582 AaiService.getVnfVersionsByInvariantId(versions).then(function (response) {
585 $log.debug("getVnfVersionsByInvariantId: response", response);
587 fromVNFVersions = vm.serviceInstancesToGetVersions
588 .map(function (serviceInstanceToGetVersion) {
589 const model = _.find(response.data.model, {'model-invariant-id': serviceInstanceToGetVersion['model-invariant-id']});
590 $log.debug("getVnfVersionsByInvariantId: model for " + serviceInstanceToGetVersion['model-invariant-id'], model);
592 const modelVer = _.find(model["model-vers"]["model-ver"], {'model-version-id': serviceInstanceToGetVersion['model-version-id']});
593 $log.debug("getVnfVersionsByInvariantId: modelVer for " + serviceInstanceToGetVersion['model-version-id'], modelVer);
595 var modelVersionId = serviceInstanceToGetVersion["model-version-id"];
596 var modelVersion = modelVer["model-version"];
598 return {"key": modelVersionId, "value": modelVersion};
601 vm.fromVNFVersions = _.uniqBy(fromVNFVersions, 'value');
608 function getVnfs(modelInvariantId) {
609 return new Promise(function (resolve, reject) {
610 AaiService.getVnfVersionsByInvariantId(modelInvariantId)
611 .then(function (response) {
612 if (response.data.httpCode !== null &&
613 response.data.httpCode === 200) {
614 var vnfsData = response.data.t.results;
615 for (var i = 0; i < vnfsData.length; i++) {
617 if (vnfsData[i].nodeType === "generic-vnf") {
618 resolve(vnfsData[i]);
619 } else if (vnfsData[i].nodeType === "service-instance") {
620 vm.serviceInstances.push(vnfsData[i]);
628 .catch(function (error) {
635 var getVersionNameForId = function(versionId) {
636 var version = _.find(fromVNFVersions, {"key": versionId});
637 return version.value;
640 vm.loadVNFNames = function () {
642 const vnfs = vm.changeManagement.fromVNFVersion ? vm.vnfs : [];
643 _.forEach(vnfs, function (vnf) {
645 var selectedVersionNumber = getVersionNameForId(vm.changeManagement.fromVNFVersion);
647 if (vnf.properties['nf-role'] === vm.changeManagement.vnfType &&
648 selectedVersionNumber === getVersionNameForId(vnf.properties["model-version-id"])) {
651 _.forEach(vnf['related-to'], function (node) {
652 if (node['node-type'] === 'vserver') {
653 vServer = extractLcpRegionIdAndTenantId(node.url);
657 var serviceInstancesIds =
658 _.filter(vnf['related-to'], {'node-type': 'service-instance'})
659 .map(function (serviceInstance) { return serviceInstance.id });
661 var serviceInstances = _.filter(vm.serviceInstances, function(serviceInstance) {
662 return _.includes(serviceInstancesIds, serviceInstance.id);
666 if (serviceInstancesIds.length === 0) {
667 $log.error("loadVNFNames: no serviceInstancesIds for vnf", vnf);
669 $log.debug("loadVNFNames: serviceInstancesIds", serviceInstancesIds);
670 $log.debug("loadVNFNames: serviceInstances", serviceInstances);
674 "id": vnf.properties["vnf-id"],
675 "name": vnf.properties["vnf-name"],
676 "invariant-id": vnf.properties["model-invariant-id"],
677 "service-instance-node": serviceInstances,
678 "modelVersionId": vnf.properties["model-version-id"],
679 "properties": vnf.properties,
680 'cloudConfiguration': vServer,
681 "relatedTo": vnf['related-to']
687 function extractLcpRegionIdAndTenantId(url) {
689 var cloudConfiguration = {
690 lcpCloudRegionId: '',
695 e.g., in both URLs below -
696 Â - lcpCloudRegionId == 'rdm5b'
697 Â - tenantId == '0675e0709bd7444a9e13eba8b40edb3c'
699 "url": "https://aai-conexus-e2e.ecomp.cci.att.com:8443/aai/v10/cloud-infrastructure/cloud-regions/cloud-region/irma-aic/rdm5b/tenants/tenant/0675e0709bd7444a9e13eba8b40edb3c/vservers/vserver/932b330d-733e-427d-a519-14eebd261f70"
700 "url": "/aai/v11/cloud-infrastructure/cloud-regions/cloud-region/irma-aic/rdm5b/tenants/tenant/0675e0709bd7444a9e13eba8b40edb3c/vservers/vserver/932b330d-733e-427d-a519-14eebd261f70"
703 var cloudRegionMatch = url.match(/\/cloud-regions\/cloud-region\/[^\/]+\/([^\/]+)/);
704 var tenantMatch = url.match(/\/tenants\/tenant\/([^\/]+)/);
706 cloudConfiguration.lcpCloudRegionId = cloudRegionMatch[1];
707 cloudConfiguration.tenantId = tenantMatch[1];
709 return cloudConfiguration;
712 vm.loadWorkFlows = function () {
713 vm.localWorkflowsParameters = new Map();
714 vm.remoteWorkflowsParameters = new Map();
715 if (featureFlags.isOn(COMPONENT.FEATURE_FLAGS.FLAG_HANDLE_SO_WORKFLOWS)) {
716 return vm.loadRemoteWorkFlows()
718 vm.workflows = vm.remoteWorkflows.map(item => item.name);
719 }).then(function () {
720 vm.loadRemoteWorkFlowsParameters();
723 return vm.loadLocalWorkFlows()
724 .then(vm.loadLocalWorkFlowsParameters)
726 vm.workflows = vm.localWorkflows;
731 vm.loadLocalWorkFlows = function () {
732 return changeManagementService.getWorkflows(vm.changeManagement.vnfNames)
733 .then(function (response) {
734 vm.localWorkflows = response.data.workflows || [];
735 }).catch(function (error) {
741 vm.loadRemoteWorkFlows = function () {
742 let vnfModelIDs = vm.changeManagement.vnfNames.map(vnfName => vnfName.modelVersionId);
743 return changeManagementService.getSOWorkflows(vnfModelIDs)
744 .then(function (response) {
745 vm.remoteWorkflows = response.data || [];
746 }).catch(function (error) {
752 vm.loadLocalWorkFlowsParameters = function () {
753 vm.localWorkflows.forEach(function(workflow) {
754 vm.loadLocalWorkFlowParameters(workflow);
758 vm.loadLocalWorkFlowParameters = function (workflow) {
759 changeManagementService.getLocalWorkflowParameter(workflow)
760 .then(function (response) {
761 vm.localWorkflowsParameters.set(workflow, response.data.parameterDefinitions);
763 .catch(function (error) {
769 vm.loadRemoteWorkFlowsParameters = function () {
770 vm.remoteWorkflows.forEach(function(workflow) {
771 if (workflow.source ==='SDC' || workflow.source === 'sdc' ){
772 vm.loadRemoteWorkFlowParameters(workflow);
774 vm.loadLocalWorkFlowParameters(workflow.name);
779 vm.loadRemoteWorkFlowParameters = function (workflow) {
781 workflow.workflowInputParameters
782 .filter( function (param) {
783 return param.soPayloadLocation === "userParams"
785 .forEach(function (param) {
786 let workflowParams = vm.repackAttributes(param);
787 if (param.validation.length > 0) {
788 let validation = param.validation[0];
789 if ('maxLength' in validation) {
790 workflowParams.maxLength = validation.maxLength;
792 if ('allowableChars' in validation) {
793 workflowParams.pattern = validation.allowableChars;
796 workflowParams.type = param.inputType;
798 parameters.push(workflowParams);
801 vm.remoteWorkflowsParameters.set(workflow.name, parameters);
804 vm.repackAttributes = function (workflowParam){
806 name: workflowParam.label,
807 required: workflowParam.required,
808 id: workflowParam.soFieldName,
809 soFieldName: workflowParam.soFieldName,
815 vm.getRemoteWorkFlowParameters = function (workflow) {
816 if (workflow && vm.remoteWorkflowsParameters.has(workflow)) {
817 return vm.remoteWorkflowsParameters.get(workflow)
822 vm.hasPatternError = function(form, itemName){
823 return form[itemName].$error.pattern;
826 vm.hasAsyncFnError = function(form, itemName){
827 return form[itemName].$error.validateAsyncFn;
830 vm.getIdFor = function(type, id, name){
831 return "internal-workflow-parameter-" + type + "-" + id + "-" + (name ? name.split(' ').join('-').toLowerCase() : "");
834 vm.getInternalWorkFlowParameters = function (workflow, type) {
835 if (workflow && vm.localWorkflowsParameters.has(workflow) && vm.localWorkflowsParameters.get(workflow).filter(parameter => parameter.type==type) != []) {
836 return vm.localWorkflowsParameters.get(workflow).filter(parameter => parameter.type==type);
841 vm.getInternalWorkFlowParameter = function (workflow, type, parameterName) {
842 if (workflow && vm.localWorkflowsParameters.has(workflow) && vm.localWorkflowsParameters.get(workflow).filter(parameter => parameter.type==type) != []) {
843 return vm.localWorkflowsParameters.get(workflow).filter(parameter => parameter.type==type).filter(parameter => parameter.name === parameterName)[0]
847 vm.getRemoteWorkflowSource = (workflow) => {
848 return vm.getCachedWorkflowDetails(workflow)[0].source;
851 vm.getCachedWorkflowDetails = function (workflow) {
852 return vm.remoteWorkflows.filter( function (remoteWorkflow) {
853 return remoteWorkflow.name === workflow;
858 //Must be $scope because we bind to the onchange of the html (cannot attached to vm variable).
859 $scope.selectFileForVNFName = function (fileInput) {
860 if (fileInput && fileInput.id) {
861 var vnfName = _.filter(vm.changeManagement.vnfNames, {"invariant-id": fileInput.id});
862 var file = fileInput.files[0];
863 var fileReader = new FileReader();
864 fileReader.onload = function (load) {
866 var lines = load.target.result;
867 vnfName[0].selectedFile = JSON.parse(lines);
873 fileReader.readAsText(file);
877 vm.selectVersionForVNFName = function (vnfName) {
878 console.log("Will add version for selected vnf name: " + vnfName.name);
881 vm.isConfigUpdate = function () {
882 return vm.changeManagement.workflow === COMPONENT.WORKFLOWS.vnfConfigUpdate;
885 vm.isScaleOut = function () {
886 return vm.changeManagement.workflow === COMPONENT.WORKFLOWS.vnfScaleOut;
889 vm.shouldShowVnfInPlaceFields = function () {
890 return vm.changeManagement.workflow === COMPONENT.WORKFLOWS.vnfInPlace;
893 vm.setPreload = function (fileEl) {
894 var files = fileEl.files;
896 var reader = new FileReader();
898 reader.onloadend = function(evt) {
899 if (evt.target.readyState === FileReader.DONE) {
900 $scope.$apply(function () {
901 $scope.moduleArr[0].userParams = JSON.parse(evt.target.result);
906 reader.readAsText(file);