hamburgscleanest\GuzzleAdvancedThrottle\Cache\Strategies\Cachable

Complexity

Total Complexity

5

Size/Duplication

Total Lines	51
Duplicated Lines	0 %

Test Coverage

Coverage

92.86%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	_saveResponse()	0	8	2
A	_getResponse()	0	3	1
A	request()	0	7	1
A	__construct()	0	3	1

<?php

namespace hamburgscleanest\GuzzleAdvancedThrottle\Cache\Strategies;

use GuzzleHttp\Promise\PromiseInterface;
use hamburgscleanest\GuzzleAdvancedThrottle\Cache\Interfaces\CacheStrategy;
use hamburgscleanest\GuzzleAdvancedThrottle\Cache\Interfaces\StorageInterface;
use Psr\Http\Message\RequestInterface;
use Psr\Http\Message\ResponseInterface;

/**
 * Class Cache
 * @package hamburgscleanest\GuzzleAdvancedThrottle\Cache\Strategies
 */
class Cachable implements CacheStrategy
{

    /** @var StorageInterface */
    private $_storage;

    /**
     * Cachable constructor.
     * @param null|StorageInterface $storage
     */
    public function __construct(StorageInterface $storage = null)
    {
        $this->_storage = $storage;
    }

    /**
     * @param RequestInterface $request
     * @param callable $handler
     * @return PromiseInterface
     */
    public function request(RequestInterface $request, callable $handler) : PromiseInterface
    {
        return $handler()->then(function(ResponseInterface $response) use ($request)
        {
            $this->_saveResponse($request, $response);

            return $response;
        });
    }

    /**
     * @param RequestInterface $request
     * @param ResponseInterface $response
     */
    protected function _saveResponse(RequestInterface $request, ResponseInterface $response) : void
    {
        if ($response->getStatusCode() !== 200)
        {
            return;
        }

        $this->_storage->saveResponse($request, $response);
    }

    /**
     * @param RequestInterface $request
     * @return null|ResponseInterface
     */
    protected function _getResponse(RequestInterface $request) : ? ResponseInterface
    {
        return $this->_storage->getResponse($request);
    }
}