vendor/symfony/messenger/TraceableMessageBus.php line 30

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;
  14. /**
  15.  * @author Samuel Roze <samuel.roze@gmail.com>
  16.  */
  17. class TraceableMessageBus implements MessageBusInterface
  18. {
  19.     private MessageBusInterface $decoratedBus;
  20.     private array $dispatchedMessages = [];
  22.     public function __construct(MessageBusInterface $decoratedBus)
  23.     {
  24.         $this->decoratedBus = $decoratedBus;
  25.     }
  27.     /**
  28.      * {@inheritdoc}
  29.      */
  30.     public function dispatch(object $message, array $stamps = []): Envelope
  31.     {
  32.         $envelope = Envelope::wrap($message, $stamps);
  33.         $context = [
  34.             'stamps' => array_merge([], ...array_values($envelope->all())),
  35.             'message' => $envelope->getMessage(),
  36.             'caller' => $this->getCaller(),
  37.             'callTime' => microtime(true),
  38.         ];
  40.         try {
  41.             return $envelope = $this->decoratedBus->dispatch($message, $stamps);
  42.         } catch (\Throwable $e) {
  43.             $context['exception'] = $e;
  45.             throw $e;
  46.         } finally {
  47.             $this->dispatchedMessages[] = $context + ['stamps_after_dispatch' => array_merge([], ...array_values($envelope->all()))];
  48.         }
  49.     }
  51.     public function getDispatchedMessages(): array
  52.     {
  53.         return $this->dispatchedMessages;
  54.     }
  56.     public function reset()
  57.     {
  58.         $this->dispatchedMessages = [];
  59.     }
  61.     private function getCaller(): array
  62.     {
  63.         $trace = debug_backtrace(\DEBUG_BACKTRACE_IGNORE_ARGS, 8);
  65.         $file = $trace[1]['file'] ?? null;
  66.         $line = $trace[1]['line'] ?? null;
  68.         $handleTraitFile = (new \ReflectionClass(HandleTrait::class))->getFileName();
  69.         $found = false;
  70.         for ($i = 1; $i < 8; ++$i) {
  71.             if (isset($trace[$i]['file'], $trace[$i + 1]['file'], $trace[$i + 1]['line']) && $trace[$i]['file'] === $handleTraitFile) {
  72.                 $file = $trace[$i + 1]['file'];
  73.                 $line = $trace[$i + 1]['line'];
  74.                 $found = true;
  76.                 break;
  77.             }
  78.         }
  80.         for ($i = 2; $i < 8 && !$found; ++$i) {
  81.             if (isset($trace[$i]['class'], $trace[$i]['function'])
  82.                 && 'dispatch' === $trace[$i]['function']
  83.                 && is_a($trace[$i]['class'], MessageBusInterface::class, true)
  84.             ) {
  85.                 $file = $trace[$i]['file'];
  86.                 $line = $trace[$i]['line'];
  88.                 while (++$i < 8) {
  89.                     if (isset($trace[$i]['function'], $trace[$i]['file']) && empty($trace[$i]['class']) && !str_starts_with($trace[$i]['function'], 'call_user_func')) {
  90.                         $file = $trace[$i]['file'];
  91.                         $line = $trace[$i]['line'];
  93.                         break;
  94.                     }
  95.                 }
  96.                 break;
  97.             }
  98.         }
  100.         $name = str_replace('\\', '/', (string) $file);
  102.         return [
  103.             'name' => substr($name, strrpos($name, '/') + 1),
  104.             'file' => $file,
  105.             'line' => $line,
  106.         ];
  107.     }
  108. }