Deprecated: Constant E_STRICT is deprecated in /home/pastorz/old-espace-client/vendor/symfony/error-handler/ErrorHandler.php on line 58

Deprecated: Constant E_STRICT is deprecated in /home/pastorz/old-espace-client/vendor/symfony/error-handler/ErrorHandler.php on line 76
Symfony Profiler

vendor/symfony/messenger/DataCollector/MessengerDataCollector.php line 124

Open in your IDE?
  1. <?php
  3. /*
  4.  * This file is part of the Symfony package.
  5.  *
  6.  * (c) Fabien Potencier <fabien@symfony.com>
  7.  *
  8.  * For the full copyright and license information, please view the LICENSE
  9.  * file that was distributed with this source code.
  10.  */
  12. namespace Symfony\Component\Messenger\DataCollector;
  14. use Symfony\Component\HttpFoundation\Request;
  15. use Symfony\Component\HttpFoundation\Response;
  16. use Symfony\Component\HttpKernel\DataCollector\DataCollector;
  17. use Symfony\Component\HttpKernel\DataCollector\LateDataCollectorInterface;
  18. use Symfony\Component\Messenger\TraceableMessageBus;
  19. use Symfony\Component\VarDumper\Caster\ClassStub;
  21. /**
  22.  * @author Samuel Roze <samuel.roze@gmail.com>
  23.  *
  24.  * @final
  25.  */
  26. class MessengerDataCollector extends DataCollector implements LateDataCollectorInterface
  27. {
  28.     private $traceableBuses = [];
  30.     public function registerBus(string $name, TraceableMessageBus $bus)
  31.     {
  32.         $this->traceableBuses[$name] = $bus;
  33.     }
  35.     /**
  36.      * {@inheritdoc}
  37.      */
  38.     public function collect(Request $request, Response $response, \Throwable $exception = null)
  39.     {
  40.         // Noop. Everything is collected live by the traceable buses & cloned as late as possible.
  41.     }
  43.     /**
  44.      * {@inheritdoc}
  45.      */
  46.     public function lateCollect()
  47.     {
  48.         $this->data = ['messages' => [], 'buses' => array_keys($this->traceableBuses)];
  50.         $messages = [];
  51.         foreach ($this->traceableBuses as $busName => $bus) {
  52.             foreach ($bus->getDispatchedMessages() as $message) {
  53.                 $debugRepresentation = $this->cloneVar($this->collectMessage($busName, $message));
  54.                 $messages[] = [$debugRepresentation, $message['callTime']];
  55.             }
  56.         }
  58.         // Order by call time
  59.         usort($messages, function ($a, $b) { return $a[1] <=> $b[1]; });
  61.         // Keep the messages clones only
  62.         $this->data['messages'] = array_column($messages, 0);
  63.     }
  65.     /**
  66.      * {@inheritdoc}
  67.      */
  68.     public function getName(): string
  69.     {
  70.         return 'messenger';
  71.     }
  73.     /**
  74.      * {@inheritdoc}
  75.      */
  76.     public function reset()
  77.     {
  78.         $this->data = [];
  79.         foreach ($this->traceableBuses as $traceableBus) {
  80.             $traceableBus->reset();
  81.         }
  82.     }
  84.     /**
  85.      * {@inheritdoc}
  86.      */
  87.     protected function getCasters(): array
  88.     {
  89.         $casters = parent::getCasters();
  91.         // Unset the default caster truncating collectors data.
  92.         unset($casters['*']);
  94.         return $casters;
  95.     }
  97.     private function collectMessage(string $busName, array $tracedMessage)
  98.     {
  99.         $message = $tracedMessage['message'];
  101.         $debugRepresentation = [
  102.             'bus' => $busName,
  103.             'stamps' => $tracedMessage['stamps'] ?? null,
  104.             'stamps_after_dispatch' => $tracedMessage['stamps_after_dispatch'] ?? null,
  105.             'message' => [
  106.                 'type' => new ClassStub(\get_class($message)),
  107.                 'value' => $message,
  108.             ],
  109.             'caller' => $tracedMessage['caller'],
  110.         ];
  112.         if (isset($tracedMessage['exception'])) {
  113.             $exception = $tracedMessage['exception'];
  115.             $debugRepresentation['exception'] = [
  116.                 'type' => \get_class($exception),
  117.                 'value' => $exception,
  118.             ];
  119.         }
  121.         return $debugRepresentation;
  122.     }
  124.     public function getExceptionsCount(string $bus = null): int
  125.     {
  126.         $count = 0;
  127.         foreach ($this->getMessages($bus) as $message) {
  128.             $count += (int) isset($message['exception']);
  129.         }
  131.         return $count;
  132.     }
  134.     public function getMessages(string $bus = null): array
  135.     {
  136.         if (null === $bus) {
  137.             return $this->data['messages'];
  138.         }
  140.         return array_filter($this->data['messages'], function ($message) use ($bus) {
  141.             return $bus === $message['bus'];
  142.         });
  143.     }
  145.     public function getBuses(): array
  146.     {
  147.         return $this->data['buses'];
  148.     }
  149. }