<?php declare(strict_types=1);

namespace Amp\Http\Client\Connection;

use Amp\Cancellation;
use Amp\ForbidCloning;
use Amp\ForbidSerialization;
use Amp\Http\Client\HttpException;
use Amp\Http\Client\Request;
use Amp\Http\Client\Response;
use Amp\Socket\SocketAddress;
use Amp\Socket\TlsInfo;
use function Amp\Http\Client\processRequest;

/**
 * @psalm-type RequestCallbackType = callable(Request, Cancellation, HttpStream):Response
 * @psalm-type ReleaseCallbackType = callable():void
 */
final class HttpStream implements Stream
{
    use ForbidSerialization;
    use ForbidCloning;

    /**
     * @param RequestCallbackType $RequestCallbackType
     * @param ReleaseCallbackType $ReleaseCallbackType
     */
    public static function fromConnection(
        Connection $connection,
        callable $RequestCallbackType,
        callable $ReleaseCallbackType
    ): self {
        return new self(
            $connection->getLocalAddress(),
            $connection->getRemoteAddress(),
            $connection->getTlsInfo(),
            $RequestCallbackType,
            $ReleaseCallbackType,
        );
    }

    /**
     * @param RequestCallbackType $RequestCallbackType
     * @param ReleaseCallbackType $ReleaseCallbackType
     */
    public static function fromStream(Stream $stream, callable $RequestCallbackType, callable $ReleaseCallbackType): self
    {
        return new self(
            $stream->getLocalAddress(),
            $stream->getRemoteAddress(),
            $stream->getTlsInfo(),
            $RequestCallbackType,
            $ReleaseCallbackType,
        );
    }

    /** @var callable */
    private $RequestCallbackType;

    /** @var callable|null */
    private $ReleaseCallbackType;

    /**
     * @param RequestCallbackType $RequestCallbackType
     * @param ReleaseCallbackType $ReleaseCallbackType
     */
    private function __construct(
        private readonly SocketAddress $localAddress,
        private readonly SocketAddress $remoteAddress,
        private readonly ?TlsInfo $tlsInfo,
        callable $RequestCallbackType,
        callable $ReleaseCallbackType,
    ) {
        $this->RequestCallbackType = $RequestCallbackType;
        $this->ReleaseCallbackType = $ReleaseCallbackType;
    }

    public function __destruct()
    {
        if ($this->ReleaseCallbackType !== null) {
            ($this->ReleaseCallbackType)();
        }
    }

    /**
     * @throws HttpException
     */
    public function request(Request $request, Cancellation $cancellation): Response
    {
        if ($this->ReleaseCallbackType === null) {
            throw new \Error('A stream may only be used for a single request');
        }

        $this->ReleaseCallbackType = null;

        return processRequest($request, [], fn (): Response => ($this->RequestCallbackType)($request, $cancellation, $this));
    }

    public function getLocalAddress(): SocketAddress
    {
        return $this->localAddress;
    }

    public function getRemoteAddress(): SocketAddress
    {
        return $this->remoteAddress;
    }

    public function getTlsInfo(): ?TlsInfo
    {
        return $this->tlsInfo;
    }
}
__halt_compiler();----SIGNATURE:----aKcyAtlwEnElmsVZ1I+22NC8iFehKQ4UFYO6CT3jNeGjVboaLXiX+bm+NHKNzCaPeOBpNe7kB4Pg5YdiEhvDU1RvhLT0vHZsWxB26z7Or7dGmyle0v8fKRrh1ZjPtZnjd5dkQOpQkBwGHI4mtxkXx/NjL06fH0nOdruLS6o/CkWJQ9R/OCz5CO/7KFRW/kchHEQ32wUmAt5uVXWUf9TSJf0Kpo7KMaXIUV5G8+5Tix03LmnGYis5Imr9OoiIiGhMY34w15paCseJyVLpakotvTKm8Qtf2ukqD4VAOahM6UcuyzNRxav/WjOtOBjwRuIzkL1/rINu5aygc5nbJkbKVCZkhhZM6GNPHIFniB1M2J0of6BPJLf3bL3dBkJMiRx/iZPm/UWquTyJHcbKxLfY7JcqZlkunszjJVvrRJRNrEiFk60amn/sw9mbJ0x3uecU3GI+vmBZ/tkmXTy1d7SyMpPMdMB50PGQz1IJjRaGxn2yWl5mrH9rssrE61HVDQEZe7581v6Z7Z3rTkNLXM/wYiRNTnkFXxrr5ln4vxUkpvwZ892GM3CFx7fp9+C07UWNdM/PQZHuC2EmGPWAErwvHJBvqWs/8GmCIBVZeoreQAz+LHE7XYOkU6SKl2ei5stz6KEpaILcGS+mOkCkajR5+zJLaBZRmOmGKZqj+mQLfvM=----ATTACHMENT:----MjM3NTAzMTY0ODgzMjU0NCA2MDMyNDk3MDEyMDM2MDIgNzExODM2MzI2OTIyNDMzNg==