gerrit.onap Code Review - dcaegen2/collectors/datafile.git/blob

   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 import org.apache.http.Header;
  24 import org.apache.http.HeaderIterator;
  25 import org.apache.http.HttpEntity;
  26 import org.apache.http.ProtocolVersion;
  27 import org.apache.http.StatusLine;
  28 import org.apache.http.client.methods.CloseableHttpResponse;
  29 import org.apache.http.params.HttpParams;
  30 import reactor.netty.http.client.HttpClientResponse;
  31 import reactor.util.context.Context;
  32 import reactor.util.context.ContextView;
  33
  34 import java.io.ByteArrayInputStream;
  35 import java.io.IOException;
  36 import java.io.InputStream;
  37 import java.io.OutputStream;
  38 import java.util.Locale;
  39 import java.util.Map;
  40 import java.util.Set;
  41
  42 public class HttpClientResponseHelper {
  43
  44     public static final HttpClientResponse NETTY_RESPONSE_OK = new HttpClientResponse() {
  45
  46         @Override
  47         public Map<CharSequence, Set<Cookie>> cookies() {
  48             return null;
  49         }
  50
  51         @Override
  52         public boolean isKeepAlive() {
  53             return false;
  54         }
  55
  56         @Override
  57         public boolean isWebsocket() {
  58             return false;
  59         }
  60
  61         @Override
  62         public HttpMethod method() {
  63             return null;
  64         }
  65
  66         @Override
  67         public String path() {
  68             return null;
  69         }
  70
  71         @Override
  72         public String fullPath() {
  73             return null;
  74         }
  75
  76         @Override
  77         public String requestId() {
  78             return null;
  79         }
  80
  81         @Override
  82         public String uri() {
  83             return null;
  84         }
  85
  86         @Override
  87         public HttpVersion version() {
  88             return null;
  89         }
  90
  91         @Override
  92         public Context currentContext() {
  93             return null;
  94         }
  95
  96         @Override
  97         public ContextView currentContextView() {
  98             return null;
  99         }
 100
 101         @Override
 102         public String[] redirectedFrom() {
 103             return new String[0];
 104         }
 105
 106         @Override
 107         public HttpHeaders requestHeaders() {
 108             return null;
 109         }
 110
 111         @Override
 112         public String resourceUrl() {
 113             return null;
 114         }
 115
 116         @Override
 117         public HttpHeaders responseHeaders() {
 118             return null;
 119         }
 120
 121         @Override
 122         public HttpResponseStatus status() {
 123             return HttpResponseStatus.OK;
 124         }
 125     };
 126
 127     public static final HttpClientResponse RESPONSE_ANY_NO_OK = new HttpClientResponse() {
 128
 129         @Override
 130         public Map<CharSequence, Set<Cookie>> cookies() {
 131             return null;
 132         }
 133
 134         @Override
 135         public boolean isKeepAlive() {
 136             return false;
 137         }
 138
 139         @Override
 140         public boolean isWebsocket() {
 141             return false;
 142         }
 143
 144         @Override
 145         public HttpMethod method() {
 146             return null;
 147         }
 148
 149         @Override
 150         public String fullPath() {
 151             return null;
 152         }
 153
 154         @Override
 155         public String requestId() {
 156             return null;
 157         }
 158
 159         @Override
 160         public String uri() {
 161             return null;
 162         }
 163
 164         @Override
 165         public HttpVersion version() {
 166             return null;
 167         }
 168
 169         @Override public Context currentContext() {
 170             return null;
 171         }
 172
 173         @Override public ContextView currentContextView() {
 174             return null;
 175         }
 176
 177         @Override public String[] redirectedFrom() {
 178             return new String[0];
 179         }
 180
 181         @Override public HttpHeaders requestHeaders() {
 182             return null;
 183         }
 184
 185         @Override public String resourceUrl() {
 186             return null;
 187         }
 188
 189         @Override public HttpHeaders responseHeaders() {
 190             return null;
 191         }
 192
 193         @Override public HttpResponseStatus status() {
 194             return HttpResponseStatus.NOT_IMPLEMENTED;
 195         }
 196     };
 197
 198     public static final CloseableHttpResponse APACHE_RESPONSE_OK = new CloseableHttpResponse() {
 199         @Override public void close() throws IOException {
 200             getEntity().getContent().close();
 201         }
 202
 203         @Override public StatusLine getStatusLine() {
 204             return new StatusLine() {
 205                 @Override public ProtocolVersion getProtocolVersion() {
 206                     return null;
 207                 }
 208
 209                 @Override public int getStatusCode() {
 210                     return 200;
 211                 }
 212
 213                 @Override public String getReasonPhrase() {
 214                     return null;
 215                 }
 216             };
 217         }
 218
 219         @Override public void setStatusLine(StatusLine statusLine) {
 220
 221         }
 222
 223         @Override public void setStatusLine(ProtocolVersion protocolVersion, int i) {
 224
 225         }
 226
 227         @Override public void setStatusLine(ProtocolVersion protocolVersion, int i, String s) {
 228
 229         }
 230
 231         @Override public void setStatusCode(int i) throws IllegalStateException {
 232
 233         }
 234
 235         @Override public void setReasonPhrase(String s) throws IllegalStateException {
 236
 237         }
 238
 239         @Override public HttpEntity getEntity() {
 240             return new HttpEntity() {
 241                 @Override public boolean isRepeatable() {
 242                     return false;
 243                 }
 244
 245                 @Override public boolean isChunked() {
 246                     return false;
 247                 }
 248
 249                 @Override public long getContentLength() {
 250                     return 0;
 251                 }
 252
 253                 @Override public Header getContentType() {
 254                     return null;
 255                 }
 256
 257                 @Override public Header getContentEncoding() {
 258                     return null;
 259                 }
 260
 261                 @Override public InputStream getContent() throws IOException, UnsupportedOperationException {
 262                     return new ByteArrayInputStream("abc".getBytes());
 263                 }
 264
 265                 @Override public void writeTo(OutputStream outputStream) throws IOException {
 266
 267                 }
 268
 269                 @Override public boolean isStreaming() {
 270                     return false;
 271                 }
 272
 273                 @Override public void consumeContent() throws IOException {
 274
 275                 }
 276             };
 277         }
 278
 279         @Override public void setEntity(HttpEntity httpEntity) {
 280
 281         }
 282
 283         @Override public Locale getLocale() {
 284             return null;
 285         }
 286
 287         @Override public void setLocale(Locale locale) {
 288
 289         }
 290
 291         @Override public ProtocolVersion getProtocolVersion() {
 292             return null;
 293         }
 294
 295         @Override public boolean containsHeader(String s) {
 296             return false;
 297         }
 298
 299         @Override public Header[] getHeaders(String s) {
 300             return new Header[0];
 301         }
 302
 303         @Override public Header getFirstHeader(String s) {
 304             return null;
 305         }
 306
 307         @Override public Header getLastHeader(String s) {
 308             return null;
 309         }
 310
 311         @Override public Header[] getAllHeaders() {
 312             return new Header[0];
 313         }
 314
 315         @Override public void addHeader(Header header) {
 316
 317         }
 318
 319         @Override public void addHeader(String s, String s1) {
 320
 321         }
 322
 323         @Override public void setHeader(Header header) {
 324
 325         }
 326
 327         @Override public void setHeader(String s, String s1) {
 328
 329         }
 330
 331         @Override public void setHeaders(Header[] headers) {
 332
 333         }
 334
 335         @Override public void removeHeader(Header header) {
 336
 337         }
 338
 339         @Override public void removeHeaders(String s) {
 340
 341         }
 342
 343         @Override public HeaderIterator headerIterator() {
 344             return null;
 345         }
 346
 347         @Override public HeaderIterator headerIterator(String s) {
 348             return null;
 349         }
 350
 351         @Override public HttpParams getParams() {
 352             return null;
 353         }
 354
 355         @Override public void setParams(HttpParams httpParams) {
 356
 357         }
 358     };
 359 }