CachedTokenProvider.php

<?php
 
declare(strict_types=1);
namespace Commercetools\Client;
 
use Commercetools\Exception\InvalidArgumentException;
use Psr\Cache\CacheItemInterface;
use Psr\Cache\CacheItemPoolInterface;
use Psr\SimpleCache\CacheInterface;
 
class CachedTokenProvider implements TokenProvider
{
    public const TOKEN_CACHE_KEY = 'access_token';
    
    private $provider;
 
    private $cache;
    
    private $cacheKey;
 
    public function __construct(TokenProvider $provider, $cache, ?string $cacheKey = null)
    {
        $this->validateCache($cache);
        $this->cache = $cache;
        $this->provider = $provider;
        $this->cacheKey = self::TOKEN_CACHE_KEY . "_" . ($cacheKey ?? sha1(self::TOKEN_CACHE_KEY));
    }
    public function __construct(TokenProvider $provider, $cache, ?string $cacheKey = null) {…}
 
    private function validateCache($cache): void
    {
        if (!$cache instanceof CacheInterface && !$cache instanceof CacheItemPoolInterface) {
            throw new InvalidArgumentException();
        }
    }
 
    public function getToken(): Token
    {
        $token = $this->getCacheToken();
        if (!is_null($token)) {
            return new TokenModel($token);
        }
 
        return $this->refreshToken();
    }
    public function getToken(): Token {…}
 
    public function refreshToken(): Token
    {
        $token = $this->provider->refreshToken();
        // ensure token to be invalidated in cache before TTL
        $ttl = max(1, ($token->getExpiresIn() - 300));
 
        $this->cache($token, $ttl);
 
        return $token;
    }
    public function refreshToken(): Token {…}
 
    private function getCacheToken(): ?string
    {
        $cache = $this->cache;
        if ($cache instanceof CacheInterface) {
            return $cache->get($this->cacheKey, null);
        }
        
        $item = $cache->getItem($this->cacheKey);
        if ($item->isHit()) {
            return (string)$item->get();
        }
        
        return null;
    }
 
    private function cache(Token $token, int $ttl): void
    {
        $cache = $this->cache;
        if ($cache instanceof CacheInterface) {
            $cache->set($this->cacheKey, $token->getValue(), $ttl);
        } else {
            $item = $cache->getItem($this->cacheKey)->set($token->getValue())->expiresAfter($ttl);
            $cache->save($item);
        }
    }
}
class CachedTokenProvider implements TokenProvider {…};