/home/arranoyd/magicraft/wp-content/plugins/ninja-popups/include/drip/drip.php
<?php
/**
* Drip API
* @author Svetoslav Marinov (SLAVI)
*/
Class Drip {
private $version = "2";
private $api_token = '';
private $error_code = '';
private $error_message = '';
private $user_agent = "Drip API PHP Wrapper (getdrip.com)";
private $api_end_point = 'https://api.getdrip.com/v2/';
//private $api_end_point = 'http://localhost/echo/'; // dbg only
private $recent_req_info = array(); // holds dbg info from a recent request
private $timeout = 30;
private $connect_timeout = 30;
private $debug = false; // Requests headers and other info to be fetched from the request. Command-line windows will show info in STDERR
const GET = 1;
const POST = 2;
const DELETE = 3;
const PUT = 4;
/**
* Accepts the token and saves it internally.
*
* @param string $api_token e.g. qsor48ughrjufyu2dadraasfa1212424
* @throws Exception
*/
public function __construct($api_token) {
$api_token = trim($api_token);
if (empty($api_token) || !preg_match('#^[\w-]+$#si', $api_token)) {
throw new Exception("Missing or invalid Drip API token.");
}
$this->api_token = $api_token;
}
/**
* Requests the campaigns for the given account.
* @param array
* @return array
*/
public function get_campaigns($params) {
if (empty($params['account_id'])) {
throw new Exception("Account ID not specified");
}
$account_id = $params['account_id'];
unset($params['account_id']); // clear it from the params
if (isset($params['status'])) {
if (!in_array($params['status'], array('active', 'draft', 'paused', 'all'))) {
throw new Exception("Invalid campaign status.");
}
} elseif (0) {
$params['status'] = 'active'; // api defaults to all but we want active ones
}
$url = $this->api_end_point . "$account_id/campaigns";
$res = $this->make_request($url, $params);
if (!empty($res['buffer'])) {
$raw_json = json_decode($res['buffer'], true);
}
// here we distinguish errors from no campaigns.
// when there's no json that's an error
$campaigns = empty($raw_json)
? false
: empty($raw_json['campaigns'])
? array()
: $raw_json['campaigns'];
return $campaigns;
}
/**
* Fetch a campaign for the given account based on it's ID.
* @param array (account_id, campaign_id)
* @return array
*/
public function fetch_campaign($params) {
if (empty($params['account_id'])) {
throw new Exception("Account ID not specified");
}
$account_id = $params['account_id'];
unset($params['account_id']); // clear it from the params
if (!empty($params['campaign_id'])) {
$campaign_id = $params['campaign_id'];
unset($params['campaign_id']); // clear it from the params
} else {
throw new Exception("Campaign ID was not specified. You must specify a Campaign ID");
}
$url = $this->api_end_point . "$account_id/campaigns/$campaign_id";
$res = $this->make_request($url, $params);
if (!empty($res['buffer'])) {
$raw_json = json_decode($res['buffer'], true);
}
// here we distinguish errors from no campaign
// when there's no json that's an error
$campaigns = empty($raw_json)
? false
: empty($raw_json['campaigns'])
? array()
: $raw_json['campaigns'];
return $campaigns;
}
/**
* Requests the accounts for the given account.
* Parses the response JSON and returns an array which contains: id, name, created_at etc
* @param void
* @return bool/array
*/
public function get_accounts() {
$url = $this->api_end_point . 'accounts';
$res = $this->make_request($url);
if (!empty($res['buffer'])) {
$raw_json = json_decode($res['buffer'], true);
}
$data = empty($raw_json)
? false
: empty($raw_json['accounts'])
? array()
: $raw_json['accounts'];
return $data;
}
/**
* Sends a request to add a subscriber and returns its record or false
*
* @param array $params
* @param array/bool $account
*/
public function create_or_update_subscriber($params) {
if (empty($params['account_id'])) {
throw new Exception("Account ID not specified");
}
$account_id = $params['account_id'];
unset($params['account_id']); // clear it from the params
$api_action = "/$account_id/subscribers";
$url = $this->api_end_point . $api_action;
// The API wants the params to be JSON encoded
$req_params = array('subscribers' => array($params));
$res = $this->make_request($url, $req_params, self::POST);
if (!empty($res['buffer'])) {
$raw_json = json_decode($res['buffer'], true);
}
$data = empty($raw_json)
? false
: empty($raw_json['subscribers'])
? array()
: $raw_json['subscribers'][0];
return $data;
}
/**
*
* @param array $params
* @param array $params
*/
public function fetch_subscriber($params) {
if (empty($params['account_id'])) {
throw new Exception("Account ID not specified");
}
$account_id = $params['account_id'];
unset($params['account_id']); // clear it from the params
if (!empty($params['subscriber_id'])) {
$subscriber_id = $params['subscriber_id'];
unset($params['subscriber_id']); // clear it from the params
} elseif (!empty($params['email'])) {
$subscriber_id = $params['email'];
unset($params['email']); // clear it from the params
} else {
throw new Exception("Subscriber ID or Email was not specified. You must specify either Subscriber ID or Email.");
}
$subscriber_id = urlencode($subscriber_id);
$api_action = "$account_id/subscribers/$subscriber_id";
$url = $this->api_end_point . $api_action;
$res = $this->make_request($url);
if (!empty($res['buffer'])) {
$raw_json = json_decode($res['buffer'], true);
}
$data = empty($raw_json)
? false
: empty($raw_json['subscribers'])
? array()
: $raw_json['subscribers'][0];
return $data;
}
/**
* Subscribes a user to a given campaign for a given account.
*
* @param array $params
* @param array $accounts
*/
public function subscribe_subscriber($params) {
if (empty($params['account_id'])) {
throw new Exception("Account ID not specified");
}
$account_id = $params['account_id'];
unset($params['account_id']); // clear it from the params
if (empty($params['campaign_id'])) {
throw new Exception("Campaign ID not specified");
}
$campaign_id = $params['campaign_id'];
unset($params['campaign_id']); // clear it from the params
if (empty($params['email'])) {
throw new Exception("Email not specified");
}
if (!isset($params['double_optin'])) {
$params['double_optin'] = true;
}
$api_action = "$account_id/campaigns/$campaign_id/subscribers";
$url = $this->api_end_point . $api_action;
// The API wants the params to be JSON encoded
$req_params = array('subscribers' => array($params));
$res = $this->make_request($url, $req_params, self::POST);
if (!empty($res['buffer'])) {
$raw_json = json_decode($res['buffer'], true);
}
$data = empty($raw_json)
? false
: empty($raw_json['subscribers'])
? array()
: $raw_json['subscribers'][0];
return $data;
}
/**
*
* Some keys are removed from the params so they don't get send with the other data to Drip.
*
* @param array $params
* @param array $params
*/
public function unsubscribe_subscriber($params) {
if (empty($params['account_id'])) {
throw new Exception("Account ID not specified");
}
$account_id = $params['account_id'];
unset($params['account_id']); // clear it from the params
if (!empty($params['subscriber_id'])) {
$subscriber_id = $params['subscriber_id'];
unset($params['subscriber_id']); // clear it from the params
} elseif (!empty($params['email'])) {
$subscriber_id = $params['email'];
unset($params['email']); // clear it from the params
} else {
throw new Exception("Subscriber ID or Email was not specified. You must specify either Subscriber ID or Email.");
}
$subscriber_id = urlencode($subscriber_id);
$api_action = "$account_id/subscribers/$subscriber_id/unsubscribe";
$url = $this->api_end_point . $api_action;
$req_params = $params;
$res = $this->make_request($url, $req_params, self::POST);
if (!empty($res['buffer'])) {
$raw_json = json_decode($res['buffer'], true);
}
$data = empty($raw_json)
? false
: empty($raw_json['subscribers'])
? array()
: $raw_json['subscribers'][0];
return $data;
}
/**
*
* This calls POST /:account_id/tags to add the tag. It just returns some status code no content
*
* @param array $params
* @param bool $status
*/
public function tag_subscriber($params) {
$status = false;
if (empty($params['account_id'])) {
throw new Exception("Account ID not specified");
}
$account_id = $params['account_id'];
unset($params['account_id']); // clear it from the params
if (empty($params['email'])) {
throw new Exception("Email was not specified");
}
if (empty($params['tag'])) {
throw new Exception("Tag was not specified");
}
$api_action = "$account_id/tags";
$url = $this->api_end_point . $api_action;
// The API wants the params to be JSON encoded
$req_params = array('tags' => array($params));
$res = $this->make_request($url, $req_params, self::POST);
if ($res['http_code'] == 201) {
$status = true;
}
return $status;
}
/**
*
* This calls DELETE /:account_id/tags to remove the tags. It just returns some status code no content
*
* @param array $params
* @param bool $status success or failure
*/
public function untag_subscriber($params) {
$status = false;
if (empty($params['account_id'])) {
throw new Exception("Account ID not specified");
}
$account_id = $params['account_id'];
unset($params['account_id']); // clear it from the params
if (empty($params['email'])) {
throw new Exception("Email was not specified");
}
if (empty($params['tag'])) {
throw new Exception("Tag was not specified");
}
$api_action = "$account_id/tags";
$url = $this->api_end_point . $api_action;
// The API wants the params to be JSON encoded
$req_params = array('tags' => array($params));
$res = $this->make_request($url, $req_params, self::DELETE);
if ($res['http_code'] == 204) {
$status = true;
}
return $status;
}
/**
*
* Posts an event specified by the user.
*
* @param array $params
* @param bool
*/
public function record_event($params) {
$status = false;
if (empty($params['account_id'])) {
throw new Exception("Account ID not specified");
}
if (empty($params['action'])) {
throw new Exception("Action was not specified");
}
$account_id = $params['account_id'];
unset($params['account_id']); // clear it from the params
$api_action = "$account_id/events";
$url = $this->api_end_point . $api_action;
// The API wants the params to be JSON encoded
$req_params = array('events' => array($params));
$res = $this->make_request($url, $req_params, self::POST);
if ($res['http_code'] == 204) {
$status = true;
}
return $status;
}
/**
*
* @param string $url
* @param array $params
* @param int $req_method
* @return type
* @throws Exception
*/
public function make_request($url, $params = array(), $req_method = self::GET) {
if (!function_exists('curl_init')) {
throw new Exception("Cannot find cURL php extension or it's not loaded.");
}
$ch = curl_init();
if ($this->debug) {
//curl_setopt($ch, CURLOPT_HEADER, true);
// TRUE to output verbose information. Writes output to STDERR, or the file specified using CURLOPT_STDERR.
curl_setopt($ch, CURLOPT_VERBOSE, true);
}
curl_setopt($ch, CURLOPT_FRESH_CONNECT, true);
curl_setopt($ch, CURLOPT_FORBID_REUSE, true);
curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
curl_setopt($ch, CURLOPT_FOLLOWLOCATION, true);
curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);
curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, false);
curl_setopt($ch, CURLOPT_TIMEOUT, $this->timeout);
curl_setopt($ch, CURLOPT_CONNECTTIMEOUT, $this->connect_timeout);
curl_setopt($ch, CURLOPT_USERPWD, $this->api_token . ":" . ''); // no pwd
curl_setopt($ch, CURLOPT_USERAGENT, empty($params['user_agent']) ? $this->user_agent : $params['user_agent']);
if ($req_method == self::POST) { // We want post but no params to supply. Probably we have a nice link structure which includes all the info.
curl_setopt($ch, CURLOPT_CUSTOMREQUEST, "POST");
} elseif ($req_method == self::DELETE) {
curl_setopt($ch, CURLOPT_CUSTOMREQUEST, "DELETE");
} elseif ($req_method == self::PUT) {
curl_setopt($ch, CURLOPT_CUSTOMREQUEST, "PUT");
}
if (!empty($params)) {
if ((isset($params['__req']) && strtolower($params['__req']) == 'get')
|| $req_method == self::GET) {
unset($params['__req']);
$url .= '?' . http_build_query($params);
} elseif ($req_method == self::POST || $req_method == self::DELETE) {
$params_str = is_array($params) ? json_encode($params) : $params;
curl_setopt($ch, CURLOPT_POSTFIELDS, $params_str);
}
}
curl_setopt($ch, CURLOPT_URL, $url);
curl_setopt($ch, CURLOPT_HTTPHEADER, array(
'Accept:application/json, text/javascript, */*; q=0.01',
'Content-Type: application/vnd.api+json',
));
$buffer = curl_exec($ch);
$status = !empty($buffer);
$data = array(
'url' => $url,
'params' => $params,
'status' => $status,
'error' => empty($buffer) ? curl_error($ch) : '',
'error_no' => empty($buffer) ? curl_errno($ch) : '',
'http_code' => curl_getinfo($ch, CURLINFO_HTTP_CODE),
'debug' => $this->debug ? curl_getinfo($ch) : '',
);
curl_close($ch);
// remove some weird headers HTTP/1.1 100 Continue or HTTP/1.1 200 OK
$buffer = preg_replace('#HTTP/[\d.]+\s+\d+\s+\w+[\r\n]+#si', '', $buffer);
$buffer = trim($buffer);
$data['buffer'] = $buffer;
$this->_parse_error($data);
$this->recent_req_info = $data;
return $data;
}
/**
* This returns the RAW data from the each request that has been sent (if any).
* @return arraay of arrays
*/
public function get_request_info() {
return $this->recent_req_info;
}
/**
* Retruns whatever was accumultaed in error_message
* @param string
*/
public function get_error_message() {
return $this->error_message;
}
/**
* Retruns whatever was accumultaed in error_code
* @return string
*/
public function get_error_code() {
return $this->error_code;
}
/**
* Some keys are removed from the params so they don't get send with the other data to Drip.
*
* @param array $params
* @param array
*/
public function _parse_error($res) {
if (empty($res['http_code']) || $res['http_code'] >= 200 && $res['http_code'] <= 299) {
return true;
}
if (empty($res['buffer'])) {
$this->error_message = "Response from the server.";
$this->error_code = $res['http_code'];
} elseif (!empty($res['buffer'])) {
$json_arr = json_decode($res['buffer'], true);
// The JSON error response looks like this.
/*
{
"errors": [{
"code": "authorization_error",
"message": "You are not authorized to access this resource"
}]
}
*/
if (!empty($json_arr['errors'])) { // JSON
$messages = $error_codes = array();
foreach ($json_arr['errors'] as $rec) {
$messages[] = $rec['message'];
$error_codes[] = $rec['code'];
}
$this->error_code = join(", ", $error_codes);
$this->error_message = join("\n", $messages);
} else { // There's no JSON in the reply so we'll extract the message from the HTML page by removing the HTML.
$msg = $res['buffer'];
$msg = preg_replace('#.*?<body[^>]*>#si', '', $msg);
$msg = preg_replace('#</body[^>]*>.*#si', '', $msg);
$msg = strip_tags($msg);
$msg = preg_replace('#[\r\n]#si', '', $msg);
$msg = preg_replace('#\s+#si', ' ', $msg);
$msg = trim($msg);
$msg = substr($msg, 0, 256);
$this->error_code = $res['http_code'];
$this->error_message = $msg;
}
} elseif ($res['http_code'] >= 400 || $res['http_code'] <= 499) {
$this->error_message = "Not authorized.";
$this->error_code = $res['http_code'];
} elseif ($res['http_code'] >= 500 || $res['http_code'] <= 599) {
$this->error_message = "Internal Server Error.";
$this->error_code = $res['http_code'];
}
}
// tmp
public function __call($method, $args) {
return array();
}
}