package com.worklight.wlclient;

import com.worklight.common.WLTrusteer;
import com.worklight.wlclient.api.WLResponseListener;
import java.util.HashMap;
import java.util.Iterator;
import java.util.Map;
import java.util.Map.Entry;
import java.util.Set;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.client.methods.HttpRequestBase;
import org.json.JSONObject;

public class AsynchronousRequestSender
{
  private static final ExecutorService pool = Executors.newFixedThreadPool(6);
  private static AsynchronousRequestSender sender = new AsynchronousRequestSender();
  private Map<String, String> globalHeaders = new HashMap();

  public static AsynchronousRequestSender getInstance()
  {
    return sender;
  }

  public void addGlobalHeader(String paramString1, String paramString2)
  {
    this.globalHeaders.put(paramString1, paramString2);
  }

  public void addGlobalHeadersToRequest(HttpRequestBase paramHttpRequestBase)
  {
    Iterator localIterator = this.globalHeaders.entrySet().iterator();
    while (localIterator.hasNext())
    {
      Map.Entry localEntry = (Map.Entry)localIterator.next();
      paramHttpRequestBase.addHeader((String)localEntry.getKey(), (String)localEntry.getValue());
    }
    if (WLTrusteer.hasTrusteerSDK())
      paramHttpRequestBase.addHeader("WL_TAS", WLTrusteer.getInstance().getRiskAssessment().toString());
  }

  public String getGlobalHeader(String paramString)
  {
    return (String)this.globalHeaders.get(paramString);
  }

  public Map<String, String> getGlobalHeaders()
  {
    return this.globalHeaders;
  }

  public void removeGlobalHeader(String paramString)
  {
    this.globalHeaders.remove(paramString);
  }

  public void sendCustomRequestAsync(HttpRequestBase paramHttpRequestBase, int paramInt, WLResponseListener paramWLResponseListener)
  {
    addGlobalHeadersToRequest(paramHttpRequestBase);
    pool.execute(new CustomRequestSender(paramHttpRequestBase, paramInt, paramWLResponseListener));
  }

  public void sendWLHybridRequestAsync(HttpPost paramHttpPost, int paramInt, HttpPostListener paramHttpPostListener)
  {
    addGlobalHeadersToRequest(paramHttpPost);
    pool.execute(new HttpPostRequestSender(paramHttpPost, paramInt, paramHttpPostListener));
  }

  public void sendWLRequestAsync(WLRequest paramWLRequest)
  {
    addGlobalHeadersToRequest(paramWLRequest.getPostRequest());
    pool.execute(new WLRequestSender(paramWLRequest));
  }
}

/* Location:           C:\Documents and Settings\Cesar Cabello Cea\Mis documentos\Downloads\apk-downloader\com.ikea.kompis-6_dex2jar.jar
 * Qualified Name:     com.worklight.wlclient.AsynchronousRequestSender
 * JD-Core Version:    0.6.2
 */