vendor/symfony/messenger/TraceableMessageBus.php line 38

  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.     public function dispatch(object $message, array $stamps = []): Envelope
  28.     {
  29.         $envelope = Envelope::wrap($message, $stamps);
  30.         $context = [
  31.             'stamps' => array_merge([], ...array_values($envelope->all())),
  32.             'message' => $envelope->getMessage(),
  33.             'caller' => $this->getCaller(),
  34.             'callTime' => microtime(true),
  35.         ];
  37.         try {
  38.             return $envelope = $this->decoratedBus->dispatch($message, $stamps);
  39.         } catch (\Throwable $e) {
  40.             $context['exception'] = $e;
  42.             throw $e;
  43.         } finally {
  44.             $this->dispatchedMessages[] = $context + ['stamps_after_dispatch' => array_merge([], ...array_values($envelope->all()))];
  45.         }
  46.     }
  48.     public function getDispatchedMessages(): array
  49.     {
  50.         return $this->dispatchedMessages;
  51.     }
  53.     public function reset()
  54.     {
  55.         $this->dispatchedMessages = [];
  56.     }
  58.     private function getCaller(): array
  59.     {
  60.         $trace = debug_backtrace(\DEBUG_BACKTRACE_IGNORE_ARGS, 8);
  62.         $file = $trace[1]['file'] ?? null;
  63.         $line = $trace[1]['line'] ?? null;
  65.         $handleTraitFile = (new \ReflectionClass(HandleTrait::class))->getFileName();
  66.         $found = false;
  67.         for ($i = 1; $i < 8; ++$i) {
  68.             if (isset($trace[$i]['file'], $trace[$i + 1]['file'], $trace[$i + 1]['line']) && $trace[$i]['file'] === $handleTraitFile) {
  69.                 $file = $trace[$i + 1]['file'];
  70.                 $line = $trace[$i + 1]['line'];
  71.                 $found = true;
  73.                 break;
  74.             }
  75.         }
  77.         for ($i = 2; $i < 8 && !$found; ++$i) {
  78.             if (isset($trace[$i]['class'], $trace[$i]['function'])
  79.                 && 'dispatch' === $trace[$i]['function']
  80.                 && is_a($trace[$i]['class'], MessageBusInterface::class, true)
  81.             ) {
  82.                 $file = $trace[$i]['file'];
  83.                 $line = $trace[$i]['line'];
  85.                 while (++$i < 8) {
  86.                     if (isset($trace[$i]['function'], $trace[$i]['file']) && empty($trace[$i]['class']) && !str_starts_with($trace[$i]['function'], 'call_user_func')) {
  87.                         $file = $trace[$i]['file'];
  88.                         $line = $trace[$i]['line'];
  90.                         break;
  91.                     }
  92.                 }
  93.                 break;
  94.             }
  95.         }
  97.         $name = str_replace('\\', '/', (string) $file);
  99.         return [
  100.             'name' => substr($name, strrpos($name, '/') + 1),
  101.             'file' => $file,
  102.             'line' => $line,
  103.         ];
  104.     }
  105. }