src/Network/FKOAuthDataStore.php

   1 <?php
   2
   3 /**
   4  * @file src/Protocol/FKOAuthDataStore.php
   5  * OAuth server
   6  * Based on oauth2-php <http://code.google.com/p/oauth2-php/>
   7  *
   8  */
   9
  10 namespace Friendica\Network;
  11
  12 use Friendica\App;
  13 use Friendica\Core\Config;
  14 use Friendica\Core\System;
  15 use Friendica\Database\DBM;
  16 use dba;
  17 use OAuthDataStore;
  18
  19 define('REQUEST_TOKEN_DURATION', 300);
  20 define('ACCESS_TOKEN_DURATION', 31536000);
  21
  22 require_once 'include/dba.php';
  23
  24 require_once "library/OAuth1.php";
  25 require_once "library/oauth2-php/lib/OAuth2.inc";
  26
  27 /**
  28  * @brief OAuthDataStore class
  29  */
  30 class FKOAuthDataStore extends OAuthDataStore
  31 {
  32         /**
  33          * @return string
  34          */
  35         private static function genToken()
  36         {
  37                 return md5(base64_encode(pack('N6', mt_rand(), mt_rand(), mt_rand(), mt_rand(), mt_rand(), uniqid())));
  38         }
  39
  40         /**
  41          * @param string $consumer_key key
  42          * @return mixed
  43          */
  44         public function lookup_consumer($consumer_key)
  45         {
  46                 logger(__function__ . ":" . $consumer_key);
  47
  48                 $s = dba::select('clients', array('client_id', 'pw', 'redirect_uri'), array('client_id' => $consumer_key));
  49                 $r = dba::inArray($s);
  50
  51                 if (DBM::is_result($r)) {
  52                         return new \OAuthConsumer($r[0]['client_id'], $r[0]['pw'], $r[0]['redirect_uri']);
  53                 }
  54
  55                 return null;
  56         }
  57
  58         /**
  59          * @param string $consumer   consumer
  60          * @param string $token_type type
  61          * @param string $token      token
  62          * @return mixed
  63          */
  64         public function lookup_token($consumer, $token_type, $token)
  65         {
  66                 logger(__function__ . ":" . $consumer . ", " . $token_type . ", " . $token);
  67
  68                 $s = dba::select('tokens', array('id', 'secret', 'scope', 'expires', 'uid'), array('client_id' => $consumer->key, 'scope' => $token_type, 'id' => $token));
  69                 $r = dba::inArray($s);
  70
  71                 if (DBM::is_result($r)) {
  72                         $ot = new \OAuthToken($r[0]['id'], $r[0]['secret']);
  73                         $ot->scope = $r[0]['scope'];
  74                         $ot->expires = $r[0]['expires'];
  75                         $ot->uid = $r[0]['uid'];
  76                         return $ot;
  77                 }
  78
  79                 return null;
  80         }
  81
  82         /**
  83          * @param string $consumer  consumer
  84          * @param string $token     token
  85          * @param string $nonce     nonce
  86          * @param string $timestamp timestamp
  87          * @return mixed
  88          */
  89         public function lookup_nonce($consumer, $token, $nonce, $timestamp)
  90         {
  91                 $r = dba::selectOne('tokens', ['id', 'secret'], ['client_id' => $consumer->key, 'id' => $nonce, 'expires' => $timestamp]);
  92
  93                 if (DBM::is_result($r)) {
  94                         return new \OAuthToken($r['id'], $r['secret']);
  95                 }
  96
  97                 return null;
  98         }
  99
 100         /**
 101          * @param string $consumer consumer
 102          * @param string $callback optional, default null
 103          * @return mixed
 104          */
 105         public function new_request_token($consumer, $callback = null)
 106         {
 107                 logger(__function__ . ":" . $consumer . ", " . $callback);
 108                 $key = self::genToken();
 109                 $sec = self::genToken();
 110
 111                 if ($consumer->key) {
 112                         $k = $consumer->key;
 113                 } else {
 114                         $k = $consumer;
 115                 }
 116
 117                 $r = dba::insert(
 118                         'tokens',
 119                         array(
 120                                 'id' => $key,
 121                                 'secret' => $sec,
 122                                 'client_id' => $k,
 123                                 'scope' => 'request',
 124                                 'expires' => time() + REQUEST_TOKEN_DURATION)
 125                 );
 126
 127                 if (!$r) {
 128                         return null;
 129                 }
 130
 131                 return new \OAuthToken($key, $sec);
 132         }
 133
 134         /**
 135          * @param string $token    token
 136          * @param string $consumer consumer
 137          * @param string $verifier optional, defult null
 138          * @return object
 139          */
 140         public function new_access_token($token, $consumer, $verifier = null)
 141         {
 142                 logger(__function__ . ":" . $token . ", " . $consumer . ", " . $verifier);
 143
 144                 // return a new access token attached to this consumer
 145                 // for the user associated with this token if the request token
 146                 // is authorized
 147                 // should also invalidate the request token
 148
 149                 $ret = null;
 150
 151                 // get user for this verifier
 152                 $uverifier = Config::get("oauth", $verifier);
 153                 logger(__function__ . ":" . $verifier . "," . $uverifier);
 154
 155                 if (is_null($verifier) || ($uverifier !== false)) {
 156                         $key = self::genToken();
 157                         $sec = self::genToken();
 158                         $r = dba::insert(
 159                                 'tokens',
 160                                 array(
 161                                         'id' => $key,
 162                                         'secret' => $sec,
 163                                         'client_id' => $consumer->key,
 164                                         'scope' => 'access',
 165                                         'expires' => time() + ACCESS_TOKEN_DURATION,
 166                                         'uid' => $uverifier)
 167                         );
 168
 169                         if ($r) {
 170                                 $ret = new \OAuthToken($key, $sec);
 171                         }
 172                 }
 173
 174                 dba::delete('tokens', array('id' => $token->key));
 175
 176                 if (!is_null($ret) && !is_null($uverifier)) {
 177                         Config::delete("oauth", $verifier);
 178                 }
 179
 180                 return $ret;
 181         }
 182 }