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;
34 vm.isSearchedVNF = false;
37 vm.nextStep = function () {
39 $(".modal-dialog").animate({"width": "1200px"}, 400, 'linear');
41 vm.prevStep = function () {
43 $(".modal-dialog").animate({"width": "600px"}, 400, 'linear');
46 vm.softwareVersionRegex = "[-a-zA-Z0-9\.]+";
50 $scope.showReportWindow = function () {
51 const modalWindow = $uibModal.open({
52 templateUrl: 'app/vid/scripts/modals/report-modal/report-modal.html',
53 controller: 'reportModalController',
56 errorMsg: function () {
57 return vm.errorMsg.message;
64 $scope.isShowErrorReport = function () {
65 return featureFlags.isOn(COMPONENT.FEATURE_FLAGS.FLAG_CREATE_ERROR_REPORTS);
68 $scope.isNewFilterChangeManagmentEnabled = function () {
69 return (featureFlags.isOn(COMPONENT.FEATURE_FLAGS.FLAG_FLASH_CLOUD_REGION_AND_NF_ROLE_OPTIONAL_SEARCH));
72 vm.isDisabledVNFmodelVersion = function (vnfTypePristine) {
73 if ($scope.isNewFilterChangeManagmentEnabled()) {
74 return !vm.isSearchedVNF;
75 } else return vnfTypePristine;
78 function fetchAttUid() {
79 var defer = $q.defer();
81 defer.resolve(attuid);
83 AaiService.getLoggedInUserID(function (response) {
84 attuid = response.data;
85 defer.resolve(attuid);
95 var init = function () {
96 vm.changeManagement = {};
97 vm.changeManagement.workflowParameters = new Map();
99 loadServicesCatalog();
100 fetchAttUid().then(registerVNFNamesWatcher);
101 vm.loadSubscribers();
104 var loadServicesCatalog = function () {
105 changeManagementService.getAllSDCServices()
106 .then(function (response) {
107 vm.SDCServicesCatalog = response.data;
109 .catch(function (error) {
115 var registerVNFNamesWatcher = function () {
116 $scope.$watch('vm.changeManagement.vnfNames', function (newVal, oldVal) {
117 if (!oldVal || newVal && newVal.length > oldVal.length) { //JUST THE LAST ONE ADDED
118 var newVNFName = _.last(vm.changeManagement.vnfNames);
120 vm.changeManagement.vnfNames = oldVal;
121 vm.changeManagement.vnfNames.push(newVNFName);
123 if (newVNFName && newVNFName["service-instance-node"]) {
124 var availableVersions = [];
125 var services = _.filter(vm.SDCServicesCatalog.services,
126 {"invariantUUID": newVNFName["service-instance-node"][0].properties["model-invariant-id"]});
128 _.each(services, function (service) {
129 changeManagementService.getSDCService(service.uuid)
130 .then(function (response) {
131 _.each(response.data.vnfs, function (vnf) {
132 if (newVNFName["invariant-id"] === vnf.invariantUuid) {
133 availableVersions.push(extractVNFModel(vnf, response.data.service, newVNFName));
135 //for scale out screen
136 if (service.uuid === newVNFName["service-instance-node"][0].properties["model-version-id"]) {
137 newVNFName.vfModules = vnf.vfModules;
138 newVNFName.category = response.data.service.category;
139 newVNFName.groupModules = _.groupBy(newVNFName.vfModules, "customizationUuid");
141 //list vfmodules ids in AAI that belong to that vnf instance
142 var modulesAaiIds = _.filter(newVNFName.relatedTo, function (item) {
143 return item["node-type"] === "vf-module";
144 }).map(function (item) {
148 _.forEach(newVNFName.vfModules, function (mdl, key) {
149 mdl.scale = false; //defaults to not scale unless user changes it
150 if (mdl.properties && mdl.properties.maxCountInstances) {
152 //how many vf modules of the same customizationId belong to that vnf instance
153 mdl.currentCount = _.filter(vm.vfModules, function (item) {
154 return modulesAaiIds.indexOf(item.id) > -1 && item.properties["model-customization-id"] === mdl.customizationUuid;
157 mdl.scalable = mdl.properties.maxCountInstances - mdl.currentCount > 0;
159 mdl.scalable = false;
165 var versions = _.uniqBy(availableVersions, 'modelInfo.modelVersion');
166 newVNFName.availableVersions = _.sortBy(_.uniq(versions, response.data.service, true), "modelInfo.modelVersion");
167 }).catch(function (error) {
177 var extractVNFModel = function (csarVNF, sdcService, selectionVNF) {
179 @param selectionVNF A vnf *instance* selected in "available VNF" drop-down box
180 @param csarVNF A VNF *MODEL* that has an invariantUuid same as selectionVNF (might be
181 a different version; i.e. selectionVNF.modelVersionId <> csarVNF.uuid)
182 @param sdcService The Service *MODEL* which has the related VNF `csarVNF`.
184 var versionCsarData = {
186 vnfName: csarVNF.name,
189 modelInvariantId: csarVNF.invariantUuid,
190 modelVersionId: csarVNF.uuid,
191 modelName: csarVNF.name,
192 modelVersion: csarVNF.version,
193 modelCustomizationName: csarVNF.modelCustomizationName,
194 modelCustomizationId: csarVNF.customizationUuid
196 cloudConfiguration: selectionVNF.cloudConfiguration || {},
199 suppressRollback: false,
202 relatedInstanceList: [
205 instanceId: selectionVNF["service-instance-node"]["0"].properties['service-instance-id'],
207 modelType: "service",
208 modelInvariantId: sdcService.invariantUuid,
209 modelVersionId: sdcService.uuid,
210 modelName: sdcService.name,
211 modelVersion: sdcService.version
221 return versionCsarData;
224 vm.close = function () {
225 $uibModalInstance.close();
228 vm.uploadConfigFile = function (file) {
229 var defer = $q.defer();
231 url: "change-management/uploadConfigUpdateFile",
233 transformResponse: [function (data) {
237 .then(function (configUpdateResponse) {
238 vm.getInternalWorkFlowParameter("VNF Config Update", "FILE", "Attach configuration file").value = configUpdateResponse && JSON.parse(configUpdateResponse.data).payload;
241 .catch(function (error) {
242 defer.resolve(false);
244 return defer.promise;
248 /***converting objects to scheduler format (taken from IST) - was altered for Scale out support ***/
249 function extractChangeManagementCallbackDataStr(changeManagement) {
250 console.log(changeManagement);
252 result.requestType = changeManagement.workflow;
253 var workflowType = changeManagement.workflow;
254 result.requestDetails = [];
255 _.forEach(changeManagement.vnfNames, function (vnf) {
258 var requestInfoData = {};
259 var requestParametersData = {};
260 var moduleToScale = _.find(vnf.vfModules, {"scale": true});
261 if (vnf.availableVersions && vnf.availableVersions.length != 0) {
264 source: vnf.availableVersions[0].requestInfo.source,
265 suppressRollback: vnf.availableVersions[0].requestInfo.suppressRollback,
266 requestorId: vnf.availableVersions[0].requestInfo.requestorId
269 if (workflowType == 'Update') {
270 requestParametersData = {
271 usePreload: vnf.availableVersions[0].requestParameters.usePreload
273 } else if (workflowType == "Replace") {
274 requestParametersData = {
275 rebuildVolumeGroups: vnf.availableVersions[0].requestParameters.usePreload
277 } else if (workflowType == "VNF In Place Software Update") {
279 'existing_software_version': vm.getInternalWorkFlowParameter(workflowType, 'text', 'Existing software version').value,
280 'new_software_version': vm.getInternalWorkFlowParameter(workflowType, 'text', 'New software version').value,
281 'operations_timeout': vm.getInternalWorkFlowParameter(workflowType, 'text', 'Operations timeout').value
283 requestParametersData = {
284 payload: JSON.stringify(payloadObj)
286 } else if (workflowType == "VNF Config Update") {
287 requestParametersData = {
288 payload: vm.getInternalWorkFlowParameter("VNF Config Update", "FILE", "Attach configuration file").value
290 } else if (workflowType == "VNF Scale Out") {
291 if (!moduleToScale) return null;
293 if (moduleToScale.userParams) {
294 requestParametersData = {
295 userParams: moduleToScale.userParams
299 requestParametersData = {
305 $log.info('SchedulerWidgetCtrl:extractChangeManagementCallbackDataStr info:: workflowType ' + workflowType);
306 $log.info('SchedulerWidgetCtrl:extractChangeManagementCallbackDataStr info:: requestParametersData ' + requestParametersData);
308 } else if (workflowType == "VNF In Place Software Update") {
310 'existing_software_version': vm.getInternalWorkFlowParameter(workflowType, 'text', 'Existing software version').value,
311 'new_software_version': vm.getInternalWorkFlowParameter(workflowType, 'text', 'New software version').value,
312 'operations_timeout': vm.getInternalWorkFlowParameter(workflowType, 'text', 'Operations timeout').value
314 requestParametersData = {
315 payload: JSON.stringify(payloadObj)
317 } else if (workflowType == "VNF Config Update") {
318 requestParametersData = {
319 payload: vm.getInternalWorkFlowParameter("VNF Config Update", "FILE", "Attach configuration file").value
324 if (workflowType == "VNF Scale Out") {
327 vnfInstanceId: vnf.id,
329 modelType: 'vfModule',
330 modelInvariantId: moduleToScale.invariantUuid,
331 modelName: moduleToScale.modelCustomizationName,
332 modelVersion: moduleToScale.version,
333 modelCustomizationName: moduleToScale.modelCustomizationName,
334 modelCustomizationId: moduleToScale.customizationUuid,
335 modelVersionId: moduleToScale.uuid
337 cloudConfiguration: vnf.cloudConfiguration,
338 requestInfo: requestInfoData,
339 relatedInstanceList: [],
340 requestParameters: requestParametersData,
341 configurationParameters: JSON.parse(vm.getInternalWorkFlowParameter("VNF Scale Out", "text", "Configuration Parameters").value)
343 requestInfoData.instanceName = vnf.name + "_" + (moduleToScale.currentCount + 1);
347 vnfInstanceId: vnf.id,
350 modelInvariantId: vnf.properties['model-invariant-id'],
351 modelVersionId: vnf.modelVersionId,
352 modelName: vnf.properties['vnf-name'],
353 modelVersion: vnf.version,
354 modelCustomizationName: vnf.properties['model-customization-name'],
355 modelCustomizationId: vnf.properties['model-customization-id']
357 cloudConfiguration: vnf.cloudConfiguration,
358 requestInfo: requestInfoData,
359 relatedInstanceList: [],
360 requestParameters: requestParametersData
364 var serviceInstanceId = '';
365 _.forEach(vnf['service-instance-node'], function (instanceNode) {
366 if (instanceNode['node-type'] === 'service-instance') {
367 serviceInstanceId = instanceNode.properties['service-instance-id'];
371 if (vnf.availableVersions && vnf.availableVersions.length != 0) {
372 _.forEach(vnf.availableVersions[0].relatedInstanceList, function (related) {
373 var rel = related.relatedInstance;
374 var relatedInstance = {
375 instanceId: serviceInstanceId,
377 modelType: rel.modelInfo.modelType,
378 modelInvariantId: rel.modelInfo.modelInvariantId,
379 modelVersionId: rel.modelInfo.modelVersionId,
380 modelName: rel.modelInfo.modelName,
381 modelVersion: rel.modelInfo.modelVersion,
382 modelCustomizationName: rel.modelInfo.modelCustomizationName,
383 modelCustomizationId: rel.modelInfo.modelCustomizationId
386 if (rel.vnfInstanceId)
387 relatedInstance.instanceId = rel.vnfInstanceId;
389 data.relatedInstanceList.push({relatedInstance: relatedInstance});
391 if (workflowType == "VNF Scale Out") {
392 //push vnf to related as well as the service instance
393 var relatedInstance = {
396 modelCustomizationId: vnf.availableVersions[0].modelInfo.modelCustomizationId,
397 modelCustomizationName: vnf.availableVersions[0].modelInfo.modelCustomizationName,
398 modelInvariantId: vnf.availableVersions[0].modelInfo.modelInvariantId,
399 modelName: vnf.availableVersions[0].modelInfo.modelName,
400 modelType: vnf.availableVersions[0].modelInfo.modelType,
401 modelVersion: vnf.availableVersions[0].modelInfo.modelVersion,
402 modelVersionId: vnf.availableVersions[0].modelInfo.modelVersionId
405 data.relatedInstanceList.push({relatedInstance: relatedInstance});
409 $log.error('SchedulerCtrl::extractChangeManagementCallbackDataStr error: ' + err);
413 result.requestDetails.push(data);
415 return JSON.stringify(result);
418 function getWorkflowParametersFromForm() {
419 let workflowParameters =
422 cloudConfiguration: {},
423 requestParameters: {userParams: [{}]}
426 workflowParameters.requestDetails.cloudConfiguration = vm.changeManagement.vnfNames[0].cloudConfiguration;
428 let parameters = vm.getRemoteWorkFlowParameters(vm.changeManagement.workflow);
429 parameters.forEach((parameter) => {
430 let inputField = document.getElementById('so-workflow-parameter-' + parameter.soFieldName);
431 workflowParameters.requestDetails.requestParameters.userParams[0][parameter.soFieldName] = inputField.value;
434 return workflowParameters;
437 vm.openModal = function () {
438 if (vm.hasScheduler) { //scheduling supported
439 vm.scheduleWorkflow();
441 //no scheduling support
442 vm.executeWorkflow();
446 vm.scheduleWorkflow = function () {
447 $scope.widgetParameter = ""; // needed by the scheduler?
449 // properties needed by the scheduler so it knows whether to show
450 // policy or sniro related features on the scheduler UI or not.
451 vm.changeManagement.policyYN = "Y";
452 vm.changeManagement.sniroYN = "Y";
454 if (featureFlags.isOn(COMPONENT.FEATURE_FLAGS.FLAG_ADD_MSO_TESTAPI_FIELD)) {
455 vm.changeManagement.testApi = DataService.getMsoRequestParametersTestApi();
458 widgetName: 'Portal-Common-Scheduler',
459 widgetData: vm.changeManagement,
460 widgetParameter: $scope.widgetParameter
463 window.parent.postMessage(data, VIDCONFIGURATION.SCHEDULER_PORTAL_URL);
466 vm.executeWorkflow = function () {
467 if (vm.localWorkflows && vm.localWorkflows.length > 0) {
468 vm.triggerLocalWorkflow();
470 let source = vm.getRemoteWorkflowSource(vm.changeManagement.workflow);
471 if (source === "NATIVE") {
472 vm.triggerLocalWorkflow();
474 vm.triggerRemoteWorkflow();
479 vm.triggerLocalWorkflow = function () {
480 var dataToSo = extractChangeManagementCallbackDataStr(vm.changeManagement);
482 var vnfName = vm.changeManagement.vnfNames[0].name;
483 changeManagementService.postChangeManagementNow(dataToSo, vnfName);
487 vm.triggerRemoteWorkflow = function () {
488 let cachedWorkflowDetails = vm.getCachedWorkflowDetails(vm.changeManagement.workflow);
489 if (cachedWorkflowDetails.length > 0) {
490 let workflowParameters = getWorkflowParametersFromForm();
491 if (workflowParameters) {
492 let servieInstanceId = vm.changeManagement.vnfNames[0]['service-instance-node'][0].properties['service-instance-id'];
493 let vnfInstanceId = vm.changeManagement.vnfNames[0].id;
494 let workflow_UUID = cachedWorkflowDetails[0].id;
495 changeManagementService.postWorkflowsParametersNow(servieInstanceId, vnfInstanceId, workflow_UUID, workflowParameters);
500 vm.loadSubscribers = function () {
502 AaiService.getSubscribers(function (response) {
503 vm.subscribers = response;
507 vm.loadServiceTypes = function () {
508 vm.serviceTypes = [];
510 AaiService.getSubscriberServiceTypes(vm.changeManagement.subscriberId)
511 .then(function (response) {
512 vm.serviceTypes = response.data;
514 .catch(function (error) {
520 vm.serviceTypeChanged = function () {
521 if (!$scope.isNewFilterChangeManagmentEnabled()) {
526 vm.searchVNFs = function () {
528 vm.vnfTypesTemp = [];
529 vm.serviceInstances = [];
531 var instances = vm.changeManagement.serviceType["service-instances"]["service-instance"];
532 // var promiseArrOfGetVnfs = preparePromiseArrOfGetVnfs(instances);
536 let vnfRole = $scope.isNewFilterChangeManagmentEnabled() ? vm.changeManagement.vnfType : null;
537 let cloudRegion = null;
540 AaiService.getVnfsByCustomerIdAndServiceType(
541 vm.changeManagement.subscriberId,
542 vm.changeManagement.serviceType["service-type"],
546 then(function (response) {
547 vm.isSearchedVNF = true;
548 var vnfsData = response.data.results;
550 for (var i = 0; i < vnfsData.length; i++) {
552 const nodeType = vnfsData[i]['node-type'];
553 if (nodeType === "generic-vnf") {
554 if (_.find(vnfsData[i]['related-to'], function (node) {
555 return node['node-type'] === 'vserver';
557 vm.vnfs.push(vnfsData[i]);
559 } else if (nodeType === "service-instance") {
560 vm.serviceInstances.push(vnfsData[i]);
561 } else if (nodeType === "vf-module") {
562 vm.vfModules.push(vnfsData[i]);
567 vm.vnfs = _.flattenDeep(
568 _.remove(vm.vnfs, function (vnf) {
569 var nfRole = vnf.properties['nf-role'];
570 if (nfRole !== undefined) {
571 return nfRole !== 'null' && nfRole !== '';
576 var filteredVnfs = _.uniqBy(vm.vnfs, function (vnf) {
577 return vnf.properties['nf-role'];
580 _.forEach(filteredVnfs, function (vnf) {
581 vm.vnfTypes.push(vnf.properties['nf-role'])
588 var fromVNFVersions = [];
590 vm.loadVNFVersions = function () {
591 fromVNFVersions = [];
592 vm.serviceInstancesToGetVersions = [];
594 _.forEach(vm.vnfs, function (vnf) {
595 if (vnf.properties['nf-role'] === vm.changeManagement['vnfType']
596 && vnf.properties["model-invariant-id"]
597 && vnf.properties["model-version-id"]) {
598 vm.serviceInstancesToGetVersions.push({
599 "model-invariant-id": vnf.properties["model-invariant-id"],
600 "model-version-id": vnf.properties["model-version-id"]
604 versions.push(vnf.properties["model-invariant-id"]);
608 if (versions.length > 0) {
609 AaiService.getVnfVersionsByInvariantId(versions).then(function (response) {
612 $log.debug("getVnfVersionsByInvariantId: response", response);
614 fromVNFVersions = vm.serviceInstancesToGetVersions
615 .map(function (serviceInstanceToGetVersion) {
616 const model = _.find(response.data.model, {'model-invariant-id': serviceInstanceToGetVersion['model-invariant-id']});
617 $log.debug("getVnfVersionsByInvariantId: model for " + serviceInstanceToGetVersion['model-invariant-id'], model);
619 const modelVer = _.find(model["model-vers"]["model-ver"], {'model-version-id': serviceInstanceToGetVersion['model-version-id']});
620 $log.debug("getVnfVersionsByInvariantId: modelVer for " + serviceInstanceToGetVersion['model-version-id'], modelVer);
622 var modelVersionId = serviceInstanceToGetVersion["model-version-id"];
623 var modelVersion = modelVer["model-version"];
625 return {"key": modelVersionId, "value": modelVersion};
628 vm.fromVNFVersions = _.uniqBy(fromVNFVersions, 'value');
635 function getVnfs(modelInvariantId) {
636 return new Promise(function (resolve, reject) {
637 AaiService.getVnfVersionsByInvariantId(modelInvariantId)
638 .then(function (response) {
639 if (response.data.httpCode !== null &&
640 response.data.httpCode === 200) {
641 var vnfsData = response.data.t.results;
642 for (var i = 0; i < vnfsData.length; i++) {
644 if (vnfsData[i].nodeType === "generic-vnf") {
645 resolve(vnfsData[i]);
646 } else if (vnfsData[i].nodeType === "service-instance") {
647 vm.serviceInstances.push(vnfsData[i]);
655 .catch(function (error) {
662 var getVersionNameForId = function (versionId) {
663 var version = _.find(fromVNFVersions, {"key": versionId});
664 return version.value;
667 vm.loadVNFNames = function () {
669 const vnfs = vm.changeManagement.fromVNFVersion ? vm.vnfs : [];
670 _.forEach(vnfs, function (vnf) {
672 var selectedVersionNumber = getVersionNameForId(vm.changeManagement.fromVNFVersion);
674 if (vnf.properties['nf-role'] === vm.changeManagement.vnfType &&
675 selectedVersionNumber === getVersionNameForId(vnf.properties["model-version-id"])) {
678 _.forEach(vnf['related-to'], function (node) {
679 if (node['node-type'] === 'vserver') {
680 vServer = extractLcpRegionIdAndTenantId(node.url);
684 var serviceInstancesIds =
685 _.filter(vnf['related-to'], {'node-type': 'service-instance'})
686 .map(function (serviceInstance) {
687 return serviceInstance.id
690 var serviceInstances = _.filter(vm.serviceInstances, function (serviceInstance) {
691 return _.includes(serviceInstancesIds, serviceInstance.id);
695 if (serviceInstancesIds.length === 0) {
696 $log.error("loadVNFNames: no serviceInstancesIds for vnf", vnf);
698 $log.debug("loadVNFNames: serviceInstancesIds", serviceInstancesIds);
699 $log.debug("loadVNFNames: serviceInstances", serviceInstances);
703 "id": vnf.properties["vnf-id"],
704 "name": vnf.properties["vnf-name"],
705 "invariant-id": vnf.properties["model-invariant-id"],
706 "service-instance-node": serviceInstances,
707 "modelVersionId": vnf.properties["model-version-id"],
708 "properties": vnf.properties,
709 'cloudConfiguration': vServer,
710 "relatedTo": vnf['related-to']
716 function extractLcpRegionIdAndTenantId(url) {
718 var cloudConfiguration = {
719 lcpCloudRegionId: '',
724 e.g., in both URLs below -
725 Â - lcpCloudRegionId == 'rdm5b'
726 Â - tenantId == '0675e0709bd7444a9e13eba8b40edb3c'
728 "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"
729 "url": "/aai/v11/cloud-infrastructure/cloud-regions/cloud-region/irma-aic/rdm5b/tenants/tenant/0675e0709bd7444a9e13eba8b40edb3c/vservers/vserver/932b330d-733e-427d-a519-14eebd261f70"
732 var cloudRegionMatch = url.match(/\/cloud-regions\/cloud-region\/[^\/]+\/([^\/]+)/);
733 var tenantMatch = url.match(/\/tenants\/tenant\/([^\/]+)/);
735 cloudConfiguration.lcpCloudRegionId = cloudRegionMatch[1];
736 cloudConfiguration.tenantId = tenantMatch[1];
738 return cloudConfiguration;
741 vm.loadWorkFlows = function () {
742 vm.localWorkflowsParameters = new Map();
743 vm.remoteWorkflowsParameters = new Map();
744 if (featureFlags.isOn(COMPONENT.FEATURE_FLAGS.FLAG_HANDLE_SO_WORKFLOWS)) {
745 return vm.loadRemoteWorkFlows()
747 vm.workflows = vm.remoteWorkflows.map(item => item.name);
748 }).then(function () {
749 vm.loadRemoteWorkFlowsParameters();
752 return vm.loadLocalWorkFlows()
753 .then(vm.loadLocalWorkFlowsParameters)
755 vm.workflows = vm.localWorkflows;
760 vm.loadLocalWorkFlows = function () {
761 return changeManagementService.getWorkflows(vm.changeManagement.vnfNames)
762 .then(function (response) {
763 vm.localWorkflows = response.data.workflows || [];
764 }).catch(function (error) {
770 vm.loadRemoteWorkFlows = function () {
771 let vnfModelIDs = vm.changeManagement.vnfNames.map(vnfName => vnfName.modelVersionId);
772 return changeManagementService.getSOWorkflows(vnfModelIDs)
773 .then(function (response) {
774 vm.remoteWorkflows = response.data || [];
775 }).catch(function (error) {
781 vm.loadLocalWorkFlowsParameters = function () {
782 vm.localWorkflows.forEach(function (workflow) {
783 vm.loadLocalWorkFlowParameters(workflow);
787 vm.loadLocalWorkFlowParameters = function (workflow) {
788 changeManagementService.getLocalWorkflowParameter(workflow)
789 .then(function (response) {
790 vm.localWorkflowsParameters.set(workflow, response.data.parameterDefinitions);
792 .catch(function (error) {
798 vm.loadRemoteWorkFlowsParameters = function () {
799 vm.remoteWorkflows.forEach(function (workflow) {
800 if (workflow.source === 'SDC' || workflow.source === 'sdc') {
801 vm.loadRemoteWorkFlowParameters(workflow);
803 vm.loadLocalWorkFlowParameters(workflow.name);
808 vm.loadRemoteWorkFlowParameters = function (workflow) {
810 workflow.workflowInputParameters
811 .filter(function (param) {
812 return param.soPayloadLocation === "userParams"
814 .forEach(function (param) {
815 let workflowParams = vm.repackAttributes(param);
816 if (param.validation.length > 0) {
817 let validation = param.validation[0];
818 if ('maxLength' in validation) {
819 workflowParams.maxLength = validation.maxLength;
821 if ('allowableChars' in validation) {
822 workflowParams.pattern = validation.allowableChars;
825 workflowParams.type = param.inputType;
827 parameters.push(workflowParams);
830 vm.remoteWorkflowsParameters.set(workflow.name, parameters);
833 vm.repackAttributes = function (workflowParam) {
835 name: workflowParam.label,
836 required: workflowParam.required,
837 id: workflowParam.soFieldName,
838 soFieldName: workflowParam.soFieldName,
844 vm.getRemoteWorkFlowParameters = function (workflow) {
845 if (workflow && vm.remoteWorkflowsParameters.has(workflow)) {
846 return vm.remoteWorkflowsParameters.get(workflow)
851 vm.hasPatternError = function (form, itemName) {
852 return form[itemName].$error.pattern;
855 vm.hasAsyncFnError = function (form, itemName) {
856 return form[itemName].$error.validateAsyncFn;
859 vm.getIdFor = function (type, id, name) {
860 return "internal-workflow-parameter-" + type + "-" + id + "-" + (name ? name.split(' ').join('-').toLowerCase() : "");
863 vm.getInternalWorkFlowParameters = function (workflow, type) {
864 if (workflow && vm.localWorkflowsParameters.has(workflow) && vm.localWorkflowsParameters.get(workflow).filter(parameter => parameter.type == type) != []) {
865 return vm.localWorkflowsParameters.get(workflow).filter(parameter => parameter.type == type);
870 vm.getInternalWorkFlowParameter = function (workflow, type, parameterName) {
871 if (workflow && vm.localWorkflowsParameters.has(workflow) && vm.localWorkflowsParameters.get(workflow).filter(parameter => parameter.type == type) != []) {
872 return vm.localWorkflowsParameters.get(workflow).filter(parameter => parameter.type == type).filter(parameter => parameter.name === parameterName)[0]
876 vm.getRemoteWorkflowSource = (workflow) => {
877 return vm.getCachedWorkflowDetails(workflow)[0].source;
880 vm.getCachedWorkflowDetails = function (workflow) {
881 return vm.remoteWorkflows.filter(function (remoteWorkflow) {
882 return remoteWorkflow.name === workflow;
887 //Must be $scope because we bind to the onchange of the html (cannot attached to vm variable).
888 $scope.selectFileForVNFName = function (fileInput) {
889 if (fileInput && fileInput.id) {
890 var vnfName = _.filter(vm.changeManagement.vnfNames, {"invariant-id": fileInput.id});
891 var file = fileInput.files[0];
892 var fileReader = new FileReader();
893 fileReader.onload = function (load) {
895 var lines = load.target.result;
896 vnfName[0].selectedFile = JSON.parse(lines);
902 fileReader.readAsText(file);
906 vm.selectVersionForVNFName = function (vnfName) {
907 console.log("Will add version for selected vnf name: " + vnfName.name);
910 vm.isConfigUpdate = function () {
911 return vm.changeManagement.workflow === COMPONENT.WORKFLOWS.vnfConfigUpdate;
914 vm.isScaleOut = function () {
915 return vm.changeManagement.workflow === COMPONENT.WORKFLOWS.vnfScaleOut;
918 vm.shouldShowVnfInPlaceFields = function () {
919 return vm.changeManagement.workflow === COMPONENT.WORKFLOWS.vnfInPlace;
922 vm.setPreload = function (fileEl) {
923 var files = fileEl.files;
925 var reader = new FileReader();
927 reader.onloadend = function (evt) {
928 if (evt.target.readyState === FileReader.DONE) {
929 $scope.$apply(function () {
930 $scope.moduleArr[0].userParams = JSON.parse(evt.target.result);
935 reader.readAsText(file);