aboutsummaryrefslogtreecommitdiffstats
path: root/bpmn/MSOInfrastructureBPMN/src/main/java/org/openecomp/mso/bpmn/infrastructure/workflow/serviceTask/SdncUnderlayVpnOperationClient.java
diff options
context:
space:
mode:
Diffstat (limited to 'bpmn/MSOInfrastructureBPMN/src/main/java/org/openecomp/mso/bpmn/infrastructure/workflow/serviceTask/SdncUnderlayVpnOperationClient.java')
-rw-r--r--bpmn/MSOInfrastructureBPMN/src/main/java/org/openecomp/mso/bpmn/infrastructure/workflow/serviceTask/SdncUnderlayVpnOperationClient.java118
1 files changed, 0 insertions, 118 deletions
diff --git a/bpmn/MSOInfrastructureBPMN/src/main/java/org/openecomp/mso/bpmn/infrastructure/workflow/serviceTask/SdncUnderlayVpnOperationClient.java b/bpmn/MSOInfrastructureBPMN/src/main/java/org/openecomp/mso/bpmn/infrastructure/workflow/serviceTask/SdncUnderlayVpnOperationClient.java
deleted file mode 100644
index 0e7904c87c..0000000000
--- a/bpmn/MSOInfrastructureBPMN/src/main/java/org/openecomp/mso/bpmn/infrastructure/workflow/serviceTask/SdncUnderlayVpnOperationClient.java
+++ /dev/null
@@ -1,118 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
- * ONAP - SO
- * ================================================================================
- * Copyright (C) 2017 AT&T 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.serviceTask;
-
-import org.apache.commons.lang3.StringUtils;
-import org.onap.msb.sdk.httpclient.RestServiceCreater;
-import org.onap.msb.sdk.httpclient.msb.MSBServiceClient;
-import org.openecomp.mso.bpmn.infrastructure.workflow.serviceTask.client.GenericResourceApi;
-import org.openecomp.mso.bpmn.infrastructure.workflow.serviceTask.client.HeaderUtil;
-import org.openecomp.mso.bpmn.infrastructure.workflow.serviceTask.client.builder.NetworkRpcInputEntityBuilder;
-import org.openecomp.mso.bpmn.infrastructure.workflow.serviceTask.client.entity.RpcNetworkTopologyOperationInputEntity;
-import org.openecomp.mso.bpmn.infrastructure.workflow.serviceTask.client.entity.RpcNetworkTopologyOperationOutputEntity;
-import org.openecomp.mso.logger.MsoLogger;
-import org.openecomp.mso.requestsdb.RequestsDatabase;
-import org.openecomp.mso.requestsdb.RequestsDbConstant;
-import org.openecomp.mso.requestsdb.ResourceOperationStatus;
-
-import java.util.Map;
-
-public class SdncUnderlayVpnOperationClient {
-
- private static final String DEFAULT_MSB_IP = "127.0.0.1";
- private static final int DEFAULT_MSB_PORT = 10081;
- private RequestsDatabase requestsDB = RequestsDatabase.getInstance();
-
- private String serviceId;
- private String operationId;
- private String resourceTemplateUUID;
-
-
- private static MsoLogger logger = MsoLogger.getMsoLogger(MsoLogger.Catalog.GENERAL);
-
- public boolean excute(String msbIp,
- int msbPort,
- Map<String, String> inputs,
- String iServiceID,
- String iOperationID,
- String resourceTemplateUUID_i){
- serviceId = iServiceID;
- operationId = iOperationID;
- resourceTemplateUUID = resourceTemplateUUID_i;
- GenericResourceApi genericResourceApiClient = getGenericResourceApiClient(msbIp, msbPort);
- updateProgress(RequestsDbConstant.Status.PROCESSING, null, "10", "execute begin!");
- return sendRestrequestAndHandleResponse(inputs, genericResourceApiClient);
- }
-
- public boolean sendRestrequestAndHandleResponse(Map<String, String> inputs, GenericResourceApi genericResourceApiClient){
- updateProgress(null, null, "40", "sendRestrequestAndHandleResponse begin!");
- NetworkRpcInputEntityBuilder builder = new NetworkRpcInputEntityBuilder();
- RpcNetworkTopologyOperationInputEntity body = builder.build(null, inputs);
- updateProgress(null, null, "50", "RequestBody build finished!");
- //RpcNetworkTopologyOperationOutputEntity networkRpcOutputEntiy = null;
- try {
- genericResourceApiClient.postNetworkTopologyOperation(HeaderUtil.DefaulAuth ,body).execute().body();
- } catch (Exception e) {
- logger.debug("Exception: ", e);
- updateProgress(RequestsDbConstant.Status.ERROR, null, null, "sendRestrequestAndHandleResponse exception:" + e.getMessage());
- return false;
- }
- updateProgress(null, null, "90", "sendRestrequestAndHandleResponse finished!");
- updateProgress(RequestsDbConstant.Status.FINISHED, null, RequestsDbConstant.Progress.ONE_HUNDRED, "execute finished!");
- return true;
- }
-
- private GenericResourceApi getGenericResourceApiClient(String msbIp, int msbPort) {
- if (StringUtils.isBlank(msbIp)) {
- msbIp = DEFAULT_MSB_IP;
- }
- if (msbPort <= 0) {
- msbPort = DEFAULT_MSB_PORT;
- }
- MSBServiceClient msbClient = new MSBServiceClient(msbIp, msbPort);
- RestServiceCreater restServiceCreater = new RestServiceCreater(msbClient);
- return restServiceCreater.createService(GenericResourceApi.class);
- }
-
- public void updateProgress(String status,
- String errorCode,
- String progress,
- String statusDescription) {
- ResourceOperationStatus resourceOperationStatus = requestsDB.getResourceOperationStatus(serviceId, operationId, resourceTemplateUUID);
- if (!StringUtils.isBlank(status)) {
- resourceOperationStatus.setStatus(status);
- }
- if (!StringUtils.isBlank(errorCode)) {
- resourceOperationStatus.setErrorCode(errorCode);
- }
- if (!StringUtils.isBlank(progress)) {
- resourceOperationStatus.setProgress(progress);
- }
- if (!StringUtils.isBlank(statusDescription)) {
- resourceOperationStatus.setStatusDescription(statusDescription);
- }
- requestsDB.updateResOperStatus(resourceOperationStatus);
- }
-
- private void saveOutput() {
- // Not implemented.
- }
-}