Edit File by line

<?php

[0] Fix | Delete

/**

[1] Fix | Delete

* Class OauthConnect

[2] Fix | Delete

[3] Fix | Delete

* Simple, lightweight class to make a connection to the Twitter API

[4] Fix | Delete

* Supports home timeline, user timeline, and search endpoints

[5] Fix | Delete

[6] Fix | Delete

namespace TwitterFeed;

[7] Fix | Delete

[8] Fix | Delete

// Don't load directly

[9] Fix | Delete

if ( ! defined( 'ABSPATH' ) ) {

[10] Fix | Delete

die( '-1' );

[11] Fix | Delete

}

[12] Fix | Delete

[13] Fix | Delete

class CtfOauthConnect

[14] Fix | Delete

{

[15] Fix | Delete

/**

[16] Fix | Delete

* @var string

[17] Fix | Delete

[18] Fix | Delete

protected $base_url;

[19] Fix | Delete

[20] Fix | Delete

/**

[21] Fix | Delete

* @var string

[22] Fix | Delete

[23] Fix | Delete

protected $get_fields;

[24] Fix | Delete

[25] Fix | Delete

/**

[26] Fix | Delete

* @var string

[27] Fix | Delete

[28] Fix | Delete

protected $request_method;

[29] Fix | Delete

[30] Fix | Delete

/**

[31] Fix | Delete

* @var array

[32] Fix | Delete

[33] Fix | Delete

protected $oauth;

[34] Fix | Delete

[35] Fix | Delete

/**

[36] Fix | Delete

* @var string

[37] Fix | Delete

[38] Fix | Delete

protected $header;

[39] Fix | Delete

[40] Fix | Delete

/**

[41] Fix | Delete

* @var bool

[42] Fix | Delete

[43] Fix | Delete

public $api_error_no = false;

[44] Fix | Delete

[45] Fix | Delete

/**

[46] Fix | Delete

* @var bool

[47] Fix | Delete

[48] Fix | Delete

public $api_error_message = false;

[49] Fix | Delete

[50] Fix | Delete

/**

[51] Fix | Delete

* @var string

[52] Fix | Delete

[53] Fix | Delete

public $json;

[54] Fix | Delete

[55] Fix | Delete

/**

[56] Fix | Delete

* @param array $request_settings all necessary tokens for OAuth connection

[57] Fix | Delete

* @param $feed_type string type of Twitter feed

[58] Fix | Delete

[59] Fix | Delete

public function __construct( array $request_settings, $feed_type )

[60] Fix | Delete

{

[61] Fix | Delete

$this->consumer_key = $request_settings['consumer_key'];

[62] Fix | Delete

$this->consumer_secret = $request_settings['consumer_secret'];

[63] Fix | Delete

$this->access_token = $request_settings['access_token'];

[64] Fix | Delete

$this->access_token_secret = $request_settings['access_token_secret'];

[65] Fix | Delete

$this->feed_type = $feed_type;

[66] Fix | Delete

}

[67] Fix | Delete

[68] Fix | Delete

/**

[69] Fix | Delete

* Sets the complete url for our API endpoint. GET fields will be added later

[70] Fix | Delete

[71] Fix | Delete

public function setUrlBase()

[72] Fix | Delete

{

[73] Fix | Delete

switch ( $this->feed_type ) {

[74] Fix | Delete

case "hometimeline":

[75] Fix | Delete

$this->base_url = 'https://api.twitter.com/1.1/statuses/home_timeline.json';

[76] Fix | Delete

break;

[77] Fix | Delete

case "search":

[78] Fix | Delete

$this->base_url = 'https://api.twitter.com/1.1/search/tweets.json';

[79] Fix | Delete

break;

[80] Fix | Delete

case "accountlookup":

[81] Fix | Delete

$this->base_url = 'https://api.twitter.com/1.1/account/verify_credentials.json';

[82] Fix | Delete

break;

[83] Fix | Delete

case "userslookup":

[84] Fix | Delete

$this->base_url = 'https://api.twitter.com/1.1/users/lookup.json';

[85] Fix | Delete

break;

[86] Fix | Delete

default:

[87] Fix | Delete

$this->base_url = 'https://api.twitter.com/1.1/statuses/user_timeline.json';

[88] Fix | Delete

}

[89] Fix | Delete

}

[90] Fix | Delete

[91] Fix | Delete

/**

[92] Fix | Delete

* Encodes an array of GET field data into html characters for including in a URL

[93] Fix | Delete

[94] Fix | Delete

* @param array $get_fields array of GET fields that are compatible with the Twitter API

[95] Fix | Delete

[96] Fix | Delete

public function setGetFields( array $get_fields )

[97] Fix | Delete

{

[98] Fix | Delete

$url_string = '?';

[99] Fix | Delete

$length = count( $get_fields );

[100] Fix | Delete

$j = 1;

[101] Fix | Delete

foreach ( $get_fields as $key => $value ) {

[102] Fix | Delete

$url_string .= rawurlencode( $key ) . '=' . rawurlencode( $value );

[103] Fix | Delete

if ( $j != $length ) {

[104] Fix | Delete

$url_string .= '&';

[105] Fix | Delete

}

[106] Fix | Delete

$j++;

[107] Fix | Delete

}

[108] Fix | Delete

[109] Fix | Delete

$this->get_fields = $url_string;

[110] Fix | Delete

}

[111] Fix | Delete

[112] Fix | Delete

/**

[113] Fix | Delete

* Users can manually set the request method if there is an uncatchable error in

[114] Fix | Delete

* the other methods

[115] Fix | Delete

[116] Fix | Delete

* @param string $request_method

[117] Fix | Delete

[118] Fix | Delete

public function setRequestMethod( $request_method = 'auto' )

[119] Fix | Delete

{

[120] Fix | Delete

$this->request_method = $request_method;

[121] Fix | Delete

}

[122] Fix | Delete

[123] Fix | Delete

/**

[124] Fix | Delete

* Uses the OAuth data to build the base string needed to create the

[125] Fix | Delete

* OAuth signature to be used in the header of the request

[126] Fix | Delete

[127] Fix | Delete

* @param $oauth array oauth data without the signature

[128] Fix | Delete

* @return string the base string for needed to construct the oauth signature

[129] Fix | Delete

[130] Fix | Delete

private function buildBaseString( $oauth )

[131] Fix | Delete

{

[132] Fix | Delete

$base_string = array();

[133] Fix | Delete

ksort( $oauth );

[134] Fix | Delete

[135] Fix | Delete

// start forming the header string by creating a numeric index array with

[136] Fix | Delete

// each part of the header string it's own element in the array

[137] Fix | Delete

foreach ( $oauth as $key => $value ) {

[138] Fix | Delete

$base_string[] = rawurlencode( $key ) . '=' . rawurlencode( $value );

[139] Fix | Delete

}

[140] Fix | Delete

[141] Fix | Delete

// convert the array of values into a single encoded string and return

[142] Fix | Delete

return 'GET&' . rawurlencode( $this->base_url ) . '&' . rawurlencode( implode( '&', $base_string ) );

[143] Fix | Delete

}

[144] Fix | Delete

[145] Fix | Delete

/**

[146] Fix | Delete

* Builds the OAuth data array that is used to authenticate the connection

[147] Fix | Delete

* to the Twitter API

[148] Fix | Delete

[149] Fix | Delete

public function buildOauth()

[150] Fix | Delete

{

[151] Fix | Delete

$oauth = array(

[152] Fix | Delete

'oauth_consumer_key' => $this->consumer_key,

[153] Fix | Delete

'oauth_nonce' => time(),

[154] Fix | Delete

'oauth_signature_method' => 'HMAC-SHA1',

[155] Fix | Delete

'oauth_token' => $this->access_token,

[156] Fix | Delete

'oauth_timestamp' => time(),

[157] Fix | Delete

'oauth_version' => '1.0'

[158] Fix | Delete

);

[159] Fix | Delete

[160] Fix | Delete

$getfields = str_replace( '?', '', explode( '&', $this->get_fields ? $this->get_fields : '' ) );

[161] Fix | Delete

[162] Fix | Delete

// add the get fields to the oauth associative array to be

[163] Fix | Delete

// formed into the header string eventually

[164] Fix | Delete

foreach ( $getfields as $getfield ) {

[165] Fix | Delete

$split = explode( '=', $getfield );

[166] Fix | Delete

[167] Fix | Delete

if ( isset( $split[1] ) ) {

[168] Fix | Delete

$oauth[$split[0]] = urldecode( $split[1] );

[169] Fix | Delete

}

[170] Fix | Delete

}

[171] Fix | Delete

[172] Fix | Delete

// the OAuth signature for Twitter is a hashed, encoded version of the base url, 4 different keys

[173] Fix | Delete

$base_string = $this->buildBaseString( $oauth );

[174] Fix | Delete

$composite_key = rawurlencode( $this->consumer_secret ) . '&' . rawurlencode( $this->access_token_secret );

[175] Fix | Delete

$oauth_signature = base64_encode( hash_hmac( 'sha1', $base_string, $composite_key, true ) );

[176] Fix | Delete

$oauth['oauth_signature'] = $oauth_signature;

[177] Fix | Delete

[178] Fix | Delete

$this->oauth = $oauth;

[179] Fix | Delete

}

[180] Fix | Delete

[181] Fix | Delete

/**

[182] Fix | Delete

* Since the OAuth data is passed in a url, special characters need to be encoded

[183] Fix | Delete

[184] Fix | Delete

private function encodeHeader()

[185] Fix | Delete

{

[186] Fix | Delete

$header = 'Authorization: OAuth ';

[187] Fix | Delete

$values = array();

[188] Fix | Delete

[189] Fix | Delete

// each element of the header needs to have it's special characters encoded for

[190] Fix | Delete

// passing through a url

[191] Fix | Delete

foreach ( $this->oauth as $key => $value ) {

[192] Fix | Delete

if ( in_array( $key, array( 'oauth_consumer_key', 'oauth_nonce', 'oauth_signature',

[193] Fix | Delete

'oauth_signature_method', 'oauth_timestamp', 'oauth_token', 'oauth_version' ) ) ){

[194] Fix | Delete

$values[] = "$key=\"" . rawurlencode( $value ) . "\"";

[195] Fix | Delete

}

[196] Fix | Delete

}

[197] Fix | Delete

[198] Fix | Delete

$header .= implode( ', ', $values );

[199] Fix | Delete

$this->header = $header;

[200] Fix | Delete

}

[201] Fix | Delete

[202] Fix | Delete

/**

[203] Fix | Delete

* Attempts to connect to the Twitter api using WP_HTTP class

[204] Fix | Delete

[205] Fix | Delete

* @param $url string the complete api endpoint url

[206] Fix | Delete

* @return mixed json string retrieved in the request

[207] Fix | Delete

[208] Fix | Delete

protected function wpHttpRequest( $url )

[209] Fix | Delete

{

[210] Fix | Delete

$args = array(

[211] Fix | Delete

'headers' => $this->header,

[212] Fix | Delete

'timeout' => 60,

[213] Fix | Delete

);

[214] Fix | Delete

$result = wp_remote_get( $url, $args );

[215] Fix | Delete

[216] Fix | Delete

if ( ! is_wp_error( $result ) ) {

[217] Fix | Delete

return $result['body']; // just need the body to keep everything simple

[218] Fix | Delete

} else {

[219] Fix | Delete

return '{}';

[220] Fix | Delete

}

[221] Fix | Delete

[222] Fix | Delete

}

[223] Fix | Delete

[224] Fix | Delete

/**

[225] Fix | Delete

* Uses the data created and gathered up to this point to make the actual connection

[226] Fix | Delete

* to the Twitter API. It first tests whether or not a curl connection is possible,

[227] Fix | Delete

* followed by file_get_contents connection, then defaults to the WordPress WP_HTTP object

[228] Fix | Delete

[229] Fix | Delete

* @return mixed|string raw json data retrieved from the API request

[230] Fix | Delete

[231] Fix | Delete

public function performRequest()

[232] Fix | Delete

{

[233] Fix | Delete

$url = $this->base_url . $this->get_fields;

[234] Fix | Delete

$this->buildOauth();

[235] Fix | Delete

$this->encodeHeader();

[236] Fix | Delete

[237] Fix | Delete

$this->json = $this->wpHttpRequest( $url );

[238] Fix | Delete

[239] Fix | Delete

return $this;

[240] Fix | Delete

}

[241] Fix | Delete

}

[242] Fix | Delete

[243] Fix | Delete