sig_method = new ClientOAuthSignatureMethod_HMAC_SHA1();
$this->host = $apiHost;
$this->request_token_url = $this->host .'/oauth/request-token';
//After getting an access token we'll want to have the user authenicate
$this->authorize_url = $this->host .'/oauth/authorize';
//this final call fetches an access token.
$this->access_token_url = $this->host .'/oauth/access-token';
$this->key = $key;
$this->secret = $secret;
}
private function _isSession(){
$token = new ClientOAuthConsumer($_SESSION['ar_oauth_token'], $_SESSION['ar_oauth_token_secret'], 0);
return ((!is_null($token->key)) && $_SESSION['ar_oauth_token']!='' && isset($_SESSION['ar_oauth_token']));
}
public function closeSession(){
$_SESSION['ar_oauth_token'] = '';
$_SESSION['ar_oauth_token_secret']= '';
return;
}
public function init(){
//session_destroy();
$test_consumer = new ClientOAuthConsumer($this->key, $this->secret, NULL);
if(!$this->_isSession()){
//Reset tokens
$this->closeSession();
//1) Get the request token
$req_req = ClientOAuthRequest::from_consumer_and_token($test_consumer, NULL, "GET", $this->request_token_url);
$req_req->sign_request($this->sig_method, $test_consumer, NULL);
$url_for_request_authorize = $req_req->to_url(). "\n";
$output = $this->_getCurlResponse(null, $url_for_request_authorize, "GET");
//var_dump($output);echo "
";
parse_str($output, $oauth);
$oauth_token = $oauth['oauth_token'];
$oauth_token_secret = $oauth['oauth_token_secret'];
// 2) Make the authorization
$output = $this->_getCurlResponse(null, $this->authorize_url . "?oauth_token=".$oauth_token, "GET");
//var_dump($output);echo "
";
// 3) Get Access token
$test_token = new ClientOAuthConsumer($oauth_token, $oauth_token_secret);
$acc_req = ClientOAuthRequest::from_consumer_and_token($test_consumer, $test_token, "GET", $this->access_token_url);
$acc_req->sign_request($this->sig_method, $test_consumer, $test_token);
$url_request_access_token = $acc_req->to_url();
$output = $this->_getCurlResponse(null, $url_request_access_token, "GET");
parse_str($output, $oauth);
//var_dump($output);
$_SESSION['ar_oauth_token'] = $oauth['oauth_token'];
$_SESSION['ar_oauth_token_secret'] = $oauth['oauth_token_secret'];
return array($oauth['oauth_token'], $oauth['oauth_token_secret']);
}
}
/**
* Does the service request for the API
* $service: service controller/action (ie: 'api/echo')
* $data: post parameters
* Returns json object
**/
public function doRequest($service, $data = array()) {
foreach ($data as $key => $value) $data[$key] = is_null($value) ? "" : urlencode($value);
$test_consumer = new ClientOAuthConsumer($this->key, $this->secret, NULL);
$token = new ClientOAuthConsumer($_SESSION['ar_oauth_token'], $_SESSION['ar_oauth_token_secret'], 1);
$endpoint = $this->host . $service;
$profileObj = ClientOAuthRequest::from_consumer_and_token($test_consumer, $token, "POST", $endpoint, $data);
$profileObj->sign_request($this->sig_method, $test_consumer, $token);
$toHeader = $profileObj->to_header();
$r = $this->_getCurlResponse($toHeader, $endpoint, "POST", $data);
$json = json_decode($r);
//If a token problem is detected - try to regenerate valids
if($json->status == AR_Client::STATUS_INVALID_ACCESS_TOKEN) $this->closeSession();
return $json;
}
private function _getCurlResponse($toHeader, $url, $method = "POST", $data = array()) {
$ch = curl_init();
$A_header[] = $toHeader;
curl_setopt($ch, CURLOPT_RETURNTRANSFER, 1);
curl_setopt($ch, CURLOPT_HTTPHEADER, $A_header);
curl_setopt($ch, CURLOPT_URL, $url);
curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, 0);
curl_setopt($ch, CURLOPT_SSL_VERIFYHOST, 0);
if($method=="POST" OR $method=="PUT") {
curl_setopt($ch, CURLOPT_POSTFIELDS, http_build_query($data, '', '&'));
curl_setopt($ch, CURLOPT_POST, true);
curl_setopt($ch, CURLOPT_CUSTOMREQUEST, $method);
}
$output = curl_exec($ch);
curl_close($ch);
return $output;
}
public function addPost($text, $teaser, $sourceId, $segmentId, $title, $pubDate, $postUrl) {
return $this->doRequest('/post/add', array('text' => $text, 'teaser' => $teaser, 'sourceId' => $sourceId, 'segmentId' => $segmentId, 'title' => $title, 'pubDate' => $pubDate, 'url' => $postUrl));
}
public function analyzePost($content, $title = '', $segmentId = null) {
return $this->doRequest('/post/analyze', array('content' => $content, 'title' => $title, 'segmentId' => $segmentId));
}
public function addSource($title, $segmentDataJson) {
return $this->doRequest('/source/add', array('title' => $title, 'segmentDataJson' => $segmentDataJson));
}
public function getAudienceList(){
return $this->doRequest('/source/get-audience-list', array());
}
public function trackWordpressData($data) {
return $this->doRequest('/wordpress/track-data', array('data' => $data));
}
}