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

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