loophp\collection\Iterator\PsrCacheIterator

Complexity

Total Complexity

9

Size/Duplication

Total Lines	67
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	next()	0	6	1
A	key()	0	7	1
A	getTupleFromCache()	0	14	2
A	rewind()	0	5	1
A	current()	0	7	1
A	valid()	0	3	2
A	__construct()	0	1	1

<?php

declare(strict_types=1);

namespace loophp\collection\Iterator;

use Iterator;
use Psr\Cache\CacheItemInterface;
use Psr\Cache\CacheItemPoolInterface;
use ReturnTypeWillChange;

/**
 * @internal
 *
 * @template TKey
 * @template T
 *
 * @implements Iterator<TKey, T>
 */
final class PsrCacheIterator implements Iterator
{
    private int $key = 0;

    /**
     * @param Iterator<TKey, T> $iterator
     */
    public function __construct(private Iterator $iterator, private CacheItemPoolInterface $cache) {}

    /**
     * @return T

The type loophp\collection\Iterator\T was not found. Maybe you did not declare it correctly or list all dependencies?

     */
    #[ReturnTypeWillChange]
    public function current()
    {
        /** @var array{TKey, T} $data */
        $data = $this->getTupleFromCache($this->key)->get();

        return $data[1];
    }

    /**
     * @return TKey

The type loophp\collection\Iterator\TKey was not found. Maybe you did not declare it correctly or list all dependencies?

     */
    #[ReturnTypeWillChange]
    public function key()
    {
        /** @var array{TKey, T} $data */
        $data = $this->getTupleFromCache($this->key)->get();

        return $data[0];
    }

    public function next(): void
    {
        // This is mostly for iterator_count().
        $this->getTupleFromCache($this->key++);

        $this->iterator->next();
    }

    public function rewind(): void
    {
        // No call to $this->iterator->rewind() because we do not know if the inner
        // iterator can be rewinded or not.
        $this->key = 0;
    }

    public function valid(): bool
    {
        return $this->iterator->valid() || $this->cache->hasItem((string) $this->key);
    }

    private function getTupleFromCache(int $key): CacheItemInterface
    {
        $item = $this->cache->getItem((string) $key);

        if (false === $item->isHit()) {
            $item->set([
                $this->iterator->key(),
                $this->iterator->current(),
            ]);

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

        return $item;
    }
}