cadi/client/src/test/java/org/onap/aaf/cadi/client/test/JU_Rcli.java

   1 /**
   2  * ============LICENSE_START====================================================
   3  * org.onap.aaf
   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
  22 package org.onap.aaf.cadi.client.test;
  23
  24 import static org.hamcrest.CoreMatchers.is;
  25 import static org.junit.Assert.assertThat;
  26 import static org.mockito.Matchers.any;
  27 import static org.mockito.Mockito.when;
  28
  29 import java.io.ByteArrayOutputStream;
  30 import java.io.IOException;
  31 import java.io.PrintStream;
  32 import java.net.HttpURLConnection;
  33 import java.net.URI;
  34 import java.net.URISyntaxException;
  35 import java.util.Enumeration;
  36
  37 import javax.servlet.ServletInputStream;
  38 import javax.servlet.http.HttpServletRequest;
  39 import javax.servlet.http.HttpServletResponse;
  40
  41 import org.junit.Before;
  42 import org.junit.Test;
  43 import org.mockito.Mock;
  44 import org.mockito.MockitoAnnotations;
  45 import org.onap.aaf.cadi.CadiException;
  46 import org.onap.aaf.cadi.SecuritySetter;
  47 import org.onap.aaf.cadi.client.EClient;
  48 import org.onap.aaf.cadi.client.Future;
  49 import org.onap.aaf.cadi.client.Rcli;
  50 import org.onap.aaf.misc.env.APIException;
  51 import org.onap.aaf.misc.env.Data;
  52 import org.onap.aaf.misc.env.Data.TYPE;
  53 import org.onap.aaf.misc.rosetta.env.RosettaDF;
  54 import org.onap.aaf.misc.rosetta.env.RosettaData;
  55
  56 public class JU_Rcli {
  57
  58         @Mock RosettaDF<HttpURLConnection> dfMock;
  59         @Mock RosettaData<HttpURLConnection> dataMock;
  60         @Mock HttpURLConnection conMock;
  61         @Mock HttpServletRequest reqMock;
  62         @Mock HttpServletResponse respMock;
  63         @Mock ServletInputStream isMock;
  64
  65         private final static String uriString = "example.com";
  66         private final static String apiVersion = "v1.0";
  67         private final static String contentType = "contentType";
  68
  69         private static URI uri;
  70         private static Enumeration<String> enumeration;
  71
  72         private Client client;
  73
  74         @Before
  75         public void setup() throws URISyntaxException, IOException {
  76                 MockitoAnnotations.initMocks(this);
  77
  78                 when(dfMock.getTypeClass()).thenReturn(HttpURLConnection.class);
  79                 when(dfMock.newData()).thenReturn(dataMock);
  80                 when(dataMock.out((TYPE) any())).thenReturn(dataMock);
  81
  82                 when(reqMock.getInputStream()).thenReturn(isMock);
  83                 when(isMock.read((byte[]) any())).thenReturn(-1);
  84
  85                 uri = new URI(uriString);
  86                 enumeration = new CustomEnumeration();
  87                 client = new Client();
  88         }
  89
  90         @Test
  91         public void createTest() throws APIException, CadiException {
  92                 RcliStub rcli = new RcliStub(uri);
  93                 rcli.type(Data.TYPE.XML);
  94
  95                 rcli.create(null, contentType, dfMock, conMock);
  96                 rcli.create("No question mark", contentType, dfMock, conMock);
  97                 rcli.create("question?mark", contentType, dfMock, conMock);
  98
  99                 rcli.create(null, dfMock, conMock);
 100                 rcli.create("No question mark", dfMock, conMock);
 101                 rcli.create("question?mark", dfMock, conMock);
 102
 103                 rcli.create(null, HttpURLConnection.class, dfMock, conMock);
 104                 rcli.create("No question mark", HttpURLConnection.class, dfMock, conMock);
 105                 rcli.create("question?mark", HttpURLConnection.class, dfMock, conMock);
 106
 107                 rcli.create(null, HttpURLConnection.class);
 108                 rcli.create("No question mark", HttpURLConnection.class);
 109                 rcli.create("question?mark", HttpURLConnection.class);
 110
 111                 rcli.create(null, contentType);
 112                 rcli.create("No question mark", contentType);
 113                 rcli.create("question?mark", contentType);
 114         }
 115
 116         @Test
 117         public void postFormTest() throws APIException, CadiException {
 118                 RcliStub rcli = new RcliStub(uri);
 119
 120                 rcli.type(Data.TYPE.DEFAULT);
 121                 rcli.postForm(null, dfMock);
 122                 rcli.postForm("No question mark", dfMock);
 123                 rcli.postForm("question?mark", dfMock);
 124
 125                 rcli.type(Data.TYPE.JSON);
 126                 rcli.postForm("question?mark", dfMock);
 127
 128                 rcli.type(Data.TYPE.XML);
 129                 rcli.postForm("question?mark", dfMock);
 130
 131         }
 132
 133         @Test
 134         public void readPostTest() throws APIException, CadiException {
 135                 RcliStub rcli = new RcliStub(uri);
 136                 rcli.type(Data.TYPE.DEFAULT);
 137
 138                 rcli.readPost(null, dfMock, conMock);
 139                 rcli.readPost("No question mark", dfMock, conMock);
 140                 rcli.readPost("question?mark", dfMock, conMock);
 141
 142                 rcli.readPost(null, dfMock, conMock, dfMock);
 143                 rcli.readPost("No question mark", dfMock, conMock, dfMock);
 144                 rcli.readPost("question?mark", dfMock, conMock, dfMock);
 145
 146                 rcli.readPost("First string", "Second string");
 147         }
 148
 149         @Test
 150         public void readTest() throws APIException, CadiException {
 151                 RcliStub rcli = new RcliStub(uri);
 152                 rcli.type(Data.TYPE.DEFAULT);
 153
 154                 rcli.read("First string", "Second string", "Third string", "Fourth string");
 155                 rcli.read("First string", "Second string", dfMock, "Third string", "Fourth string");
 156                 rcli.read("First string", dfMock, "Third string", "Fourth string");
 157                 rcli.read("First string", HttpURLConnection.class ,dfMock);
 158         }
 159
 160         @Test
 161         public void updateTest() throws APIException, CadiException {
 162                 RcliStub rcli = new RcliStub(uri);
 163                 rcli.type(Data.TYPE.DEFAULT);
 164
 165                 rcli.update("First string", "Second string", dfMock, conMock);
 166                 rcli.update("First string", dfMock, conMock);
 167                 rcli.update("First string", HttpURLConnection.class, dfMock, conMock);
 168                 rcli.update("First string");
 169                 rcli.updateRespondString("First string", dfMock, conMock);
 170         }
 171
 172         @Test
 173         public void deleteTest() throws APIException, CadiException {
 174                 RcliStub rcli = new RcliStub(uri);
 175                 rcli.type(Data.TYPE.DEFAULT);
 176
 177                 rcli.delete("First string", "Second string", dfMock, conMock);
 178                 rcli.delete("First string", dfMock, conMock);
 179                 rcli.delete("First string", HttpURLConnection.class, dfMock, conMock);
 180                 rcli.delete("First string", HttpURLConnection.class);
 181                 rcli.delete("First string", "Second string");
 182         }
 183
 184         @Test
 185         public void transferTest() throws APIException, CadiException {
 186                 RcliStub rcli = new RcliStub(uri);
 187                 rcli.type(Data.TYPE.DEFAULT);
 188
 189                 when(reqMock.getRequestURI()).thenReturn(uriString);
 190                 when(reqMock.getHeaderNames()).thenReturn(enumeration);
 191                 rcli.transfer(reqMock, respMock, "string", 200);
 192
 193                 // coverage...
 194                 when(reqMock.getMethod()).thenReturn("GET");
 195                 rcli.transfer(reqMock, respMock, "string", 200);
 196         }
 197
 198         @Test(expected = CadiException.class)
 199         public void transferThrowsTest() throws APIException, CadiException {
 200                 RcliStub rcli = new RcliStub(uri);
 201                 rcli.type(Data.TYPE.DEFAULT);
 202
 203                 rcli.transfer(reqMock, respMock, "string", 200);
 204         }
 205
 206         @Test
 207         public void accessorMutatorTest() throws URISyntaxException {
 208                 RcliStub rcli = new RcliStub();
 209                 Rcli<?> rcliClone = rcli.forUser(null);
 210
 211                 rcli = new RcliStub(uri);
 212                 assertThat(rcli.toString(), is(uriString));
 213                 assertThat(rcli.getURI(), is(uri));
 214                 assertThat(rcli.getReadTimeout(), is(5000));
 215                 assertThat(rcli.getConnectionTimeout(), is(3000));
 216
 217                 rcli.connectionTimeout(3001);
 218                 assertThat(rcli.getConnectionTimeout(), is(3001));
 219                 rcli.readTimeout(5001);
 220                 assertThat(rcli.getReadTimeout(), is(5001));
 221                 rcli.apiVersion(apiVersion);
 222                 assertThat(rcli.isApiVersion(apiVersion), is(true));
 223                 rcli.type(Data.TYPE.XML);
 224                 assertThat(rcli.typeString(HttpURLConnection.class), is("application/HttpURLConnection+xml;version=" + apiVersion));
 225                 rcli.apiVersion(null);
 226                 assertThat(rcli.typeString(HttpURLConnection.class), is("application/HttpURLConnection+xml"));
 227
 228                 rcliClone = rcli.forUser(null);
 229                 assertThat(rcliClone.toString(), is(uriString));
 230         }
 231
 232         private class RcliStub extends Rcli<HttpURLConnection> {
 233                 public RcliStub() { super(); }
 234                 public RcliStub(URI uri) { this.uri = uri; }
 235                 @Override public void setSecuritySetter(SecuritySetter<HttpURLConnection> ss) { }
 236                 @Override public SecuritySetter<HttpURLConnection> getSecuritySetter() { return null; }
 237                 @Override protected Rcli<HttpURLConnection> clone(URI uri, SecuritySetter<HttpURLConnection> ss) { return this; }
 238                 @Override public void invalidate() throws CadiException { }
 239                 @Override protected EClient<HttpURLConnection> client() throws CadiException { return client; }
 240                 public int getReadTimeout() { return readTimeout; }
 241                 public int getConnectionTimeout() { return connectionTimeout; }
 242         }
 243
 244         private class CustomEnumeration implements Enumeration<String> {
 245                 private int idx = 0;
 246                 private final String[] elements = {"This", "is", "a", "test"};
 247                 @Override
 248                 public String nextElement() {
 249                         return idx >= elements.length ? null : elements[idx++];
 250                 }
 251                 @Override
 252                 public boolean hasMoreElements() {
 253                         return idx < elements.length;
 254                 }
 255         }
 256
 257         private class Client implements EClient<HttpURLConnection> {
 258                 private Transfer transfer;
 259                 @Override public void setPayload(Transfer transfer) { this.transfer = transfer; }
 260                 @Override public void setMethod(String meth) { }
 261                 @Override public void setPathInfo(String pathinfo) { }
 262                 @Override public void addHeader(String tag, String value) { }
 263                 @Override public void setQueryParams(String q) { }
 264                 @Override public void setFragment(String f) { }
 265                 @Override public void send() throws APIException {
 266                         try {
 267                                 if (transfer != null) {
 268                                         transfer.transfer(new PrintStream(new ByteArrayOutputStream()));
 269                                 }
 270                         } catch (IOException e) {
 271                         }
 272                 }
 273                 @Override public <T> Future<T> futureCreate(Class<T> t) { return null; }
 274                 @Override public Future<String> futureReadString() { return null; }
 275                 @Override public <T> Future<T> futureRead(RosettaDF<T> df, TYPE type) { return null; }
 276                 @Override public <T> Future<T> future(T t) { return null; }
 277                 @Override public Future<Void> future(HttpServletResponse resp, int expected) throws APIException { return null; }
 278         }
 279
 280         //private class FutureStub implements Future<String> {
 281         //}
 282 }