84 lines
2.4 KiB
PHP
84 lines
2.4 KiB
PHP
<?php
|
|
|
|
namespace Pickles\OAuth2;
|
|
|
|
use \League\OAuth2\Server\Entity\AbstractTokenEntity;
|
|
use \League\OAuth2\Server\Entity\AccessTokenEntity;
|
|
use \League\OAuth2\Server\Entity\ScopeEntity;
|
|
use \League\OAuth2\Server\Storage\AccessTokenInterface;
|
|
|
|
class AccessTokenStorage extends StorageAdapter implements AccessTokenInterface
|
|
{
|
|
public function get($token)
|
|
{
|
|
$sql = 'SELECT oauth_access_tokens.*'
|
|
. ' FROM oauth_access_tokens'
|
|
. ' WHERE access_token = ?'
|
|
. ' AND expires_at >= ?;';
|
|
|
|
$results = $this->db->fetch($sql, [$token, time()]);
|
|
|
|
if (count($results) === 1)
|
|
{
|
|
return (new AccessTokenEntity($this->server))
|
|
->setId($results[0]['access_token'])
|
|
->setExpireTime($results[0]['expires_at']);
|
|
}
|
|
|
|
return null;
|
|
}
|
|
|
|
public function getScopes(AbstractTokenEntity $token)
|
|
{
|
|
$sql = 'SELECT oauth_scopes.id, oauth_scopes.description'
|
|
. ' FROM oauth_access_token_scopes'
|
|
. ' INNER JOIN oauth_scopes'
|
|
. ' ON oauth_access_token_scopes.scope_id = oauth_scopes.id'
|
|
. ' WHERE oauth_access_token_scopes.access_token_id = ?;';
|
|
|
|
$results = $this->db->fetch($sql, [$token->getId()]);
|
|
$response = [];
|
|
|
|
if (count($results) > 0)
|
|
{
|
|
foreach ($results as $row)
|
|
{
|
|
$response[] = (new ScopeEntity($this->server))->hydrate([
|
|
'id' => $row['id'],
|
|
'description' => $row['description']
|
|
]);
|
|
}
|
|
}
|
|
|
|
return $response;
|
|
}
|
|
|
|
public function create($token, $expiration, $session_id)
|
|
{
|
|
$sql = 'INSERT INTO oauth_access_tokens'
|
|
. ' (access_token, session_id, expires_at)'
|
|
. ' VALUES'
|
|
. ' (?, ?, ?);';
|
|
|
|
$this->db->execute($sql, [$token, $session_id, $expiration]);
|
|
}
|
|
|
|
public function associateScope(AbstractTokenEntity $token, ScopeEntity $scope)
|
|
{
|
|
$sql = 'INSERT INTO oauth_access_token_scopes'
|
|
. ' (access_token, scope)'
|
|
. ' VALUES'
|
|
. ' (?, ?);';
|
|
|
|
$this->db->execute($sql, [$token->getId(), $scope->getId()]);
|
|
}
|
|
|
|
public function delete(AbstractTokenEntity $token)
|
|
{
|
|
$sql = 'DELETE FROM oauth_access_token_scopes'
|
|
. ' WHERE access_token = ?;';
|
|
|
|
$this->db->execute($sql, [$token->getId()]);
|
|
}
|
|
}
|
|
|