token decode

Author: longbai

library/src/main/java/com/qiniu/android/http/HttpManager.java

@@ -43,7 +43,7 @@ public HttpManager(Proxy proxy, IReport reporter, String backUpIp,
         client.setConnectTimeout(connectTimeout*1000);
         client.setResponseTimeout(responseTimeout*1000);
         client.setUserAgent(userAgent);
-        client.setEnableRedirects(false);
+        client.setEnableRedirects(true);
         AsyncHttpClient.blockRetryExceptionClass(CancellationHandler.CancellationException.class);
         if (proxy != null) {
             client.setProxy(proxy.hostAddress, proxy.port, proxy.user, proxy.password);

library/src/main/java/com/qiniu/android/http/UpRedirectHandler.java

@@ -0,0 +1,138 @@
+package com.qiniu.android.http;
+
+import org.apache.http.Header;
+import org.apache.http.HttpHost;
+import org.apache.http.HttpRequest;
+import org.apache.http.HttpResponse;
+import org.apache.http.HttpStatus;
+import org.apache.http.ProtocolException;
+import org.apache.http.client.CircularRedirectException;
+import org.apache.http.client.RedirectHandler;
+import org.apache.http.client.params.ClientPNames;
+import org.apache.http.client.utils.URIUtils;
+import org.apache.http.impl.client.RedirectLocations;
+import org.apache.http.params.HttpParams;
+import org.apache.http.protocol.ExecutionContext;
+import org.apache.http.protocol.HttpContext;
+
+import java.net.URI;
+import java.net.URISyntaxException;
+
+/**
+ * Created by bailong on 15/5/25.
+ */
+public class UpRedirectHandler implements RedirectHandler {
+
+    private static final String REDIRECT_LOCATIONS = "http.protocol.redirect-locations";
+
+    private static boolean isQiniu(final HttpResponse response){
+        return response.getFirstHeader("X-Reqid") != null;
+    }
+
+    public boolean isRedirectRequested(
+            final HttpResponse response,
+            final HttpContext context) {
+        if (response == null) {
+            throw new IllegalArgumentException("HTTP response may not be null");
+        }
+
+        final int statusCode = response.getStatusLine().getStatusCode();
+        switch (statusCode) {
+            //upload only allow 303
+            case HttpStatus.SC_SEE_OTHER:
+                return isQiniu(response);
+            default:
+                return false;
+        } //end of switch
+    }
+
+    public URI getLocationURI(
+            final HttpResponse response,
+            final HttpContext context) throws ProtocolException {
+        if (response == null) {
+            throw new IllegalArgumentException("HTTP response may not be null");
+        }
+        //get the location header to find out where to redirect to
+        Header locationHeader = response.getFirstHeader("location");
+        if (locationHeader == null) {
+            // got a redirect response, but no location header
+            throw new ProtocolException(
+                    "Received redirect response " + response.getStatusLine()
+                            + " but no location header"
+            );
+        }
+        //HERE IS THE MODIFIED LINE OF CODE
+        String location = locationHeader.getValue().replaceAll(" ", "%20");
+
+        URI uri;
+        try {
+            uri = new URI(location);
+        } catch (URISyntaxException ex) {
+            throw new ProtocolException("Invalid redirect URI: " + location, ex);
+        }
+
+        HttpParams params = response.getParams();
+        // rfc2616 demands the location value be a complete URI
+        // Location       = "Location" ":" absoluteURI
+        if (!uri.isAbsolute()) {
+            if (params.isParameterTrue(ClientPNames.REJECT_RELATIVE_REDIRECT)) {
+                throw new ProtocolException("Relative redirect location '"
+                        + uri + "' not allowed");
+            }
+            // Adjust location URI
+            HttpHost target = (HttpHost) context.getAttribute(
+                    ExecutionContext.HTTP_TARGET_HOST);
+            if (target == null) {
+                throw new IllegalStateException("Target host not available " +
+                        "in the HTTP context");
+            }
+
+            HttpRequest request = (HttpRequest) context.getAttribute(
+                    ExecutionContext.HTTP_REQUEST);
+
+            try {
+                URI requestURI = new URI(request.getRequestLine().getUri());
+                URI absoluteRequestURI = URIUtils.rewriteURI(requestURI, target, true);
+                uri = URIUtils.resolve(absoluteRequestURI, uri);
+            } catch (URISyntaxException ex) {
+                throw new ProtocolException(ex.getMessage(), ex);
+            }
+        }
+
+        if (params.isParameterFalse(ClientPNames.ALLOW_CIRCULAR_REDIRECTS)) {
+
+            RedirectLocations redirectLocations = (RedirectLocations) context.getAttribute(
+                    REDIRECT_LOCATIONS);
+
+            if (redirectLocations == null) {
+                redirectLocations = new RedirectLocations();
+                context.setAttribute(REDIRECT_LOCATIONS, redirectLocations);
+            }
+
+            URI redirectURI;
+            if (uri.getFragment() != null) {
+                try {
+                    HttpHost target = new HttpHost(
+                            uri.getHost(),
+                            uri.getPort(),
+                            uri.getScheme());
+                    redirectURI = URIUtils.rewriteURI(uri, target, true);
+                } catch (URISyntaxException ex) {
+                    throw new ProtocolException(ex.getMessage(), ex);
+                }
+            } else {
+                redirectURI = uri;
+            }
+
+            if (redirectLocations.contains(redirectURI)) {
+                throw new CircularRedirectException("Circular redirect to '" +
+                        redirectURI + "'");
+            } else {
+                redirectLocations.add(redirectURI);
+            }
+        }
+
+        return uri;
+    }
+
+}

library/src/main/java/com/qiniu/android/storage/UpPolicy.java

@@ -0,0 +1,41 @@
+package com.qiniu.android.storage;
+
+import com.qiniu.android.utils.UrlSafeBase64;
+
+import org.json.JSONException;
+import org.json.JSONObject;
+
+/**
+ * Created by bailong on 15/5/25.
+ */
+final class UpPolicy {
+    private String returnUrl = null;
+    static UpPolicy parse(String token){
+        byte[] dtoken = UrlSafeBase64.decode(token);
+        JSONObject obj;
+        try {
+            obj = new JSONObject(new String(dtoken));
+        } catch (JSONException e) {
+            return null;
+        }
+        String scope = obj.optString("scope");
+        if (scope.equals("")){
+            return null;
+        }
+
+        int deadline = obj.optInt("deadline");
+        if (deadline == 0){
+            return null;
+        }
+        return new UpPolicy(obj);
+    }
+
+    private UpPolicy(JSONObject obj){
+        returnUrl = obj.optString("returnUrl");
+    }
+
+    private boolean hasReturnUrl(){
+        return !returnUrl.equals("");
+    }
+
+}