datafilecollector/src/test/java/org/oran/datafile/http/HttpClientResponseHelper.java

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