forked from qwerty/tupali
264 lines
10 KiB
PHP
264 lines
10 KiB
PHP
|
<?php
|
||
|
|
|
||
|
|
/* !
|
||
|
|
* HybridAuth
|
||
|
|
* http://hybridauth.sourceforge.net | http://github.com/hybridauth/hybridauth
|
||
|
|
* (c) 2009-2012, HybridAuth authors | http://hybridauth.sourceforge.net/licenses.html
|
||
|
|
*/
|
||
|
|
|
||
|
|
/**
|
||
|
|
* Hybrid_Providers_Twitter provider adapter based on OAuth1 protocol
|
||
|
|
*/
|
||
|
|
class Hybrid_Providers_Twitter extends Hybrid_Provider_Model_OAuth1 {
|
||
|
|
|
||
|
|
/**
|
||
|
|
* {@inheritdoc}
|
||
|
|
*/
|
||
|
|
function initialize() {
|
||
|
|
parent::initialize();
|
||
|
|
|
||
|
|
// Provider api end-points
|
||
|
|
$this->api->api_base_url = "https://api.twitter.com/1.1/";
|
||
|
|
$this->api->authorize_url = "https://api.twitter.com/oauth/authenticate";
|
||
|
|
$this->api->request_token_url = "https://api.twitter.com/oauth/request_token";
|
||
|
|
$this->api->access_token_url = "https://api.twitter.com/oauth/access_token";
|
||
|
|
|
||
|
|
if (isset($this->config['api_version']) && $this->config['api_version']) {
|
||
|
|
$this->api->api_base_url = "https://api.twitter.com/{$this->config['api_version']}/";
|
||
|
|
}
|
||
|
|
|
||
|
|
if (isset($this->config['authorize']) && $this->config['authorize']) {
|
||
|
|
$this->api->authorize_url = "https://api.twitter.com/oauth/authorize";
|
||
|
|
}
|
||
|
|
|
||
|
|
$this->api->curl_auth_header = false;
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* {@inheritdoc}
|
||
|
|
*/
|
||
|
|
function loginBegin() {
|
||
|
|
// Initiate the Reverse Auth flow; cf. https://dev.twitter.com/docs/ios/using-reverse-auth
|
||
|
|
if (isset($_REQUEST['reverse_auth']) && ($_REQUEST['reverse_auth'] == 'yes')) {
|
||
|
|
$stage1 = $this->api->signedRequest($this->api->request_token_url, 'POST', array('x_auth_mode' => 'reverse_auth'));
|
||
|
|
if ($this->api->http_code != 200) {
|
||
|
|
throw new Exception("Authentication failed! {$this->providerId} returned an error. " . $this->errorMessageByStatus($this->api->http_code), 5);
|
||
|
|
}
|
||
|
|
$responseObj = array('x_reverse_auth_parameters' => $stage1, 'x_reverse_auth_target' => $this->config["keys"]["key"]);
|
||
|
|
$response = json_encode($responseObj);
|
||
|
|
header("Content-Type: application/json", true, 200);
|
||
|
|
echo $response;
|
||
|
|
die();
|
||
|
|
}
|
||
|
|
$tokens = $this->api->requestToken($this->endpoint);
|
||
|
|
|
||
|
|
// request tokens as received from provider
|
||
|
|
$this->request_tokens_raw = $tokens;
|
||
|
|
|
||
|
|
// check the last HTTP status code returned
|
||
|
|
if ($this->api->http_code != 200) {
|
||
|
|
throw new Exception("Authentication failed! {$this->providerId} returned an error. " . $this->errorMessageByStatus($this->api->http_code), 5);
|
||
|
|
}
|
||
|
|
|
||
|
|
if (!isset($tokens["oauth_token"])) {
|
||
|
|
throw new Exception("Authentication failed! {$this->providerId} returned an invalid oauth token.", 5);
|
||
|
|
}
|
||
|
|
|
||
|
|
$this->token("request_token", $tokens["oauth_token"]);
|
||
|
|
$this->token("request_token_secret", $tokens["oauth_token_secret"]);
|
||
|
|
|
||
|
|
// redirect the user to the provider authentication url with force_login
|
||
|
|
if (( isset($this->config['force_login']) && $this->config['force_login'] ) || ( isset($this->config['force']) && $this->config['force'] === true )) {
|
||
|
|
Hybrid_Auth::redirect($this->api->authorizeUrl($tokens, array('force_login' => true)));
|
||
|
|
}
|
||
|
|
|
||
|
|
// else, redirect the user to the provider authentication url
|
||
|
|
Hybrid_Auth::redirect($this->api->authorizeUrl($tokens));
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* {@inheritdoc}
|
||
|
|
*/
|
||
|
|
function loginFinish() {
|
||
|
|
// in case we are completing a Reverse Auth flow; cf. https://dev.twitter.com/docs/ios/using-reverse-auth
|
||
|
|
if (isset($_REQUEST['oauth_token_secret'])) {
|
||
|
|
$tokens = $_REQUEST;
|
||
|
|
$this->access_tokens_raw = $tokens;
|
||
|
|
|
||
|
|
// we should have an access_token unless something has gone wrong
|
||
|
|
if (!isset($tokens["oauth_token"])) {
|
||
|
|
throw new Exception("Authentication failed! {$this->providerId} returned an invalid access token.", 5);
|
||
|
|
}
|
||
|
|
|
||
|
|
// Get rid of tokens we don't need
|
||
|
|
$this->deleteToken("request_token");
|
||
|
|
$this->deleteToken("request_token_secret");
|
||
|
|
|
||
|
|
// Store access_token and secret for later use
|
||
|
|
$this->token("access_token", $tokens['oauth_token']);
|
||
|
|
$this->token("access_token_secret", $tokens['oauth_token_secret']);
|
||
|
|
|
||
|
|
// set user as logged in to the current provider
|
||
|
|
$this->setUserConnected();
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
parent::loginFinish();
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* {@inheritdoc}
|
||
|
|
*/
|
||
|
|
function getUserProfile() {
|
||
|
|
$includeEmail = isset($this->config['includeEmail']) ? (bool) $this->config['includeEmail'] : false;
|
||
|
|
$response = $this->api->get('account/verify_credentials.json'. ($includeEmail ? '?include_email=true' : ''));
|
||
|
|
|
||
|
|
// check the last HTTP status code returned
|
||
|
|
if ($this->api->http_code != 200) {
|
||
|
|
throw new Exception("User profile request failed! {$this->providerId} returned an error. " . $this->errorMessageByStatus($this->api->http_code), 6);
|
||
|
|
}
|
||
|
|
|
||
|
|
if (!is_object($response) || !isset($response->id)) {
|
||
|
|
throw new Exception("User profile request failed! {$this->providerId} api returned an invalid response: " . Hybrid_Logger::dumpData( $response ), 6);
|
||
|
|
}
|
||
|
|
|
||
|
|
# store the user profile.
|
||
|
|
$this->user->profile->identifier = (property_exists($response, 'id')) ? $response->id : "";
|
||
|
|
$this->user->profile->displayName = (property_exists($response, 'screen_name')) ? $response->screen_name : "";
|
||
|
|
$this->user->profile->description = (property_exists($response, 'description')) ? $response->description : "";
|
||
|
|
$this->user->profile->firstName = (property_exists($response, 'name')) ? $response->name : "";
|
||
|
|
$this->user->profile->photoURL = (property_exists($response, 'profile_image_url')) ? (str_replace('_normal', '', $response->profile_image_url)) : "";
|
||
|
|
$this->user->profile->profileURL = (property_exists($response, 'screen_name')) ? ("http://twitter.com/" . $response->screen_name) : "";
|
||
|
|
$this->user->profile->webSiteURL = (property_exists($response, 'url')) ? $response->url : "";
|
||
|
|
$this->user->profile->region = (property_exists($response, 'location')) ? $response->location : "";
|
||
|
|
if($includeEmail) $this->user->profile->email = (property_exists($response, 'email')) ? $response->email : "";
|
||
|
|
|
||
|
|
return $this->user->profile;
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* {@inheritdoc}
|
||
|
|
*/
|
||
|
|
function getUserContacts() {
|
||
|
|
$parameters = array('cursor' => '-1');
|
||
|
|
$response = $this->api->get('friends/ids.json', $parameters);
|
||
|
|
|
||
|
|
// check the last HTTP status code returned
|
||
|
|
if ($this->api->http_code != 200) {
|
||
|
|
throw new Exception("User contacts request failed! {$this->providerId} returned an error. " . $this->errorMessageByStatus($this->api->http_code));
|
||
|
|
}
|
||
|
|
|
||
|
|
if (!$response || !count($response->ids)) {
|
||
|
|
return array();
|
||
|
|
}
|
||
|
|
|
||
|
|
// 75 id per time should be okey
|
||
|
|
$contactsids = array_chunk($response->ids, 75);
|
||
|
|
|
||
|
|
$contacts = array();
|
||
|
|
|
||
|
|
foreach ($contactsids as $chunk) {
|
||
|
|
$parameters = array('user_id' => implode(",", $chunk));
|
||
|
|
$response = $this->api->get('users/lookup.json', $parameters);
|
||
|
|
|
||
|
|
// check the last HTTP status code returned
|
||
|
|
if ($this->api->http_code != 200) {
|
||
|
|
throw new Exception("User contacts request failed! {$this->providerId} returned an error. " . $this->errorMessageByStatus($this->api->http_code));
|
||
|
|
}
|
||
|
|
|
||
|
|
if ($response && count($response)) {
|
||
|
|
foreach ($response as $item) {
|
||
|
|
$uc = new Hybrid_User_Contact();
|
||
|
|
|
||
|
|
$uc->identifier = (property_exists($item, 'id')) ? $item->id : "";
|
||
|
|
$uc->displayName = (property_exists($item, 'name')) ? $item->name : "";
|
||
|
|
$uc->profileURL = (property_exists($item, 'screen_name')) ? ("http://twitter.com/" . $item->screen_name) : "";
|
||
|
|
$uc->photoURL = (property_exists($item, 'profile_image_url')) ? $item->profile_image_url : "";
|
||
|
|
$uc->description = (property_exists($item, 'description')) ? $item->description : "";
|
||
|
|
|
||
|
|
$contacts[] = $uc;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
return $contacts;
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* {@inheritdoc}
|
||
|
|
*/
|
||
|
|
function setUserStatus($status) {
|
||
|
|
|
||
|
|
if (is_array($status) && isset($status['message']) && isset($status['picture'])) {
|
||
|
|
$response = $this->api->post('statuses/update_with_media.json', array('status' => $status['message'], 'media[]' => file_get_contents($status['picture'])), null, null, true);
|
||
|
|
} else {
|
||
|
|
$response = $this->api->post('statuses/update.json', array('status' => $status));
|
||
|
|
}
|
||
|
|
|
||
|
|
// check the last HTTP status code returned
|
||
|
|
if ($this->api->http_code != 200) {
|
||
|
|
throw new Exception("Update user status failed! {$this->providerId} returned an error. " . $this->errorMessageByStatus($this->api->http_code));
|
||
|
|
}
|
||
|
|
|
||
|
|
return $response;
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* {@inheritdoc}
|
||
|
|
*/
|
||
|
|
function getUserStatus($tweetid) {
|
||
|
|
$info = $this->api->get('statuses/show.json?id=' . $tweetid . '&include_entities=true');
|
||
|
|
|
||
|
|
// check the last HTTP status code returned
|
||
|
|
if ($this->api->http_code != 200 || !isset($info->id)) {
|
||
|
|
throw new Exception("Cannot retrieve user status! {$this->providerId} returned an error. " . $this->errorMessageByStatus($this->api->http_code));
|
||
|
|
}
|
||
|
|
|
||
|
|
return $info;
|
||
|
|
}
|
||
|
|
|
||
|
|
/**
|
||
|
|
* load the user latest activity
|
||
|
|
* - timeline : all the stream
|
||
|
|
* - me : the user activity only
|
||
|
|
*
|
||
|
|
* by default return the timeline
|
||
|
|
* {@inheritdoc}
|
||
|
|
*/
|
||
|
|
function getUserActivity($stream) {
|
||
|
|
if ($stream == "me") {
|
||
|
|
$response = $this->api->get('statuses/user_timeline.json');
|
||
|
|
} else {
|
||
|
|
$response = $this->api->get('statuses/home_timeline.json');
|
||
|
|
}
|
||
|
|
|
||
|
|
// check the last HTTP status code returned
|
||
|
|
if ($this->api->http_code != 200) {
|
||
|
|
throw new Exception("User activity stream request failed! {$this->providerId} returned an error. " . $this->errorMessageByStatus($this->api->http_code));
|
||
|
|
}
|
||
|
|
|
||
|
|
if (!$response) {
|
||
|
|
return array();
|
||
|
|
}
|
||
|
|
|
||
|
|
$activities = array();
|
||
|
|
|
||
|
|
foreach ($response as $item) {
|
||
|
|
$ua = new Hybrid_User_Activity();
|
||
|
|
|
||
|
|
$ua->id = (property_exists($item, 'id')) ? $item->id : "";
|
||
|
|
$ua->date = (property_exists($item, 'created_at')) ? strtotime($item->created_at) : "";
|
||
|
|
$ua->text = (property_exists($item, 'text')) ? $item->text : "";
|
||
|
|
|
||
|
|
$ua->user->identifier = (property_exists($item->user, 'id')) ? $item->user->id : "";
|
||
|
|
$ua->user->displayName = (property_exists($item->user, 'name')) ? $item->user->name : "";
|
||
|
|
$ua->user->profileURL = (property_exists($item->user, 'screen_name')) ? ("http://twitter.com/" . $item->user->screen_name) : "";
|
||
|
|
$ua->user->photoURL = (property_exists($item->user, 'profile_image_url')) ? $item->user->profile_image_url : "";
|
||
|
|
|
||
|
|
$activities[] = $ua;
|
||
|
|
}
|
||
|
|
|
||
|
|
return $activities;
|
||
|
|
}
|
||
|
|
|
||
|
|
}
|