Cerbero\LazyJsonPages\Services\Book

Complexity

Total Complexity

6

Size/Duplication

Total Lines	72
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	addPage()	0	5	1
A	pullFailedPages()	0	7	1
A	pullPages()	0	8	2
A	addFailedPage()	0	5	1
A	pullFailedPage()	0	3	1

<?php

namespace Cerbero\LazyJsonPages\Services;

use Generator;
use Psr\Http\Message\ResponseInterface;

/**
 * The collector of pages.
 */
final class Book
{
    /**
     * The HTTP responses of the fetched pages.
     *
     * @var array<int, ResponseInterface>
     */
    private array $pages = [];

    /**
     * The pages unable to be fetched.
     *
     * @var int[]
     */
    private array $failedPages = [];

    /**
     * Add the HTTP response of the given page.
     */
    public function addPage(int $page, ResponseInterface $response): self
    {
        $this->pages[$page] = $response;

        return $this;
    }

    /**
     * Yield and forget each page.
     *
     * @return Generator<int, ResponseInterface>
     */
    public function pullPages(): Generator
    {
        ksort($this->pages);

        foreach ($this->pages as $page => $response) {
            yield $response;

            unset($this->pages[$page]);
        }
    }

    /**
     * Add the given failed page.
     */
    public function addFailedPage(int $page): self
    {
        $this->failedPages[] = $page;

        return $this;
    }

    /**
     * Retrieve and unset the failed pages.
     *
     * @return array<int, int>
     */
    public function pullFailedPages(): array
    {
        $failedPages = $this->failedPages;

        $this->failedPages = [];

        return $failedPages;
    }

    /**
     * Retrieve and unset the oldest failed page.
     */
    public function pullFailedPage(): ?int
    {
        return array_shift($this->failedPages);
    }
}