Drop TimeConverter, stick to RFC 2616, close AsyncHttpClient#778

Author: Stephane Landelle

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

@@ -29,7 +29,6 @@
 import javax.net.ssl.HostnameVerifier;
 import javax.net.ssl.SSLContext;
 
-import org.asynchttpclient.date.TimeConverter;
 import org.asynchttpclient.filter.IOExceptionFilter;
 import org.asynchttpclient.filter.RequestFilter;
 import org.asynchttpclient.filter.ResponseFilter;
@@ -103,7 +102,6 @@ public class AsyncHttpClientConfig {
     protected int maxRequestRetry;
     protected boolean disableUrlEncodingForBoundRequests;
     protected int ioThreadMultiplier;
-    protected TimeConverter timeConverter;
     protected String[] enabledProtocols;
     protected String[] enabledCipherSuites;
     protected AsyncHttpProviderConfig<?, ?> providerConfig;
@@ -145,7 +143,6 @@ private AsyncHttpClientConfig(int connectTimeout,//
             int maxRequestRetry, //
             boolean disableUrlEncodingForBoundRequests, //
             int ioThreadMultiplier, //
-            TimeConverter timeConverter,//
             String[] enabledProtocols,//
             String[] enabledCipherSuites,//
             AsyncHttpProviderConfig<?, ?> providerConfig,//
@@ -182,7 +179,6 @@ private AsyncHttpClientConfig(int connectTimeout,//
         this.maxRequestRetry = maxRequestRetry;
         this.disableUrlEncodingForBoundRequests = disableUrlEncodingForBoundRequests;
         this.ioThreadMultiplier = ioThreadMultiplier;
-        this.timeConverter = timeConverter;
         this.enabledProtocols = enabledProtocols;
         this.enabledCipherSuites = enabledCipherSuites;
         this.providerConfig = providerConfig;
@@ -517,15 +513,6 @@ public int getConnectionTTL() {
         return connectionTTL;
     }
 
-    /**
-     * @return the TimeConverter used for converting RFC2616Dates into time
-     *
-     * since 1.9.0
-     */
-    public TimeConverter getTimeConverter() {
-        return timeConverter;
-    }
-
     public boolean isAcceptAnyCertificate() {
         return acceptAnyCertificate;
     }
@@ -579,7 +566,6 @@ public static class Builder {
         private int maxRequestRetry = defaultMaxRequestRetry();
         private boolean disableUrlEncodingForBoundRequests = defaultDisableUrlEncodingForBoundRequests();
         private int ioThreadMultiplier = defaultIoThreadMultiplier();
-        private TimeConverter timeConverter;
         private String[] enabledProtocols;
         private String[] enabledCipherSuites;
         private AsyncHttpProviderConfig<?, ?> providerConfig;
@@ -1041,11 +1027,6 @@ public Builder setSpdyMaxConcurrentStreams(int spdyMaxConcurrentStreams) {
             return this;
         }
 
-        public Builder setTimeConverter(TimeConverter timeConverter) {
-            this.timeConverter = timeConverter;
-            return this;
-        }
-
         public Builder setAcceptAnyCertificate(boolean acceptAnyCertificate) {
             this.acceptAnyCertificate = acceptAnyCertificate;
             return this;
@@ -1100,7 +1081,6 @@ public Builder(AsyncHttpClientConfig prototype) {
             removeQueryParamOnRedirect = prototype.isRemoveQueryParamOnRedirect();
             hostnameVerifier = prototype.getHostnameVerifier();
             strict302Handling = prototype.isStrict302Handling();
-            timeConverter = prototype.timeConverter;
             acceptAnyCertificate = prototype.acceptAnyCertificate;
             enabledProtocols = prototype.enabledProtocols;
             enabledCipherSuites = prototype.enabledCipherSuites;
@@ -1160,7 +1140,6 @@ else if (hostnameVerifier == null)
                     maxRequestRetry, //
                     disableUrlEncodingForBoundRequests, //
                     ioThreadMultiplier, //
-                    timeConverter,//
                     enabledProtocols, //
                     enabledCipherSuites, //
                     providerConfig, //

api/src/main/java/org/asynchttpclient/cookie/CookieDecoder.java

@@ -12,32 +12,21 @@
  */
 package org.asynchttpclient.cookie;
 
-import org.asynchttpclient.date.CalendarTimeConverter;
-import org.asynchttpclient.date.TimeConverter;
 import org.asynchttpclient.util.StringUtils;
 
 public class CookieDecoder {
 
-    public static final TimeConverter DEFAULT_TIME_CONVERTER = new CalendarTimeConverter();
-
-    public static Cookie decode(String header) {
-        return decode(header, DEFAULT_TIME_CONVERTER);
-    }
-
     /**
      * Decodes the specified HTTP header value into {@link Cookie}.
      * 
      * @return the decoded {@link Cookie}
      */
-    public static Cookie decode(String header, TimeConverter timeConverter) {
-
-        if (timeConverter == null)
-            timeConverter = DEFAULT_TIME_CONVERTER;
+    public static Cookie decode(String header) {
 
         if (header.isEmpty())
             return null;
 
-        KeyValuePairsParser pairsParser = new KeyValuePairsParser(timeConverter);
+        KeyValuePairsParser pairsParser = new KeyValuePairsParser();
 
         final int headerLen = header.length();
         loop: for (int i = 0;;) {

api/src/main/java/org/asynchttpclient/cookie/KeyValuePairsParser.java

@@ -12,9 +12,8 @@
  */
 package org.asynchttpclient.cookie;
 
-import org.asynchttpclient.date.RFC2616Date;
-import org.asynchttpclient.date.RFC2616DateParser;
-import org.asynchttpclient.date.TimeConverter;
+import java.text.ParsePosition;
+import java.util.Date;
 
 /**
  * A companion for CookieDecoder that parses key-value pairs (cookie name/value
@@ -24,26 +23,28 @@
  */
 class KeyValuePairsParser {
 
-    private final TimeConverter timeBuilder;
     private String name;
     private String value;
     private String rawValue;
     private String domain;
     private String path;
-    private long expires = -1L;
+    private String expires;
     private int maxAge = -1;
     private boolean secure;
     private boolean httpOnly;
 
-    /**
-     * @param timeBuilder used for parsing expires attribute
-     */
-    public KeyValuePairsParser(TimeConverter timeBuilder) {
-        this.timeBuilder = timeBuilder;
+    public Cookie cookie() {
+        return name != null ? new Cookie(name, value, rawValue, domain, path, computeExpires(), maxAge, secure, httpOnly) : null;
     }
 
-    public Cookie cookie() {
-        return name != null ? new Cookie(name, value, rawValue, domain, path, expires, maxAge, secure, httpOnly) : null;
+    private long computeExpires() {
+        if (expires != null) {
+            Date expiresDate = RFC2616DateParser.get().parse(expires, new ParsePosition(0));
+            if (expiresDate != null)
+                return expiresDate.getTime();
+        }
+        
+        return -1L;
     }
 
     /**
@@ -156,15 +157,7 @@ private boolean isMaxAge(char c0, char c1, char c2, char c3, char c4, char c5, c
     }
 
     private void setExpire(String value) {
-
-        RFC2616Date dateElements = new RFC2616DateParser(value).parse();
-        if (dateElements != null) {
-            try {
-                expires = timeBuilder.toTime(dateElements);
-            } catch (Exception e1) {
-                // ignore failure to parse -> treat as session cookie
-            }
-        }
+        expires = value;
     }
 
     private void setMaxAge(String value) {

api/src/main/java/org/asynchttpclient/cookie/RFC2616DateParser.java

@@ -0,0 +1,91 @@
+/*
+ * Copyright (c) 2014 AsyncHttpClient Project. All rights reserved.
+ *
+ * This program is licensed to you under the Apache License Version 2.0,
+ * and you may not use this file except in compliance with the Apache License Version 2.0.
+ * You may obtain a copy of the Apache License Version 2.0 at http://www.apache.org/licenses/LICENSE-2.0.
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the Apache License Version 2.0 is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the Apache License Version 2.0 for the specific language governing permissions and limitations there under.
+ */
+package org.asynchttpclient.cookie;
+
+import java.text.ParsePosition;
+import java.text.SimpleDateFormat;
+import java.util.Date;
+import java.util.Locale;
+import java.util.TimeZone;
+
+/**
+ * A parser for <a href="http://tools.ietf.org/html/rfc2616#section-3.3">RFC2616
+ * Date format</a>.
+ * 
+ * @author slandelle
+ */
+@SuppressWarnings("serial")
+public class RFC2616DateParser extends SimpleDateFormat {
+
+    private final SimpleDateFormat format1 = new RFC2616DateParserObsolete1();
+    private final SimpleDateFormat format2 = new RFC2616DateParserObsolete2();
+
+    private static final ThreadLocal<RFC2616DateParser> DATE_FORMAT_HOLDER = new ThreadLocal<RFC2616DateParser>() {
+        @Override
+        protected RFC2616DateParser initialValue() {
+            return new RFC2616DateParser();
+        }
+    };
+
+    public static RFC2616DateParser get() {
+        return DATE_FORMAT_HOLDER.get();
+    }
+
+    /**
+     * Standard date format<p>
+     * Sun, 06 Nov 1994 08:49:37 GMT -> E, d MMM yyyy HH:mm:ss z
+     */
+    private RFC2616DateParser() {
+        super("E, dd MMM yyyy HH:mm:ss z", Locale.ENGLISH);
+        setTimeZone(TimeZone.getTimeZone("GMT"));
+    }
+
+    @Override
+    public Date parse(String text, ParsePosition pos) {
+        Date date = super.parse(text, pos);
+        if (date == null) {
+            date = format1.parse(text, pos);
+        }
+        if (date == null) {
+            date = format2.parse(text, pos);
+        }
+        return date;
+    }
+
+    /**
+     * First obsolete format<p>
+     * Sunday, 06-Nov-94 08:49:37 GMT -> E, d-MMM-y HH:mm:ss z
+     */
+    private static final class RFC2616DateParserObsolete1 extends SimpleDateFormat {
+        private static final long serialVersionUID = -3178072504225114298L;
+
+        RFC2616DateParserObsolete1() {
+            super("E, dd-MMM-yy HH:mm:ss z", Locale.ENGLISH);
+            setTimeZone(TimeZone.getTimeZone("GMT"));
+        }
+    }
+
+    /**
+     * Second obsolete format
+     * <p>
+     * Sun Nov 6 08:49:37 1994 -> EEE, MMM d HH:mm:ss yyyy
+     */
+    private static final class RFC2616DateParserObsolete2 extends SimpleDateFormat {
+        private static final long serialVersionUID = 3010674519968303714L;
+
+        RFC2616DateParserObsolete2() {
+            super("E MMM d HH:mm:ss yyyy", Locale.ENGLISH);
+            setTimeZone(TimeZone.getTimeZone("GMT"));
+        }
+    }
+}