ldc-arcadia-genesis-php-client/tests/Unit/Lib/Pagination/StreamOfTest.php

<?php

declare(strict_types=1);

namespace Tests\Unit\Lib\Pagination;

use PHPUnit\Framework\TestCase;
use Uwil\ArcadiaApiPhpClient\Error\NetworkError;
use Uwil\ArcadiaApiPhpClient\Lib\ApiDto\Dto\PageOf;
use Uwil\ArcadiaApiPhpClient\Lib\ApiDto\Dto\PaginationDto;
use Uwil\ArcadiaApiPhpClient\Lib\Pagination\PageSize;
use Uwil\ArcadiaApiPhpClient\Lib\Pagination\Pagination;
use Uwil\ArcadiaApiPhpClient\Lib\Pagination\StreamOf;

covers(StreamOf::class);

uses(TestCase::class);

describe('StreamOf Unit Tests', function (): void {
    it('iterates through multiple pages sequentially', function (): void {
        // GIVEN
        $data = range(1, 25); // 25 items across 3 pages of size 10

        $fetcher = function (Pagination $pagination) use ($data): PageOf {
            $offset = $pagination->from();
            $limit  = $pagination->pageSize();
            $slice  = array_slice($data, $offset, $limit);

            $paginationDto = new PaginationDto(
                page: $pagination->pageNumber(),
                pageSize: $limit,
                totalItems: count($data),
                totalPages: (int) ceil(count($data) / $limit),
            );

            return new PageOf($paginationDto, $slice);
        };

        $stream = new StreamOf($fetcher, new PageSize(10));

        // WHEN
        $result = iterator_to_array($stream);

        // THEN
        expect($result)->toBe($data)
            ->and($stream->totalCount())->toBe(25)
            ->and($stream->totalPages())->toBe(3)
            ->and($stream->lastError())->toBeNull();
    });

    it('handles empty page result', function (): void {
        // GIVEN
        $fetcher = function (Pagination $_): PageOf {
            $paginationDto = new PaginationDto(
                page: 1,
                pageSize: 10,
                totalItems: 0,
                totalPages: 0,
            );

            return new PageOf($paginationDto, []);
        };

        $stream = new StreamOf($fetcher, new PageSize(10));

        // WHEN
        $result = iterator_to_array($stream);

        // THEN
        expect($result)->toBeEmpty()
            ->and($stream->totalCount())->toBe(0)
            ->and($stream->totalPages())->toBe(0);
    });

    it('stops iteration on error and captures lastError', function (): void {
        // GIVEN
        $fetcher = function (Pagination $_): NetworkError {
            return new NetworkError('Connection timed out');
        };

        $stream = new StreamOf($fetcher, new PageSize(10));

        // WHEN
        $result = iterator_to_array($stream);

        // THEN
        expect($result)->toBeEmpty()
            ->and($stream->lastError())->toBeInstanceOf(NetworkError::class)
            ->and($stream->lastError()?->message())->toBe('Connection timed out');
    });
});