<?php

$response='';
$response_code = 400;
$auth_token="";
$ipost_client_group = 'g003';
$ipost_api_version = 'v1';
$ipost_base_api_url = 'http://' . $ipost_client_group . '-api/' . $ipost_api_version .'/';
$client_token = $_GET["client_token"];
$name_suffix = '';
if ($_GET["timestamp_names"]) {
  $name_suffix = "_" . time();
}

try {
    if (!$client_token) {
        throw new Exception('No client token specified');
    }
    if (!($_SERVER['REQUEST_METHOD'] === 'POST')) {
        $response_code = 405;
        throw new Exception('POST method required');
    }
    // Get the JSON data from the request body
    $json_data = file_get_contents('php://input');

    // Check if the JSON data is valid
    $decoded_data = json_decode($json_data, true);
    if ($decoded_data === null) {
        throw new Exception('Invalid JSON data');
    }
    // Check if the required "content" parameters are present
    if (!isset($decoded_data['content'])) {
        throw new Exception('"content" is a required parameter');
    }
    if (!is_array($decoded_data['content'])) {
        throw new Exception('"content" parameter must be a JSON object');
    }
    if (!is_string($decoded_data['content']['html'])) {
        throw new Exception('"content" parameter must be a JSON object');
    }

    // Check if the required "contacts" parameters are present
    if (!isset($decoded_data['contacts'])) {
        throw new Exception('"contacts" is a required parameter');
    } elseif (!is_array($decoded_data['contacts'])) {
        throw new Exception('"contacts" parameter must be a JSON array');
    }
    if (!isset($decoded_data['mailing_name'])) {
        throw new Exception('"mailing_name" is a required parameter');
    } elseif (!is_string($decoded_data['mailing_name'])) {
        throw new Exception('"mailing_name" parameter must be a JSON string');
    }

    $ahdrs = getallheaders();
    $auth_hdr = $ahdrs['X-Auth-Token'];
    if ($auth_hdr) {
        $hparts = explode(" ", $auth_hdr, 2);
        $hcount = count($hparts);
        if ($hcount === 1) {
            $auth_token=$hparts[0];
        }
    }
    if (!$auth_token) {
        throw new Exception('Valid "X-Auth-Token" header required');
    }
    // Access the parameters
    $contacts = $decoded_data['contacts'];
    $content = $decoded_data['content'];

// EMAIL CREATION
    $ipost_api_url = $ipost_base_api_url . $client_token . '/emails/create';
    $headers = array(
        'X-Auth-Token: ' . $auth_token,
        'accept: application/json',
        'content-type: application/json'
    );
    $from_name = $content['from']['name'];
    $from_addr = $content['from']['email'];
    $payload = array();
    $payload['HeaderID'] = 0;
    $payload['FooterID'] = 0;
    $payload['Subject'] = $decoded_data['subject'];
    $payload['HTML_Body'] = $content['html'];
    if (isset($content['text']) && gettype($content['text']) === 'string' && strlen($content['text'])) {
      $payload['Text_Body'] = $content['text'];
    }
    if (isset($content['preheader']) && gettype($content['preheader']) === 'string' && strlen($content['preheader'])) {
      $payload['Preheader'] = $content['preheader'];
    }
    $payload['Email_Name'] = $decoded_data['mailing_name'] . $name_suffix;

    $ch = curl_init();
    curl_setopt($ch, CURLOPT_URL, $ipost_api_url);
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
    curl_setopt($ch, CURLOPT_POST, true);
    curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);
    curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($payload));
    $response = curl_exec($ch);
    $rcode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
    $r = json_decode($response);
    if ($r && $r->status === 'error') {
        throw new Exception(json_encode($r->errors[0]));
    }

    $ec_id = $r->data->Email_Content_ID;
    if (!$ec_id) {
        throw new Exception("No email_content_id found");
    }

// EMAIL VALIDATION
    $ipost_api_url = $ipost_base_api_url . $client_token . '/emails/' . $ec_id . '/validate/';
    $ch = curl_init();
    curl_setopt($ch, CURLOPT_URL, $ipost_api_url);
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
    curl_setopt($ch, CURLOPT_POST, false);
    curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);

    $response = curl_exec($ch);
    $rcode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
    $r = json_decode($response);
    if ($r && $r->status === 'error') {
        throw new Exception(json_encode($r->errors[0]));
    }

// DATA TABLE CREATION
    $ipost_api_url = $ipost_base_api_url . $client_token . '/DataTables/create/';
    $ch = curl_init();
    curl_setopt($ch, CURLOPT_URL, $ipost_api_url);
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
    curl_setopt($ch, CURLOPT_POST, true);
    curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);

  // CREATE TABLE SCHEMA
    $proto = $decoded_data["contacts"][0]; // first element defines schema
    $field_names = array_keys($proto);
   
    if (!is_array($field_names)) {
        throw new Exception('"contacts" parameter must be an array of data field_names');
    }

    $email_field_name = "email";
    $attrs = array();
    foreach ($field_names as $key) {
      switch(gettype($proto[$key])) {
        case "string" : $dtype = "Short Text"; break;
        case "boolean" : $dtype = "Boolean"; break;
        case "integer" : $dtype = "Integer"; break;
	default   : $dtype = "Short Text"; break;
      }
      $field["Name"] = $key;
      $field["DataType"] = $dtype;
      $field["Required"] = false;
      $field["PrimaryKey"] = false;
      $field["Sendable"] = false;
      if ($key === 'email') {
          $email_field_name = $key;
          $field["DataType"] = "Email";
          $field["Required"] = true;
          $field["PrimaryKey"] = true;
          $field["Sendable"] = true;
      }
      array_push($attrs, $field);
    }

    $payload = array();
    $payload["Attributes"] = $attrs;
    $payload["DataTableName"] = preg_replace('/(\W+)/i' ,"_",$decoded_data['mailing_name'] . $name_suffix);
    $payload["Description"] = "API Upload";
    $payload["ContentType"] = "Custom";
    $payload["Sendable"] = true;
    $payload["SendableType"] = 1;
    $payload["Testing"] = false;
    $rk["Name"] = $email_field_name;
    $payload["RecipientKey"] = Array($rk);

    curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($payload));

    $response = curl_exec($ch);
    $rcode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
    $r = json_decode($response);
    if ($r && $r->status === 'error') {
        throw new Exception(json_encode($r->errors[0]));
    }

    $cdt_id = $r->data->data_table_id;

// DATABASE UPLOAD
    $ipost_api_url = $ipost_base_api_url . $client_token . '/DataTables/' . $cdt_id . '/addupdate/';
    $ch = curl_init();
    curl_setopt($ch, CURLOPT_URL, $ipost_api_url);
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
    curl_setopt($ch, CURLOPT_POST, true);
    curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);

    $payload = json_encode(array('Records' => $contacts));
    curl_setopt($ch, CURLOPT_POSTFIELDS, $payload);

    $response = curl_exec($ch);
    $rcode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
    $r = json_decode($response);
    if ($r && $r->status === 'error') {
        throw new Exception(json_encode($r->errors[0]));
    }

// AUTOMATION CREATION
    $ipost_api_url = $ipost_base_api_url . $client_token . '/automations/process/create/';
    $ch = curl_init();
    curl_setopt($ch, CURLOPT_URL, $ipost_api_url);
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
    curl_setopt($ch, CURLOPT_POST, true);
    curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);

    $activity = array();
    $activity[0]["type"] = "email";
    $activity[0]["name"] = $decoded_data["mailing_name"] . $name_suffix;
    $activity[0]["from_name"] = $decoded_data["from"]["name"];
    $activity[0]["from_address"] = $decoded_data["from"]["email"];
    $activity[0]["email_id"] = $ec_id;
    $activity[0]["subject"] = $decoded_data["subject"];
    $activity[0]["destination"][0]["destination_type"] = "cdt";
    $activity[0]["destination"][0]["destination_ids"] = array($cdt_id);

    $schedule = array();
    $schedule[0]["schedule_date"] = date('Y-m-d H:i:s', time() + 7*60*60);
    $schedule[0]["schedule_time"] = date('Y-m-d H:i:s', time() + 7*60*60);
    $schedule[0]["schedule_reccurence"] = "run-once";
    $schedule[0]["email_frequency_limit"] = 0;
    $schedule[0]["EndDate"] = date('Y-m-d', time() + 60*60*24*30);
    $schedule[0]["EndOcurrences"] = 1;

    $payload = array();
    $payload["Automation_Name"] = $decoded_data["mailing_name"] . $name_suffix;
    $payload["Automation_Status"] = "Active";
    $payload["type"] = "email";
    $payload["Automation_Activities"] = $activity;
    $payload["Automation_Schedule"] = $schedule;
    $payload["schedule_date"] = date('Y-m-d H:i:s', time() + 7*60*60);
    $payload["schedule_time_zone"] = "America/Los_Angeles";

    $payload = json_encode($payload);
    curl_setopt($ch, CURLOPT_POSTFIELDS, $payload);

    $response = curl_exec($ch);
    $rcode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
    $r = json_decode($response);
    if ($r && $r->status === 'error') {
        throw new Exception(json_encode($r->errors[0]));
    }
    $auto_id = $r->data->Automation_ID;
    if (!$ec_id) {
        throw new Exception("No automation_id found");
    }

// START AUTOMATION
    $ipost_api_url = $ipost_base_api_url . $client_token . '/automations/' . $auto_id . '/startProcess/';
    $ch = curl_init();
    curl_setopt($ch, CURLOPT_URL, $ipost_api_url);
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
    curl_setopt($ch, CURLOPT_POST, false);
    curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);

    $response = curl_exec($ch);
    $rcode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
    $r = json_decode($response);
    if ($r && $r->status === 'error') {
        throw new Exception(json_encode($r->errors[0]));
    }

    $ipost_api_url = 'http://g003.enterprise.ipost.com/elliancedigitalmediallc/f2f/9z4zlv51f3f24kc347orl0gfmpmabtuuoas5nao17b8?email_content_id=' . $ec_id . '&automation_id=' . $auto_id;
    $ch = curl_init();
    curl_setopt($ch, CURLOPT_URL, $ipost_api_url);
    curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
    curl_setopt($ch, CURLOPT_POST, false);
    curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);

    $response = curl_exec($ch);
    $rcode = curl_getinfo($ch, CURLINFO_HTTP_CODE);
    $r = json_decode($response);
    if (!$r || !$r->Mailing_ID) {
        throw new Exception('Mailing_ID not found');
    }
    $mailing_id=$r->mailing_id;
    $response_code = 200;
    throw new Exception($response);
} catch (Exception $e) {
    $msg = $e->getMessage();
    $status = 'error';
    if ($response_code == 200) {
        $status = 'success';
    }
    $resp = '{"' . $status . '":';
    if ($status != 'error') {
        $resp .= '"data":' . $msg . '}';
    } else {
        if ($msg[0] != '{') {
          $resp .= '{"error":"' . $msg . '"}';
        } else {
	  $resp .= $msg;
	}
    }
    $resp .= "}";
# {"errors":[{"code":"EAUTH","description":"Invalid client_id / client_secret combination.","error":"Authentication failed"}],"status":"error"}	
    http_response_code($response_code);
    echo $resp;
exit;

?>