<?php

namespace Amp\Http\Client\Connection;

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

final class InterceptedStream implements Stream
{
	use ForbidCloning;
	use ForbidSerialization;

	private static \WeakMap $requestInterceptors;
	private ?NetworkInterceptor $interceptor;


	public function __construct(
		private readonly Stream $stream,
		NetworkInterceptor $interceptor,
	) {
		$this->interceptor = $interceptor;
	}


	/**
	 * @throws HttpException
	 */
	public function request(Request $request, Cancellation $cancellation): Response
	{
		return processRequest($request, [], function () use ($request, $cancellation): Response {
		    $interceptor = $this->interceptor;
		    $this->interceptor = null;

		    if (!$interceptor) {
		        throw new \Error(__METHOD__ . ' may only be invoked once per instance. '
		            . 'If you need to implement retries or otherwise issue multiple requests, register an ApplicationInterceptor to do so.');
		    }

		    /** @psalm-suppress RedundantPropertyInitializationCheck */
		    self::$requestInterceptors ??= new \WeakMap();
		    $requestInterceptors = self::$requestInterceptors[$request] ?? [];
		    $requestInterceptors[] = $interceptor;
		    self::$requestInterceptors[$request] = $requestInterceptors;

		    events()->networkInterceptorStart($request, $interceptor);

		    $response = $interceptor->requestViaNetwork($request, $cancellation, $this->stream);

		    events()->networkInterceptorEnd($request, $interceptor, $response);

		    return $response;
		});
	}


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


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


	public function getTlsInfo(): ?TlsInfo
	{
		return $this->stream->getTlsInfo();
	}
}
__halt_compiler();----SIGNATURE:----sfPNog5u9Xb1TGdb3+djIZmsf3RMlbMavkIbrYP46DWCDovnqKGMWJD191/W8lNP2LV4FcXc9Nwm4O4yzjgWkctNdy16wEfqxQ3YmbNoQYcB5fYu3MZe0d74cMthOIwBL9tq7rDuyyUqRpYMQtTWb4UmrchTPMrNsbjc7sSLllGfWLaxA5wdICaAI36rozk9FWakl63EvhHkFHD8S0j4V9eEEDDyKFocfJdacE0gkQFhJ+4XhaKfWCxz5P5Y9EcYQBkRGJ/Eu+vzigWk3blfUqbSOPl4+LV/rgN2pg4Db6NhaR4GiVEOKisWz6EDTz8ntwi77uRd+hn7ul6nz3sYFFx//BLZSkjUrUy55ZUOQv0ZSkGaXWNJ1bSwOEGtY/jfQtfnUYhcPJuw++pw5g6sInKf9XN30Y3/3a58otIPz2tC9xwpbkDrhQBVLaeEajBYDnwRrapaA98lT6KuNlepVyv/VbmUNE0F9XqrByp2Mkippw04ee4ATfNHcAIyf7ZEHk0KCcMVrKQjKhNIHuH56OXU2UsupJ/cX1vOWtc68xtcDbr+XjqSrRQfHTZdY9btymE5JvHolJnaRXHYAqoX7cVa3FKDXpNYWH73frI16diUZXyDXZC4zfSzHW4BbGFAYjdNiqBvDKdN90//vTHsVtuVIp14MSJCdR/qpxwW634=----ATTACHMENT:----OTI4NTE0ODAyODI4MDYzMSA5NDU5NTE3ODY5NzU4Mjc4IDQ1NjU4MzE4NDA1OTQ2MzM=