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