Skip to content

Commit b1d9471

Browse files
author
oleksiys
committed
[1.9.x] + move all the com.ning.http.client.providers.netty.util.HttpUtil methods except getNettyHeaderValuesByCaseInsensitiveName to the com.ning.http.util.AsyncHttpProviderUtils
1 parent 6e9a62b commit b1d9471

File tree

8 files changed

+50
-57
lines changed

8 files changed

+50
-57
lines changed

src/main/java/com/ning/http/client/providers/grizzly/AhcEventFilter.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -55,7 +55,6 @@
5555
import org.slf4j.Logger;
5656
import org.slf4j.LoggerFactory;
5757

58-
import static com.ning.http.client.providers.netty.util.HttpUtils.getNTLM;
5958
import static com.ning.http.util.AsyncHttpProviderUtils.*;
6059
import static com.ning.http.util.MiscUtils.isNonEmpty;
6160
/**

src/main/java/com/ning/http/client/providers/netty/channel/ChannelManager.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
/*
2-
* Copyright (c) 2014 AsyncHttpClient Project. All rights reserved.
2+
* Copyright (c) 2014-2015 AsyncHttpClient Project. All rights reserved.
33
*
44
* This program is licensed to you under the Apache License Version 2.0,
55
* and you may not use this file except in compliance with the Apache License Version 2.0.
@@ -13,9 +13,9 @@
1313
*/
1414
package com.ning.http.client.providers.netty.channel;
1515

16-
import static com.ning.http.client.providers.netty.util.HttpUtils.WEBSOCKET;
17-
import static com.ning.http.client.providers.netty.util.HttpUtils.isSecure;
18-
import static com.ning.http.client.providers.netty.util.HttpUtils.isWebSocket;
16+
import static com.ning.http.util.AsyncHttpProviderUtils.WEBSOCKET;
17+
import static com.ning.http.util.AsyncHttpProviderUtils.isSecure;
18+
import static com.ning.http.util.AsyncHttpProviderUtils.isWebSocket;
1919
import static com.ning.http.util.MiscUtils.buildStaticIOException;
2020
import static org.jboss.netty.channel.Channels.pipeline;
2121
import static org.jboss.netty.handler.ssl.SslHandler.getDefaultBufferPool;

src/main/java/com/ning/http/client/providers/netty/handler/HttpProtocol.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
/*
2-
* Copyright (c) 2014 AsyncHttpClient Project. All rights reserved.
2+
* Copyright (c) 2014-2015 AsyncHttpClient Project. All rights reserved.
33
*
44
* This program is licensed to you under the Apache License Version 2.0,
55
* and you may not use this file except in compliance with the Apache License Version 2.0.
@@ -13,7 +13,7 @@
1313
*/
1414
package com.ning.http.client.providers.netty.handler;
1515

16-
import static com.ning.http.client.providers.netty.util.HttpUtils.getNTLM;
16+
import static com.ning.http.util.AsyncHttpProviderUtils.getNTLM;
1717
import static com.ning.http.util.AsyncHttpProviderUtils.getDefaultPort;
1818
import static com.ning.http.util.MiscUtils.isNonEmpty;
1919
import static org.jboss.netty.handler.codec.http.HttpResponseStatus.CONTINUE;

src/main/java/com/ning/http/client/providers/netty/handler/Protocol.java

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
/*
2-
* Copyright (c) 2014 AsyncHttpClient Project. All rights reserved.
2+
* Copyright (c) 2014-2015 AsyncHttpClient Project. All rights reserved.
33
*
44
* This program is licensed to you under the Apache License Version 2.0,
55
* and you may not use this file except in compliance with the Apache License Version 2.0.
@@ -13,8 +13,6 @@
1313
*/
1414
package com.ning.http.client.providers.netty.handler;
1515

16-
import static com.ning.http.client.providers.netty.util.HttpUtils.HTTP;
17-
import static com.ning.http.client.providers.netty.util.HttpUtils.WEBSOCKET;
1816
import static com.ning.http.util.AsyncHttpProviderUtils.*;
1917
import static org.jboss.netty.handler.codec.http.HttpHeaders.Names.*;
2018
import static org.jboss.netty.handler.codec.http.HttpResponseStatus.*;

src/main/java/com/ning/http/client/providers/netty/request/NettyRequestFactory.java

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
/*
2-
* Copyright (c) 2014 AsyncHttpClient Project. All rights reserved.
2+
* Copyright (c) 2014-2015 AsyncHttpClient Project. All rights reserved.
33
*
44
* This program is licensed to you under the Apache License Version 2.0,
55
* and you may not use this file except in compliance with the Apache License Version 2.0.
@@ -13,10 +13,10 @@
1313
*/
1414
package com.ning.http.client.providers.netty.request;
1515

16-
import static com.ning.http.client.providers.netty.util.HttpUtils.getNTLM;
17-
import static com.ning.http.client.providers.netty.util.HttpUtils.isSecure;
18-
import static com.ning.http.client.providers.netty.util.HttpUtils.isWebSocket;
19-
import static com.ning.http.client.providers.netty.util.HttpUtils.useProxyConnect;
16+
import static com.ning.http.util.AsyncHttpProviderUtils.getNTLM;
17+
import static com.ning.http.util.AsyncHttpProviderUtils.isSecure;
18+
import static com.ning.http.util.AsyncHttpProviderUtils.isWebSocket;
19+
import static com.ning.http.util.AsyncHttpProviderUtils.useProxyConnect;
2020
import static com.ning.http.client.providers.netty.ws.WebSocketUtils.getKey;
2121
import static com.ning.http.util.AsyncHttpProviderUtils.DEFAULT_CHARSET;
2222
import static com.ning.http.util.AsyncHttpProviderUtils.getAuthority;

src/main/java/com/ning/http/client/providers/netty/request/NettyRequestSender.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
/*
2-
* Copyright (c) 2014 AsyncHttpClient Project. All rights reserved.
2+
* Copyright (c) 2014-2015 AsyncHttpClient Project. All rights reserved.
33
*
44
* This program is licensed to you under the Apache License Version 2.0,
55
* and you may not use this file except in compliance with the Apache License Version 2.0.
@@ -12,9 +12,9 @@
1212
*/
1313
package com.ning.http.client.providers.netty.request;
1414

15-
import static com.ning.http.client.providers.netty.util.HttpUtils.WEBSOCKET;
16-
import static com.ning.http.client.providers.netty.util.HttpUtils.isSecure;
17-
import static com.ning.http.client.providers.netty.util.HttpUtils.useProxyConnect;
15+
import static com.ning.http.util.AsyncHttpProviderUtils.WEBSOCKET;
16+
import static com.ning.http.util.AsyncHttpProviderUtils.isSecure;
17+
import static com.ning.http.util.AsyncHttpProviderUtils.useProxyConnect;
1818
import static com.ning.http.util.AsyncHttpProviderUtils.REMOTELY_CLOSED_EXCEPTION;
1919
import static com.ning.http.util.AsyncHttpProviderUtils.getDefaultPort;
2020
import static com.ning.http.util.AsyncHttpProviderUtils.requestTimeout;
Lines changed: 1 addition & 37 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
/*
2-
* Copyright (c) 2014 AsyncHttpClient Project. All rights reserved.
2+
* Copyright (c) 2014-2015 AsyncHttpClient Project. All rights reserved.
33
*
44
* This program is licensed to you under the Apache License Version 2.0,
55
* and you may not use this file except in compliance with the Apache License Version 2.0.
@@ -15,34 +15,14 @@
1515

1616
import org.jboss.netty.handler.codec.http.HttpHeaders;
1717

18-
import com.ning.http.client.uri.Uri;
19-
import com.ning.http.util.MiscUtils;
20-
2118
import java.util.ArrayList;
2219
import java.util.List;
2320
import java.util.Map.Entry;
2421

2522
public final class HttpUtils {
26-
27-
public static final String HTTP = "http";
28-
public static final String HTTPS = "https";
29-
public static final String WEBSOCKET = "ws";
30-
public static final String WEBSOCKET_SSL = "wss";
31-
3223
private HttpUtils() {
3324
}
3425

35-
public static String getNTLM(List<String> authenticateHeaders) {
36-
if (MiscUtils.isNonEmpty(authenticateHeaders)) {
37-
for (String authenticateHeader: authenticateHeaders) {
38-
if (authenticateHeader.startsWith("NTLM"))
39-
return authenticateHeader;
40-
}
41-
}
42-
43-
return null;
44-
}
45-
4626
public static List<String> getNettyHeaderValuesByCaseInsensitiveName(HttpHeaders headers, String name) {
4727
ArrayList<String> l = new ArrayList<>();
4828
for (Entry<String, String> e : headers) {
@@ -52,20 +32,4 @@ public static List<String> getNettyHeaderValuesByCaseInsensitiveName(HttpHeaders
5232
}
5333
return l;
5434
}
55-
56-
public static boolean isWebSocket(String scheme) {
57-
return WEBSOCKET.equals(scheme) || WEBSOCKET_SSL.equalsIgnoreCase(scheme);
58-
}
59-
60-
public static boolean isSecure(String scheme) {
61-
return HTTPS.equals(scheme) || WEBSOCKET_SSL.equals(scheme);
62-
}
63-
64-
public static boolean isSecure(Uri uri) {
65-
return isSecure(uri.getScheme());
66-
}
67-
68-
public static boolean useProxyConnect(Uri uri) {
69-
return isSecure(uri) || isWebSocket(uri.getScheme());
70-
}
7135
}

src/main/java/com/ning/http/util/AsyncHttpProviderUtils.java

Lines changed: 33 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
/*
2-
* Copyright (c) 2010-2012 Sonatype, Inc. All rights reserved.
2+
* Copyright (c) 2010-2015 Sonatype, Inc. All rights reserved.
33
*
44
* This program is licensed to you under the Apache License Version 2.0,
55
* and you may not use this file except in compliance with the Apache License Version 2.0.
@@ -41,6 +41,11 @@ public class AsyncHttpProviderUtils {
4141

4242
public final static Charset DEFAULT_CHARSET = ISO_8859_1;
4343

44+
public static final String HTTP = "http";
45+
public static final String HTTPS = "https";
46+
public static final String WEBSOCKET = "ws";
47+
public static final String WEBSOCKET_SSL = "wss";
48+
4449
static final byte[] EMPTY_BYTE_ARRAY = "".getBytes();
4550

4651
public static final void validateSupportedScheme(Uri uri) {
@@ -191,4 +196,31 @@ private static void encodeAndAppendFormParam(final StringBuilder sb, final CharS
191196
}
192197
sb.append('&');
193198
}
199+
200+
public static String getNTLM(List<String> authenticateHeaders) {
201+
if (MiscUtils.isNonEmpty(authenticateHeaders)) {
202+
for (String authenticateHeader: authenticateHeaders) {
203+
if (authenticateHeader.startsWith("NTLM"))
204+
return authenticateHeader;
205+
}
206+
}
207+
208+
return null;
209+
}
210+
211+
public static boolean isWebSocket(String scheme) {
212+
return WEBSOCKET.equals(scheme) || WEBSOCKET_SSL.equalsIgnoreCase(scheme);
213+
}
214+
215+
public static boolean isSecure(String scheme) {
216+
return HTTPS.equals(scheme) || WEBSOCKET_SSL.equals(scheme);
217+
}
218+
219+
public static boolean isSecure(Uri uri) {
220+
return isSecure(uri.getScheme());
221+
}
222+
223+
public static boolean useProxyConnect(Uri uri) {
224+
return isSecure(uri) || isWebSocket(uri.getScheme());
225+
}
194226
}

0 commit comments

Comments
 (0)