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
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;
23 import reactor.netty.http.client.HttpClientResponse;
24 import reactor.util.context.Context;
25 import reactor.util.context.ContextView;
30 public class HttpClientResponseHelper {
32 public static final HttpClientResponse RESPONSE_OK = new HttpClientResponse() {
35 public Map<CharSequence, Set<Cookie>> cookies() {
40 public boolean isKeepAlive() {
45 public boolean isWebsocket() {
50 public HttpMethod method() {
55 public String fullPath() {
65 public HttpVersion version() {
70 public Context currentContext() {
75 public ContextView currentContextView() {
80 public String[] redirectedFrom() {
85 public HttpHeaders requestHeaders() {
90 public String resourceUrl() {
95 public HttpHeaders responseHeaders() {
100 public HttpResponseStatus status() {
101 return HttpResponseStatus.OK;
105 public static final HttpClientResponse RESPONSE_ANY_NO_OK = new HttpClientResponse() {
108 public Map<CharSequence, Set<Cookie>> cookies() {
113 public boolean isKeepAlive() {
118 public boolean isWebsocket() {
123 public HttpMethod method() {
128 public String fullPath() {
133 public String uri() {
138 public HttpVersion version() {
142 @Override public Context currentContext() {
146 @Override public ContextView currentContextView() {
150 @Override public String[] redirectedFrom() {
151 return new String[0];
154 @Override public HttpHeaders requestHeaders() {
158 @Override public String resourceUrl() {
162 @Override public HttpHeaders responseHeaders() {
166 @Override public HttpResponseStatus status() {
167 return HttpResponseStatus.NOT_IMPLEMENTED;