ScayTrase\Api\Rpc\Decorators\CacheableResponseCollection

Complexity

Total Complexity

7

Size/Duplication

Total Lines	71
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

100%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	getResponse()	0	18	2
A	__construct()	0	13	2
A	getIterator()	0	13	3

<?php

namespace ScayTrase\Api\Rpc\Decorators;

use Psr\Cache\CacheItemInterface;
use Psr\Cache\CacheItemPoolInterface;
use ScayTrase\Api\Rpc\ResponseCollectionInterface;
use ScayTrase\Api\Rpc\RpcRequestInterface;

final class CacheableResponseCollection implements \IteratorAggregate, ResponseCollectionInterface
{
    /** @var  CacheItemPoolInterface */
    private $cache;
    /** @var  CacheKeyStrategyInterface */
    private $keyStrategy;
    /** @var  array */
    private $items;
    /** @var  ResponseCollectionInterface */
    private $proxiedCollection;
    /** @var  int|null */
    private $ttl;

    /**
     * CacheableResponseCollection constructor.
     *
     * @param CacheItemPoolInterface      $cache
     * @param CacheKeyStrategyInterface   $keyStrategy
     * @param array                       $items
     * @param ResponseCollectionInterface $proxiedCollection
     * @param int|null                    $ttl
     */
    public function __construct(
        CacheItemPoolInterface $cache,
        CacheKeyStrategyInterface $keyStrategy,
        array $items,
        ResponseCollectionInterface $proxiedCollection,
        $ttl
    ) {
        $this->cache             = $cache;
        $this->keyStrategy       = $keyStrategy;
        $this->items             = $items;
        $this->proxiedCollection = $proxiedCollection;
        $this->ttl               = $ttl ?: null;
    }

    /** {@inheritdoc} */
    public function getResponse(RpcRequestInterface $request)
    {
        $key = $this->keyStrategy->getKey($request);

        /** @var CacheItemInterface $item */
        $item = $this->items[$key]['item'];

        if ($item->isHit()) {
            return $item->get();
        }

        $item->expiresAfter($this->ttl);
        $item->set($this->proxiedCollection->getResponse($request));

        $this->cache->save($item);

        return $item->get();
    }

    /** {@inheritdoc} */
    public function getIterator()
    {
        foreach ($this->items as $key => $data) {
            /** @var CacheItemInterface $item */
            $item = $data['item'];

            if ($item->isHit()) {
                yield $item->get();
            }

            yield $this->getResponse($data['request']);
        }
    }
}