2 * ============LICENSE_START=======================================================
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
11 * http://www.apache.org/licenses/LICENSE-2.0
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=========================================================
21 package org.onap.so.client.adapter.vnf;
23 import static com.github.tomakehurst.wiremock.client.WireMock.aResponse;
24 import static com.github.tomakehurst.wiremock.client.WireMock.equalTo;
25 import static com.github.tomakehurst.wiremock.client.WireMock.get;
26 import static com.github.tomakehurst.wiremock.client.WireMock.post;
27 import static com.github.tomakehurst.wiremock.client.WireMock.put;
28 import static com.github.tomakehurst.wiremock.client.WireMock.stubFor;
29 import static com.github.tomakehurst.wiremock.client.WireMock.urlPathEqualTo;
30 import static org.junit.Assert.assertEquals;
32 import org.junit.BeforeClass;
33 import org.junit.Test;
34 import org.onap.so.BaseTest;
35 import org.onap.so.adapters.vnfrest.CreateVfModuleRequest;
36 import org.onap.so.adapters.vnfrest.CreateVfModuleResponse;
37 import org.onap.so.adapters.vnfrest.DeleteVfModuleRequest;
38 import org.onap.so.adapters.vnfrest.DeleteVfModuleResponse;
39 import org.onap.so.adapters.vnfrest.QueryVfModuleResponse;
40 import org.onap.so.adapters.vnfrest.RollbackVfModuleRequest;
41 import org.onap.so.adapters.vnfrest.RollbackVfModuleResponse;
42 import org.onap.so.adapters.vnfrest.UpdateVfModuleRequest;
43 import org.onap.so.adapters.vnfrest.UpdateVfModuleResponse;
44 import org.onap.so.adapters.vnfrest.VfModuleExceptionResponse;
45 import org.onap.so.adapters.vnfrest.VfModuleRollback;
47 import com.fasterxml.jackson.core.JsonProcessingException;
48 import com.fasterxml.jackson.databind.ObjectMapper;
50 public class VnfAdapterClientIT extends BaseTest{
52 private static final String TESTING_ID = "___TESTING___";
53 private static final String AAI_VNF_ID = "test";
54 private static final String AAI_VF_MODULE_ID = "test";
55 private static final String REST_ENDPOINT = "/services/rest/v1/vnfs";
57 private VnfAdapterClientImpl client = new VnfAdapterClientImpl();
58 private ObjectMapper mapper = new ObjectMapper();
61 public static void setUp() {
62 System.setProperty("mso.config.path", "src/test/resources");
66 public void createVfModuleTest() throws JsonProcessingException, VnfAdapterClientException {
67 CreateVfModuleRequest request = new CreateVfModuleRequest();
68 request.setCloudSiteId(TESTING_ID);
70 CreateVfModuleResponse mockResponse = new CreateVfModuleResponse();
71 mockResponse.setVfModuleCreated(true);
72 stubFor(post(urlPathEqualTo(REST_ENDPOINT + "/" + AAI_VNF_ID + "/vf-modules"))
73 .willReturn(aResponse().withHeader("Content-Type", "application/json")
74 .withBody(mapper.writeValueAsString(mockResponse)).withStatus(200)));
76 CreateVfModuleResponse response = client.createVfModule(AAI_VNF_ID, request);
77 assertEquals("Testing CreateVfModule response", true, response.getVfModuleCreated());
80 @Test(expected = VnfAdapterClientException.class)
81 public void createVfModuleTestThrowException() throws JsonProcessingException, VnfAdapterClientException {
82 CreateVfModuleRequest request = new CreateVfModuleRequest();
83 request.setCloudSiteId(TESTING_ID);
85 VfModuleExceptionResponse mockResponse = new VfModuleExceptionResponse();
86 mockResponse.setMessage("Error in create Vf module");
87 stubFor(post(urlPathEqualTo(REST_ENDPOINT + "/" + AAI_VNF_ID + "/vf-modules"))
88 .willReturn(aResponse().withHeader("Content-Type", "application/json")
89 .withBody(mapper.writeValueAsString(mockResponse)).withStatus(500)));
91 client.createVfModule(AAI_VNF_ID, request);
95 public void rollbackVfModuleTest() throws JsonProcessingException, VnfAdapterClientException {
96 RollbackVfModuleRequest request = new RollbackVfModuleRequest();
97 VfModuleRollback rollback = new VfModuleRollback();
98 rollback.setCloudSiteId(TESTING_ID);
99 request.setVfModuleRollback(rollback);
101 RollbackVfModuleResponse mockResponse = new RollbackVfModuleResponse();
102 mockResponse.setVfModuleRolledback(true);
104 post(urlPathEqualTo(REST_ENDPOINT + "/" + AAI_VNF_ID + "/vf-modules/" + AAI_VF_MODULE_ID + "/rollback"))
105 .willReturn(aResponse().withHeader("Content-Type", "application/json")
106 .withBody(mapper.writeValueAsString(mockResponse)).withStatus(200)));
108 RollbackVfModuleResponse response = client.rollbackVfModule(AAI_VNF_ID, AAI_VF_MODULE_ID, request);
109 assertEquals("Testing RollbackVfModule response", true, response.getVfModuleRolledback());
112 @Test(expected = VnfAdapterClientException.class)
113 public void rollbackVfModuleTestThrowException() throws JsonProcessingException, VnfAdapterClientException {
114 RollbackVfModuleRequest request = new RollbackVfModuleRequest();
115 VfModuleRollback rollback = new VfModuleRollback();
116 rollback.setCloudSiteId(TESTING_ID);
117 request.setVfModuleRollback(rollback);
119 VfModuleExceptionResponse mockResponse = new VfModuleExceptionResponse();
120 mockResponse.setMessage("Error in rollback Vf module");
122 post(urlPathEqualTo(REST_ENDPOINT + "/" + AAI_VNF_ID + "/vf-modules/" + AAI_VF_MODULE_ID + "/rollback"))
123 .willReturn(aResponse().withHeader("Content-Type", "application/json")
124 .withBody(mapper.writeValueAsString(mockResponse)).withStatus(500)));
126 client.rollbackVfModule(AAI_VNF_ID, AAI_VF_MODULE_ID, request);
130 public void deleteVfModuleTest() throws JsonProcessingException, VnfAdapterClientException {
131 DeleteVfModuleRequest request = new DeleteVfModuleRequest();
132 request.setCloudSiteId(TESTING_ID);
134 DeleteVfModuleResponse mockResponse = new DeleteVfModuleResponse();
135 mockResponse.setVfModuleDeleted(true);
136 stubFor(post(urlPathEqualTo(REST_ENDPOINT + "/" + AAI_VNF_ID + "/vf-modules/" + AAI_VF_MODULE_ID))
137 .willReturn(aResponse().withHeader("Content-Type", "application/json")
138 .withBody(mapper.writeValueAsString(mockResponse)).withStatus(200)));
140 DeleteVfModuleResponse response = client.deleteVfModule(AAI_VNF_ID, AAI_VF_MODULE_ID, request);
141 assertEquals("Testing DeleteVfModule response", true, response.getVfModuleDeleted());
144 @Test(expected = VnfAdapterClientException.class)
145 public void deleteVfModuleTestThrowException() throws JsonProcessingException, VnfAdapterClientException {
146 DeleteVfModuleRequest request = new DeleteVfModuleRequest();
147 request.setCloudSiteId(TESTING_ID);
149 VfModuleExceptionResponse mockResponse = new VfModuleExceptionResponse();
150 mockResponse.setMessage("Error in delete Vf module");
151 stubFor(post(urlPathEqualTo(REST_ENDPOINT + "/" + AAI_VNF_ID + "/vf-modules/" + AAI_VF_MODULE_ID))
152 .willReturn(aResponse().withHeader("Content-Type", "application/json")
153 .withBody(mapper.writeValueAsString(mockResponse)).withStatus(500)));
155 client.deleteVfModule(AAI_VNF_ID, AAI_VF_MODULE_ID, request);
159 public void updateVfModuleTest() throws JsonProcessingException, VnfAdapterClientException {
160 UpdateVfModuleRequest request = new UpdateVfModuleRequest();
161 request.setCloudSiteId(TESTING_ID);
162 request.setVfModuleId("test1");
164 UpdateVfModuleResponse mockResponse = new UpdateVfModuleResponse();
165 mockResponse.setVfModuleId("test1");
166 stubFor(put(urlPathEqualTo(REST_ENDPOINT + "/" + AAI_VNF_ID + "/vf-modules/" + AAI_VF_MODULE_ID))
167 .willReturn(aResponse().withHeader("Content-Type", "application/json")
168 .withBody(mapper.writeValueAsString(mockResponse)).withStatus(200)));
170 UpdateVfModuleResponse response = client.updateVfModule(AAI_VNF_ID, AAI_VF_MODULE_ID, request);
171 assertEquals("Testing UpdateVfModule response", "test1", response.getVfModuleId());
174 @Test(expected = VnfAdapterClientException.class)
175 public void updateVfModuleTestThrowException() throws JsonProcessingException, VnfAdapterClientException {
176 UpdateVfModuleRequest request = new UpdateVfModuleRequest();
177 request.setCloudSiteId(TESTING_ID);
178 request.setVfModuleId("test1");
180 VfModuleExceptionResponse mockResponse = new VfModuleExceptionResponse();
181 mockResponse.setMessage("Error in update Vf module");
182 stubFor(put(urlPathEqualTo(REST_ENDPOINT + "/" + AAI_VNF_ID + "/vf-modules/" + AAI_VF_MODULE_ID))
183 .willReturn(aResponse().withHeader("Content-Type", "application/json")
184 .withBody(mapper.writeValueAsString(mockResponse)).withStatus(500)));
186 client.updateVfModule(AAI_VNF_ID, AAI_VF_MODULE_ID, request);
190 public void queryVfModuleTest() throws JsonProcessingException, VnfAdapterClientException {
191 QueryVfModuleResponse mockResponse = new QueryVfModuleResponse();
192 mockResponse.setVnfId(AAI_VNF_ID);
193 mockResponse.setVfModuleId(AAI_VF_MODULE_ID);
194 stubFor(get(urlPathEqualTo(REST_ENDPOINT + "/" + AAI_VNF_ID + "/vf-modules/" + AAI_VF_MODULE_ID))
195 .withQueryParam("cloudSiteId", equalTo(TESTING_ID))
196 .withQueryParam("tenantId", equalTo(TESTING_ID))
197 .withQueryParam("vfModuleName", equalTo("someName"))
198 .withQueryParam("skipAAI", equalTo("true"))
199 .withQueryParam("msoRequest.requestId", equalTo("testRequestId"))
200 .withQueryParam("msoRequest.serviceInstanceId", equalTo("serviceInstanceId"))
201 .willReturn(aResponse().withHeader("Content-Type", "application/json")
202 .withBody(mapper.writeValueAsString(mockResponse)).withStatus(200)));
203 QueryVfModuleResponse response = client.queryVfModule(AAI_VNF_ID, AAI_VF_MODULE_ID, TESTING_ID, TESTING_ID,
204 "someName", true, "testRequestId", "serviceInstanceId");
205 assertEquals("Testing QueryVfModule response", AAI_VF_MODULE_ID, response.getVfModuleId());
208 @Test(expected = VnfAdapterClientException.class)
209 public void queryVfModuleTestThrowException() throws JsonProcessingException, VnfAdapterClientException {
210 VfModuleExceptionResponse mockResponse = new VfModuleExceptionResponse();
211 mockResponse.setMessage("Error in update Vf module");
212 stubFor(get(urlPathEqualTo(REST_ENDPOINT + "/" + AAI_VNF_ID + "/vf-modules/" + AAI_VF_MODULE_ID))
213 .withQueryParam("cloudSiteId", equalTo(TESTING_ID))
214 .withQueryParam("tenantId", equalTo(TESTING_ID))
215 .withQueryParam("vfModuleName", equalTo("someName"))
216 .withQueryParam("skipAAI", equalTo("true"))
217 .withQueryParam("msoRequest.requestId", equalTo("testRequestId"))
218 .withQueryParam("msoRequest.serviceInstanceId", equalTo("serviceInstanceId"))
219 .willReturn(aResponse().withHeader("Content-Type", "application/json")
220 .withBody(mapper.writeValueAsString(mockResponse)).withStatus(500)));
221 client.queryVfModule(AAI_VNF_ID, AAI_VF_MODULE_ID, TESTING_ID, TESTING_ID,
222 "someName", true, "testRequestId", "serviceInstanceId");