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
8 * http://www.apache.org/licenses/LICENSE-2.0
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
14 * ============LICENSE_END========================================================================
16 package org.onap.dcaegen2.collectors.datafile.http;
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;
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;
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;
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;
45 public class HttpClientResponseHelper {
47 public static final HttpClientResponse NETTY_RESPONSE_OK = new HttpClientResponse() {
50 public Map<CharSequence, Set<Cookie>> cookies() {
55 public boolean isKeepAlive() {
60 public boolean isWebsocket() {
65 public HttpMethod method() {
70 public String path() {
75 public String fullPath() {
80 public String requestId() {
90 public HttpVersion version() {
95 public Context currentContext() {
100 public ContextView currentContextView() {
105 public String[] redirectedFrom() {
106 return new String[0];
110 public HttpHeaders requestHeaders() {
115 public String resourceUrl() {
120 public HttpHeaders responseHeaders() {
125 public HttpResponseStatus status() {
126 return HttpResponseStatus.OK;
130 public Mono<HttpHeaders> trailerHeaders() {
135 public static final HttpClientResponse RESPONSE_ANY_NO_OK = new HttpClientResponse() {
138 public Map<CharSequence, Set<Cookie>> cookies() {
143 public boolean isKeepAlive() {
148 public boolean isWebsocket() {
153 public HttpMethod method() {
158 public String fullPath() {
163 public String requestId() {
168 public String uri() {
173 public HttpVersion version() {
178 public Context currentContext() {
183 public ContextView currentContextView() {
188 public String[] redirectedFrom() {
189 return new String[0];
193 public HttpHeaders requestHeaders() {
198 public String resourceUrl() {
203 public HttpHeaders responseHeaders() {
208 public HttpResponseStatus status() {
209 return HttpResponseStatus.NOT_IMPLEMENTED;
213 public Mono<HttpHeaders> trailerHeaders() {
218 public static final CloseableHttpResponse APACHE_RESPONSE_OK = new CloseableHttpResponse() {
220 public void close() throws IOException {
221 getEntity().getContent().close();
225 public StatusLine getStatusLine() {
226 return new StatusLine() {
228 public ProtocolVersion getProtocolVersion() {
233 public int getStatusCode() {
238 public String getReasonPhrase() {
245 public void setStatusLine(StatusLine statusLine) {
250 public void setStatusLine(ProtocolVersion protocolVersion, int i) {
255 public void setStatusLine(ProtocolVersion protocolVersion, int i, String s) {
260 public void setStatusCode(int i) throws IllegalStateException {
265 public void setReasonPhrase(String s) throws IllegalStateException {
270 public HttpEntity getEntity() {
271 return new HttpEntity() {
273 public boolean isRepeatable() {
278 public boolean isChunked() {
283 public long getContentLength() {
288 public Header getContentType() {
293 public Header getContentEncoding() {
298 public InputStream getContent() throws IOException, UnsupportedOperationException {
299 return new ByteArrayInputStream("abc".getBytes());
303 public void writeTo(OutputStream outputStream) throws IOException {
308 public boolean isStreaming() {
313 public void consumeContent() throws IOException {
320 public void setEntity(HttpEntity httpEntity) {
325 public Locale getLocale() {
330 public void setLocale(Locale locale) {
335 public ProtocolVersion getProtocolVersion() {
340 public boolean containsHeader(String s) {
345 public Header[] getHeaders(String s) {
346 return new Header[0];
350 public Header getFirstHeader(String s) {
355 public Header getLastHeader(String s) {
360 public Header[] getAllHeaders() {
361 return new Header[0];
365 public void addHeader(Header header) {
370 public void addHeader(String s, String s1) {
375 public void setHeader(Header header) {
380 public void setHeader(String s, String s1) {
385 public void setHeaders(Header[] headers) {
390 public void removeHeader(Header header) {
395 public void removeHeaders(String s) {
400 public HeaderIterator headerIterator() {
405 public HeaderIterator headerIterator(String s) {
410 public HttpParams getParams() {
415 public void setParams(HttpParams params) {