inherit SOTN codes for CCVPN Services

Change-Id: Idaa55084f5ecb0dd3636c232cebc14fa60000000
Issue-ID: SO-683
Signed-off-by: Yulian Han <elaine.hanyulian@huawei.com>

2 files changed, 444 insertions, 1 deletions

diff --git a/bpmn/MSOInfrastructureBPMN/src/main/java/org/openecomp/mso/bpmn/infrastructure/workflow/service/ServicePluginFactory.java b/bpmn/MSOInfrastructureBPMN/src/main/java/org/openecomp/mso/bpmn/infrastructure/workflow/service/ServicePluginFactory.java
new file mode 100644
index 0000000000..344d8cd4fa
--- /dev/null
+++ b/bpmn/MSOInfrastructureBPMN/src/main/java/org/openecomp/mso/bpmn/infrastructure/workflow/service/ServicePluginFactory.java
@@ -0,0 +1,443 @@
+/*-
+ * ============LICENSE_START=======================================================
+ * ONAP - SO
+ * ================================================================================
+ * Copyright (C) 2018 Huawei Intellectual Property. All rights reserved.
+ * ================================================================================
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ * ============LICENSE_END=========================================================
+ */
+
+package org.openecomp.mso.bpmn.infrastructure.workflow.service;
+
+import java.io.IOException;
+import java.net.SocketTimeoutException;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.Map.Entry;
+
+import org.apache.http.HttpResponse;
+import org.apache.http.ParseException;
+import org.apache.http.client.HttpClient;
+import org.apache.http.client.config.RequestConfig;
+import org.apache.http.client.methods.HttpDelete;
+import org.apache.http.client.methods.HttpGet;
+import org.apache.http.client.methods.HttpPost;
+import org.apache.http.client.methods.HttpPut;
+import org.apache.http.client.methods.HttpRequestBase;
+import org.apache.http.conn.ConnectTimeoutException;
+import org.apache.http.entity.ContentType;
+import org.apache.http.entity.StringEntity;
+import org.apache.http.impl.client.HttpClientBuilder;
+import org.apache.http.util.EntityUtils;
+import org.camunda.bpm.engine.runtime.Execution;
+import org.openecomp.mso.bpmn.core.PropertyConfiguration;
+import org.openecomp.mso.bpmn.core.domain.ServiceDecomposition;
+import org.openecomp.mso.bpmn.core.json.JsonUtils;
+import org.openecomp.mso.logger.MessageEnum;
+import org.openecomp.mso.logger.MsoLogger;
+
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.fasterxml.jackson.databind.SerializationFeature;
+
+public class ServicePluginFactory {
+
+	// SOTN calculate route
+	public static final String OOF_Default_EndPoint = "http://192.168.1.223:8443/oof/sotncalc";
+
+	public static final String Third_SP_Default_EndPoint = "http://192.168.1.223:8443/sp/resourcemgr/querytps";
+
+	private static final int DEFAULT_TIME_OUT = 60000;
+
+	static JsonUtils jsonUtil = new JsonUtils();
+
+	private static MsoLogger LOGGER = MsoLogger.getMsoLogger(MsoLogger.Catalog.RA);
+
+	private static ServicePluginFactory instance;
+	
+
+	public static synchronized ServicePluginFactory getInstance() {
+		if (null == instance) {
+			instance = new ServicePluginFactory();
+		}
+		return instance;
+	}
+
+	private ServicePluginFactory() {
+
+	}
+	
+	public String test()
+	{
+		return "";
+	}
+	
+	private String getThirdSPEndPoint(){
+	    Map<String, String> properties = PropertyConfiguration.getInstance().getProperties("topology.properties");
+	    if (properties != null) {
+	        String thirdSPEndPoint = properties.get("third-sp-endpoint");
+	        if(null != thirdSPEndPoint && !thirdSPEndPoint.isEmpty()){
+	        	return thirdSPEndPoint;
+	        }
+	    }
+		return Third_SP_Default_EndPoint;
+	}
+
+	private String getOOFCalcEndPoint(){
+	    Map<String, String> properties = PropertyConfiguration.getInstance().getProperties("topology.properties");
+	    if (properties != null) {
+	        String oofCalcEndPoint = properties.get("oof-calc-endpoint");
+	        if(null != oofCalcEndPoint && !oofCalcEndPoint.isEmpty()){
+	        	return oofCalcEndPoint;
+	        }
+	    }
+		return OOF_Default_EndPoint;
+	}
+	
+
+	public String preProcessService(ServiceDecomposition serviceDecomposition, String uuiRequest) {
+
+		// now only for sotn
+		if (isSOTN(serviceDecomposition, uuiRequest)) {
+			// We Need to query the terminalpoint of the VPN by site location
+			// info
+			return preProcessSOTNService(serviceDecomposition, uuiRequest);
+		}
+		return uuiRequest;
+	}
+
+	public String doServiceHoming(ServiceDecomposition serviceDecomposition, String uuiRequest) {
+		// now only for sotn
+		if (isSOTN(serviceDecomposition, uuiRequest)) {
+			return doSOTNServiceHoming(serviceDecomposition, uuiRequest);
+		}
+		return uuiRequest;
+	}
+
+	private boolean isSOTN(ServiceDecomposition serviceDecomposition, String uuiRequest) {
+		// there should be a register platform , we check it very simple here.
+		return uuiRequest.contains("clientSignal") && uuiRequest.contains("vpnType");
+	}
+
+	private String preProcessSOTNService(ServiceDecomposition serviceDecomposition, String uuiRequest) {
+		Map<String, Object> uuiObject = getJsonObject(uuiRequest, Map.class);
+		Map<String, Object> serviceObject = (Map<String, Object>) uuiObject.get("service");
+		Map<String, Object> serviceParametersObject = (Map<String, Object>) serviceObject.get("parameters");
+		Map<String, Object> serviceRequestInputs = (Map<String, Object>) serviceParametersObject.get("requestInputs");
+		List<Object> resources = (List<Object>) serviceParametersObject.get("resources");
+		// This is a logic for demo , it could not be finalized to community.
+		String srcLocation = "";
+		String dstLocation = "";
+		String srcClientSignal = "";
+		String dstClientSignal = "";
+		// support R2 uuiReq and R1 uuiReq
+		// logic for R2 uuiRequest params in service level
+		for (Entry<String, Object> entry : serviceRequestInputs.entrySet()) {
+			if (entry.getKey().toLowerCase().contains("location")) {
+				if ("".equals(srcLocation)) {
+					srcLocation = (String) entry.getValue();
+				} else if ("".equals(dstLocation)) {
+					dstLocation = (String) entry.getValue();
+				}
+			}
+			if (entry.getKey().toLowerCase().contains("clientsignal")) {
+				if ("".equals(srcClientSignal)) {
+					srcClientSignal = (String) entry.getValue();
+				} else if ("".equals(dstClientSignal)) {
+					dstClientSignal = (String) entry.getValue();
+				}
+			}
+		}
+
+		// logic for R1 uuiRequest, params in resource level
+		for (Object resource : resources) {
+			Map<String, Object> resourceObject = (Map<String, Object>) resource;
+			Map<String, Object> resourceParametersObject = (Map<String, Object>) resourceObject.get("parameters");
+			Map<String, Object> resourceRequestInputs = (Map<String, Object>) resourceParametersObject
+					.get("requestInputs");
+			for (Entry<String, Object> entry : resourceRequestInputs.entrySet()) {
+				if (entry.getKey().toLowerCase().contains("location")) {
+					if ("".equals(srcLocation)) {
+						srcLocation = (String) entry.getValue();
+					} else if ("".equals(dstLocation)) {
+						dstLocation = (String) entry.getValue();
+					}
+				}
+				if (entry.getKey().toLowerCase().contains("clientsignal")) {
+					if ("".equals(srcClientSignal)) {
+						srcClientSignal = (String) entry.getValue();
+					} else if ("".equals(dstClientSignal)) {
+						dstClientSignal = (String) entry.getValue();
+					}
+				}
+			}
+		}
+
+		Map<String, Object> vpnRequestInputs = getVPNResourceRequestInputs(resources);
+		// here we put client signal to vpn resource inputs
+		vpnRequestInputs.put("src-client-signal", srcClientSignal);
+		vpnRequestInputs.put("dst-client-signal", dstClientSignal);
+
+		// Now we need to query terminal points from SP resourcemgr system.
+		List<Object> locationTerminalPointList = queryTerminalPointsFromServiceProviderSystem(srcLocation, dstLocation);
+		Map<String, Object> tpInfoMap = (Map<String, Object>) locationTerminalPointList.get(0);
+
+		serviceRequestInputs.put("inner-src-access-provider-id", tpInfoMap.get("access-provider-id"));
+		serviceRequestInputs.put("inner-src-access-client-id", tpInfoMap.get("access-client-id"));
+		serviceRequestInputs.put("inner-src-access-topology-id", tpInfoMap.get("access-topology-id"));
+		serviceRequestInputs.put("inner-src-access-node-id", tpInfoMap.get("access-node-id"));
+		serviceRequestInputs.put("inner-src-access-ltp-id", tpInfoMap.get("access-ltp-id"));
+		tpInfoMap = (Map<String, Object>) locationTerminalPointList.get(1);
+
+		serviceRequestInputs.put("inner-dst-access-provider-id", tpInfoMap.get("access-provider-id"));
+		serviceRequestInputs.put("inner-dst-access-client-id", tpInfoMap.get("access-client-id"));
+		serviceRequestInputs.put("inner-dst-access-topology-id", tpInfoMap.get("access-topology-id"));
+		serviceRequestInputs.put("inner-dst-access-node-id", tpInfoMap.get("access-node-id"));
+		serviceRequestInputs.put("inner-dst-access-ltp-id", tpInfoMap.get("access-ltp-id"));
+
+		String newRequest = getJsonString(uuiObject);
+		return newRequest;
+	}
+
+	private List<Object> queryTerminalPointsFromServiceProviderSystem(String srcLocation, String dstLocation) {
+		Map<String, String> locationSrc = new HashMap<String, String>();
+		locationSrc.put("location", srcLocation);
+		Map<String, String> locationDst = new HashMap<String, String>();
+		locationDst.put("location", dstLocation);
+		List<Map<String, String>> locations = new ArrayList<Map<String, String>>();
+		locations.add(locationSrc);
+		locations.add(locationDst);
+		List<Object> returnList = new ArrayList<Object>();
+		String reqContent = getJsonString(locations);
+		String url = getThirdSPEndPoint();
+		String responseContent = sendRequest(url, "POST", reqContent);
+		if (null != responseContent) {
+			returnList = getJsonObject(responseContent, List.class);
+		}
+		return returnList;
+	}
+
+	private Map<String, Object> getVPNResourceRequestInputs(List<Object> resources) {
+		for (Object resource : resources) {
+			Map<String, Object> resourceObject = (Map<String, Object>) resource;
+			Map<String, Object> resourceParametersObject = (Map<String, Object>) resourceObject.get("parameters");
+			Map<String, Object> resourceRequestInputs = (Map<String, Object>) resourceParametersObject
+					.get("requestInputs");
+			for (Entry<String, Object> entry : resourceRequestInputs.entrySet()) {
+				if (entry.getKey().toLowerCase().contains("vpntype")) {
+					return resourceRequestInputs;
+				}
+			}
+		}
+		return null;
+	}
+	
+	public static void main(String args[]){
+		String str = "restconf/config/GENERIC-RESOURCE-API:services/service/eca7e542-12ba-48de-8544-fac59303b14e/service-data/networks/network/aec07806-1671-4af2-b722-53c8e320a633/network-data/";
+		
+		int index1 = str.indexOf("/network/");
+		int index2 = str.indexOf("/network-data");
+		
+		String str1 = str.substring(index1 + "/network/".length(), index2);
+		System.out.println(str1);
+		
+	}
+
+	private String doSOTNServiceHoming(ServiceDecomposition serviceDecomposition, String uuiRequest) {
+		// query the route for the service.
+		Map<String, Object> uuiObject = getJsonObject(uuiRequest, Map.class);
+		Map<String, Object> serviceObject = (Map<String, Object>) uuiObject.get("service");
+		Map<String, Object> serviceParametersObject = (Map<String, Object>) serviceObject.get("parameters");
+		Map<String, Object> serviceRequestInputs = (Map<String, Object>) serviceParametersObject.get("requestInputs");
+		Map<String, Object> oofQueryObject = new HashMap<String, Object>();
+		List<Object> resources = (List<Object>) serviceParametersObject.get("resources");
+		oofQueryObject.put("src-access-provider-id", serviceRequestInputs.get("inner-src-access-provider-id"));
+		oofQueryObject.put("src-access-client-id", serviceRequestInputs.get("inner-src-access-client-id"));
+		oofQueryObject.put("src-access-topology-id", serviceRequestInputs.get("inner-src-access-topology-id"));
+		oofQueryObject.put("src-access-node-id", serviceRequestInputs.get("inner-src-access-node-id"));
+		oofQueryObject.put("src-access-ltp-id", serviceRequestInputs.get("inner-src-access-ltp-id"));
+		oofQueryObject.put("dst-access-provider-id", serviceRequestInputs.get("inner-dst-access-provider-id"));
+		oofQueryObject.put("dst-access-client-id", serviceRequestInputs.get("inner-dst-access-client-id"));
+		oofQueryObject.put("dst-access-topology-id", serviceRequestInputs.get("inner-dst-access-topology-id"));
+		oofQueryObject.put("dst-access-node-id", serviceRequestInputs.get("inner-dst-access-node-id"));
+		oofQueryObject.put("dst-access-ltp-id", serviceRequestInputs.get("inner-dst-access-ltp-id"));
+		String oofRequestReq = getJsonString(oofQueryObject);
+		String url = getOOFCalcEndPoint();
+		String responseContent = sendRequest(url, "POST", oofRequestReq);
+
+		List<Object> returnList = new ArrayList<Object>();
+		if (null != responseContent) {
+			returnList = getJsonObject(responseContent, List.class);
+		}
+		// in demo we have only one VPN. no cross VPNs, so get first item.
+		Map<String, Object> returnRoute = getReturnRoute(returnList);
+		Map<String, Object> vpnRequestInputs = getVPNResourceRequestInputs(resources);
+		vpnRequestInputs.putAll(returnRoute);
+		String newRequest = getJsonString(uuiObject);
+		return newRequest;
+	}
+	
+	private Map<String, Object> getReturnRoute(List<Object> returnList){
+		Map<String, Object> returnRoute = new HashMap<String,Object>();
+		for(Object returnVpn :returnList){
+			Map<String, Object> returnVpnInfo = (Map<String, Object>) returnVpn;
+		    String accessTopoId = (String)returnVpnInfo.get("access-topology-id");
+			if("100".equals(accessTopoId)){
+				returnRoute.putAll(returnVpnInfo);
+			}
+			else if("101".equals(accessTopoId)){
+				for(String key : returnVpnInfo.keySet()){
+					returnRoute.put("domain1-" + key, returnVpnInfo.get(key));
+				}
+			}
+			else if("102".equals(accessTopoId)){
+				for(String key : returnVpnInfo.keySet()){
+					returnRoute.put("domain2-" + key, returnVpnInfo.get(key));
+				}
+			}
+			else{
+				for(String key : returnVpnInfo.keySet()){
+					returnRoute.put("domain" + accessTopoId +"-" + key, returnVpnInfo.get(key));
+				}
+			}
+		}
+		return returnRoute;
+	}
+
+	private Map<String, Object> getResourceParams(Execution execution, String resourceCustomizationUuid,
+			String serviceParameters) {
+		List<String> resourceList = jsonUtil.StringArrayToList(execution,
+				(String) JsonUtils.getJsonValue(serviceParameters, "resources"));
+		// Get the right location str for resource. default is an empty array.
+		String resourceInputsFromUui = "";
+		for (String resource : resourceList) {
+			String resCusUuid = (String) JsonUtils.getJsonValue(resource, "resourceCustomizationUuid");
+			if (resourceCustomizationUuid.equals(resCusUuid)) {
+				String resourceParameters = JsonUtils.getJsonValue(resource, "parameters");
+				resourceInputsFromUui = JsonUtils.getJsonValue(resourceParameters, "requestInputs");
+			}
+		}
+		Map<String, Object> resourceInputsFromUuiMap = getJsonObject(resourceInputsFromUui, Map.class);
+		return resourceInputsFromUuiMap;
+	}
+
+	public static <T> T getJsonObject(String jsonstr, Class<T> type) {
+		ObjectMapper mapper = new ObjectMapper();
+		mapper.configure(SerializationFeature.WRAP_ROOT_VALUE, true);
+		try {
+			return mapper.readValue(jsonstr, type);
+		} catch (IOException e) {
+			LOGGER.error(MessageEnum.RA_NS_EXC, "", "", MsoLogger.ErrorCode.BusinessProcesssError,
+					"fail to unMarshal json", e);
+		}
+		return null;
+	}
+
+	public static String getJsonString(Object srcObj) {
+		ObjectMapper mapper = new ObjectMapper();
+		mapper.configure(SerializationFeature.WRAP_ROOT_VALUE, false);
+		String jsonStr = null;
+		try {
+			jsonStr = mapper.writeValueAsString(srcObj);
+		} catch (JsonProcessingException e) {
+			LOGGER.debug("SdcToscaParserException", e);
+			e.printStackTrace();
+		}
+		return jsonStr;
+	}
+
+	private static String sendRequest(String url, String methodType, String content) {
+		
+		String msbUrl = url;
+		HttpRequestBase method = null;
+		HttpResponse httpResponse = null;
+
+		try {
+			int timeout = DEFAULT_TIME_OUT;
+
+			RequestConfig requestConfig = RequestConfig.custom().setSocketTimeout(timeout).setConnectTimeout(timeout)
+					.setConnectionRequestTimeout(timeout).build();
+
+			HttpClient client = HttpClientBuilder.create().build();
+
+			if ("POST".equals(methodType.toUpperCase())) {
+				HttpPost httpPost = new HttpPost(msbUrl);
+				httpPost.setConfig(requestConfig);
+				httpPost.setEntity(new StringEntity(content, ContentType.APPLICATION_JSON));
+				method = httpPost;
+			} else if ("PUT".equals(methodType.toUpperCase())) {
+				HttpPut httpPut = new HttpPut(msbUrl);
+				httpPut.setConfig(requestConfig);
+				httpPut.setEntity(new StringEntity(content, ContentType.APPLICATION_JSON));
+				method = httpPut;
+			} else if ("GET".equals(methodType.toUpperCase())) {
+				HttpGet httpGet = new HttpGet(msbUrl);
+				httpGet.setConfig(requestConfig);
+				method = httpGet;
+			} else if ("DELETE".equals(methodType.toUpperCase())) {
+				HttpDelete httpDelete = new HttpDelete(msbUrl);
+				httpDelete.setConfig(requestConfig);
+				method = httpDelete;
+			}
+
+			// now have no auth
+			// String userCredentials =
+			// SDNCAdapterProperties.getEncryptedProperty(Constants.SDNC_AUTH_PROP,
+			// Constants.DEFAULT_SDNC_AUTH, Constants.ENCRYPTION_KEY);
+			// String authorization = "Basic " +
+			// DatatypeConverter.printBase64Binary(userCredentials.getBytes());
+			// method.setHeader("Authorization", authorization);
+
+			httpResponse = client.execute(method);
+			String responseContent = null;
+			if (null != httpResponse && httpResponse.getEntity() != null) {
+				try {
+					responseContent = EntityUtils.toString(httpResponse.getEntity(), "UTF-8");
+				} catch (ParseException e) {
+					e.printStackTrace();
+				} catch (IOException e) {
+					e.printStackTrace();
+				}
+			}
+			if (null != method) {
+				method.reset();
+			}
+			method = null;
+			return responseContent;
+
+		} catch (SocketTimeoutException | ConnectTimeoutException e) {
+			return null;
+
+		} catch (Exception e) {
+			return null;
+
+		} finally {
+			if (httpResponse != null) {
+				try {
+					EntityUtils.consume(httpResponse.getEntity());
+				} catch (Exception e) {
+				}
+			}
+			if (method != null) {
+				try {
+					method.reset();
+				} catch (Exception e) {
+
+				}
+			}
+		}
+	}
+}
diff --git a/bpmn/MSOInfrastructureBPMN/src/main/java/org/openecomp/mso/bpmn/infrastructure/workflow/serviceTask/client/builder/AbstractBuilder.java b/bpmn/MSOInfrastructureBPMN/src/main/java/org/openecomp/mso/bpmn/infrastructure/workflow/serviceTask/client/builder/AbstractBuilder.java
index 09561a620e..2f5bda6f46 100644
--- a/bpmn/MSOInfrastructureBPMN/src/main/java/org/openecomp/mso/bpmn/infrastructure/workflow/serviceTask/client/builder/AbstractBuilder.java
+++ b/bpmn/MSOInfrastructureBPMN/src/main/java/org/openecomp/mso/bpmn/infrastructure/workflow/serviceTask/client/builder/AbstractBuilder.java
@@ -231,7 +231,7 @@ public abstract class AbstractBuilder<IN, OUT> {
 
      protected ServiceInformationEntity getServiceInformationEntity(DelegateExecution execution) {
           ServiceInformationEntity serviceInformationEntity = new ServiceInformationEntity();
-          serviceInformationEntity.setServiceId("VOLTE_SERVICE_ID");
+          serviceInformationEntity.setServiceId((String) execution.getVariable("serviceInstanceId"));
           serviceInformationEntity.setSubscriptionServiceType((String) execution.getVariable("serviceType"));
           serviceInformationEntity.setOnapModelInformation(getOnapServiceModelInformationEntity(execution));
           serviceInformationEntity.setServiceInstanceId((String) execution.getVariable("serviceInstanceId"));