vendor/sentry/sentry-symfony/src/Tracing/HttpClient/AbstractTraceableResponse.php line 116

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace Sentry\SentryBundle\Tracing\HttpClient;
  7. use Sentry\Tracing\Span;
  8. use Symfony\Contracts\HttpClient\ChunkInterface;
  9. use Symfony\Contracts\HttpClient\HttpClientInterface;
  10. use Symfony\Contracts\HttpClient\ResponseInterface;
  12. /**
  13.  * @internal
  14.  */
  15. abstract class AbstractTraceableResponse implements ResponseInterface
  16. {
  17.     /**
  18.      * @var ResponseInterface
  19.      */
  20.     protected $response;
  22.     /**
  23.      * @var HttpClientInterface
  24.      */
  25.     protected $client;
  27.     /**
  28.      * @var Span|null
  29.      */
  30.     protected $span;
  32.     public function __construct(HttpClientInterface $client, ResponseInterface $response, ?Span $span)
  33.     {
  34.         $this->client = $client;
  35.         $this->response = $response;
  36.         $this->span = $span;
  37.     }
  39.     public function __destruct()
  40.     {
  41.         try {
  42.             if (method_exists($this->response, '__destruct')) {
  43.                 $this->response->__destruct();
  44.             }
  45.         } finally {
  46.             $this->finishSpan();
  47.         }
  48.     }
  50.     public function __sleep(): array
  51.     {
  52.         throw new \BadMethodCallException('Serializing instances of this class is forbidden.');
  53.     }
  55.     public function __wakeup()
  56.     {
  57.         throw new \BadMethodCallException('Unserializing instances of this class is forbidden.');
  58.     }
  60.     public function getStatusCode(): int
  61.     {
  62.         return $this->response->getStatusCode();
  63.     }
  65.     public function getHeaders(bool $throw = true): array
  66.     {
  67.         return $this->response->getHeaders($throw);
  68.     }
  70.     public function getContent(bool $throw = true): string
  71.     {
  72.         try {
  73.             return $this->response->getContent($throw);
  74.         } finally {
  75.             $this->finishSpan();
  76.         }
  77.     }
  79.     public function toArray(bool $throw = true): array
  80.     {
  81.         try {
  82.             return $this->response->toArray($throw);
  83.         } finally {
  84.             $this->finishSpan();
  85.         }
  86.     }
  88.     public function cancel(): void
  89.     {
  90.         $this->response->cancel();
  91.         $this->finishSpan();
  92.     }
  94.     /**
  95.      * @internal
  96.      *
  97.      * @param iterable<AbstractTraceableResponse> $responses
  98.      *
  99.      * @return \Generator<AbstractTraceableResponse, ChunkInterface>
  100.      */
  101.     public static function stream(HttpClientInterface $client, iterable $responses, ?float $timeout): \Generator
  102.     {
  103.         /** @var \SplObjectStorage<ResponseInterface, AbstractTraceableResponse> $traceableMap */
  104.         $traceableMap = new \SplObjectStorage();
  105.         $wrappedResponses = [];
  107.         foreach ($responses as $response) {
  108.             if (!$response instanceof self) {
  109.                 throw new \TypeError(sprintf('"%s::stream()" expects parameter 1 to be an iterable of TraceableResponse objects, "%s" given.', TraceableHttpClient::class, get_debug_type($response)));
  110.             }
  112.             $traceableMap[$response->response] = $response;
  113.             $wrappedResponses[] = $response->response;
  114.         }
  116.         foreach ($client->stream($wrappedResponses, $timeout) as $response => $chunk) {
  117.             $traceableResponse = $traceableMap[$response];
  118.             $traceableResponse->finishSpan();
  120.             yield $traceableResponse => $chunk;
  121.         }
  122.     }
  124.     private function finishSpan(): void
  125.     {
  126.         if (null !== $this->span) {
  127.             $this->span->finish();
  128.             $this->span = null;
  129.         }
  130.     }
  131. }