adapters/mso-openstack-adapters/src/test/java/org/onap/so/adapters/network/MSONetworkAdapterImplTest.java

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * ONAP - SO
   4  * ================================================================================
   5  * Copyright (C) 2017 - 2018 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.onap.so.adapters.network;
  22
  23 import org.apache.http.HttpStatus;
  24 import org.junit.Test;
  25 import org.onap.so.adapters.vnf.BaseRestTestUtils;
  26 import org.springframework.http.HttpEntity;
  27 import org.springframework.http.HttpMethod;
  28 import org.springframework.http.ResponseEntity;
  29 import org.springframework.web.util.UriComponentsBuilder;
  30
  31 import javax.ws.rs.core.MediaType;
  32 import javax.ws.rs.core.Response;
  33 import java.io.IOException;
  34 import java.nio.file.Files;
  35 import java.nio.file.Paths;
  36
  37 import static org.junit.Assert.assertEquals;
  38 import static org.onap.so.bpmn.mock.StubOpenStack.mockOpenStackDeleteNeutronNetwork;
  39 import static org.onap.so.bpmn.mock.StubOpenStack.mockOpenStackDeleteStack_200;
  40 import static org.onap.so.bpmn.mock.StubOpenStack.mockOpenStackDeleteStack_500;
  41 import static org.onap.so.bpmn.mock.StubOpenStack.mockOpenStackGetAllNeutronNetworks_200;
  42 import static org.onap.so.bpmn.mock.StubOpenStack.mockOpenStackGetAllNeutronNetworks_404;
  43 import static org.onap.so.bpmn.mock.StubOpenStack.mockOpenStackGetNeutronNetwork;
  44 import static org.onap.so.bpmn.mock.StubOpenStack.mockOpenStackGetNeutronNetwork_404;
  45 import static org.onap.so.bpmn.mock.StubOpenStack.mockOpenStackGetStackCreated_200;
  46 import static org.onap.so.bpmn.mock.StubOpenStack.mockOpenStackGetStackDeleteOrUpdateComplete_200;
  47 import static org.onap.so.bpmn.mock.StubOpenStack.mockOpenStackGetStack_404;
  48 import static org.onap.so.bpmn.mock.StubOpenStack.mockOpenStackGetStack_500;
  49 import static org.onap.so.bpmn.mock.StubOpenStack.mockOpenStackPostNeutronNetwork_200;
  50 import static org.onap.so.bpmn.mock.StubOpenStack.mockOpenStackPostStack_200;
  51 import static org.onap.so.bpmn.mock.StubOpenStack.mockOpenStackPutNeutronNetwork;
  52 import static org.onap.so.bpmn.mock.StubOpenStack.mockOpenStackPutNeutronNetwork_200;
  53 import static org.onap.so.bpmn.mock.StubOpenStack.mockOpenStackPutStack;
  54 import static org.onap.so.bpmn.mock.StubOpenStack.mockOpenStackResponseAccess;
  55 import static org.onap.so.bpmn.mock.StubOpenStack.mockOpenstackGet;
  56 import static org.onap.so.bpmn.mock.StubOpenStack.mockOpenstackPost;
  57
  58 public class MSONetworkAdapterImplTest extends BaseRestTestUtils {
  59
  60         public static final String NETWORK_ID = "43173f6a-d699-414b-888f-ab243dda6dfe";
  61         public static final String NETWORK_NAME = "vUSP-23804-T-01-dpa2b_EVUSP-CORE-VIF-TSIG0_net_0";
  62
  63
  64
  65         @Test
  66         public void createNetworkByModelNameNeutronModeGetNetworkException() throws IOException{
  67                 mockOpenStackResponseAccess(wireMockServer, wireMockPort);
  68
  69                 mockOpenstackGet(wireMockServer, "/mockPublicUrl/v2.0/networks",HttpStatus.SC_INTERNAL_SERVER_ERROR);
  70
  71                 String uri =  "/services/NetworkAdapter";
  72                 headers.set("X-ECOMP-RequestID", "123456789456127");
  73                 ResponseEntity<String> response = sendXMLRequest(inputStream("/CreateNetwork_NEUTRON_Mode.xml"), uri, HttpMethod.POST);
  74                 assertEquals(Response.Status.INTERNAL_SERVER_ERROR.getStatusCode(), response.getStatusCode().value());
  75         }
  76
  77         @Test
  78         public void createNetworkByModelNameNeutronModeCreateNetworkException() throws IOException{
  79
  80                 mockOpenStackResponseAccess(wireMockServer, wireMockPort);
  81
  82                 mockOpenStackGetNeutronNetwork_404(wireMockServer, "dvspg-VCE_VPE-mtjnj40avbc");
  83
  84                 mockOpenStackGetAllNeutronNetworks_404(wireMockServer);
  85
  86                 mockOpenstackPost(wireMockServer, "/mockPublicUrl/v2.0/networks", HttpStatus.SC_INTERNAL_SERVER_ERROR);
  87
  88                 String uri =  "/services/NetworkAdapter";
  89                 headers.set("X-ECOMP-RequestID", "123456789456127");
  90                 ResponseEntity<String> response = sendXMLRequest(inputStream("/CreateNetwork_NEUTRON_Mode.xml"), uri, HttpMethod.POST);
  91                 assertEquals(Response.Status.INTERNAL_SERVER_ERROR.getStatusCode(), response.getStatusCode().value());
  92         }
  93
  94         @Test
  95         public void createNetworkByModelNameNeutronMode() throws IOException{
  96
  97                 mockOpenStackResponseAccess(wireMockServer, wireMockPort);
  98
  99                 mockOpenStackGetNeutronNetwork_404(wireMockServer, "dvspg-VCE_VPE-mtjnj40avbc");
 100
 101                 mockOpenStackGetAllNeutronNetworks_404(wireMockServer);
 102
 103                 mockOpenStackPostNeutronNetwork_200(wireMockServer, "OpenstackCreateNeutronNetworkResponse.json");
 104
 105                 String uri =  "/services/NetworkAdapter";
 106                 headers.set("X-ECOMP-RequestID", "123456789456127");
 107                 ResponseEntity<String> response = sendXMLRequest(inputStream("/CreateNetwork_NEUTRON_Mode.xml"), uri, HttpMethod.POST);
 108                 assertEquals(Response.Status.OK.getStatusCode(), response.getStatusCode().value());
 109         }
 110
 111         @Test
 112         public void createNetworkByModelNameAlreadyExistNeutronMode() throws IOException{
 113
 114                 mockOpenStackResponseAccess(wireMockServer, wireMockPort);
 115
 116                 mockOpenStackGetAllNeutronNetworks_200(wireMockServer, "OpenstackGetNeutronNetworks.json");
 117
 118                 String uri =  "/services/NetworkAdapter";
 119                 headers.set("X-ECOMP-RequestID", "123456789456127");
 120                 ResponseEntity<String> response = sendXMLRequest(inputStream("/CreateNetwork_NEUTRON_Mode.xml"), uri, HttpMethod.POST);
 121                 assertEquals(Response.Status.OK.getStatusCode(), response.getStatusCode().value());
 122         }
 123
 124         @Test
 125         public void createNetworkByModelNameAlreadyExistNeutronModeFailIfExistTrue() throws IOException{
 126
 127                 mockOpenStackResponseAccess(wireMockServer, wireMockPort);
 128
 129                 mockOpenStackGetAllNeutronNetworks_200(wireMockServer, "OpenstackGetNeutronNetworks.json");
 130
 131                 String uri =  "/services/NetworkAdapter";
 132                 headers.set("X-ECOMP-RequestID", "123456789456127");
 133                 ResponseEntity<String> response = sendXMLRequest(inputStream("/CreateNetwork_NEUTRON_Mode_Fail_If_Exist_True.xml"), uri, HttpMethod.POST);
 134                 assertEquals(Response.Status.INTERNAL_SERVER_ERROR.getStatusCode(), response.getStatusCode().value());
 135         }
 136
 137         @Test
 138         public void createNetworkByModelNameHeatMode() throws IOException{
 139
 140                 mockOpenStackResponseAccess(wireMockServer, wireMockPort);
 141
 142                 mockOpenStackGetStack_404(wireMockServer, "dvspg-VCE_VPE-mtjnj40avbc");
 143
 144                 mockOpenStackPostStack_200(wireMockServer, "OpenstackResponse_Stack.json");
 145
 146                 mockOpenStackGetStackCreated_200(wireMockServer, "OpenstackResponse_Stack_Created.json", "dvspg-VCE_VPE-mtjnj40avbc/stackId");
 147
 148                 String uri =  "/services/NetworkAdapter";
 149                 headers.set("X-ECOMP-RequestID", "123456789456127");
 150                 ResponseEntity<String> response = sendXMLRequest(inputStream("/CreateNetwork.xml"), uri, HttpMethod.POST);
 151                 assertEquals(Response.Status.OK.getStatusCode(), response.getStatusCode().value());
 152         }
 153
 154         @Test
 155         public void createNetworkByModelNameAlreadyExistHeatMode() throws IOException{
 156
 157                 mockOpenStackResponseAccess(wireMockServer, wireMockPort);
 158
 159                 mockOpenStackPostStack_200(wireMockServer, "OpenstackResponse_Stack.json");
 160
 161                 mockOpenStackGetStackCreated_200(wireMockServer, "OpenstackResponse_Stack_Created.json", "dvspg-VCE_VPE-mtjnj40avbc");
 162
 163                 String uri =  "/services/NetworkAdapter";
 164                 headers.set("X-ECOMP-RequestID", "123456789456127");
 165                 ResponseEntity<String> response = sendXMLRequest(inputStream("/CreateNetwork.xml"), uri, HttpMethod.POST);
 166                 assertEquals(Response.Status.OK.getStatusCode(), response.getStatusCode().value());
 167         }
 168
 169         @Test
 170         public void createNetworkByModelNameAlreadyExistHeatModeFailIfExistTrue() throws IOException{
 171
 172                 mockOpenStackResponseAccess(wireMockServer, wireMockPort);
 173
 174                 mockOpenStackGetStackCreated_200(wireMockServer, "OpenstackResponse_Stack_Created.json", "dvspg-VCE_VPE-mtjnj40avbc");
 175
 176                 String uri =  "/services/NetworkAdapter";
 177                 headers.set("X-ECOMP-RequestID", "123456789456127");
 178                 ResponseEntity<String> response = sendXMLRequest(inputStream("/CreateNetwork_Fail_If_Exist_True.xml"), uri, HttpMethod.POST);
 179                 assertEquals(Response.Status.INTERNAL_SERVER_ERROR.getStatusCode(), response.getStatusCode().value());
 180         }
 181
 182
 183         @Test
 184         public void createNetworkByModelNameHeatModeQueryNetworkException() throws IOException{
 185
 186                 mockOpenStackResponseAccess(wireMockServer, wireMockPort);
 187
 188                 mockOpenstackGet(wireMockServer, "/mockPublicUrl/stacks/dvspg-VCE_VPE-mtjnj40avbc",HttpStatus.SC_INTERNAL_SERVER_ERROR);
 189
 190                 String uri =  "/services/NetworkAdapter";
 191                 headers.set("X-ECOMP-RequestID", "123456789456127");
 192                 ResponseEntity<String> response = sendXMLRequest(inputStream("/CreateNetwork.xml"), uri, HttpMethod.POST);
 193                 assertEquals(Response.Status.INTERNAL_SERVER_ERROR.getStatusCode(), response.getStatusCode().value());
 194         }
 195
 196         @Test
 197         public void createNetworkByModelNameHeatModeCreateNetworkException() throws IOException{
 198
 199                 mockOpenStackResponseAccess(wireMockServer, wireMockPort);
 200
 201                 mockOpenStackGetStack_404(wireMockServer, "dvspg-VCE_VPE-mtjnj40avbc");
 202
 203                 mockOpenstackPost(wireMockServer, "/mockPublicUrl/stacks",HttpStatus.SC_INTERNAL_SERVER_ERROR);
 204
 205                 String uri =  "/services/NetworkAdapter";
 206                 headers.set("X-ECOMP-RequestID", "123456789456127");
 207                 ResponseEntity<String> response = sendXMLRequest(inputStream("/CreateNetwork.xml"), uri, HttpMethod.POST);
 208                 assertEquals(Response.Status.INTERNAL_SERVER_ERROR.getStatusCode(), response.getStatusCode().value());
 209         }
 210
 211         @Test
 212         public void createNetworkByModelNameCloudSiteNotPresentError() throws IOException{
 213
 214                 mockOpenStackResponseAccess(wireMockServer, wireMockPort);
 215
 216                 mockOpenStackPostStack_200(wireMockServer, "OpenstackResponse_Stack.json");
 217
 218                 mockOpenStackGetStackCreated_200(wireMockServer, "OpenstackResponse_Stack_Created.json", "dvspg-VCE_VPE-mtjnj40avbc");
 219
 220                 String uri =  "/services/NetworkAdapter";
 221                 headers.set("X-ECOMP-RequestID", "123456789456127");
 222                 ResponseEntity<String> response = sendXMLRequest(inputStream("/CreateNetwork_InvalidCloudSiteId.xml"), uri, HttpMethod.POST);
 223                 assertEquals(Response.Status.INTERNAL_SERVER_ERROR.getStatusCode(), response.getStatusCode().value());
 224         }
 225
 226         @Test
 227         public void deleteNetworkHeatModeSuccess() throws IOException{
 228
 229                 mockOpenStackResponseAccess(wireMockServer, wireMockPort);
 230
 231                 mockOpenStackGetStackDeleteOrUpdateComplete_200(wireMockServer, "OpenstackResponse_Stack_DeleteComplete.json");
 232
 233                 mockOpenStackDeleteStack_200(wireMockServer);
 234
 235                 mockOpenStackGetStackCreated_200(wireMockServer, "OpenstackResponse_Stack_Created.json", "43173f6a-d699-414b-888f-ab243dda6dfe");
 236
 237                 String uri =  "/services/NetworkAdapter";
 238                 headers.set("X-ECOMP-RequestID", "123456789456127");
 239                 ResponseEntity<String> response = sendXMLRequest(inputStream("/DeleteNetwork.xml"), uri, HttpMethod.POST);
 240                 assertEquals(Response.Status.OK.getStatusCode(), response.getStatusCode().value());
 241         }
 242
 243         @Test
 244         public void deleteNetworkDeleteStackException() throws IOException{
 245
 246                 mockOpenStackResponseAccess(wireMockServer, wireMockPort);
 247
 248                 mockOpenStackGetStackDeleteOrUpdateComplete_200(wireMockServer, "OpenstackResponse_Stack_DeleteComplete.json");
 249
 250                 mockOpenStackDeleteStack_500(wireMockServer);
 251
 252                 mockOpenStackGetStackCreated_200(wireMockServer, "OpenstackResponse_Stack_Created.json", "43173f6a-d699-414b-888f-ab243dda6dfe");
 253
 254                 String uri =  "/services/NetworkAdapter";
 255                 headers.set("X-ECOMP-RequestID", "123456789456127");
 256                 ResponseEntity<String> response = sendXMLRequest(inputStream("/DeleteNetwork.xml"), uri, HttpMethod.POST);
 257                 assertEquals(Response.Status.INTERNAL_SERVER_ERROR.getStatusCode(), response.getStatusCode().value());
 258         }
 259
 260         @Test
 261         public void deleteNetworkError() throws IOException{
 262
 263                 mockOpenStackResponseAccess(wireMockServer, wireMockPort);
 264
 265                 mockOpenStackGetStackDeleteOrUpdateComplete_200(wireMockServer, "OpenstackResponse_Stack_DeleteComplete.json");
 266
 267                 mockOpenStackDeleteStack_200(wireMockServer);
 268
 269                 mockOpenStackGetStackCreated_200(wireMockServer, "OpenstackResponse_Stack_Created.json", "43173f6a-d699-414b-888f-ab243dda6dfe");
 270
 271                 String uri =  "/services/NetworkAdapter";
 272                 headers.set("X-ECOMP-RequestID", "123456789456127");
 273                 ResponseEntity<String> response = sendXMLRequest(inputStream("/DeleteNetwork.xml").replace("mtn13",""), uri, HttpMethod.POST);
 274                 assertEquals(Response.Status.INTERNAL_SERVER_ERROR.getStatusCode(), response.getStatusCode().value());
 275         }
 276
 277
 278         @Test
 279         public void deleteNetworkNeureonMode() throws IOException{
 280
 281                 mockOpenStackResponseAccess(wireMockServer, wireMockPort);
 282
 283                 mockOpenStackGetNeutronNetwork(wireMockServer, "GetNeutronNetwork.json",NETWORK_ID,HttpStatus.SC_OK);
 284
 285                 mockOpenStackDeleteNeutronNetwork(wireMockServer, NETWORK_ID,HttpStatus.SC_OK);
 286
 287                 String uri =  "/services/NetworkAdapter";
 288                 headers.set("X-ECOMP-RequestID", "123456789456127");
 289                 ResponseEntity<String> response = sendXMLRequest(inputStream("/DeleteNetwork.xml").replace("CONTRAIL30_BASIC","CONTRAIL31_GNDIRECT"), uri, HttpMethod.POST);
 290                 assertEquals(Response.Status.OK.getStatusCode(), response.getStatusCode().value());
 291         }
 292
 293         @Test
 294         public void deleteNetworkNeutronModeDeleteStackException() throws IOException{
 295
 296                 mockOpenStackResponseAccess(wireMockServer, wireMockPort);
 297
 298                 mockOpenStackGetNeutronNetwork(wireMockServer, "GetNeutronNetwork.json",NETWORK_ID,HttpStatus.SC_OK);
 299
 300                 mockOpenStackDeleteNeutronNetwork(wireMockServer, NETWORK_ID,HttpStatus.SC_INTERNAL_SERVER_ERROR);
 301
 302                 //mockOpenStackGetStackCreated_200("OpenstackResponse_Stack_Created.json", NETWORK_ID);
 303
 304                 String uri =  "/services/NetworkAdapter";
 305                 headers.set("X-ECOMP-RequestID", "123456789456127");
 306                 ResponseEntity<String> response = sendXMLRequest(inputStream("/DeleteNetwork.xml").replace("CONTRAIL30_BASIC","CONTRAIL31_GNDIRECT"), uri, HttpMethod.POST);
 307                 assertEquals(Response.Status.INTERNAL_SERVER_ERROR.getStatusCode(), response.getStatusCode().value());
 308         }
 309
 310         @Test
 311         public void updateNetworkNeutronModeSuccess() throws IOException{
 312
 313                 mockOpenStackResponseAccess(wireMockServer, wireMockPort);
 314
 315                 mockOpenStackGetNeutronNetwork(wireMockServer, "GetNeutronNetwork.json",NETWORK_ID,HttpStatus.SC_OK);
 316                 mockOpenStackPutNeutronNetwork_200(wireMockServer, "OpenstackCreateNeutronNetworkResponse.json",NETWORK_ID);
 317
 318                 String uri =  "/services/NetworkAdapter";
 319                 headers.set("X-ECOMP-RequestID", "123456789456127");
 320                 ResponseEntity<String> response = sendXMLRequest(inputStream("/UpdateNetwork.xml").replace("CONTRAIL30_BASIC","CONTRAIL31_GNDIRECT"), uri, HttpMethod.POST);
 321                 assertEquals(Response.Status.OK.getStatusCode(), response.getStatusCode().value());
 322         }
 323
 324         @Test
 325         public void updateNetworkNeutronUpdateException() throws IOException{
 326
 327                 mockOpenStackResponseAccess(wireMockServer, wireMockPort);
 328
 329                 mockOpenStackGetNeutronNetwork(wireMockServer, "GetNeutronNetwork.json",NETWORK_ID,HttpStatus.SC_OK);
 330                 mockOpenStackPutNeutronNetwork(wireMockServer, NETWORK_ID,HttpStatus.SC_INTERNAL_SERVER_ERROR);
 331
 332                 String uri =  "/services/NetworkAdapter";
 333                 headers.set("X-ECOMP-RequestID", "123456789456127");
 334                 ResponseEntity<String> response = sendXMLRequest(inputStream("/UpdateNetwork.xml").replace("CONTRAIL30_BASIC","CONTRAIL31_GNDIRECT"), uri, HttpMethod.POST);
 335                 assertEquals(Response.Status.INTERNAL_SERVER_ERROR.getStatusCode(), response.getStatusCode().value());
 336         }
 337
 338         @Test
 339         public void updateNetworkHeatUpdateException() throws IOException{
 340
 341                 mockOpenStackResponseAccess(wireMockServer, wireMockPort);
 342
 343                 mockOpenStackGetStackCreated_200(wireMockServer, "OpenstackResponse_Stack_Created.json", NETWORK_NAME);
 344
 345                 mockOpenStackPutStack(wireMockServer, NETWORK_ID,HttpStatus.SC_INTERNAL_SERVER_ERROR);
 346
 347                 String uri =  "/services/NetworkAdapter";
 348                 headers.set("X-ECOMP-RequestID", "123456789456127");
 349                 ResponseEntity<String> response = sendXMLRequest(inputStream("/UpdateNetwork.xml"), uri, HttpMethod.POST);
 350                 assertEquals(Response.Status.INTERNAL_SERVER_ERROR.getStatusCode(), response.getStatusCode().value());
 351         }
 352
 353         @Test
 354         public void updateNetworkHeatQueryException() throws IOException{
 355
 356                 mockOpenStackResponseAccess(wireMockServer, wireMockPort);
 357
 358                 mockOpenStackGetStack_500(wireMockServer, NETWORK_NAME);
 359
 360                 String uri =  "/services/NetworkAdapter";
 361                 headers.set("X-ECOMP-RequestID", "123456789456127");
 362                 ResponseEntity<String> response = sendXMLRequest(inputStream("/UpdateNetwork.xml"), uri, HttpMethod.POST);
 363                 assertEquals(Response.Status.INTERNAL_SERVER_ERROR.getStatusCode(), response.getStatusCode().value());
 364         }
 365
 366         @Test
 367         public void updateNetworkHeatStackNotFound() throws IOException{
 368
 369                 mockOpenStackResponseAccess(wireMockServer, wireMockPort);
 370
 371                 mockOpenStackGetStack_404(wireMockServer, NETWORK_NAME);
 372
 373                 String uri =  "/services/NetworkAdapter";
 374                 headers.set("X-ECOMP-RequestID", "123456789456127");
 375                 ResponseEntity<String> response = sendXMLRequest(inputStream("/UpdateNetwork.xml"), uri, HttpMethod.POST);
 376                 assertEquals(Response.Status.INTERNAL_SERVER_ERROR.getStatusCode(), response.getStatusCode().value());
 377         }
 378
 379         @Test
 380         public void updateNetworkNeutronQueryException() throws IOException{
 381
 382                 mockOpenStackResponseAccess(wireMockServer, wireMockPort);
 383
 384                 mockOpenStackGetNeutronNetwork(wireMockServer, NETWORK_ID,HttpStatus.SC_INTERNAL_SERVER_ERROR);
 385
 386                 String uri =  "/services/NetworkAdapter";
 387                 headers.set("X-ECOMP-RequestID", "123456789456127");
 388                 ResponseEntity<String> response = sendXMLRequest(inputStream("/UpdateNetwork.xml").replace("CONTRAIL30_BASIC","CONTRAIL31_GNDIRECT"), uri, HttpMethod.POST);
 389                 assertEquals(Response.Status.INTERNAL_SERVER_ERROR.getStatusCode(), response.getStatusCode().value());
 390         }
 391
 392         @Test
 393         public void updateNetworkNeutronStackNotFound() throws IOException{
 394
 395                 mockOpenStackResponseAccess(wireMockServer, wireMockPort);
 396
 397                 mockOpenStackGetNeutronNetwork(wireMockServer, NETWORK_ID,HttpStatus.SC_NOT_FOUND);
 398
 399                 String uri =  "/services/NetworkAdapter";
 400                 headers.set("X-ECOMP-RequestID", "123456789456127");
 401                 ResponseEntity<String> response = sendXMLRequest(inputStream("/UpdateNetwork.xml").replace("CONTRAIL30_BASIC","CONTRAIL31_GNDIRECT"), uri, HttpMethod.POST);
 402                 assertEquals(Response.Status.INTERNAL_SERVER_ERROR.getStatusCode(), response.getStatusCode().value());
 403         }
 404
 405         @Test
 406         public void queryNetworkHeatModesuccess() throws IOException{
 407
 408                 mockOpenStackResponseAccess(wireMockServer, wireMockPort);
 409
 410                 mockOpenStackGetStackCreated_200(wireMockServer, "OpenstackResponse_Stack_Created.json", NETWORK_ID);
 411
 412                 String uri =  "/services/NetworkAdapter";
 413                 headers.set("X-ECOMP-RequestID", "123456789456127");
 414                 ResponseEntity<String> response = sendXMLRequest(inputStream("/QueryNetwork.xml").replace("CONTRAIL30_BASIC","CONTRAIL31_GNDIRECT"), uri, HttpMethod.POST);
 415                 assertEquals(Response.Status.OK.getStatusCode(), response.getStatusCode().value());
 416         }
 417
 418         @Test
 419         public void queryNetworkHeatModeQueryException() throws IOException{
 420
 421                 mockOpenStackResponseAccess(wireMockServer, wireMockPort);
 422
 423                 mockOpenStackGetStack_500(wireMockServer, NETWORK_ID);
 424
 425                 String uri =  "/services/NetworkAdapter";
 426                 headers.set("X-ECOMP-RequestID", "123456789456127");
 427                 ResponseEntity<String> response = sendXMLRequest(inputStream("/QueryNetwork.xml").replace("CONTRAIL30_BASIC","CONTRAIL31_GNDIRECT"), uri, HttpMethod.POST);
 428                 assertEquals(Response.Status.INTERNAL_SERVER_ERROR.getStatusCode(), response.getStatusCode().value());
 429         }
 430
 431         @Test
 432         public void queryNetworkNeutronModeSuccess() throws IOException{
 433
 434                 mockOpenStackResponseAccess(wireMockServer, wireMockPort);
 435
 436                 mockOpenStackGetNeutronNetwork(wireMockServer, "GetNeutronNetwork.json",NETWORK_ID,HttpStatus.SC_OK);
 437
 438                 String uri =  "/services/NetworkAdapter";
 439                 headers.set("X-ECOMP-RequestID", "123456789456127");
 440                 ResponseEntity<String> response = sendXMLRequest(inputStream("/QueryNetwork.xml").replace("CONTRAIL30_BASIC","CONTRAIL31_GNDIRECT"), uri, HttpMethod.POST);
 441                 assertEquals(Response.Status.OK.getStatusCode(), response.getStatusCode().value());
 442         }
 443
 444         @Test
 445         public void queryNetworkNeutronModeException() throws IOException{
 446
 447                 mockOpenStackResponseAccess(wireMockServer, wireMockPort);
 448
 449                 mockOpenStackGetNeutronNetwork(wireMockServer, NETWORK_ID,HttpStatus.SC_INTERNAL_SERVER_ERROR);
 450
 451                 String uri =  "/services/NetworkAdapter";
 452                 headers.set("X-ECOMP-RequestID", "123456789456127");
 453                 ResponseEntity<String> response = sendXMLRequest(inputStream("/QueryNetwork.xml").replace("CONTRAIL30_BASIC","CONTRAIL31_GNDIRECT"), uri, HttpMethod.POST);
 454                 assertEquals(Response.Status.INTERNAL_SERVER_ERROR.getStatusCode(), response.getStatusCode().value());
 455         }
 456
 457         public ResponseEntity<String> sendXMLRequest(String requestJson, String uriPath, HttpMethod reqMethod){
 458                 headers.set("Accept", MediaType.APPLICATION_XML);
 459                 headers.set("Content-Type", MediaType.APPLICATION_XML);
 460
 461                 UriComponentsBuilder builder = UriComponentsBuilder.fromHttpUrl(createURLWithPort(uriPath));
 462
 463                 HttpEntity<String> request = new HttpEntity<String>(requestJson, headers);
 464                 ResponseEntity<String> response = restTemplate.exchange(builder.toUriString(),
 465                                 reqMethod, request, String.class);
 466
 467                 return response;
 468         }
 469
 470         public String inputStream(String JsonInput)throws IOException{
 471                 JsonInput = "src/test/resources/" + JsonInput;
 472                 String input = new String(Files.readAllBytes(Paths.get(JsonInput)));
 473                 return input;
 474         }
 475 }