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.BaseIntegrationTest;
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;
46 import org.onap.so.client.policy.JettisonStyleMapperProvider;
48 import com.fasterxml.jackson.core.JsonProcessingException;
49 import com.fasterxml.jackson.databind.ObjectMapper;
51 public class VnfAdapterClientIT extends BaseIntegrationTest{
53 private static final String TESTING_ID = "___TESTING___";
54 private static final String AAI_VNF_ID = "test";
55 private static final String AAI_VF_MODULE_ID = "test";
56 private static final String REST_ENDPOINT = "/services/rest/v1/vnfs";
58 private VnfAdapterClientImpl client = new VnfAdapterClientImpl();
59 private ObjectMapper mapper = new JettisonStyleMapperProvider().getMapper();
62 public static void setUp() {
63 System.setProperty("mso.config.path", "src/test/resources");
67 public void createVfModuleTest() throws JsonProcessingException, VnfAdapterClientException {
68 CreateVfModuleRequest request = new CreateVfModuleRequest();
69 request.setCloudSiteId(TESTING_ID);
71 CreateVfModuleResponse mockResponse = new CreateVfModuleResponse();
72 mockResponse.setVfModuleCreated(true);
73 stubFor(post(urlPathEqualTo(REST_ENDPOINT + "/" + AAI_VNF_ID + "/vf-modules"))
74 .willReturn(aResponse().withHeader("Content-Type", "application/json")
75 .withBody(mapper.writeValueAsString(mockResponse)).withStatus(200)));
77 CreateVfModuleResponse response = client.createVfModule(AAI_VNF_ID, request);
78 assertEquals("Testing CreateVfModule response", true, response.getVfModuleCreated());
81 @Test(expected = VnfAdapterClientException.class)
82 public void createVfModuleTestThrowException() throws JsonProcessingException, VnfAdapterClientException {
83 CreateVfModuleRequest request = new CreateVfModuleRequest();
84 request.setCloudSiteId(TESTING_ID);
86 VfModuleExceptionResponse mockResponse = new VfModuleExceptionResponse();
87 mockResponse.setMessage("Error in create Vf module");
88 stubFor(post(urlPathEqualTo(REST_ENDPOINT + "/" + AAI_VNF_ID + "/vf-modules"))
89 .willReturn(aResponse().withHeader("Content-Type", "application/json")
90 .withBody(mapper.writeValueAsString(mockResponse)).withStatus(500)));
92 client.createVfModule(AAI_VNF_ID, request);
96 public void rollbackVfModuleTest() throws JsonProcessingException, VnfAdapterClientException {
97 RollbackVfModuleRequest request = new RollbackVfModuleRequest();
98 VfModuleRollback rollback = new VfModuleRollback();
99 rollback.setCloudSiteId(TESTING_ID);
100 request.setVfModuleRollback(rollback);
102 RollbackVfModuleResponse mockResponse = new RollbackVfModuleResponse();
103 mockResponse.setVfModuleRolledback(true);
105 post(urlPathEqualTo(REST_ENDPOINT + "/" + AAI_VNF_ID + "/vf-modules/" + AAI_VF_MODULE_ID + "/rollback"))
106 .willReturn(aResponse().withHeader("Content-Type", "application/json")
107 .withBody(mapper.writeValueAsString(mockResponse)).withStatus(200)));
109 RollbackVfModuleResponse response = client.rollbackVfModule(AAI_VNF_ID, AAI_VF_MODULE_ID, request);
110 assertEquals("Testing RollbackVfModule response", true, response.getVfModuleRolledback());
113 @Test(expected = VnfAdapterClientException.class)
114 public void rollbackVfModuleTestThrowException() throws JsonProcessingException, VnfAdapterClientException {
115 RollbackVfModuleRequest request = new RollbackVfModuleRequest();
116 VfModuleRollback rollback = new VfModuleRollback();
117 rollback.setCloudSiteId(TESTING_ID);
118 request.setVfModuleRollback(rollback);
120 VfModuleExceptionResponse mockResponse = new VfModuleExceptionResponse();
121 mockResponse.setMessage("Error in rollback Vf module");
123 post(urlPathEqualTo(REST_ENDPOINT + "/" + AAI_VNF_ID + "/vf-modules/" + AAI_VF_MODULE_ID + "/rollback"))
124 .willReturn(aResponse().withHeader("Content-Type", "application/json")
125 .withBody(mapper.writeValueAsString(mockResponse)).withStatus(500)));
127 client.rollbackVfModule(AAI_VNF_ID, AAI_VF_MODULE_ID, request);
131 public void deleteVfModuleTest() throws JsonProcessingException, VnfAdapterClientException {
132 DeleteVfModuleRequest request = new DeleteVfModuleRequest();
133 request.setCloudSiteId(TESTING_ID);
135 DeleteVfModuleResponse mockResponse = new DeleteVfModuleResponse();
136 mockResponse.setVfModuleDeleted(true);
137 stubFor(post(urlPathEqualTo(REST_ENDPOINT + "/" + AAI_VNF_ID + "/vf-modules/" + AAI_VF_MODULE_ID))
138 .willReturn(aResponse().withHeader("Content-Type", "application/json")
139 .withBody(mapper.writeValueAsString(mockResponse)).withStatus(200)));
141 DeleteVfModuleResponse response = client.deleteVfModule(AAI_VNF_ID, AAI_VF_MODULE_ID, request);
142 assertEquals("Testing DeleteVfModule response", true, response.getVfModuleDeleted());
145 @Test(expected = VnfAdapterClientException.class)
146 public void deleteVfModuleTestThrowException() throws JsonProcessingException, VnfAdapterClientException {
147 DeleteVfModuleRequest request = new DeleteVfModuleRequest();
148 request.setCloudSiteId(TESTING_ID);
150 VfModuleExceptionResponse mockResponse = new VfModuleExceptionResponse();
151 mockResponse.setMessage("Error in delete Vf module");
152 stubFor(post(urlPathEqualTo(REST_ENDPOINT + "/" + AAI_VNF_ID + "/vf-modules/" + AAI_VF_MODULE_ID))
153 .willReturn(aResponse().withHeader("Content-Type", "application/json")
154 .withBody(mapper.writeValueAsString(mockResponse)).withStatus(500)));
156 client.deleteVfModule(AAI_VNF_ID, AAI_VF_MODULE_ID, request);
160 public void updateVfModuleTest() throws JsonProcessingException, VnfAdapterClientException {
161 UpdateVfModuleRequest request = new UpdateVfModuleRequest();
162 request.setCloudSiteId(TESTING_ID);
163 request.setVfModuleId("test1");
165 UpdateVfModuleResponse mockResponse = new UpdateVfModuleResponse();
166 mockResponse.setVfModuleId("test1");
167 stubFor(put(urlPathEqualTo(REST_ENDPOINT + "/" + AAI_VNF_ID + "/vf-modules/" + AAI_VF_MODULE_ID))
168 .willReturn(aResponse().withHeader("Content-Type", "application/json")
169 .withBody(mapper.writeValueAsString(mockResponse)).withStatus(200)));
171 UpdateVfModuleResponse response = client.updateVfModule(AAI_VNF_ID, AAI_VF_MODULE_ID, request);
172 assertEquals("Testing UpdateVfModule response", "test1", response.getVfModuleId());
175 @Test(expected = VnfAdapterClientException.class)
176 public void updateVfModuleTestThrowException() throws JsonProcessingException, VnfAdapterClientException {
177 UpdateVfModuleRequest request = new UpdateVfModuleRequest();
178 request.setCloudSiteId(TESTING_ID);
179 request.setVfModuleId("test1");
181 VfModuleExceptionResponse mockResponse = new VfModuleExceptionResponse();
182 mockResponse.setMessage("Error in update Vf module");
183 stubFor(put(urlPathEqualTo(REST_ENDPOINT + "/" + AAI_VNF_ID + "/vf-modules/" + AAI_VF_MODULE_ID))
184 .willReturn(aResponse().withHeader("Content-Type", "application/json")
185 .withBody(mapper.writeValueAsString(mockResponse)).withStatus(500)));
187 client.updateVfModule(AAI_VNF_ID, AAI_VF_MODULE_ID, request);
191 public void queryVfModuleTest() throws JsonProcessingException, VnfAdapterClientException {
192 QueryVfModuleResponse mockResponse = new QueryVfModuleResponse();
193 mockResponse.setVnfId(AAI_VNF_ID);
194 mockResponse.setVfModuleId(AAI_VF_MODULE_ID);
195 stubFor(get(urlPathEqualTo(REST_ENDPOINT + "/" + AAI_VNF_ID + "/vf-modules/" + AAI_VF_MODULE_ID))
196 .withQueryParam("cloudSiteId", equalTo(TESTING_ID))
197 .withQueryParam("tenantId", equalTo(TESTING_ID))
198 .withQueryParam("vfModuleName", equalTo("someName"))
199 .withQueryParam("skipAAI", equalTo("true"))
200 .withQueryParam("msoRequest.requestId", equalTo("testRequestId"))
201 .withQueryParam("msoRequest.serviceInstanceId", equalTo("serviceInstanceId"))
202 .willReturn(aResponse().withHeader("Content-Type", "application/json")
203 .withBody(mapper.writeValueAsString(mockResponse)).withStatus(200)));
204 QueryVfModuleResponse response = client.queryVfModule(AAI_VNF_ID, AAI_VF_MODULE_ID, TESTING_ID, TESTING_ID,
205 "someName", true, "testRequestId", "serviceInstanceId");
206 assertEquals("Testing QueryVfModule response", AAI_VF_MODULE_ID, response.getVfModuleId());
209 @Test(expected = VnfAdapterClientException.class)
210 public void queryVfModuleTestThrowException() throws JsonProcessingException, VnfAdapterClientException {
211 VfModuleExceptionResponse mockResponse = new VfModuleExceptionResponse();
212 mockResponse.setMessage("Error in update Vf module");
213 stubFor(get(urlPathEqualTo(REST_ENDPOINT + "/" + AAI_VNF_ID + "/vf-modules/" + AAI_VF_MODULE_ID))
214 .withQueryParam("cloudSiteId", equalTo(TESTING_ID))
215 .withQueryParam("tenantId", equalTo(TESTING_ID))
216 .withQueryParam("vfModuleName", equalTo("someName"))
217 .withQueryParam("skipAAI", equalTo("true"))
218 .withQueryParam("msoRequest.requestId", equalTo("testRequestId"))
219 .withQueryParam("msoRequest.serviceInstanceId", equalTo("serviceInstanceId"))
220 .willReturn(aResponse().withHeader("Content-Type", "application/json")
221 .withBody(mapper.writeValueAsString(mockResponse)).withStatus(500)));
222 client.queryVfModule(AAI_VNF_ID, AAI_VF_MODULE_ID, TESTING_ID, TESTING_ID,
223 "someName", true, "testRequestId", "serviceInstanceId");