Ray-Di / Ray.AuraSqlModule

src/Pagerfanta/AuraSqlQueryPager.php

<?php

declare(strict_types=1);

namespace Ray\AuraSqlModule\Pagerfanta;

use ArrayAccess;
use Aura\Sql\ExtendedPdoInterface;
use Aura\SqlQuery\Common\Select;
use Aura\SqlQuery\Common\SelectInterface;
use Override;

The type Override was not found. Maybe you did not declare it correctly or list all dependencies?

use Pagerfanta\Exception\LogicException;
use Pagerfanta\Pagerfanta;
use Pagerfanta\View\ViewInterface;
use Ray\AuraSqlModule\Annotation\PagerViewOption;
use Ray\AuraSqlModule\Exception\NotInitialized;

use function array_keys;

/** @implements ArrayAccess<int, Page> */

final class AuraSqlQueryPager implements AuraSqlQueryPagerInterface, ArrayAccess
{
    private ExtendedPdoInterface $pdo;
    private ?RouteGeneratorInterface $routeGenerator = null;
    private SelectInterface $select;

    /** @phpstan-var positive-int */
    private int $paging;

    /** @param array<string, mixed> $viewOptions */
    public function __construct(
        private readonly ViewInterface $view,
        #[PagerViewOption]
        private readonly array $viewOptions
    ) {
    }

    /**
     * @phpstan-param positive-int $paging
     *
     * @return AuraSqlQueryPagerInterface
     *
     * {@inheritDoc}
     */
    #[Override]
    public function init(ExtendedPdoInterface $pdo, SelectInterface $select, int $paging, RouteGeneratorInterface $routeGenerator)
    {
        $this->pdo = $pdo;
        $this->select = $select;
        $this->paging = $paging;
        $this->routeGenerator = $routeGenerator;

        return $this;
    }

    /**
     * @phpstan-param positive-int $page
     * {@inheritDoc}
     */
    #[Override]
    public function offsetGet($page): Page
    {
        if (! $this->routeGenerator instanceof RouteGeneratorInterface) {
            throw new NotInitialized();
        }

        $countQueryBuilderModifier = static function (Select $select): Select {
            foreach (array_keys($select->getCols()) as $key) {
                $select->removeCol($key);
            }

            return $select->cols(['COUNT(*) AS total_results'])->resetOrderBy()->limit(1);
        };
        $pagerfanta = new Pagerfanta(new AuraSqlQueryAdapter($this->pdo, $this->select, $countQueryBuilderModifier));
        $pagerfanta->setMaxPerPage($this->paging);
        $pagerfanta->setCurrentPage($page);
        $pager = new Page($pagerfanta, $this->routeGenerator, $this->view, $this->viewOptions);
        $pager->maxPerPage = $pagerfanta->getMaxPerPage();
        $pager->current = $pagerfanta->getCurrentPage();
        /** @psalm-suppress UndefinedDocblockClass */
        $pager->hasNext = $pagerfanta->hasNextPage();
        /** @psalm-suppress UndefinedDocblockClass */
        $pager->hasPrevious = $pagerfanta->hasPreviousPage();
        $pager->data = $pagerfanta->getCurrentPageResults();
        $pager->total = $pagerfanta->getNbResults();

        return $pager;
    }

    /**
     * {@inheritDoc}
     */
    #[Override]
    public function offsetExists($offset): bool
    {
        throw new LogicException('unsupported');
    }

    /**
     * {@inheritDoc}
     */
    #[Override]
    public function offsetSet($offset, $value): void
    {
        throw new LogicException('read only');
    }

    /**
     * {@inheritDoc}
     */
    #[Override]
    public function offsetUnset($offset): void
    {
        throw new LogicException('read only');
    }
}