datafilecollector/src/test/java/org/onap/dcaegen2/collectors/datafile/http/HttpClientResponseHelper.java

   1 /*-
   2  * ============LICENSE_START======================================================================
   3  * Copyright (C) 2020-2021 Nokia. All rights reserved.
   4  * ===============================================================================================
   5  * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except
   6  * in compliance with the License. You may obtain a copy of the License at
   7  *
   8  * http://www.apache.org/licenses/LICENSE-2.0
   9  *
  10  * Unless required by applicable law or agreed to in writing, software distributed under the License
  11  * is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express
  12  * or implied. See the License for the specific language governing permissions and limitations under
  13  * the License.
  14  * ============LICENSE_END========================================================================
  15  */
  16 package org.onap.dcaegen2.collectors.datafile.http;
  17
  18 import io.netty.handler.codec.http.HttpHeaders;
  19 import io.netty.handler.codec.http.HttpMethod;
  20 import io.netty.handler.codec.http.HttpResponseStatus;
  21 import io.netty.handler.codec.http.HttpVersion;
  22 import io.netty.handler.codec.http.cookie.Cookie;
  23
  24 import java.io.ByteArrayInputStream;
  25 import java.io.IOException;
  26 import java.io.InputStream;
  27 import java.io.OutputStream;
  28 import java.util.Locale;
  29 import java.util.Map;
  30 import java.util.Set;
  31
  32 import org.apache.http.Header;
  33 import org.apache.http.HeaderIterator;
  34 import org.apache.http.HttpEntity;
  35 import org.apache.http.ProtocolVersion;
  36 import org.apache.http.StatusLine;
  37 import org.apache.http.client.methods.CloseableHttpResponse;
  38 import org.apache.http.params.HttpParams;
  39
  40 import reactor.core.publisher.Mono;
  41 import reactor.netty.http.client.HttpClientResponse;
  42 import reactor.util.context.Context;
  43 import reactor.util.context.ContextView;
  44
  45 public class HttpClientResponseHelper {
  46
  47     public static final HttpClientResponse NETTY_RESPONSE_OK = new HttpClientResponse() {
  48
  49         @Override
  50         public Map<CharSequence, Set<Cookie>> cookies() {
  51             return null;
  52         }
  53
  54         @Override
  55         public boolean isKeepAlive() {
  56             return false;
  57         }
  58
  59         @Override
  60         public boolean isWebsocket() {
  61             return false;
  62         }
  63
  64         @Override
  65         public HttpMethod method() {
  66             return null;
  67         }
  68
  69         @Override
  70         public String path() {
  71             return null;
  72         }
  73
  74         @Override
  75         public String fullPath() {
  76             return null;
  77         }
  78
  79         @Override
  80         public String requestId() {
  81             return null;
  82         }
  83
  84         @Override
  85         public String uri() {
  86             return null;
  87         }
  88
  89         @Override
  90         public HttpVersion version() {
  91             return null;
  92         }
  93
  94         @Override
  95         public Context currentContext() {
  96             return null;
  97         }
  98
  99         @Override
 100         public ContextView currentContextView() {
 101             return null;
 102         }
 103
 104         @Override
 105         public String[] redirectedFrom() {
 106             return new String[0];
 107         }
 108
 109         @Override
 110         public HttpHeaders requestHeaders() {
 111             return null;
 112         }
 113
 114         @Override
 115         public String resourceUrl() {
 116             return null;
 117         }
 118
 119         @Override
 120         public HttpHeaders responseHeaders() {
 121             return null;
 122         }
 123
 124         @Override
 125         public HttpResponseStatus status() {
 126             return HttpResponseStatus.OK;
 127         }
 128
 129         @Override
 130         public Mono<HttpHeaders> trailerHeaders() {
 131             return null;
 132         }
 133     };
 134
 135     public static final HttpClientResponse RESPONSE_ANY_NO_OK = new HttpClientResponse() {
 136
 137         @Override
 138         public Map<CharSequence, Set<Cookie>> cookies() {
 139             return null;
 140         }
 141
 142         @Override
 143         public boolean isKeepAlive() {
 144             return false;
 145         }
 146
 147         @Override
 148         public boolean isWebsocket() {
 149             return false;
 150         }
 151
 152         @Override
 153         public HttpMethod method() {
 154             return null;
 155         }
 156
 157         @Override
 158         public String fullPath() {
 159             return null;
 160         }
 161
 162         @Override
 163         public String requestId() {
 164             return null;
 165         }
 166
 167         @Override
 168         public String uri() {
 169             return null;
 170         }
 171
 172         @Override
 173         public HttpVersion version() {
 174             return null;
 175         }
 176
 177         @Override
 178         public Context currentContext() {
 179             return null;
 180         }
 181
 182         @Override
 183         public ContextView currentContextView() {
 184             return null;
 185         }
 186
 187         @Override
 188         public String[] redirectedFrom() {
 189             return new String[0];
 190         }
 191
 192         @Override
 193         public HttpHeaders requestHeaders() {
 194             return null;
 195         }
 196
 197         @Override
 198         public String resourceUrl() {
 199             return null;
 200         }
 201
 202         @Override
 203         public HttpHeaders responseHeaders() {
 204             return null;
 205         }
 206
 207         @Override
 208         public HttpResponseStatus status() {
 209             return HttpResponseStatus.NOT_IMPLEMENTED;
 210         }
 211
 212         @Override
 213         public Mono<HttpHeaders> trailerHeaders() {
 214             return null;
 215         }
 216     };
 217
 218     public static final CloseableHttpResponse APACHE_RESPONSE_OK = new CloseableHttpResponse() {
 219         @Override
 220         public void close() throws IOException {
 221             getEntity().getContent().close();
 222         }
 223
 224         @Override
 225         public StatusLine getStatusLine() {
 226             return new StatusLine() {
 227                 @Override
 228                 public ProtocolVersion getProtocolVersion() {
 229                     return null;
 230                 }
 231
 232                 @Override
 233                 public int getStatusCode() {
 234                     return 200;
 235                 }
 236
 237                 @Override
 238                 public String getReasonPhrase() {
 239                     return null;
 240                 }
 241             };
 242         }
 243
 244         @Override
 245         public void setStatusLine(StatusLine statusLine) {
 246
 247         }
 248
 249         @Override
 250         public void setStatusLine(ProtocolVersion protocolVersion, int i) {
 251
 252         }
 253
 254         @Override
 255         public void setStatusLine(ProtocolVersion protocolVersion, int i, String s) {
 256
 257         }
 258
 259         @Override
 260         public void setStatusCode(int i) throws IllegalStateException {
 261
 262         }
 263
 264         @Override
 265         public void setReasonPhrase(String s) throws IllegalStateException {
 266
 267         }
 268
 269         @Override
 270         public HttpEntity getEntity() {
 271             return new HttpEntity() {
 272                 @Override
 273                 public boolean isRepeatable() {
 274                     return false;
 275                 }
 276
 277                 @Override
 278                 public boolean isChunked() {
 279                     return false;
 280                 }
 281
 282                 @Override
 283                 public long getContentLength() {
 284                     return 0;
 285                 }
 286
 287                 @Override
 288                 public Header getContentType() {
 289                     return null;
 290                 }
 291
 292                 @Override
 293                 public Header getContentEncoding() {
 294                     return null;
 295                 }
 296
 297                 @Override
 298                 public InputStream getContent() throws IOException, UnsupportedOperationException {
 299                     return new ByteArrayInputStream("abc".getBytes());
 300                 }
 301
 302                 @Override
 303                 public void writeTo(OutputStream outputStream) throws IOException {
 304
 305                 }
 306
 307                 @Override
 308                 public boolean isStreaming() {
 309                     return false;
 310                 }
 311
 312                 @Override
 313                 public void consumeContent() throws IOException {
 314
 315                 }
 316             };
 317         }
 318
 319         @Override
 320         public void setEntity(HttpEntity httpEntity) {
 321
 322         }
 323
 324         @Override
 325         public Locale getLocale() {
 326             return null;
 327         }
 328
 329         @Override
 330         public void setLocale(Locale locale) {
 331
 332         }
 333
 334         @Override
 335         public ProtocolVersion getProtocolVersion() {
 336             return null;
 337         }
 338
 339         @Override
 340         public boolean containsHeader(String s) {
 341             return false;
 342         }
 343
 344         @Override
 345         public Header[] getHeaders(String s) {
 346             return new Header[0];
 347         }
 348
 349         @Override
 350         public Header getFirstHeader(String s) {
 351             return null;
 352         }
 353
 354         @Override
 355         public Header getLastHeader(String s) {
 356             return null;
 357         }
 358
 359         @Override
 360         public Header[] getAllHeaders() {
 361             return new Header[0];
 362         }
 363
 364         @Override
 365         public void addHeader(Header header) {
 366
 367         }
 368
 369         @Override
 370         public void addHeader(String s, String s1) {
 371
 372         }
 373
 374         @Override
 375         public void setHeader(Header header) {
 376
 377         }
 378
 379         @Override
 380         public void setHeader(String s, String s1) {
 381
 382         }
 383
 384         @Override
 385         public void setHeaders(Header[] headers) {
 386
 387         }
 388
 389         @Override
 390         public void removeHeader(Header header) {
 391
 392         }
 393
 394         @Override
 395         public void removeHeaders(String s) {
 396
 397         }
 398
 399         @Override
 400         public HeaderIterator headerIterator() {
 401             return null;
 402         }
 403
 404         @Override
 405         public HeaderIterator headerIterator(String s) {
 406             return null;
 407         }
 408
 409         @Override
 410         public HttpParams getParams() {
 411             return null;
 412         }
 413
 414         @Override
 415         public void setParams(HttpParams params) {
 416         }
 417     };
 418 }