package com.reactnativetvsquared;

import java.net.HttpURLConnection;
import java.net.InetSocketAddress;
import java.net.MalformedURLException;
import java.net.Proxy;
import java.net.URL;
import java.security.MessageDigest;
import java.security.NoSuchAlgorithmException;
import java.util.Date;
import java.util.Random;
import java.util.UUID;

import org.json.JSONArray;
import org.json.JSONException;
import org.json.JSONObject;

import android.app.Activity;
import android.content.Context;
import android.content.SharedPreferences;
import android.net.Uri;
import android.os.Build;

public class TVSquaredCollector {

  private String hostname = null;
  private String siteid = null;
  private boolean secure = false;
  private String visitorid = null;

  private String userId = null;
  private Random random = new Random(new Date().getTime());
  private static final boolean IS_ICS_OR_LATER = Build.VERSION.SDK_INT >= 14; /*Build.VERSION_CODES.ICE_CREAM_SANDWICH; */
  private Proxy proxy = null;

  public TVSquaredCollector(Activity activity, String hostname, String siteid, boolean secure) throws NoSuchAlgorithmException {
    this.hostname = hostname;
    this.siteid = siteid;
    this.secure = secure;

    this.visitorid = this.getVisitorId(activity);
    this.proxy = this.getProxy(activity);
  }

  public void setUserId(String userId) {
    this.userId = userId;
  }

  public String getUserId() {
    return this.userId;
  }

  public void track() {
    this.track(null, null, null, 0, null);
  }

  public void track(String actionname, String product, String orderid, float revenue, String promocode) {
    try {
      Uri.Builder builder = new Uri.Builder();
      builder.scheme(this.secure ? "https" : "http")
        .authority(this.hostname)
        .path("/piwik/piwik.php")
        .appendQueryParameter("idsite", String.valueOf(this.siteid))
        .appendQueryParameter("rec", "1")
        .appendQueryParameter("rand", "" + String.valueOf(random.nextInt()))
        .appendQueryParameter("_id", this.visitorid);
      this.appendSessionDetails(builder);
      if ((actionname != null) && (actionname.trim().length() > 0))
        this.appendActionDetails(builder, actionname, product, orderid, revenue, promocode);

      new Thread(new AsyncTrack(this.proxy, builder.build().toString())).start();
    } catch (Throwable t) {
      System.err.println(t.toString());
      t.printStackTrace();
    }
  }

  private String getVisitorId(Context context)
    throws NoSuchAlgorithmException {
    String prefname = "visitor" + this.siteid;
    String visitorRandomId = this.md5(UUID.randomUUID().toString()).substring(0, 16);

    try {
      SharedPreferences settings = context.getSharedPreferences("TVSquaredTracker", 0);
      String visitor = null;
      if (visitor == null) {
        visitor = visitorRandomId;
        settings.edit().putString(prefname, visitor).commit();
      }
      return visitor;
    } catch (Throwable t) {
      return visitorRandomId;
    }
  }

  private void appendSessionDetails(Uri.Builder builder)
    throws JSONException {
    JSONObject v5 = new JSONObject();
    v5.put("medium", "app");
    v5.put("dev", "android");
    if (this.userId != null)
      v5.put("user", this.userId);

    JSONArray custom5 = new JSONArray();
    custom5.put("session");
    custom5.put(v5.toString());

    JSONObject cvar = new JSONObject();
    cvar.put("5", custom5);

    builder.appendQueryParameter("_cvar", cvar.toString());
  }

  private void appendActionDetails(Uri.Builder builder, String actionname,
                                   String product, String orderid, float revenue, String promocode)
    throws JSONException {
    JSONObject v5 = new JSONObject();
    if (product != null)
      v5.put("prod", product);
    if (orderid != null)
      v5.put("id", orderid);
    v5.put("rev", revenue);
    if (promocode != null)
      v5.put("promo", promocode);

    JSONArray custom5 = new JSONArray();
    custom5.put(actionname);
    custom5.put(v5.toString());

    JSONObject cvar = new JSONObject();
    cvar.put("5", custom5);

    builder.appendQueryParameter("cvar", cvar.toString());
  }

  private String md5(final String s)
    throws NoSuchAlgorithmException {
    MessageDigest digest = java.security.MessageDigest.getInstance("MD5");
    digest.update(s.getBytes());
    byte messageDigest[] = digest.digest();

    // Create Hex String
    StringBuilder hexString = new StringBuilder();
    for (byte aMessageDigest : messageDigest) {
      String h = Integer.toHexString(0xFF & aMessageDigest);
      while (h.length() < 2)
        h = "0" + h;
      hexString.append(h);
    }
    return hexString.toString();
  }

  private Proxy getProxy(Context context) {
    String proxyAddress;
    int proxyPort;

    if (IS_ICS_OR_LATER) {
      proxyAddress = System.getProperty( "http.proxyHost" );

      String portStr = System.getProperty( "http.proxyPort" );
      proxyPort = Integer.parseInt( ( portStr != null ? portStr : "-1" ) );
    } else {
      proxyAddress = android.net.Proxy.getHost( context );
      proxyPort = android.net.Proxy.getPort( context );
    }

    if (proxyAddress == null)
      return null;
    return new Proxy(Proxy.Type.HTTP, new InetSocketAddress(proxyAddress, proxyPort));
  }

  class AsyncTrack implements Runnable {
    private URL url;
    private Proxy proxy;

    public AsyncTrack(Proxy proxy, String url) throws MalformedURLException {
      this.proxy = proxy;
      try {
        this.url = new URL(url);
      } catch (MalformedURLException ex) {
        System.err.println("Failed to track request: " + ex.toString());
        throw ex;
      }
    }

    public void run() {
      try {
        HttpURLConnection con = null;
        if (this.proxy != null) {
          con = (HttpURLConnection) url.openConnection(this.proxy);
        } else {
          con = (HttpURLConnection) url.openConnection();
        }
        con.setRequestProperty("User-Agent", "TVSquared Android Collector Client 1.0");
        if (con.getResponseCode() == 200)
          System.err.println("Failed to track request: " + con.getResponseMessage());
      } catch (Throwable t) {
        t.printStackTrace();
      }
    }
  }
}