src/DataCollector/HttpClientDataCollector.php line 101

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace App\DataCollector;
  7. use App\DataCollector\Model\HttpClientFlowCall;
  8. use App\Event\HttpClient\Events;
  9. use App\Event\HttpClient\HttpClientRequestEvent;
  10. use App\Event\HttpClient\HttpClientResponseEvent;
  11. use Doctrine\Common\Collections\ArrayCollection;
  12. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  13. use Symfony\Component\HttpFoundation\Request;
  14. use Symfony\Component\HttpFoundation\Response;
  15. use Symfony\Component\HttpKernel\DataCollector\DataCollector;
  17. class HttpClientDataCollector extends DataCollector implements EventSubscriberInterface
  18. {
  19.     protected $data = [
  20.         'calls' => null
  21.     ];
  23.     public function __construct()
  24.     {
  25.         $this->data['calls'] = new ArrayCollection();
  26.     }
  28.     public function collect(Request $request, Response $response, \Throwable $exception = null)
  29.     {
  30.         //nothing to do here, please look into event's method
  31.     }
  33.     public function getName()
  34.     {
  35.         return 'http_client.collector';
  36.     }
  38.     public static function getSubscribedEvents()
  39.     {
  40.         return [
  41.             Events::HTTP_CALL_OUTGOING => 'onRequest',
  42.             Events::HTTP_CALL_INCOMING => 'onResponse',
  43.         ];
  44.     }
  46.     public function getCalls() : ArrayCollection
  47.     {
  48.         return $this->data['calls'];
  49.     }
  51.     public function reset()
  52.     {
  53.         // TODO: Implement reset() method.
  54.     }
  56.     public function onRequest(HttpClientRequestEvent $requestEvent) : void
  57.     {
  58.         $httpClientFlowCall = new HttpClientFlowCall();
  60.         $httpClientFlowCall->setRequestId($requestEvent->getRequestIdentifier());
  61.         $httpClientFlowCall->setRequestMethod($requestEvent->getMethod());
  62.         $httpClientFlowCall->setRequestUrl($requestEvent->getRequest()->getUrl());
  63.         $httpClientFlowCall->setRequestParameters($requestEvent->getRequest()->getParameters() ?? []);
  64.         $httpClientFlowCall->setRequestBody($requestEvent->getRequest()->getBody());
  65.         $httpClientFlowCall->setRequestHeaders($requestEvent->getRequest()->getHeaders());
  67.         $requestBodyRaw = $httpClientFlowCall->getRequestBody();
  69.         $decodedRequestBody = null;
  71.         if ($requestBodyRaw !== null){
  72.             try{
  73.                 $decodedRequestBody = @\json_decode($requestBodyRaw, true, 1024, JSON_THROW_ON_ERROR);
  74.             }
  75.             catch(\Exception){
  76.                 $decodedRequestBody = null;
  77.             }
  78.         }
  80.         if (\is_array($decodedRequestBody)){
  81.             try{
  82.                 $decodedRequestBody = @\json_encode($decodedRequestBody, JSON_PRETTY_PRINT);
  83.             }
  84.             catch(\Exception){
  85.                 $decodedRequestBody = null;
  86.             }
  87.         }
  88.         else{
  89.             $decodedRequestBody = null;
  90.         }
  92.         $httpClientFlowCall->setRequestBodyDecoded($decodedRequestBody);
  94.         $collection = $this->data['calls'];
  96.         assert($collection instanceof ArrayCollection);
  98.         $collection->add($httpClientFlowCall);
  99.     }
  101.     public function onResponse(HttpClientResponseEvent $responseEvent) : void
  102.     {
  103.         $response = $responseEvent->getResponse();
  105.         $collection = $this->data['calls'];
  107.         assert($collection instanceof ArrayCollection);
  109.         $filteredCollection = $collection->filter(fn (HttpClientFlowCall $call) =>
  110.             $call->getRequestId() === $responseEvent->getRequestIdentifier()
  111.         );
  113.         $httpClientFlowCall = $filteredCollection->first() === false ? null :
  114.             $filteredCollection->first();
  116.         assert($httpClientFlowCall instanceof HttpClientFlowCall || $httpClientFlowCall === null);
  118.         $httpResponseStatusCode = (int) $response->getStatusCode();
  120.         $responseRawBody = (string) $response->getRawBody();
  122.         try{
  123.             $responseDecoded = json_decode($responseRawBody, true, 1024, JSON_THROW_ON_ERROR);
  124.         }
  125.         catch(\Exception){
  126.             $responseDecoded = null;
  127.         }
  129.         if (\is_array($responseDecoded)){
  131.             try{
  132.                 $responseDecoded = \json_encode($responseDecoded, JSON_PRETTY_PRINT);
  133.             }
  134.             catch(\Exception){
  135.                 $responseDecoded = null;
  136.             }
  137.         }
  139.         $httpClientFlowCall->setResponseStatusCode($httpResponseStatusCode);
  140.         $httpClientFlowCall->setResponseRawBody($responseRawBody);
  141.         $httpClientFlowCall->setResponseDecoded($responseDecoded);
  143.     }
  148. }