bpmn/MSOCommonBPMN/src/main/java/org/openecomp/mso/bpmn/appc/payload/PayloadClient.java

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * ONAP - SO
   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
  10  *
  11  *      http://www.apache.org/licenses/LICENSE-2.0
  12  *
  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=========================================================
  19  */
  20
  21 package org.openecomp.mso.bpmn.appc.payload;
  22
  23 import org.openecomp.mso.bpmn.appc.payload.beans.*;
  24
  25 import java.util.Optional;
  26
  27 import com.fasterxml.jackson.core.JsonProcessingException;
  28 import org.openecomp.mso.bpmn.core.json.JsonUtils;
  29 import com.fasterxml.jackson.databind.JsonMappingException;
  30 import com.fasterxml.jackson.databind.ObjectMapper;
  31
  32 public class PayloadClient {
  33
  34         protected static ObjectMapper mapper = new ObjectMapper();
  35
  36
  37         public static Optional<String> upgradeFormat(Optional<String> payload, String vnfName) throws JsonProcessingException{
  38                         UpgradeAction payloadResult = new UpgradeAction();
  39                         ConfigurationParametersUpgrade configParams = new ConfigurationParametersUpgrade();
  40                     String payloadString = payload.get();
  41                         String existingSoftware = JsonUtils.getJsonValue(payloadString, "existing-software-version");
  42                         String newSoftware = JsonUtils.getJsonValue(payloadString, "new-software-version");
  43                         configParams.setExistingSoftwareVersion(existingSoftware);
  44                         configParams.setNewSoftwareVersion(newSoftware);
  45                         configParams.setVnfName(vnfName);
  46                         payloadResult.setConfigurationParameters(configParams);
  47                         return Optional.of(mapper.writeValueAsString(payloadResult));
  48         }
  49
  50         public static Optional<String> resumeTrafficFormat(String vnfName) throws JsonProcessingException{
  51                         ResumeTrafficAction payloadResult = new ResumeTrafficAction();
  52                         ConfigurationParametersResumeTraffic configParams = new ConfigurationParametersResumeTraffic();
  53                         configParams.setVnfName(vnfName);
  54                         payloadResult.setConfigurationParameters(configParams);
  55                         return Optional.of(mapper.writeValueAsString(payloadResult));
  56         }
  57
  58         public static Optional<String> quiesceTrafficFormat(Optional<String> payload, String vnfName) throws JsonProcessingException{
  59                         QuiesceTrafficAction payloadResult = new QuiesceTrafficAction();
  60                         ConfigurationParametersQuiesce configParams = new ConfigurationParametersQuiesce();
  61                         String payloadString = payload.get();
  62                         String operationsTimeout = JsonUtils.getJsonValue(payloadString, "operations-timeout");
  63                         configParams.setOperationsTimeout(operationsTimeout);
  64                         configParams.setVnfName(vnfName);
  65                         payloadResult.setConfigurationParameters(configParams);
  66                         return Optional.of(mapper.writeValueAsString(payloadResult));
  67         }
  68
  69         public static Optional<String> startStopFormat(String aicIdentity) throws JsonProcessingException{
  70                         StartStopAction payloadResult = new StartStopAction();
  71                         payloadResult.setAICIdentity(aicIdentity);
  72                         return Optional.of(mapper.writeValueAsString(payloadResult));
  73         }
  74
  75         public static Optional<String> healthCheckFormat(String vnfName, String vnfHostIpAddress) throws JsonProcessingException{
  76                         HealthCheckAction payloadResult = new HealthCheckAction();
  77                         RequestParametersHealthCheck requestParams = new RequestParametersHealthCheck();
  78                         ConfigurationParametersHealthCheck configParams = new ConfigurationParametersHealthCheck();
  79                         requestParams.setVnfName(vnfName);
  80                         configParams.setVnfName(vnfName);
  81                         payloadResult.setConfigurationParameters(configParams);
  82                         payloadResult.setRequestParameters(requestParams);
  83                         return Optional.of(mapper.writeValueAsString(payloadResult));
  84         }
  85
  86         public static Optional<String> snapshotFormat(String vmId, String identityUrl)throws JsonProcessingException{
  87                         SnapshotAction payloadResult = new SnapshotAction();
  88                         payloadResult.setVmId(vmId);
  89                         payloadResult.setIdentityUrl(identityUrl);
  90                         return Optional.of(mapper.writeValueAsString(payloadResult));
  91         }
  92
  93         /*public Optional<String>  verifySnapshotFormat(Optional<String> payload) throws Exception, JsonProcessingException, JsonMappingException{
  94                 final Snapshot check = mapper.readValue(payload.get(), Snapshot.class);
  95                 return Optional.of(mapper.writeValueAsString(check));
  96         }
  97
  98         public Optional<String> verifyUpgradeFormat(Optional<String> payload) throws Exception, JsonProcessingException, JsonMappingException{
  99                 final UpdateCheck check = mapper.readValue(payload.get(), UpdateCheck.class);
 100                 return Optional.of(mapper.writeValueAsString(check));
 101         }
 102
 103         public Optional<String> verifyQuiesceTrafficFormat(Optional<String> payload)throws Exception, JsonProcessingException, JsonMappingException{
 104                 final QuiesceTraffic check = mapper.readValue(payload.get(), QuiesceTraffic.class);
 105                 return Optional.of(mapper.writeValueAsString(check));
 106         }
 107         */
 108
 109 }