2 * ============LICENSE_START=======================================================
4 * ================================================================================
5 * Copyright (C) 2017 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=========================================================
21 package org.onap.so.client.sdnc.mapper;
24 import java.util.UUID;
26 import org.onap.so.bpmn.servicedecomposition.bbobjects.CloudRegion;
27 import org.onap.so.bpmn.servicedecomposition.bbobjects.Customer;
28 import org.onap.so.bpmn.servicedecomposition.bbobjects.GenericVnf;
29 import org.onap.so.bpmn.servicedecomposition.bbobjects.VfModule;
30 import org.onap.so.bpmn.servicedecomposition.bbobjects.VolumeGroup;
31 import org.onap.so.bpmn.servicedecomposition.generalobjects.RequestContext;
32 import org.onap.so.bpmn.servicedecomposition.bbobjects.ServiceInstance;
33 import org.onap.so.client.sdnc.beans.SDNCSvcAction;
34 import org.onap.so.client.sdnc.beans.SDNCSvcOperation;
35 import org.onap.so.logger.MessageEnum;
36 import org.onap.so.logger.MsoLogger;
37 import org.springframework.stereotype.Component;
39 import org.onap.sdnc.apps.client.model.GenericResourceApiParam;
40 import org.onap.sdnc.apps.client.model.GenericResourceApiParamParam;
41 import org.onap.sdnc.apps.client.model.GenericResourceApiRequestActionEnumeration;
42 import org.onap.sdnc.apps.client.model.GenericResourceApiRequestinformationRequestInformation;
43 import org.onap.sdnc.apps.client.model.GenericResourceApiSdncrequestheaderSdncRequestHeader;
44 import org.onap.sdnc.apps.client.model.GenericResourceApiServiceinformationServiceInformation;
45 import org.onap.sdnc.apps.client.model.GenericResourceApiSvcActionEnumeration;
46 import org.onap.sdnc.apps.client.model.GenericResourceApiVfModuleOperationInformation;
47 import org.onap.sdnc.apps.client.model.GenericResourceApiVnfinformationVnfInformation;
48 import org.onap.sdnc.apps.client.model.GenericResourceApiVfmoduleinformationVfModuleInformation;
49 import org.onap.sdnc.apps.client.model.GenericResourceApiVfmodulerequestinputVfModuleRequestInput;
50 import org.onap.sdnc.apps.client.model.GenericResourceApiVfModuleResponseInformation;
52 import com.fasterxml.jackson.databind.ObjectMapper;
55 public class VfModuleTopologyOperationRequestMapper {
56 private static final MsoLogger msoLogger = MsoLogger.getMsoLogger(MsoLogger.Catalog.BPEL, VfModuleTopologyOperationRequestMapper.class);
57 static GeneralTopologyObjectMapper generalTopologyObjectMapper = new GeneralTopologyObjectMapper();
59 public GenericResourceApiVfModuleOperationInformation reqMapper(SDNCSvcOperation svcOperation,
60 SDNCSvcAction svcAction, VfModule vfModule, VolumeGroup volumeGroup, GenericVnf vnf, ServiceInstance serviceInstance,
61 Customer customer, CloudRegion cloudRegion, RequestContext requestContext, String sdncAssignResponse) {
62 GenericResourceApiVfModuleOperationInformation req = new GenericResourceApiVfModuleOperationInformation();
64 boolean includeModelInformation = false;
66 GenericResourceApiRequestActionEnumeration requestAction = GenericResourceApiRequestActionEnumeration.CREATEVFMODULEINSTANCE;
67 GenericResourceApiSvcActionEnumeration genericResourceApiSvcAction = GenericResourceApiSvcActionEnumeration.ASSIGN;
69 if (svcAction.equals(SDNCSvcAction.ACTIVATE)) {
70 genericResourceApiSvcAction = GenericResourceApiSvcActionEnumeration.ACTIVATE;
71 requestAction = GenericResourceApiRequestActionEnumeration.CREATEVFMODULEINSTANCE;
72 includeModelInformation = true;
73 } else if (svcAction.equals(SDNCSvcAction.ASSIGN)) {
74 genericResourceApiSvcAction = GenericResourceApiSvcActionEnumeration.ASSIGN;
75 requestAction = GenericResourceApiRequestActionEnumeration.CREATEVFMODULEINSTANCE;
76 includeModelInformation = true;
77 } else if (svcAction.equals(SDNCSvcAction.DEACTIVATE)) {
78 genericResourceApiSvcAction = GenericResourceApiSvcActionEnumeration.DEACTIVATE;
79 requestAction = GenericResourceApiRequestActionEnumeration.DELETEVFMODULEINSTANCE;
80 includeModelInformation = false;
81 } else if (svcAction.equals(SDNCSvcAction.DELETE)) {
82 genericResourceApiSvcAction = GenericResourceApiSvcActionEnumeration.DELETE;
83 requestAction = GenericResourceApiRequestActionEnumeration.DELETEVFMODULEINSTANCE;
84 includeModelInformation = false;
85 } else if (svcAction.equals(SDNCSvcAction.UNASSIGN)) {
86 genericResourceApiSvcAction = GenericResourceApiSvcActionEnumeration.UNASSIGN;
87 requestAction = GenericResourceApiRequestActionEnumeration.DELETEVFMODULEINSTANCE;
88 includeModelInformation = false;
91 String sdncReqId = UUID.randomUUID().toString();
93 GenericResourceApiRequestinformationRequestInformation requestInformation = generalTopologyObjectMapper.buildGenericResourceApiRequestinformationRequestInformation(sdncReqId,
95 GenericResourceApiServiceinformationServiceInformation serviceInformation = generalTopologyObjectMapper.buildServiceInformation(serviceInstance, requestContext, customer, includeModelInformation);
96 GenericResourceApiVnfinformationVnfInformation vnfInformation = generalTopologyObjectMapper.buildVnfInformation(vnf, serviceInstance, includeModelInformation);
97 GenericResourceApiVfmoduleinformationVfModuleInformation vfModuleInformation = generalTopologyObjectMapper.buildVfModuleInformation(vfModule, vnf, serviceInstance, includeModelInformation);
98 GenericResourceApiVfmodulerequestinputVfModuleRequestInput vfModuleRequestInput = buildVfModuleRequestInput(vfModule, volumeGroup, cloudRegion, requestContext);
99 GenericResourceApiSdncrequestheaderSdncRequestHeader sdncRequestHeader = buildVfModuleSdncRequestHeader(sdncReqId, genericResourceApiSvcAction);
101 req.setRequestInformation(requestInformation);
102 req.setSdncRequestHeader(sdncRequestHeader);
103 req.setServiceInformation(serviceInformation);
104 req.setVnfInformation(vnfInformation);
105 req.setVfModuleInformation(vfModuleInformation);
106 req.setVfModuleRequestInput(vfModuleRequestInput);
111 private GenericResourceApiVfmodulerequestinputVfModuleRequestInput buildVfModuleRequestInput(VfModule vfModule, VolumeGroup volumeGroup, CloudRegion cloudRegion, RequestContext requestContext) {
112 GenericResourceApiVfmodulerequestinputVfModuleRequestInput vfModuleRequestInput = new GenericResourceApiVfmodulerequestinputVfModuleRequestInput();
113 if (cloudRegion != null) {
114 vfModuleRequestInput.setTenant(cloudRegion.getTenantId());
115 vfModuleRequestInput.setAicCloudRegion(cloudRegion.getLcpCloudRegionId());
117 if (vfModule.getVfModuleName() != null && !vfModule.getVfModuleName().equals("")) {
118 vfModuleRequestInput.setVfModuleName(vfModule.getVfModuleName());
120 GenericResourceApiParam vfModuleInputParameters = new GenericResourceApiParam();
122 if (requestContext != null && requestContext.getUserParams() != null) {
123 for (Map.Entry<String, String> entry : requestContext.getUserParams().entrySet()) {
124 GenericResourceApiParamParam paramItem = new GenericResourceApiParamParam();
125 paramItem.setName(entry.getKey());
126 paramItem.setValue(entry.getValue());
127 vfModuleInputParameters.addParamItem(paramItem);
131 if (volumeGroup != null) {
132 GenericResourceApiParamParam paramItem = new GenericResourceApiParamParam();
133 paramItem.setName("volume-group-id");
134 paramItem.setValue(volumeGroup.getVolumeGroupId());
135 vfModuleInputParameters.addParamItem(paramItem);
137 vfModuleRequestInput.setVfModuleInputParameters(vfModuleInputParameters);
139 return vfModuleRequestInput;
142 private GenericResourceApiSdncrequestheaderSdncRequestHeader buildVfModuleSdncRequestHeader(String sdncReqId, GenericResourceApiSvcActionEnumeration svcAction) {
143 GenericResourceApiSdncrequestheaderSdncRequestHeader sdncRequestHeader = new GenericResourceApiSdncrequestheaderSdncRequestHeader();
145 sdncRequestHeader.setSvcRequestId(sdncReqId);
146 sdncRequestHeader.setSvcAction(svcAction);
148 return sdncRequestHeader;
151 public String buildObjectPath(String sdncAssignResponse) {
152 String objectPath = null;
153 if (sdncAssignResponse != null) {
154 ObjectMapper mapper = new ObjectMapper();
156 GenericResourceApiVfModuleResponseInformation assignResponseInfo = mapper.readValue(sdncAssignResponse, GenericResourceApiVfModuleResponseInformation.class);
157 objectPath = assignResponseInfo.getVfModuleResponseInformation().getObjectPath();
158 } catch (Exception e) {
159 msoLogger.error(MessageEnum.RA_RESPONSE_FROM_SDNC, e.getMessage(), "BPMN", MsoLogger.getServiceName(), MsoLogger.ErrorCode.UnknownError, e.getMessage());