mirror of
https://github.com/elyby/accounts.git
synced 2024-12-27 07:30:18 +05:30
89 lines
2.4 KiB
PHP
89 lines
2.4 KiB
PHP
<?php
|
|
namespace api\components\OAuth2\Storage;
|
|
|
|
use api\components\OAuth2\Entities\AccessTokenEntity;
|
|
use common\models\OauthAccessToken;
|
|
use League\OAuth2\Server\Entity\AccessTokenEntity as OriginalAccessTokenEntity;
|
|
use League\OAuth2\Server\Entity\ScopeEntity;
|
|
use League\OAuth2\Server\Storage\AbstractStorage;
|
|
use League\OAuth2\Server\Storage\AccessTokenInterface;
|
|
use yii\db\Exception;
|
|
|
|
class AccessTokenStorage extends AbstractStorage implements AccessTokenInterface {
|
|
|
|
private $cache = [];
|
|
|
|
/**
|
|
* @param string $token
|
|
* @return OauthAccessToken|null
|
|
*/
|
|
private function getTokenModel($token) {
|
|
if (!isset($this->cache[$token])) {
|
|
$this->cache[$token] = OauthAccessToken::findOne($token);
|
|
}
|
|
|
|
return $this->cache[$token];
|
|
}
|
|
|
|
/**
|
|
* @inheritdoc
|
|
*/
|
|
public function get($token) {
|
|
$model = $this->getTokenModel($token);
|
|
if ($model === null) {
|
|
return null;
|
|
}
|
|
|
|
/** @var SessionStorage $sessionStorage */
|
|
$sessionStorage = $this->server->getSessionStorage();
|
|
|
|
$token = new AccessTokenEntity($this->server);
|
|
$token->setId($model->access_token);
|
|
$token->setExpireTime($model->expire_time);
|
|
$token->setSession($sessionStorage->getById($model->session_id));
|
|
|
|
return $token;
|
|
}
|
|
|
|
/**
|
|
* @inheritdoc
|
|
*/
|
|
public function getScopes(OriginalAccessTokenEntity $token) {
|
|
$entities = [];
|
|
foreach($this->getTokenModel($token->getId())->getScopes() as $scope) {
|
|
$entities[] = (new ScopeEntity($this->server))->hydrate(['id' => $scope]);
|
|
}
|
|
|
|
return $entities;
|
|
}
|
|
|
|
/**
|
|
* @inheritdoc
|
|
*/
|
|
public function create($token, $expireTime, $sessionId) {
|
|
$model = new OauthAccessToken();
|
|
$model->access_token = $token;
|
|
$model->expire_time = $expireTime;
|
|
$model->session_id = $sessionId;
|
|
|
|
if (!$model->save()) {
|
|
throw new Exception('Cannot save ' . OauthAccessToken::class . ' model.');
|
|
}
|
|
}
|
|
|
|
/**
|
|
* @inheritdoc
|
|
*/
|
|
public function associateScope(OriginalAccessTokenEntity $token, ScopeEntity $scope) {
|
|
$this->getTokenModel($token->getId())->getScopes()->add($scope->getId());
|
|
}
|
|
|
|
/**
|
|
* @inheritdoc
|
|
*/
|
|
public function delete(OriginalAccessTokenEntity $token) {
|
|
$this->getTokenModel($token->getId())->delete();
|
|
}
|
|
|
|
}
|