vendor/symfony/messenger/Handler/HandlersLocator.php line 38

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\Handler;
  14. use Symfony\Component\Messenger\Envelope;
  15. use Symfony\Component\Messenger\Stamp\ReceivedStamp;
  17. /**
  18.  * Maps a message to a list of handlers.
  19.  *
  20.  * @author Nicolas Grekas <p@tchwork.com>
  21.  * @author Samuel Roze <samuel.roze@gmail.com>
  22.  */
  23. class HandlersLocator implements HandlersLocatorInterface
  24. {
  25.     private $handlers;
  27.     /**
  28.      * @param HandlerDescriptor[][]|callable[][] $handlers
  29.      */
  30.     public function __construct(array $handlers)
  31.     {
  32.         $this->handlers = $handlers;
  33.     }
  35.     /**
  36.      * {@inheritdoc}
  37.      */
  38.     public function getHandlers(Envelope $envelope): iterable
  39.     {
  40.         $seen = [];
  42.         foreach (self::listTypes($envelope) as $type) {
  43.             foreach ($this->handlers[$type] ?? [] as $handlerDescriptor) {
  44.                 if (\is_callable($handlerDescriptor)) {
  45.                     $handlerDescriptor = new HandlerDescriptor($handlerDescriptor);
  46.                 }
  48.                 if (!$this->shouldHandle($envelope, $handlerDescriptor)) {
  49.                     continue;
  50.                 }
  52.                 $name = $handlerDescriptor->getName();
  53.                 if (\in_array($name, $seen)) {
  54.                     continue;
  55.                 }
  57.                 $seen[] = $name;
  59.                 yield $handlerDescriptor;
  60.             }
  61.         }
  62.     }
  64.     /**
  65.      * @internal
  66.      */
  67.     public static function listTypes(Envelope $envelope): array
  68.     {
  69.         $class = \get_class($envelope->getMessage());
  71.         return [$class => $class]
  72.             + class_parents($class)
  73.             + class_implements($class)
  74.             + ['*' => '*'];
  75.     }
  77.     private function shouldHandle(Envelope $envelope, HandlerDescriptor $handlerDescriptor): bool
  78.     {
  79.         if (null === $received = $envelope->last(ReceivedStamp::class)) {
  80.             return true;
  81.         }
  83.         if (null === $expectedTransport = $handlerDescriptor->getOption('from_transport')) {
  84.             return true;
  85.         }
  87.         return $received->getTransportName() === $expectedTransport;
  88.     }
  89. }