import cz.msebera.android.httpclient.protocol.HttpContext; //导入依赖的package包/类
@Override
public boolean isRedirectRequested(
        final HttpResponse response,
        final HttpContext context) {
    if (!enableRedirects) {
        return false;
    }
    if (response == null) {
        throw new IllegalArgumentException("HTTP response may not be null");
    }
    int statusCode = response.getStatusLine().getStatusCode();
    switch (statusCode) {
        case HttpStatus.SC_MOVED_TEMPORARILY:
        case HttpStatus.SC_MOVED_PERMANENTLY:
        case HttpStatus.SC_SEE_OTHER:
        case HttpStatus.SC_TEMPORARY_REDIRECT:
            return true;
        default:
            return false;
    } //end of switch
}
 

import cz.msebera.android.httpclient.protocol.HttpContext; //导入依赖的package包/类
@Override
  protected RequestHandle sendRequest(DefaultHttpClient client,
                                      HttpContext httpContext, HttpUriRequest uriRequest,
                                      String contentType, ResponseHandlerInterface responseHandler,
                                      Context context) {
      if (contentType != null) {
          uriRequest.addHeader(AsyncHttpClient.HEADER_CONTENT_TYPE, contentType);
      }

      responseHandler.setUseSynchronousMode(true);

/*
       * will execute the request directly
*/
      newAsyncHttpRequest(client, httpContext, uriRequest, contentType, responseHandler, context).run();

      // Return a Request Handle that cannot be used to cancel the request
      // because it is already complete by the time this returns
      return new RequestHandle(null);
  }
 

import cz.msebera.android.httpclient.protocol.HttpContext; //导入依赖的package包/类
public static void cleanCookie() {
    // first clear store
    // new PersistentCookieStore(AppContext.getInstance()).clear();
    // clear header
    AsyncHttpClient client = CLIENT;
    if (client != null) {
        HttpContext httpContext = client.getHttpContext();
        CookieStore cookies = (CookieStore) httpContext
                .getAttribute(HttpClientContext.COOKIE_STORE);
        // 清理Async本地存储
        if (cookies != null) {
            cookies.clear();
        }
        // 清理当前正在使用的Cookie
        client.removeHeader("Cookie");
    }
    log("cleanCookie");
}
 

import cz.msebera.android.httpclient.protocol.HttpContext; //导入依赖的package包/类
/**
 * 从AsyncHttpClient自带缓存中获取CookieString
 *
 * @param client AsyncHttpClient
 * @return CookieString
 */
private static String getClientCookie(AsyncHttpClient client) {
    String cookie = "";
    if (client != null) {
        HttpContext httpContext = client.getHttpContext();
        CookieStore cookies = (CookieStore) httpContext
                .getAttribute(HttpClientContext.COOKIE_STORE);

        if (cookies != null && cookies.getCookies() != null && cookies.getCookies().size() > 0) {
            for (Cookie c : cookies.getCookies()) {
                cookie += (c.getName() + "=" + c.getValue()) + ";";
            }
        }
    }
    log("getClientCookie:" + cookie);
    return cookie;
}
 

import cz.msebera.android.httpclient.protocol.HttpContext; //导入依赖的package包/类
@Override
public void process(HttpResponse httpResponse, HttpContext httpContext) throws HttpException, IOException {
    if (httpResponse.getStatusLine().getStatusCode() == 302) {
        final URI reqUri = ((HttpUriRequest) httpContext.getAttribute(ExecutionContext.HTTP_REQUEST)).getURI();
        final HttpHost currentHost = (HttpHost) httpContext.getAttribute(ExecutionContext.HTTP_TARGET_HOST);
        final String url = (reqUri.isAbsolute()) ? reqUri.toString() : (currentHost.toURI() + reqUri.getPath());
        final String redirect = httpResponse.getLastHeader("Location").getValue();

        String strDate = "";
        if(url.equals(Fetcher.ROOT)) {
            strDate = CommonUtils.splitDate(pattern,redirect);
            newIssueNum = CommonUtils.dateStrToLong("yyyy-MM-dd",strDate);

        }
        Log.d(SectionFragment.class.getName(),"interceptor" + redirect + ":::" + strDate + " "+ (newIssueNum >AppContext.getLatestIssueNum()));
        Log.d(SectionFragment.class.getName(),"interceptor: " + url);
    }
}
 

import cz.msebera.android.httpclient.protocol.HttpContext; //导入依赖的package包/类
@Override
public void process(HttpResponse httpResponse, HttpContext httpContext) throws HttpException, IOException {
    if (httpResponse.getStatusLine().getStatusCode() == 302) {
        final URI reqUri = ((HttpUriRequest) httpContext.getAttribute(ExecutionContext.HTTP_REQUEST)).getURI();
        final HttpHost currentHost = (HttpHost) httpContext.getAttribute(ExecutionContext.HTTP_TARGET_HOST);
        final String url = (reqUri.isAbsolute()) ? reqUri.toString() : (currentHost.toURI() + reqUri.getPath());
        final String redirect = httpResponse.getLastHeader("Location").getValue();

        String pattern = "([0-9]{4}-[0-9]{2}-[0-9]{2})";
        String strDate="";
        if(url.equals(Fetcher.ROOT)) {
            strDate = CommonUtils.splitDate(pattern,redirect);
            newIssueNum = CommonUtils.dateStrToLong("yyyy-MM-dd",strDate);

        }
        Log.d("interceptor",redirect + ":::" + strDate + " "+ newIssueNum);
        Log.d("interceptor",url);
    }
}
 

import cz.msebera.android.httpclient.protocol.HttpContext; //导入依赖的package包/类
@Override
protected AsyncHttpRequest newAsyncHttpRequest(DefaultHttpClient client, HttpContext httpContext, HttpUriRequest uriRequest, String contentType, ResponseHandlerInterface responseHandler, Context context) {
    AsyncHttpRequest httpRequest = getHttpRequest(client, httpContext, uriRequest, contentType, responseHandler, context);
    return httpRequest == null
            ? super.newAsyncHttpRequest(client, httpContext, uriRequest, contentType, responseHandler, context)
            : httpRequest;
}
 

import cz.msebera.android.httpclient.protocol.HttpContext; //导入依赖的package包/类
@Override
public boolean retryRequest(IOException exception, int executionCount, HttpContext context) {
    boolean retry = true;

    Boolean b = (Boolean) context.getAttribute(ExecutionContext.HTTP_REQ_SENT);
    boolean sent = (b != null && b);

    if (executionCount > maxRetries) {
        // Do not retry if over max retry count
        retry = false;
    } else if (isInList(exceptionWhitelist, exception)) {
        // immediately retry if error is whitelisted
        retry = true;
    } else if (isInList(exceptionBlacklist, exception)) {
        // immediately cancel retry if the error is blacklisted
        retry = false;
    } else if (!sent) {
        // for most other errors, retry only if request hasn't been fully sent yet
        retry = true;
    }

    if (retry) {
        // resend all idempotent requests
        HttpUriRequest currentReq = (HttpUriRequest) context.getAttribute(ExecutionContext.HTTP_REQUEST);
        if (currentReq == null) {
            return false;
        }
    }

    if (retry) {
        SystemClock.sleep(retrySleepTimeMS);
    } else {
        exception.printStackTrace();
    }

    return retry;
}
 

import cz.msebera.android.httpclient.protocol.HttpContext; //导入依赖的package包/类
public void process(final HttpRequest request, final HttpContext context) throws HttpException, IOException {
    AuthState authState = (AuthState) context.getAttribute(ClientContext.TARGET_AUTH_STATE);
    CredentialsProvider credsProvider = (CredentialsProvider) context.getAttribute(
            ClientContext.CREDS_PROVIDER);
    HttpHost targetHost = (HttpHost) context.getAttribute(ExecutionContext.HTTP_TARGET_HOST);

    if (authState.getAuthScheme() == null) {
        AuthScope authScope = new AuthScope(targetHost.getHostName(), targetHost.getPort());
        Credentials creds = credsProvider.getCredentials(authScope);
        if (creds != null) {
            authState.setAuthScheme(new BasicScheme());
            authState.setCredentials(creds);
        }
    }
}
 

import cz.msebera.android.httpclient.protocol.HttpContext; //导入依赖的package包/类
@Override
public Header authenticate(Credentials credentials, HttpRequest request, HttpContext httpContext)
        throws AuthenticationException {
    CharArrayBuffer buffer = new CharArrayBuffer(32);
    buffer.append(AUTH.WWW_AUTH_RESP);
    buffer.append(": Bearer ");
    buffer.append(credentials.getUserPrincipal().getName());
    return new BufferedHeader(buffer);
}
 

import cz.msebera.android.httpclient.protocol.HttpContext; //导入依赖的package包/类
private void handleLoginResult(LoginResult result) {
    if(result.getDataResult().isOK()) {
        AsyncHttpClient client = ApiHttpClient.getHttpClient();
        HttpContext httpContext = client.getHttpContext();
        CookieStore cookies = (CookieStore)httpContext
                .getAttribute(ClientContext.COOKIE_STORE);
        if(cookies != null) {
            String tmp_cookies = "";
            for(Cookie c : cookies.getCookies()) {
                LogUtil.log("cookie:" + c.getName() + " " + c.getValue());
                tmp_cookies += (c.getName() + "=" + c.getValue()) + ";";
                AppContext.getContext().setProperty(AppConfig.CONF_COOKIE,
                        tmp_cookies);
                ApiHttpClient.setCookie(ApiHttpClient.getCookie(AppContext
                        .getContext()));
                HttpConfig.sCookie = tmp_cookies;
            }
        }
        User user = result.getUser();
        result.getUser().setAccount(user.getUsername());
        result.getUser().setPassword(user.getPassword());
        result.getUser().setRememberMe(true);
        AppContext.getContext().saveUserInfo(user);
    }
    else {
        AppContext.getContext().cleanLoginInfo();
        ToastUtil.showToast("错误：" + result.getDataResult().getErrorMsg());
    }
}
 

import cz.msebera.android.httpclient.protocol.HttpContext; //导入依赖的package包/类
public Socket connectSocket(
        final int connectTimeout,
        final Socket socket,
        final HttpHost host,
        final InetSocketAddress remoteAddress,
        final InetSocketAddress localAddress,
        final HttpContext context) throws IOException {
    Args.notNull(host, "HTTP host");
    Args.notNull(remoteAddress, "Remote address");
    final Socket sock = socket != null ? socket : createSocket(context);
    if (localAddress != null) {
        sock.bind(localAddress);
    }
    try {
        if (connectTimeout > 0 && sock.getSoTimeout() == 0) {
            sock.setSoTimeout(connectTimeout);
        }
        sock.connect(remoteAddress, connectTimeout);
    } catch (final IOException ex) {
        try {
            sock.close();
        } catch (final IOException ignore) {
        }
        throw ex;
    }
    // Setup SSL layering if necessary
    if (sock instanceof SSLSocket) {
        final SSLSocket sslsock = (SSLSocket) sock;
        sslsock.startHandshake();
        verifyHostname(sslsock, host.getHostName());
        return sock;
    } else {
        return createLayeredSocket(sock, host.getHostName(), remoteAddress.getPort(), context);
    }
}
 

import cz.msebera.android.httpclient.protocol.HttpContext; //导入依赖的package包/类
@Override
public AsyncHttpRequest getHttpRequest(DefaultHttpClient client, HttpContext httpContext, HttpUriRequest uriRequest, String contentType, ResponseHandlerInterface responseHandler, Context context) {
    return null;
}
 

import cz.msebera.android.httpclient.protocol.HttpContext; //导入依赖的package包/类
@Override
public AsyncHttpRequest getHttpRequest(DefaultHttpClient client, HttpContext httpContext, HttpUriRequest uriRequest, String contentType, ResponseHandlerInterface responseHandler, Context context) {
    return new PrePostProcessRequest(client, httpContext, uriRequest, responseHandler);
}
 

import cz.msebera.android.httpclient.protocol.HttpContext; //导入依赖的package包/类
public PrePostProcessRequest(AbstractHttpClient client, HttpContext httpContext, HttpUriRequest request, ResponseHandlerInterface responseHandler) {
    super(client, httpContext, request, responseHandler);
}
 

import cz.msebera.android.httpclient.protocol.HttpContext; //导入依赖的package包/类
/**
 * Puts a new request in queue as a new thread in pool to be executed
 *
 * @param client          HttpClient to be used for request, can differ in single requests
 * @param contentType     MIME body type, for POST and PUT requests, may be null
 * @param context         Context of Android application, to hold the reference of request
 * @param httpContext     HttpContext in which the request will be executed
 * @param responseHandler ResponseHandler or its subclass to put the response into
 * @param uriRequest      instance of HttpUriRequest, which means it must be of HttpDelete,
 *                        HttpPost, HttpGet, HttpPut, etc.
 * @return RequestHandle of future request process
 */
protected RequestHandle sendRequest(DefaultHttpClient client, HttpContext httpContext, HttpUriRequest uriRequest, String contentType, ResponseHandlerInterface responseHandler, Context context) {
    if (uriRequest == null) {
        throw new IllegalArgumentException("HttpUriRequest must not be null");
    }

    if (responseHandler == null) {
        throw new IllegalArgumentException("ResponseHandler must not be null");
    }

    if (responseHandler.getUseSynchronousMode() && !responseHandler.getUsePoolThread()) {
        throw new IllegalArgumentException("Synchronous ResponseHandler used in AsyncHttpClient. You should create your response handler in a looper thread or use SyncHttpClient instead.");
    }

    if (contentType != null) {
        if (uriRequest instanceof HttpEntityEnclosingRequestBase && ((HttpEntityEnclosingRequestBase) uriRequest).getEntity() != null && uriRequest.containsHeader(HEADER_CONTENT_TYPE)) {
            log.w(LOG_TAG, "Passed contentType will be ignored because HttpEntity sets content type");
        } else {
            uriRequest.setHeader(HEADER_CONTENT_TYPE, contentType);
        }
    }

    responseHandler.setRequestHeaders(uriRequest.getAllHeaders());
    responseHandler.setRequestURI(uriRequest.getURI());

    AsyncHttpRequest request = newAsyncHttpRequest(client, httpContext, uriRequest, contentType, responseHandler, context);
    threadPool.submit(request);
    RequestHandle requestHandle = new RequestHandle(request);

    if (context != null) {
        List<RequestHandle> requestList;
        // Add request to request map
        synchronized (requestMap) {
            requestList = requestMap.get(context);
            if (requestList == null) {
                requestList = Collections.synchronizedList(new LinkedList<RequestHandle>());
                requestMap.put(context, requestList);
            }
        }

        requestList.add(requestHandle);

        Iterator<RequestHandle> iterator = requestList.iterator();
        while (iterator.hasNext()) {
            if (iterator.next().shouldBeGarbageCollected()) {
                iterator.remove();
            }
        }
    }

    return requestHandle;
}
 

import cz.msebera.android.httpclient.protocol.HttpContext; //导入依赖的package包/类
public AsyncHttpRequest(AbstractHttpClient client, HttpContext context, HttpUriRequest request, ResponseHandlerInterface responseHandler) {
    this.client = Utils.notNull(client, "client");
    this.context = Utils.notNull(context, "context");
    this.request = Utils.notNull(request, "request");
    this.responseHandler = Utils.notNull(responseHandler, "responseHandler");
}