cloudify-client/src/test/java/org/onap/so/cloudify/base/client/CloudifyClientTest.java

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * ONAP - SO
   4  * ================================================================================
   5  * Copyright (C) 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.cloudify.base.client;
  22
  23 import static com.github.tomakehurst.wiremock.client.WireMock.aResponse;
  24 import static com.github.tomakehurst.wiremock.client.WireMock.get;
  25 import static com.github.tomakehurst.wiremock.client.WireMock.urlPathEqualTo;
  26 import static com.github.tomakehurst.wiremock.core.WireMockConfiguration.wireMockConfig;
  27 import static org.junit.Assert.assertEquals;
  28 import org.apache.http.HttpStatus;
  29 import org.junit.Rule;
  30 import org.junit.Test;
  31 import org.junit.rules.ExpectedException;
  32 import org.onap.so.cloudify.v3.model.Execution;
  33 import com.github.tomakehurst.wiremock.junit.WireMockRule;
  34
  35 public class CloudifyClientTest {
  36     @Rule
  37     public WireMockRule wireMockRule = new WireMockRule(wireMockConfig().dynamicPort());
  38
  39     @Rule
  40     public ExpectedException thrown = ExpectedException.none();
  41
  42     @Test
  43     public void clientCreate() {
  44         wireMockRule.stubFor(
  45                 get(urlPathEqualTo("/testUrl")).willReturn(aResponse().withHeader("Content-Type", "application/json")
  46                         .withBody("{\"id\": \"123\"}").withStatus(HttpStatus.SC_OK)));
  47         int port = wireMockRule.port();
  48         CloudifyClient cc = new CloudifyClient("http://localhost:" + port);
  49         cc.setToken("token");
  50         CloudifyRequest<Execution> crx = cc.get("/testUrl", Execution.class);
  51         Execution x = crx.execute();
  52         assertEquals("123", x.getId());
  53     }
  54
  55     @Test
  56     public void clientCreateWithBadConnector() {
  57         thrown.expect(CloudifyResponseException.class);
  58         wireMockRule.stubFor(
  59                 get(urlPathEqualTo("/testUrl")).willReturn(aResponse().withHeader("Content-Type", "application/json")
  60                         .withBody("{\"id\": \"123\"}").withStatus(HttpStatus.SC_OK)));
  61         int port = wireMockRule.port();
  62         CloudifyClientConnector ccc = new CloudifyClientConnector() {
  63             @Override
  64             public <T> CloudifyResponse request(CloudifyRequest<T> request) {
  65                 throw new CloudifyResponseException("test case", 401);
  66             }
  67         };
  68         CloudifyClient cc = new CloudifyClient("http://localhost:" + port, ccc);
  69         // cc.setToken("token");
  70         CloudifyRequest<Execution> crx = cc.get("/testUrl", Execution.class);
  71         Execution x = crx.execute();
  72     }
  73
  74     @Test
  75     public void clientCreateWithBadConnectorAndToken() {
  76         thrown.expect(CloudifyResponseException.class);
  77         wireMockRule.stubFor(
  78                 get(urlPathEqualTo("/testUrl")).willReturn(aResponse().withHeader("Content-Type", "application/json")
  79                         .withBody("{\"id\": \"123\"}").withStatus(HttpStatus.SC_OK)));
  80         int port = wireMockRule.port();
  81         CloudifyClientConnector ccc = new CloudifyClientConnector() {
  82             @Override
  83             public <T> CloudifyResponse request(CloudifyRequest<T> request) {
  84                 throw new CloudifyResponseException("test case", 401);
  85             }
  86         };
  87         CloudifyClient cc = new CloudifyClient("http://localhost:" + port, ccc);
  88         cc.setToken("token");
  89         CloudifyRequest<Execution> crx = cc.get("/testUrl", Execution.class);
  90         Execution x = crx.execute();
  91     }
  92
  93     @Test
  94     public void clientCreateWithTenant() {
  95         wireMockRule.stubFor(
  96                 get(urlPathEqualTo("/testUrl")).willReturn(aResponse().withHeader("Content-Type", "application/json")
  97                         .withBody("{\"id\": \"123\"}").withStatus(HttpStatus.SC_OK)));
  98         int port = wireMockRule.port();
  99         CloudifyClient cc = new CloudifyClient("http://localhost:" + port, "other_tenant");
 100         cc.setToken("token");
 101         cc.property("property", "value");
 102         CloudifyRequest<Execution> crx = cc.get("/testUrl", Execution.class);
 103         Execution x = crx.execute();
 104         assertEquals("123", x.getId());
 105     }
 106
 107 }