Sludio\HelperBundle\Guzzle\GuzzleHttp\Middleware\CacheMiddleware

Complexity

Total Complexity

6

Size/Duplication

Total Lines	44
Duplicated Lines	0 %

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__invoke()	0	10	2
A	__construct()	0	4	1
A	addDebugHeader()	0	7	2
A	handleSave()	0	6	1

<?php

namespace Sludio\HelperBundle\Guzzle\GuzzleHttp\Middleware;

use Sludio\HelperBundle\Guzzle\Cache\StorageAdapterInterface;
use GuzzleHttp\Promise\FulfilledPromise;
use Psr\Http\Message\RequestInterface;
use Psr\Http\Message\ResponseInterface;

class CacheMiddleware
{
    const DEBUG_HEADER = 'X-Guzzle-Cache';
    const DEBUG_HEADER_HIT = 'HIT';
    const DEBUG_HEADER_MISS = 'MISS';

    protected $adapter;
    protected $debug;

    public function __construct(StorageAdapterInterface $adapter, $debug = false)
    {
        $this->adapter = $adapter;
        $this->debug = $debug;
    }

    public function __invoke(callable $handler)
    {
        return function(RequestInterface $request, array $options) use ($handler) {
            if (!$response = $this->adapter->fetch($request)) {
                return $this->handleSave($handler, $request, $options);
            }

            $response = $this->addDebugHeader($response, static::DEBUG_HEADER_HIT);

            return new FulfilledPromise($response);
        };
    }

    protected function handleSave(callable $handler, RequestInterface $request, array $options)
    {
        return $handler($request, $options)->then(function(ResponseInterface $response) use ($request) {
            $this->adapter->save($request, $response);

            return $this->addDebugHeader($response, static::DEBUG_HEADER_MISS);
        });
    }

    protected function addDebugHeader(ResponseInterface $response, $value)
    {
        if (!$this->debug) {
            return $response;
        }

        return $response->withHeader(static::DEBUG_HEADER, $value);
    }
}