Rename UriComponents into Uri, close AsyncHttpClient#691

Author: Stephane Landelle

api/src/main/java/org/asynchttpclient/ConnectionPoolKeyStrategy.java

@@ -15,9 +15,9 @@
  */
 package org.asynchttpclient;
 
-import org.asynchttpclient.uri.UriComponents;
+import org.asynchttpclient.uri.Uri;
 
 public interface ConnectionPoolKeyStrategy {
 
-    String getKey(UriComponents uri, ProxyServer proxy);
+    String getKey(Uri uri, ProxyServer proxy);
 }

api/src/main/java/org/asynchttpclient/DefaultConnectionPoolStrategy.java

@@ -15,15 +15,15 @@
  */
 package org.asynchttpclient;
 
-import org.asynchttpclient.uri.UriComponents;
+import org.asynchttpclient.uri.Uri;
 import org.asynchttpclient.util.AsyncHttpProviderUtils;
 
 public enum DefaultConnectionPoolStrategy implements ConnectionPoolKeyStrategy {
 
     INSTANCE;
 
     @Override
-    public String getKey(UriComponents uri, ProxyServer proxyServer) {
+    public String getKey(Uri uri, ProxyServer proxyServer) {
         String serverPart = AsyncHttpProviderUtils.getBaseUrl(uri);
         return proxyServer != null ? proxyServer.getUrl() + serverPart : serverPart;
     }

api/src/main/java/org/asynchttpclient/HttpResponseStatus.java

@@ -18,27 +18,27 @@
 
 import java.util.List;
 
-import org.asynchttpclient.uri.UriComponents;
+import org.asynchttpclient.uri.Uri;
 
 /**
  * A class that represent the HTTP response' status line (code + text)
  */
 public abstract class HttpResponseStatus {
 
-    private final UriComponents uri;
+    private final Uri uri;
     protected final AsyncHttpClientConfig config;
 
-    public HttpResponseStatus(UriComponents uri, AsyncHttpClientConfig config) {
+    public HttpResponseStatus(Uri uri, AsyncHttpClientConfig config) {
         this.uri = uri;
         this.config = config;
     }
 
     /**
-     * Return the request {@link UriComponents}
+     * Return the request {@link Uri}
      * 
-     * @return the request {@link UriComponents}
+     * @return the request {@link Uri}
      */
-    public final UriComponents getUri() {
+    public final Uri getUri() {
         return uri;
     }
 

api/src/main/java/org/asynchttpclient/ProxyServerSelector.java

@@ -1,6 +1,6 @@
 package org.asynchttpclient;
 
-import org.asynchttpclient.uri.UriComponents;
+import org.asynchttpclient.uri.Uri;
 
 /**
  * Selector for a proxy server
@@ -13,14 +13,14 @@ public interface ProxyServerSelector {
      * @param uri The URI to select a proxy server for.
      * @return The proxy server to use, if any.  May return null.
      */
-    ProxyServer select(UriComponents uri);
+    ProxyServer select(Uri uri);
 
     /**
      * A selector that always selects no proxy.
      */
     static final ProxyServerSelector NO_PROXY_SELECTOR = new ProxyServerSelector() {
         @Override
-        public ProxyServer select(UriComponents uri) {
+        public ProxyServer select(Uri uri) {
             return null;
         }
     };

api/src/main/java/org/asynchttpclient/Realm.java

@@ -18,7 +18,7 @@
 
 import static org.asynchttpclient.util.MiscUtils.isNonEmpty;
 
-import org.asynchttpclient.uri.UriComponents;
+import org.asynchttpclient.uri.Uri;
 import org.asynchttpclient.util.StandardCharsets;
 
 import java.nio.charset.Charset;
@@ -43,7 +43,7 @@ public class Realm {
     private final String qop;
     private final String nc;
     private final String cnonce;
-    private final UriComponents uri;
+    private final Uri uri;
     private final String methodName;
     private final boolean usePreemptiveAuth;
     private final String enc;
@@ -60,7 +60,7 @@ public enum AuthScheme {
     }
 
     private Realm(AuthScheme scheme, String principal, String password, String realmName, String nonce, String algorithm, String response,
-            String qop, String nc, String cnonce, UriComponents uri, String method, boolean usePreemptiveAuth, String ntlmDomain, String enc,
+            String qop, String nc, String cnonce, Uri uri, String method, boolean usePreemptiveAuth, String ntlmDomain, String enc,
             String host, boolean messageType2Received, String opaque, boolean useAbsoluteURI, boolean omitQuery, boolean targetProxy) {
 
         this.principal = principal;
@@ -136,7 +136,7 @@ public String getCnonce() {
         return cnonce;
     }
 
-    public UriComponents getUri() {
+    public Uri getUri() {
         return uri;
     }
 
@@ -275,7 +275,7 @@ public static class RealmBuilder {
         private String qop = "auth";
         private String nc = "00000001";
         private String cnonce = "";
-        private UriComponents uri;
+        private Uri uri;
         private String methodName = "GET";
         private boolean usePreemptive;
         private String ntlmDomain = System.getProperty("http.auth.ntlm.domain", "");
@@ -394,11 +394,11 @@ public RealmBuilder setNc(String nc) {
             return this;
         }
 
-        public UriComponents getUri() {
+        public Uri getUri() {
             return uri;
         }
 
-        public RealmBuilder setUri(UriComponents uri) {
+        public RealmBuilder setUri(Uri uri) {
             this.uri = uri;
             return this;
         }

api/src/main/java/org/asynchttpclient/Request.java

@@ -18,7 +18,7 @@
 
 import org.asynchttpclient.cookie.Cookie;
 import org.asynchttpclient.multipart.Part;
-import org.asynchttpclient.uri.UriComponents;
+import org.asynchttpclient.uri.Uri;
 
 import java.io.File;
 import java.io.InputStream;
@@ -45,7 +45,7 @@ public interface Request {
      */
     String getMethod();
 
-    UriComponents getURI();
+    Uri getUri();
 
     String getUrl();
 

api/src/main/java/org/asynchttpclient/RequestBuilderBase.java

@@ -19,7 +19,7 @@
 
 import org.asynchttpclient.cookie.Cookie;
 import org.asynchttpclient.multipart.Part;
-import org.asynchttpclient.uri.UriComponents;
+import org.asynchttpclient.uri.Uri;
 import org.asynchttpclient.util.AsyncHttpProviderUtils;
 import org.asynchttpclient.util.QueryComputer;
 import org.slf4j.Logger;
@@ -42,11 +42,11 @@
 public abstract class RequestBuilderBase<T extends RequestBuilderBase<T>> {
     private final static Logger logger = LoggerFactory.getLogger(RequestBuilderBase.class);
 
-    private static final UriComponents DEFAULT_REQUEST_URL = UriComponents.create("http://localhost/");
+    private static final Uri DEFAULT_REQUEST_URL = Uri.create("http://localhost/");
 
     private static final class RequestImpl implements Request {
         private String method;
-        private UriComponents uri;
+        private Uri uri;
         private InetAddress address;
         private InetAddress localAddress;
         private FluentCaseInsensitiveStringsMap headers = new FluentCaseInsensitiveStringsMap();
@@ -75,7 +75,7 @@ public RequestImpl() {
         public RequestImpl(Request prototype) {
             if (prototype != null) {
                 this.method = prototype.getMethod();
-                this.uri = prototype.getURI();
+                this.uri = prototype.getUri();
                 this.address = prototype.getInetAddress();
                 this.localAddress = prototype.getLocalAddress();
                 this.headers = new FluentCaseInsensitiveStringsMap(prototype.getHeaders());
@@ -120,7 +120,7 @@ public InetAddress getLocalAddress() {
         }
 
         @Override
-        public UriComponents getURI() {
+        public Uri getUri() {
             return uri;
         }
 
@@ -289,10 +289,10 @@ protected RequestBuilderBase(Class<T> derived, Request prototype, QueryComputer
     }
 
     public T setUrl(String url) {
-        return setURI(UriComponents.create(url));
+        return setUri(Uri.create(url));
     }
 
-    public T setURI(UriComponents uri) {
+    public T setUri(Uri uri) {
         request.uri = uri;
         return derived.cast(this);
     }

api/src/main/java/org/asynchttpclient/Response.java

@@ -17,7 +17,7 @@
 package org.asynchttpclient;
 
 import org.asynchttpclient.cookie.Cookie;
-import org.asynchttpclient.uri.UriComponents;
+import org.asynchttpclient.uri.Uri;
 
 import java.io.IOException;
 import java.io.InputStream;
@@ -110,11 +110,11 @@ public interface Response {
     String getResponseBody() throws IOException;
 
     /**
-     * Return the request {@link UriComponents}. Note that if the request got redirected, the value of the {@link URI} will be the last valid redirect url.
+     * Return the request {@link Uri}. Note that if the request got redirected, the value of the {@link Uri} will be the last valid redirect url.
      * 
-     * @return the request {@link UriComponents}.
+     * @return the request {@link Uri}.
      */
-    UriComponents getUri();
+    Uri getUri();
 
     /**
      * Return the content-type header value.

api/src/main/java/org/asynchttpclient/SimpleAsyncHttpClient.java

@@ -30,7 +30,7 @@
 import org.asynchttpclient.resumable.ResumableIOExceptionFilter;
 import org.asynchttpclient.simple.HeaderMap;
 import org.asynchttpclient.simple.SimpleAHCTransferListener;
-import org.asynchttpclient.uri.UriComponents;
+import org.asynchttpclient.uri.Uri;
 
 /**
  * Simple implementation of {@link AsyncHttpClient} and it's related builders ({@link AsyncHttpClientConfig},
@@ -282,7 +282,7 @@ private Future<Response> execute(RequestBuilder rb, BodyConsumer bodyConsumer, T
 
         Request request = rb.build();
         ProgressAsyncHandler<Response> handler = new BodyConsumerAsyncHandler(bodyConsumer, throwableHandler, errorDocumentBehaviour,
-                request.getURI(), listener);
+                request.getUri(), listener);
 
         if (resumeEnabled && request.getMethod().equals("GET") && bodyConsumer != null && bodyConsumer instanceof ResumableBodyConsumer) {
             ResumableBodyConsumer fileBodyConsumer = (ResumableBodyConsumer) bodyConsumer;
@@ -719,7 +719,7 @@ private final static class BodyConsumerAsyncHandler extends AsyncCompletionHandl
         private final BodyConsumer bodyConsumer;
         private final ThrowableHandler exceptionHandler;
         private final ErrorDocumentBehaviour errorDocumentBehaviour;
-        private final UriComponents uri;
+        private final Uri uri;
         private final SimpleAHCTransferListener listener;
 
         private boolean accumulateBody = false;
@@ -728,7 +728,7 @@ private final static class BodyConsumerAsyncHandler extends AsyncCompletionHandl
         private long total = -1;
 
         public BodyConsumerAsyncHandler(BodyConsumer bodyConsumer, ThrowableHandler exceptionHandler,
-                ErrorDocumentBehaviour errorDocumentBehaviour, UriComponents uri, SimpleAHCTransferListener listener) {
+                ErrorDocumentBehaviour errorDocumentBehaviour, Uri uri, SimpleAHCTransferListener listener) {
             this.bodyConsumer = bodyConsumer;
             this.exceptionHandler = exceptionHandler;
             this.errorDocumentBehaviour = errorDocumentBehaviour;
@@ -851,7 +851,7 @@ private void fireHeaders(HttpResponseHeaders headers) {
             }
         }
 
-        private void fireSent(UriComponents uri, long amount, long current, long total) {
+        private void fireSent(Uri uri, long amount, long current, long total) {
             if (listener != null) {
                 listener.onBytesSent(uri, amount, current, total);
             }

api/src/main/java/org/asynchttpclient/oauth/OAuthSignatureCalculator.java

@@ -22,7 +22,7 @@
 import org.asynchttpclient.Request;
 import org.asynchttpclient.RequestBuilderBase;
 import org.asynchttpclient.SignatureCalculator;
-import org.asynchttpclient.uri.UriComponents;
+import org.asynchttpclient.uri.Uri;
 import org.asynchttpclient.util.Base64;
 import org.asynchttpclient.util.StandardCharsets;
 import org.asynchttpclient.util.UTF8UrlEncoder;
@@ -86,15 +86,15 @@ public OAuthSignatureCalculator(ConsumerKey consumerAuth, RequestToken userAuth)
     public void calculateAndAddSignature(Request request, RequestBuilderBase<?> requestBuilder) {
         String nonce = generateNonce();
         long timestamp = System.currentTimeMillis() / 1000L;
-        String signature = calculateSignature(request.getMethod(), request.getURI(), timestamp, nonce, request.getFormParams(), request.getQueryParams());
+        String signature = calculateSignature(request.getMethod(), request.getUri(), timestamp, nonce, request.getFormParams(), request.getQueryParams());
         String headerValue = constructAuthHeader(signature, nonce, timestamp);
         requestBuilder.setHeader(HEADER_AUTHORIZATION, headerValue);
     }
 
     /**
      * Method for calculating OAuth signature using HMAC/SHA-1 method.
      */
-    public String calculateSignature(String method, UriComponents uri, long oauthTimestamp, String nonce,
+    public String calculateSignature(String method, Uri uri, long oauthTimestamp, String nonce,
                                      List<Param> formParams, List<Param> queryParams) {
         StringBuilder signedText = new StringBuilder(100);
         signedText.append(method); // POST / GET etc (nothing to URL encode)

api/src/main/java/org/asynchttpclient/providers/ResponseBase.java

@@ -8,7 +8,7 @@
 import org.asynchttpclient.HttpResponseStatus;
 import org.asynchttpclient.Response;
 import org.asynchttpclient.cookie.Cookie;
-import org.asynchttpclient.uri.UriComponents;
+import org.asynchttpclient.uri.Uri;
 import org.asynchttpclient.util.AsyncHttpProviderUtils;
 
 import java.util.Collections;
@@ -51,7 +51,7 @@ public final String getStatusText() {
     }
 
     @Override
-    public final UriComponents getUri() {
+    public final Uri getUri() {
         return status.getUri();
     }
 

api/src/main/java/org/asynchttpclient/simple/SimpleAHCTransferListener.java

@@ -14,7 +14,7 @@
  */
 
 import org.asynchttpclient.SimpleAsyncHttpClient;
-import org.asynchttpclient.uri.UriComponents;
+import org.asynchttpclient.uri.Uri;
 
 /**
  * A simple transfer listener for use with the {@link SimpleAsyncHttpClient}.
@@ -34,15 +34,15 @@ public interface SimpleAHCTransferListener {
      * @param statusCode the received status code.
      * @param statusText the received status text.
      */
-    void onStatus(UriComponents uri, int statusCode, String statusText);
+    void onStatus(Uri uri, int statusCode, String statusText);
 
     /**
      * This method is called after the response headers are received.
      *
      * @param uri     the uri
      * @param headers the received headers, never {@code null}.
      */
-    void onHeaders(UriComponents uri, HeaderMap headers);
+    void onHeaders(Uri uri, HeaderMap headers);
 
     /**
      * This method is called when bytes of the responses body are received.
@@ -54,7 +54,7 @@ public interface SimpleAHCTransferListener {
      * @param total   the total number of bytes to be transferred. This is taken
      *                from the Content-Length-header and may be unspecified (-1).
      */
-    void onBytesReceived(UriComponents uri, long amount, long current, long total);
+    void onBytesReceived(Uri uri, long amount, long current, long total);
 
     /**
      * This method is called when bytes are sent.
@@ -66,7 +66,7 @@ public interface SimpleAHCTransferListener {
      * @param total   the total number of bytes to be transferred. This is taken
      *                from the Content-Length-header and may be unspecified (-1).
      */
-    void onBytesSent(UriComponents uri, long amount, long current, long total);
+    void onBytesSent(Uri uri, long amount, long current, long total);
 
     /**
      * This method is called when the request is completed.
@@ -75,6 +75,6 @@ public interface SimpleAHCTransferListener {
      * @param statusCode the received status code.
      * @param statusText the received status text.
      */
-    void onCompleted(UriComponents uri, int statusCode, String statusText);
+    void onCompleted(Uri uri, int statusCode, String statusText);
 }