<?php
if ($this->__pmg_request->o == 'createconsumer') {
			$provider = new Oauth_Provider();
			Oauth_Provider::createConsumer('sobiz10','http://www.sobiz10.com');
		}
		else if ($this->__pmg_request->o == 'requesttoken') {
			$provider = new Oauth_Provider($this->__pmg_request->d->oauth_consumer_key);
			$provider->setRequestTokenQuery();
			$provider->checkRequest();
			$provider->generateRequestToken();
		}
?>

<?php
class Oauth_Provider {
	private $oauth = null;
	private $consumer = null;
	private $oauth_error = null;
	private $user = null;
	private $consumer_key = null;
	private $consumer_secret = null;
	private $authentification_url = "http://www.abc.loc/signin";

	public function __construct($consumer_key=null, $consumer_secret=null)
	{
		$this->oauth = new OAuthProvider();
		$this->oauth->consumerHandler(array($this,'checkConsumer'));
		$this->oauth->timestampNonceHandler(array($this,'checkNonce'));
		$this->oauth->tokenHandler(array($this,'checkToken'));
	}

	public static function createConsumer($app_name,$callback) {
		$fp = fopen('/dev/urandom','rb');
        $entropy = fread($fp, 32);
        fclose($fp);
        $entropy .= uniqid(mt_rand(), true);
        $hash = sha1($entropy);
        return Oauth_Consumer::create(substr($hash,0,30), substr($hash,30,10),$app_name,$callback);
	}

	public function checkConsumer($provider){
		$return = OAUTH_CONSUMER_KEY_UNKNOWN;

		$consumer = Oauth_Consumer::findByKey($provider->consumer_key);

		if(is_object($consumer)){
			if(!$consumer->getActive()){
				$return = OAUTH_CONSUMER_KEY_REFUSED;
			} else {
				$this->consumer = $consumer;
				$provider->consumer_secret = $this->consumer->getSecret();
				$return = OAUTH_OK;
			}
		}
		return $return;
	}

	public function checkNonce($provider){
		if($this->oauth->timestamp < time() - 5*60){
			return OAUTH_BAD_TIMESTAMP;
		} elseif($this->consumer->hasNonce($provider->nonce,$this->oauth->timestamp)) {
			return OAUTH_BAD_NONCE;
		} else {
			$this->consumer->addNonce($this->oauth->nonce,$this->oauth->timestamp);
			return OAUTH_OK;
		}
	}

	public function checkToken($provider){
		$token = Oauth_Token::findByToken($provider->token);

		if(is_null($token)){
			return OAUTH_TOKEN_REJECTED;
		} elseif($token->getType() == 1 && $token->getVerifier() != $provider->verifier){
			return OAUTH_VERIFIER_INVALID;
		} else {
			if($token->getType() == 2){
				$this->user = $token->getUser();
			}
			$provider->token_secret = $token->getSecret();
			return OAUTH_OK;
		}
	}

	public function setRequestTokenQuery(){
		$this->oauth->isRequestTokenEndpoint(true);
		//$this->oauth->addRequiredParameter("oauth_callback");
	}

	public function checkRequest(){
		try{
			$this->oauth->checkOAuthRequest();
		} catch(OAuthException $E){
			echo OAuthProvider::reportProblem($E);
			$this->oauth_error = true;
		}
	}

	public function generateRequestToken(){

		if($this->oauth_error){
			return false;
		}

		$token = sha1(OAuthProvider::generateToken(20,true));
		$token_secret = sha1(OAuthProvider::generateToken(20,true));

		$callback = 'http://www.abc.loc';

		//Token::createRequestToken($this->consumer, $token, $token_secret, $callback);
		return "authentification_url=".$this->authentification_url."&oauth_token=".$token."&oauth_token_secret=".$token_secret."&oauth_callback_confirmed=true";
	}
}
?>


<?php
class Oauth_Consumer {
	private $id = null;
	private $key = null;
 	private $secret = null;
 	private $appname = null;
 	private $callbackUrl = null;
	private $active = true;

	public function __construct($id = 0)
	{
		if($id != 0){
			$this->id = $id;
			$this->load();
		}
	}

	public function getAppname()
	{
		return $this->appname;
	}

	public function getCallbackUrl()
	{
		return $this->callbackUrl;
	}

	public function setAppname($appname)
	{
		$this->appname = $appname;
	}

	public function setCallbackUrl($callbackUrl)
	{
		$this->callbackUrl = $callbackUrl;
	}

	public function getId()
	{
		return $this->id;
	}

	public function getKey()
	{
		return $this->key;
	}

	public function getSecret()
	{
		return $this->secret;
	}

	public function getActive()
	{
		return $this->active;
	}

	public function setId($id)
	{
		$this->id = $id;
	}

	public function setKey($key)
	{
		$this->key = $key;
	}

	public function setSecret($secret)
	{
		$this->secret = $secret;
	}

	public function setActive($active)
	{
		$this->active = $active;
	}

	public static function findByKey($key)
	{
		//"select id from consumers where consumer_key = @key"
		$consumer = null;

		$consumer = new Oauth_Consumer(1/*$row->id*/);
		return $consumer;
	}

	private function load()
	{
	//SELECT consumer_key,consumer_secret,app_name,callback_url FROM consumers WHERE id = $this->id



			$this->key = $row['consumer_key'];
			$this->secret = $row['consumer_secret'];
			$this->appname = $row['app_name'];
			$this->callbackUrl = $row['callback_url'];

	}

	public static function create($key,$secret,$appname,$callback){
//INSERT INTO consumers (consumer_ke}y,consumer_secret,app_name,callback_url,active) VALUES ($key,$secret,$appname,$callback,1)

		$consumer = new Oauth_Consumer(/*mysql_insert_id()*/'1');
		return $consumer;
	}

	public function hasNonce($nonce,$timestamp)
	{
//select count(*) as count from consumer_nonce where timestamp = $timestamp and nonce = $nonce and consumer_id = $this->id


			if($row['count'] > 0){
				return true;
			} else {
				return false;
			}

	}

	public function addNonce($nonce,$timestamp)
	{
	//insert into sb_consumer_nonce (consumer_id,timestamp,nonce) values ($id,$time,$nonce)

	}
}
?>