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
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
|
/**
* Copyright 2017-2018 Huawei Technologies Co., Ltd.
*
* 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.
*/
package org.onap.vnfsdk.marketplace.onboarding.hooks.validatelifecycle;
import java.io.File;
import java.io.IOException;
import java.util.Map;
import org.apache.http.entity.ContentType;
import org.apache.http.entity.mime.MultipartEntityBuilder;
import org.onap.vnfsdk.marketplace.common.CommonConstant;
import org.onap.vnfsdk.marketplace.common.FileUtil;
import org.onap.vnfsdk.marketplace.msb.MsbDetails;
import org.onap.vnfsdk.marketplace.msb.MsbDetailsHolder;
import org.onap.vnfsdk.marketplace.onboarding.entity.OnBoradingRequest;
import org.onap.vnfsdk.marketplace.rest.RestConstant;
import org.onap.vnfsdk.marketplace.rest.RestResponse;
import org.onap.vnfsdk.marketplace.rest.RestfulClient;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.google.gson.Gson;
import com.google.gson.reflect.TypeToken;
/** CALL Flow: onBoardingHandler --> LifecycleTestHook--> LifecycleTestExecutor */
public class LifecycleTestExceutor {
private static final Logger logger = LoggerFactory.getLogger(LifecycleTestExceutor.class);
private static Gson gson = new Gson();
public static final String CATALOUGE_UPLOAD_URL_IN = "{0}:{1}/onapapi/catalog/v1/csars";
private LifecycleTestExceutor() {
// Empty constructor
}
/**
* Interface to upload package to catalogue
*
* @param onBoradFuncTestReq
* @return- csarId or null (in case of failure)
*/
@SuppressWarnings("unchecked")
public static String uploadPackageToCatalouge(OnBoradingRequest onBoradFuncTestReq) {
String packagePath = onBoradFuncTestReq.getPackagePath() + File.separator + onBoradFuncTestReq.getPackageName();
logger.info("Package file path uploadPackageToCatalouge:" + packagePath);
String catalougeCsarId = null;
// Validate package path
if (!FileUtil.validatePath(packagePath)) {
logger.error("Failed to validate package path");
return catalougeCsarId;
}
MsbDetails oMsbDetails = MsbDetailsHolder.getMsbDetails();
if (null == oMsbDetails) {
logger.error("Failed to get MSB details during uploadPackageToCatalouge !!!");
return catalougeCsarId;
}
File fileData = new File(packagePath);
// Validate file
if (!FileUtil.validateFile(fileData)) {
logger.error("Failed to validate file information");
return catalougeCsarId;
}
MultipartEntityBuilder builder = MultipartEntityBuilder.create();
builder.addBinaryBody("file", fileData, ContentType.MULTIPART_FORM_DATA, onBoradFuncTestReq.getPackageName());
// IP and Port needs to be configured !!!
RestResponse rsp = RestfulClient.post(oMsbDetails.getDefaultServer().getHost(),
Integer.parseInt(oMsbDetails.getDefaultServer().getPort()), CommonConstant.CATALOUGE_UPLOAD_URL,
builder.build());
if (!checkValidResponse(rsp)) {
logger.error("Failed to upload package to catalouge:" + rsp.getStatusCode());
return catalougeCsarId;
}
logger.info("Response for uploadPackageToCatalouge :" + rsp.getResult());
catalougeCsarId = getCsarIdValue(rsp.getResult());
logger.info("CSARID for uploadPackageToCatalouge :" + catalougeCsarId);
return catalougeCsarId;
}
/**
* Interface to execute lifecycle test
*
* @param onBoradFuncTestReq,
* oLifeCycleTestReq
* @return result of the test or null (in case of failure)
*/
public static String execlifecycleTest(OnBoradingRequest onBoradFuncTestReq, LifeCycleTestReq oLifeCycleTestReq) {
String result = null;
if ((null == onBoradFuncTestReq.getPackagePath()) || (null == onBoradFuncTestReq.getPackageName())) {
logger.error("Package path or name is invalid");
return result;
}
String packagePath = onBoradFuncTestReq.getPackagePath() + File.separator + onBoradFuncTestReq.getPackageName();
logger.info("Package file path Function test:" + packagePath);
// Validate package path
if (!FileUtil.validatePath(packagePath)) {
logger.error("Failed to validate path");
return result;
}
MsbDetails oMsbDetails = MsbDetailsHolder.getMsbDetails();
if (null == oMsbDetails) {
logger.error("Failed to get MSB details during execlifecycleTest !!!");
return result;
}
String rawDataJson = "";
//TBD - Use Gson - jackson has security issue//JsonUtil.toJson(oLifeCycleTestReq);
RestResponse oResponse = RestfulClient.sendPostRequest(oMsbDetails.getDefaultServer().getHost(),
oMsbDetails.getDefaultServer().getPort(), CommonConstant.LifeCycleTest.LIFECYCLE_TEST_URL, rawDataJson);
if (!checkValidResponse(oResponse)) {
logger.error("execlifecycleTest response is faliure :" + oResponse.getStatusCode());
return result;
}
result = oResponse.getResult();
logger.info("Response execlifecycleTest :" + oResponse.getResult());
return result;
}
/**
* Check Response is Valid
*
* @param rsp
* @return valid(true) or invalid(false)
*/
private static boolean checkValidResponse(RestResponse rsp) {
return ((null != rsp.getStatusCode()) && (null != rsp.getResult())
&& (RestConstant.RESPONSE_CODE_200 == rsp.getStatusCode()
|| RestConstant.RESPONSE_CODE_201 == rsp.getStatusCode()));
}
/**
* Get csar Id value
*
* @param strJsonData
* @return empty(failure), or csarId(success)
*/
private static String getCsarIdValue(String strJsonData) {
/*
Gson will ignore the unknown fields and simply match the fields that it's able to.
ref: https://www.baeldung.com/gson-deserialization-guide
By default, Gson just ignores extra JSON elements that do not have matching Java fields.
ref: https://programmerbruce.blogspot.com/2011/06/gson-v-jackson.html
*/
Map<String, String> dataMap = null;
try {
dataMap = gson.fromJson(strJsonData, new TypeToken<Map<String,String>>(){}.getType());
} catch (Exception e) { //NOSONAR
logger.error("Exception:Failed to upload package to catalouge:", e);
}
try {
if (null != dataMap) {
return dataMap.get("csarId");
}
} catch (NullPointerException e) {
logger.error("NullPointerException:Failed to get csarId", e);
}
return "";
}
}
|
