<?php declare(strict_types=1);

namespace Amp\Postgres\Internal;

use Amp\ForbidCloning;
use Amp\ForbidSerialization;
use Amp\Future;
use Amp\Postgres\PostgresResult;
use pq;

/**
 * @internal
 * @psalm-import-type TRowType from PostgresResult
 * @implements \IteratorAggregate<int, TRowType>
 */
final class PqBufferedResultSet implements PostgresResult, \IteratorAggregate
{
    use ForbidCloning;
    use ForbidSerialization;

    private readonly \Generator $iterator;

    private readonly int $rowCount;

    private readonly int $columnCount;

    /**
     * @param Future<PostgresResult|null> $nextResult Promise for next result set.
     */
    public function __construct(
        pq\Result $result,
        private readonly Future $nextResult,
    ) {
        $this->rowCount = $result->numRows;
        $this->columnCount = $result->numCols;

        $this->iterator = self::generate($result);
    }

    private static function generate(pq\Result $result): \Generator
    {
        $position = 0;

        while (++$position <= $result->numRows) {
            $result->autoConvert = pq\Result::CONV_SCALAR | pq\Result::CONV_ARRAY | pq\Result::CONV_BYTEA;
            yield $result->fetchRow(pq\Result::FETCH_ASSOC);
        }
    }

    #[\Override]
    public function fetchRow(): ?array
    {
        if (!$this->iterator->valid()) {
            return null;
        }

        $current = $this->iterator->current();
        $this->iterator->next();
        return $current;
    }

    #[\Override]
    public function getIterator(): \Traversable
    {
        return $this->iterator;
    }

    #[\Override]
    public function getNextResult(): ?PostgresResult
    {
        return $this->nextResult->await();
    }

    #[\Override]
    public function getRowCount(): int
    {
        return $this->rowCount;
    }

    #[\Override]
    public function getColumnCount(): int
    {
        return $this->columnCount;
    }
}