Newer
Older
Andreas Åkre Solberg
committed
<?php
// vim: foldmethod=marker
Andjelko Horvat
committed
class OAuthException extends Exception {
Andreas Åkre Solberg
committed
// pass
Andjelko Horvat
committed
}
Andreas Åkre Solberg
committed
Andjelko Horvat
committed
class OAuthConsumer {
Andreas Åkre Solberg
committed
public $key;
public $secret;
Andjelko Horvat
committed
function __construct($key, $secret, $callback_url=NULL) {
Andreas Åkre Solberg
committed
$this->key = $key;
$this->secret = $secret;
$this->callback_url = $callback_url;
Andjelko Horvat
committed
}
Andreas Åkre Solberg
committed
Andjelko Horvat
committed
function __toString() {
Andreas Åkre Solberg
committed
return "OAuthConsumer[key=$this->key,secret=$this->secret]";
Andjelko Horvat
committed
}
}
Andreas Åkre Solberg
committed
Andjelko Horvat
committed
class OAuthToken {
Andreas Åkre Solberg
committed
// access tokens and request tokens
public $key;
public $secret;
/**
* key = the token
* secret = the token secret
*/
Andjelko Horvat
committed
function __construct($key, $secret) {
Andreas Åkre Solberg
committed
$this->key = $key;
$this->secret = $secret;
Andjelko Horvat
committed
}
Andreas Åkre Solberg
committed
/**
* generates the basic string serialization of a token that a server
* would respond to request_token and access_token calls with
*/
Andjelko Horvat
committed
function to_string() {
return "oauth_token=" .
OAuthUtil::urlencode_rfc3986($this->key) .
"&oauth_token_secret=" .
OAuthUtil::urlencode_rfc3986($this->secret);
}
Andreas Åkre Solberg
committed
Andjelko Horvat
committed
function __toString() {
Andreas Åkre Solberg
committed
return $this->to_string();
Andjelko Horvat
committed
}
}
/**
* A class for implementing a Signature Method
* See section 9 ("Signing Requests") in the spec
*/
abstract class OAuthSignatureMethod {
/**
* Needs to return the name of the Signature Method (ie HMAC-SHA1)
* @return string
*/
abstract public function get_name();
/**
* Build up the signature
* NOTE: The output of this function MUST NOT be urlencoded.
* the encoding is handled in OAuthRequest when the final
* request is serialized
* @param OAuthRequest $request
* @param OAuthConsumer $consumer
* @param OAuthToken $token
* @return string
*/
abstract public function build_signature($request, $consumer, $token);
Andreas Åkre Solberg
committed
Andjelko Horvat
committed
/**
* Verifies that a given signature is correct
* @param OAuthRequest $request
* @param OAuthConsumer $consumer
* @param OAuthToken $token
* @param string $signature
* @return bool
*/
public function check_signature($request, $consumer, $token, $signature) {
Andreas Åkre Solberg
committed
$built = $this->build_signature($request, $consumer, $token);
Andjelko Horvat
committed
// Check for zero length, although unlikely here
if (strlen($built) == 0 || strlen($signature) == 0) {
return false;
}
if (strlen($built) != strlen($signature)) {
return false;
}
// Avoid a timing leak with a (hopefully) time insensitive compare
$result = 0;
for ($i = 0; $i < strlen($signature); $i++) {
$result |= ord($built{$i}) ^ ord($signature{$i});
}
return $result == 0;
}
Andreas Åkre Solberg
committed
}
Andjelko Horvat
committed
/**
* The HMAC-SHA1 signature method uses the HMAC-SHA1 signature algorithm as defined in [RFC2104]
* where the Signature Base String is the text and the key is the concatenated values (each first
* encoded per Parameter Encoding) of the Consumer Secret and Token Secret, separated by an '&'
* character (ASCII code 38) even if empty.
* - Chapter 9.2 ("HMAC-SHA1")
*/
class OAuthSignatureMethod_HMAC_SHA1 extends OAuthSignatureMethod {
function get_name() {
Andreas Åkre Solberg
committed
return "HMAC-SHA1";
Andjelko Horvat
committed
}
Andreas Åkre Solberg
committed
Andjelko Horvat
committed
public function build_signature($request, $consumer, $token) {
Andreas Åkre Solberg
committed
$base_string = $request->get_signature_base_string();
$request->base_string = $base_string;
$key_parts = array(
$consumer->secret,
($token) ? $token->secret : ""
);
$key_parts = OAuthUtil::urlencode_rfc3986($key_parts);
$key = implode('&', $key_parts);
return base64_encode( hash_hmac('sha1', $base_string, $key, true));
Andjelko Horvat
committed
}
}
Andreas Åkre Solberg
committed
Andjelko Horvat
committed
/**
* The PLAINTEXT method does not provide any security protection and SHOULD only be used
* over a secure channel such as HTTPS. It does not use the Signature Base String.
* - Chapter 9.4 ("PLAINTEXT")
*/
class OAuthSignatureMethod_PLAINTEXT extends OAuthSignatureMethod {
public function get_name() {
Andreas Åkre Solberg
committed
return "PLAINTEXT";
Andjelko Horvat
committed
}
Andreas Åkre Solberg
committed
Andjelko Horvat
committed
/**
* oauth_signature is set to the concatenated encoded values of the Consumer Secret and
* Token Secret, separated by a '&' character (ASCII code 38), even if either secret is
* empty. The result MUST be encoded again.
* - Chapter 9.4.1 ("Generating Signatures")
*
* Please note that the second encoding MUST NOT happen in the SignatureMethod, as
* OAuthRequest handles this!
*/
public function build_signature($request, $consumer, $token) {
$key_parts = array(
$consumer->secret,
($token) ? $token->secret : ""
Andreas Åkre Solberg
committed
);
Andjelko Horvat
committed
$key_parts = OAuthUtil::urlencode_rfc3986($key_parts);
$key = implode('&', $key_parts);
$request->base_string = $key;
Andreas Åkre Solberg
committed
Andjelko Horvat
committed
return $key;
}
}
/**
* The RSA-SHA1 signature method uses the RSASSA-PKCS1-v1_5 signature algorithm as defined in
* [RFC3447] section 8.2 (more simply known as PKCS#1), using SHA-1 as the hash function for
* EMSA-PKCS1-v1_5. It is assumed that the Consumer has provided its RSA public key in a
* verified way to the Service Provider, in a manner which is beyond the scope of this
* specification.
* - Chapter 9.3 ("RSA-SHA1")
*/
abstract class OAuthSignatureMethod_RSA_SHA1 extends OAuthSignatureMethod {
public function get_name() {
Andreas Åkre Solberg
committed
return "RSA-SHA1";
Andjelko Horvat
committed
}
Andreas Åkre Solberg
committed
Andjelko Horvat
committed
// Up to the SP to implement this lookup of keys. Possible ideas are:
Andreas Åkre Solberg
committed
// (1) do a lookup in a table of trusted certs keyed off of consumer
// (2) fetch via http using a URL provided by the requester
Andreas Åkre Solberg
committed
// (3) some sort of specific discovery code based on request
//
Andjelko Horvat
committed
// Either way should return a string representation of the certificate
protected abstract function fetch_public_cert(&$request);
Andreas Åkre Solberg
committed
Andjelko Horvat
committed
// Up to the SP to implement this lookup of keys. Possible ideas are:
Andreas Åkre Solberg
committed
// (1) do a lookup in a table of trusted certs keyed off of consumer
//
Andjelko Horvat
committed
// Either way should return a string representation of the certificate
protected abstract function fetch_private_cert(&$request);
Andreas Åkre Solberg
committed
Andjelko Horvat
committed
public function build_signature($request, $consumer, $token) {
Andreas Åkre Solberg
committed
$base_string = $request->get_signature_base_string();
$request->base_string = $base_string;
// Fetch the private key cert based on the request
$cert = $this->fetch_private_cert($request);
// Pull the private key ID from the certificate
$privatekeyid = openssl_get_privatekey($cert);
// Sign using the key
$ok = openssl_sign($base_string, $signature, $privatekeyid);
// Release the key resource
openssl_free_key($privatekeyid);
return base64_encode($signature);
Andjelko Horvat
committed
}
Andreas Åkre Solberg
committed
Andjelko Horvat
committed
public function check_signature($request, $consumer, $token, $signature) {
Andreas Åkre Solberg
committed
$decoded_sig = base64_decode($signature);
$base_string = $request->get_signature_base_string();
// Fetch the public key cert based on the request
$cert = $this->fetch_public_cert($request);
// Pull the public key ID from the certificate
$publickeyid = openssl_get_publickey($cert);
// Check the computed signature against the one passed in the query
$ok = openssl_verify($base_string, $decoded_sig, $publickeyid);
// Release the key resource
openssl_free_key($publickeyid);
return $ok == 1;
Andjelko Horvat
committed
}
}
Andreas Åkre Solberg
committed
Andjelko Horvat
committed
class OAuthRequest {
protected $parameters;
protected $http_method;
protected $http_url;
Andreas Åkre Solberg
committed
// for debug purposes
public $base_string;
Andjelko Horvat
committed
public static $version = '1.0';
public static $POST_INPUT = 'php://input';
Andreas Åkre Solberg
committed
Andjelko Horvat
committed
function __construct($http_method, $http_url, $parameters=NULL) {
$parameters = ($parameters) ? $parameters : array();
$parameters = array_merge( OAuthUtil::parse_parameters(parse_url($http_url, PHP_URL_QUERY)), $parameters);
Andreas Åkre Solberg
committed
$this->parameters = $parameters;
$this->http_method = $http_method;
$this->http_url = $http_url;
Andjelko Horvat
committed
}
Andreas Åkre Solberg
committed
/**
* attempt to build up a request from what was passed to the server
*/
Andjelko Horvat
committed
public static function from_request($http_method=NULL, $http_url=NULL, $parameters=NULL) {
$scheme = (!isset($_SERVER['HTTPS']) || $_SERVER['HTTPS'] != "on")
? 'http'
: 'https';
$http_url = ($http_url) ? $http_url : $scheme .
'://' . $_SERVER['SERVER_NAME'] .
':' .
$_SERVER['SERVER_PORT'] .
$_SERVER['REQUEST_URI'];
$http_method = ($http_method) ? $http_method : $_SERVER['REQUEST_METHOD'];
// We weren't handed any parameters, so let's find the ones relevant to
Andjelko Horvat
committed
// If you run XML-RPC or similar you should use this to provide your own
// parsed parameter-list
if (!$parameters) {
// Find request headers
$request_headers = OAuthUtil::get_headers();
// Parse the query-string to find GET parameters
$parameters = OAuthUtil::parse_parameters($_SERVER['QUERY_STRING']);
// It's a POST request of the proper content-type, so parse POST
// parameters and add those overriding any duplicates from GET
if ($http_method == "POST"
&& isset($request_headers['Content-Type'])
&& strstr($request_headers['Content-Type'],
'application/x-www-form-urlencoded')
) {
$post_data = OAuthUtil::parse_parameters(
file_get_contents(self::$POST_INPUT)
);
$parameters = array_merge($parameters, $post_data);
}
Andreas Åkre Solberg
committed
Andjelko Horvat
committed
// We have a Authorization-header with OAuth data. Parse the header
// and add those overriding any duplicates from GET or POST
if (isset($request_headers['Authorization']) && substr($request_headers['Authorization'], 0, 6) == 'OAuth ') {
$header_parameters = OAuthUtil::split_header(
$request_headers['Authorization']
);
$parameters = array_merge($parameters, $header_parameters);
Andreas Åkre Solberg
committed
}
}
Andjelko Horvat
committed
return new OAuthRequest($http_method, $http_url, $parameters);
}
Andreas Åkre Solberg
committed
/**
* pretty much a helper function to set up the request
*/
Andjelko Horvat
committed
public static function from_consumer_and_token($consumer, $token, $http_method, $http_url, $parameters=NULL) {
$parameters = ($parameters) ? $parameters : array();
$defaults = array("oauth_version" => OAuthRequest::$version,
Andreas Åkre Solberg
committed
"oauth_nonce" => OAuthRequest::generate_nonce(),
"oauth_timestamp" => OAuthRequest::generate_timestamp(),
"oauth_consumer_key" => $consumer->key);
Andjelko Horvat
committed
if ($token)
$defaults['oauth_token'] = $token->key;
Andreas Åkre Solberg
committed
$parameters = array_merge($defaults, $parameters);
return new OAuthRequest($http_method, $http_url, $parameters);
Andjelko Horvat
committed
}
Andreas Åkre Solberg
committed
Andjelko Horvat
committed
public function set_parameter($name, $value, $allow_duplicates = true) {
if ($allow_duplicates && isset($this->parameters[$name])) {
// We have already added parameter(s) with this name, so add to the list
if (is_scalar($this->parameters[$name])) {
// This is the first duplicate, so transform scalar (string)
// into an array so we can add the duplicates
$this->parameters[$name] = array($this->parameters[$name]);
}
$this->parameters[$name][] = $value;
} else {
Andreas Åkre Solberg
committed
$this->parameters[$name] = $value;
Andjelko Horvat
committed
}
}
Andreas Åkre Solberg
committed
Andjelko Horvat
committed
public function get_parameter($name) {
Andreas Åkre Solberg
committed
return isset($this->parameters[$name]) ? $this->parameters[$name] : null;
Andjelko Horvat
committed
}
Andreas Åkre Solberg
committed
Andjelko Horvat
committed
public function get_parameters() {
Andreas Åkre Solberg
committed
return $this->parameters;
Andjelko Horvat
committed
}
Andreas Åkre Solberg
committed
Andjelko Horvat
committed
public function unset_parameter($name) {
unset($this->parameters[$name]);
}
Andreas Åkre Solberg
committed
/**
Andjelko Horvat
committed
* The request parameters, sorted and concatenated into a normalized string.
Andreas Åkre Solberg
committed
* @return string
*/
Andjelko Horvat
committed
public function get_signable_parameters() {
Andreas Åkre Solberg
committed
// Grab all parameters
$params = $this->parameters;
// Remove oauth_signature if present
Andjelko Horvat
committed
// Ref: Spec: 9.1.1 ("The oauth_signature parameter MUST be excluded.")
Andreas Åkre Solberg
committed
if (isset($params['oauth_signature'])) {
unset($params['oauth_signature']);
}
Andjelko Horvat
committed
return OAuthUtil::build_http_query($params);
Andreas Åkre Solberg
committed
}
/**
* Returns the base string of this request
*
* The base string defined as the method, the url
* and the parameters (normalized), each urlencoded
* and the concated with &.
*/
Andjelko Horvat
committed
public function get_signature_base_string() {
Andreas Åkre Solberg
committed
$parts = array(
$this->get_normalized_http_method(),
$this->get_normalized_http_url(),
$this->get_signable_parameters()
);
$parts = OAuthUtil::urlencode_rfc3986($parts);
return implode('&', $parts);
Andjelko Horvat
committed
}
Andreas Åkre Solberg
committed
/**
* just uppercases the http method
*/
Andjelko Horvat
committed
public function get_normalized_http_method() {
Andreas Åkre Solberg
committed
return strtoupper($this->http_method);
Andjelko Horvat
committed
}
Andreas Åkre Solberg
committed
/**
Andreas Åkre Solberg
committed
* scheme://host/path
*/
Andjelko Horvat
committed
public function get_normalized_http_url() {
Andreas Åkre Solberg
committed
$parts = parse_url($this->http_url);
Andjelko Horvat
committed
$scheme = (isset($parts['scheme'])) ? $parts['scheme'] : 'http';
$port = (isset($parts['port'])) ? $parts['port'] : (($scheme == 'https') ? '443' : '80');
$host = (isset($parts['host'])) ? strtolower($parts['host']) : '';
$path = (isset($parts['path'])) ? $parts['path'] : '';
Andreas Åkre Solberg
committed
if (($scheme == 'https' && $port != '443')
|| ($scheme == 'http' && $port != '80')) {
$host = "$host:$port";
}
return "$scheme://$host$path";
Andjelko Horvat
committed
}
Andreas Åkre Solberg
committed
/**
Andreas Åkre Solberg
committed
*/
Andjelko Horvat
committed
public function to_url() {
$post_data = $this->to_postdata();
$out = $this->get_normalized_http_url();
if ($post_data) {
$out .= '?'.$post_data;
}
Andreas Åkre Solberg
committed
return $out;
Andjelko Horvat
committed
}
Andreas Åkre Solberg
committed
/**
* builds the data one would send in a POST request
*/
Andjelko Horvat
committed
public function to_postdata() {
return OAuthUtil::build_http_query($this->parameters);
Andreas Åkre Solberg
committed
}
/**
* builds the Authorization: header
*/
Andjelko Horvat
committed
public function to_header($realm=null) {
$first = true;
if($realm) {
$out = 'Authorization: OAuth realm="' . OAuthUtil::urlencode_rfc3986($realm) . '"';
$first = false;
} else
$out = 'Authorization: OAuth';
Andreas Åkre Solberg
committed
$total = array();
foreach ($this->parameters as $k => $v) {
if (substr($k, 0, 5) != "oauth") continue;
Andjelko Horvat
committed
if (is_array($v)) {
throw new OAuthException('Arrays not supported in headers');
}
$out .= ($first) ? ' ' : ',';
$out .= OAuthUtil::urlencode_rfc3986($k) .
'="' .
OAuthUtil::urlencode_rfc3986($v) .
'"';
$first = false;
Andreas Åkre Solberg
committed
}
return $out;
Andjelko Horvat
committed
}
Andreas Åkre Solberg
committed
Andjelko Horvat
committed
public function __toString() {
Andreas Åkre Solberg
committed
return $this->to_url();
Andjelko Horvat
committed
}
Andreas Åkre Solberg
committed
Andjelko Horvat
committed
public function sign_request($signature_method, $consumer, $token) {
$this->set_parameter(
"oauth_signature_method",
$signature_method->get_name(),
false
);
Andreas Åkre Solberg
committed
$signature = $this->build_signature($signature_method, $consumer, $token);
Andjelko Horvat
committed
$this->set_parameter("oauth_signature", $signature, false);
}
Andreas Åkre Solberg
committed
Andjelko Horvat
committed
public function build_signature($signature_method, $consumer, $token) {
Andreas Åkre Solberg
committed
$signature = $signature_method->build_signature($this, $consumer, $token);
return $signature;
Andjelko Horvat
committed
}
Andreas Åkre Solberg
committed
/**
* util function: current timestamp
*/
Andjelko Horvat
committed
private static function generate_timestamp() {
Andreas Åkre Solberg
committed
return time();
Andjelko Horvat
committed
}
Andreas Åkre Solberg
committed
/**
* util function: current nonce
*/
Andjelko Horvat
committed
private static function generate_nonce() {
Andreas Åkre Solberg
committed
$mt = microtime();
$rand = mt_rand();
return md5($mt . $rand); // md5s look nicer than numbers
}
}
Andjelko Horvat
committed
class OAuthServer {
Andreas Åkre Solberg
committed
protected $timestamp_threshold = 300; // in seconds, five minutes
Andjelko Horvat
committed
protected $version = '1.0'; // hi blaine
Andreas Åkre Solberg
committed
protected $signature_methods = array();
protected $data_store;
Andjelko Horvat
committed
function __construct($data_store) {
Andreas Åkre Solberg
committed
$this->data_store = $data_store;
Andjelko Horvat
committed
}
Andreas Åkre Solberg
committed
Andjelko Horvat
committed
public function add_signature_method($signature_method) {
Andreas Åkre Solberg
committed
$this->signature_methods[$signature_method->get_name()] =
$signature_method;
Andjelko Horvat
committed
}
Andreas Åkre Solberg
committed
// high level functions
/**
* process a request_token request
* returns the request token on success
*/
Andjelko Horvat
committed
public function fetch_request_token(&$request) {
$this->get_version($request);
Andreas Åkre Solberg
committed
$consumer = $this->get_consumer($request);
// no token required for the initial token request
$token = NULL;
$this->check_signature($request, $consumer, $token);
Andreas Åkre Solberg
committed
// Rev A change
Andjelko Horvat
committed
$callback = $request->get_parameter('oauth_callback');
$new_token = $this->data_store->new_request_token($consumer, $callback);
Andreas Åkre Solberg
committed
return $new_token;
Andjelko Horvat
committed
}
Andreas Åkre Solberg
committed
/**
* process an access_token request
* returns the access token on success
*/
Andjelko Horvat
committed
public function fetch_access_token(&$request) {
$this->get_version($request);
Andreas Åkre Solberg
committed
$consumer = $this->get_consumer($request);
// requires authorized request token
$token = $this->get_token($request, $consumer, "request");
$this->check_signature($request, $consumer, $token);
Andreas Åkre Solberg
committed
// Rev A change
Andjelko Horvat
committed
$verifier = $request->get_parameter('oauth_verifier');
Andreas Åkre Solberg
committed
$new_token = $this->data_store->new_access_token($token, $consumer, $verifier);
Andreas Åkre Solberg
committed
return $new_token;
Andjelko Horvat
committed
}
Andreas Åkre Solberg
committed
/**
* verify an api call, checks all the parameters
*/
Andjelko Horvat
committed
public function verify_request(&$request) {
Andreas Åkre Solberg
committed
$this->get_version($request);
$consumer = $this->get_consumer($request);
$token = $this->get_token($request, $consumer, "access");
$this->check_signature($request, $consumer, $token);
return array($consumer, $token);
Andjelko Horvat
committed
}
Andreas Åkre Solberg
committed
// Internals from here
/**
* version 1
*/
Andjelko Horvat
committed
private function get_version(&$request) {
Andreas Åkre Solberg
committed
$version = $request->get_parameter("oauth_version");
if (!$version) {
Andjelko Horvat
committed
// Service Providers MUST assume the protocol version to be 1.0 if this parameter is not present.
// Chapter 7.0 ("Accessing Protected Ressources")
$version = '1.0';
Andreas Åkre Solberg
committed
}
Andjelko Horvat
committed
if ($version !== $this->version) {
Andreas Åkre Solberg
committed
throw new OAuthException("OAuth version '$version' not supported");
}
return $version;
Andjelko Horvat
committed
}
Andreas Åkre Solberg
committed
/**
* figure out the signature with some defaults
*/
Andjelko Horvat
committed
private function get_signature_method($request) {
$signature_method = $request instanceof OAuthRequest
? $request->get_parameter("oauth_signature_method")
: NULL;
Andreas Åkre Solberg
committed
if (!$signature_method) {
Andjelko Horvat
committed
// According to chapter 7 ("Accessing Protected Ressources") the signature-method
// parameter is required, and we can't just fallback to PLAINTEXT
throw new OAuthException('No signature method parameter. This parameter is required');
Andreas Åkre Solberg
committed
}
Andjelko Horvat
committed
Andreas Åkre Solberg
committed
if (!in_array($signature_method,
array_keys($this->signature_methods))) {
throw new OAuthException(
Andjelko Horvat
committed
"Signature method '$signature_method' not supported " .
"try one of the following: " .
implode(", ", array_keys($this->signature_methods))
Andreas Åkre Solberg
committed
);
}
return $this->signature_methods[$signature_method];
Andjelko Horvat
committed
}
Andreas Åkre Solberg
committed
/**
* try to find the consumer for the provided request's consumer key
*/
Andjelko Horvat
committed
private function get_consumer($request) {
$consumer_key = $request instanceof OAuthRequest
? $request->get_parameter("oauth_consumer_key")
: NULL;
Andreas Åkre Solberg
committed
if (!$consumer_key) {
throw new OAuthException("Invalid consumer key");
}
$consumer = $this->data_store->lookup_consumer($consumer_key);
if (!$consumer) {
throw new OAuthException("Invalid consumer");
}
return $consumer;
Andjelko Horvat
committed
}
Andreas Åkre Solberg
committed
/**
* try to find the token for the provided request's token key
*/
Andjelko Horvat
committed
private function get_token($request, $consumer, $token_type="access") {
$token_field = $request instanceof OAuthRequest
? $request->get_parameter('oauth_token')
: NULL;
Andreas Åkre Solberg
committed
Andreas Åkre Solberg
committed
$token = $this->data_store->lookup_token(
Andjelko Horvat
committed
$consumer, $token_type, $token_field
Andreas Åkre Solberg
committed
);
if (!$token) {
Andjelko Horvat
committed
throw new OAuthException("Invalid $token_type token: $token_field");
Andreas Åkre Solberg
committed
}
return $token;
Andjelko Horvat
committed
}
Andreas Åkre Solberg
committed
/**
* all-in-one function to check the signature on a request
* should guess the signature method appropriately
*/
Andjelko Horvat
committed
private function check_signature($request, $consumer, $token) {
Andreas Åkre Solberg
committed
// this should probably be in a different method
Andjelko Horvat
committed
$timestamp = $request instanceof OAuthRequest
? $request->get_parameter('oauth_timestamp')
: NULL;
$nonce = $request instanceof OAuthRequest
? $request->get_parameter('oauth_nonce')
: NULL;
Andreas Åkre Solberg
committed
$this->check_timestamp($timestamp);
$this->check_nonce($consumer, $token, $nonce, $timestamp);
$signature_method = $this->get_signature_method($request);
Andreas Åkre Solberg
committed
$signature = $request->get_parameter('oauth_signature');
Andreas Åkre Solberg
committed
$valid_sig = $signature_method->check_signature(
$request,
$consumer,
$token,
$signature
);
if (!$valid_sig) {
throw new OAuthException("Invalid signature");
}
Andjelko Horvat
committed
}
Andreas Åkre Solberg
committed
/**
* check that the timestamp is new enough
*/
Andjelko Horvat
committed
private function check_timestamp($timestamp) {
if( ! $timestamp )
throw new OAuthException(
'Missing timestamp parameter. The parameter is required'
);
Andreas Åkre Solberg
committed
// verify that timestamp is recentish
$now = time();
Andjelko Horvat
committed
if (abs($now - $timestamp) > $this->timestamp_threshold) {
throw new OAuthException(
"Expired timestamp, yours $timestamp, ours $now"
);
}
Andreas Åkre Solberg
committed
}
/**
* check that the nonce is not repeated
*/
Andjelko Horvat
committed
private function check_nonce($consumer, $token, $nonce, $timestamp) {
if( ! $nonce )
throw new OAuthException(
'Missing nonce parameter. The parameter is required'
);
Andreas Åkre Solberg
committed
// verify that the nonce is uniqueish
Andjelko Horvat
committed
$found = $this->data_store->lookup_nonce(
$consumer,
$token,
$nonce,
$timestamp
);
Andreas Åkre Solberg
committed
if ($found) {
throw new OAuthException("Nonce already used: $nonce");
}
Andjelko Horvat
committed
}
Andreas Åkre Solberg
committed
Andjelko Horvat
committed
}
Andreas Åkre Solberg
committed
Andjelko Horvat
committed
class OAuthDataStore {
function lookup_consumer($consumer_key) {
Andreas Åkre Solberg
committed
// implement me
Andjelko Horvat
committed
}
Andreas Åkre Solberg
committed
Andjelko Horvat
committed
function lookup_token($consumer, $token_type, $token) {
Andreas Åkre Solberg
committed
// implement me
Andjelko Horvat
committed
}
Andreas Åkre Solberg
committed
Andjelko Horvat
committed
function lookup_nonce($consumer, $token, $nonce, $timestamp) {
Andreas Åkre Solberg
committed
// implement me
Andjelko Horvat
committed
}
Andreas Åkre Solberg
committed
Andjelko Horvat
committed
function new_request_token($consumer, $callback = null) {
Andreas Åkre Solberg
committed
// return a new token attached to this consumer
Andjelko Horvat
committed
}
Andreas Åkre Solberg
committed
Andjelko Horvat
committed
function new_access_token($token, $consumer, $verifier = null) {
Andreas Åkre Solberg
committed
// return a new access token attached to this consumer
// for the user associated with this token if the request token
// is authorized
// should also invalidate the request token
Andjelko Horvat
committed
}
Andreas Åkre Solberg
committed
Andjelko Horvat
committed
}
Andreas Åkre Solberg
committed
Andjelko Horvat
committed
class OAuthUtil {
public static function urlencode_rfc3986($input) {
Andreas Åkre Solberg
committed
if (is_array($input)) {
return array_map(array('OAuthUtil','urlencode_rfc3986'), $input);
} else if (is_scalar($input)) {
Andjelko Horvat
committed
return str_replace(
'+',
' ',
str_replace('%7E', '~', rawurlencode($input))
);
Andreas Åkre Solberg
committed
} else {
return '';
}
Andjelko Horvat
committed
}
Andreas Åkre Solberg
committed
// This decode function isn't taking into consideration the above
// modifications to the encoding process. However, this method doesn't
// seem to be used anywhere so leaving it as is.
Andjelko Horvat
committed
763
764
765
766
767
768
769
770
771
772
773
774
775
776
777
778
779
780
781
782
783
784
785
786
787
788
789
790
791
792
793
794
795
796
797
798
799
800
801
802
803
804
805
806
807
808
809
810
811
812
813
814
815
816
817
818
819
820
821
822
823
824
825
826
827
828
829
830
831
832
833
834
835
836
837
838
839
840
841
842
843
844
845
846
847
848
849
850
851
852
853
854
855
856
857
858
859
860
861
862
863
864
865
866
867
868
869
870
871
872
873
874
875
876
877
878
879
880
881
882
883
884
885
886
887
888
889
890
891
892
893
public static function urldecode_rfc3986($string) {
return urldecode($string);
}
// Utility function for turning the Authorization: header into
// parameters, has to do some unescaping
// Can filter out any non-oauth parameters if needed (default behaviour)
// May 28th, 2010 - method updated to tjerk.meesters for a speed improvement.
// see http://code.google.com/p/oauth/issues/detail?id=163
public static function split_header($header, $only_allow_oauth_parameters = true) {
$params = array();
if (preg_match_all('/('.($only_allow_oauth_parameters ? 'oauth_' : '').'[a-z_-]*)=(:?"([^"]*)"|([^,]*))/', $header, $matches)) {
foreach ($matches[1] as $i => $h) {
$params[$h] = OAuthUtil::urldecode_rfc3986(empty($matches[3][$i]) ? $matches[4][$i] : $matches[3][$i]);
}
if (isset($params['realm'])) {
unset($params['realm']);
}
}
return $params;
}
// helper to try to sort out headers for people who aren't running apache
public static function get_headers() {
if (function_exists('apache_request_headers')) {
// we need this to get the actual Authorization: header
// because apache tends to tell us it doesn't exist
$headers = apache_request_headers();
// sanitize the output of apache_request_headers because
// we always want the keys to be Cased-Like-This and arh()
// returns the headers in the same case as they are in the
// request
$out = array();
foreach ($headers AS $key => $value) {
$key = str_replace(
" ",
"-",
ucwords(strtolower(str_replace("-", " ", $key)))
);
$out[$key] = $value;
}
} else {
// otherwise we don't have apache and are just going to have to hope
// that $_SERVER actually contains what we need
$out = array();
if( isset($_SERVER['CONTENT_TYPE']) )
$out['Content-Type'] = $_SERVER['CONTENT_TYPE'];
if( isset($_ENV['CONTENT_TYPE']) )
$out['Content-Type'] = $_ENV['CONTENT_TYPE'];
foreach ($_SERVER as $key => $value) {
if (substr($key, 0, 5) == "HTTP_") {
// this is chaos, basically it is just there to capitalize the first
// letter of every word that is not an initial HTTP and strip HTTP
// code from przemek
$key = str_replace(
" ",
"-",
ucwords(strtolower(str_replace("_", " ", substr($key, 5))))
);
$out[$key] = $value;
}
}
}
return $out;
}
// This function takes a input like a=b&a=c&d=e and returns the parsed
// parameters like this
// array('a' => array('b','c'), 'd' => 'e')
public static function parse_parameters( $input ) {
if (!isset($input) || !$input) return array();
$pairs = explode('&', $input);
$parsed_parameters = array();
foreach ($pairs as $pair) {
$split = explode('=', $pair, 2);
$parameter = OAuthUtil::urldecode_rfc3986($split[0]);
$value = isset($split[1]) ? OAuthUtil::urldecode_rfc3986($split[1]) : '';
if (isset($parsed_parameters[$parameter])) {
// We have already recieved parameter(s) with this name, so add to the list
// of parameters with this name
if (is_scalar($parsed_parameters[$parameter])) {
// This is the first duplicate, so transform scalar (string) into an array
// so we can add the duplicates
$parsed_parameters[$parameter] = array($parsed_parameters[$parameter]);
}
$parsed_parameters[$parameter][] = $value;
} else {
$parsed_parameters[$parameter] = $value;
}
}
return $parsed_parameters;
}
public static function build_http_query($params) {
if (!$params) return '';
// Urlencode both keys and values
$keys = OAuthUtil::urlencode_rfc3986(array_keys($params));
$values = OAuthUtil::urlencode_rfc3986(array_values($params));
$params = array_combine($keys, $values);
// Parameters are sorted by name, using lexicographical byte value ordering.
// Ref: Spec: 9.1.1 (1)
uksort($params, 'strcmp');
$pairs = array();
foreach ($params as $parameter => $value) {
if (is_array($value)) {
// If two or more parameters share the same name, they are sorted by their value
// Ref: Spec: 9.1.1 (1)
// June 12th, 2010 - changed to sort because of issue 164 by hidetaka
sort($value, SORT_STRING);
foreach ($value as $duplicate_value) {
$pairs[] = $parameter . '=' . $duplicate_value;
}
} else {
$pairs[] = $parameter . '=' . $value;
}
}
// For each parameter, the name is separated from the corresponding value by an '=' character (ASCII code 61)
// Each name-value pair is separated by an '&' character (ASCII code 38)
return implode('&', $pairs);
}
}