src/Core/Domain/Infrastructure/Handler.php line 43

  1. <?php
  3.     namespace App\Core\Domain\Infrastructure;
  5.     use Symfony\Component\Messenger\Exception\HandlerFailedException;
  6.     use Symfony\Component\Messenger\Exception\LogicException;
  7.     use Symfony\Component\Messenger\Exception\RuntimeException;
  8.     use Symfony\Component\Messenger\MessageBusInterface;
  9.     use Symfony\Component\Messenger\Stamp\HandledStamp;
  11.     /**
  12.      * Class Handler
  13.      * @package App\Core\Infrastructure
  14.      */
  15.     final class Handler implements HandlerInterface
  16.     {
  18.         /**
  19.          * @param MessageBusInterface $messageBus
  20.          */
  21.         public function __construct(
  22.             protected MessageBusInterface $messageBus,
  23.         )
  24.         {
  25.         }
  27.         /**
  28.          * @param object $message
  29.          *
  30.          * @return mixed
  31.          * @throws \Throwable
  32.          * @see \Symfony\Component\Messenger\HandleTrait
  33.          */
  34.         public function handle(object $message): mixed
  35.         {
  37.             if (!$this->messageBus instanceof MessageBusInterface) {
  38.                 throw new LogicException(sprintf('You must provide a "%s" instance in the "%s::$messageBus" property, "%s" given.', MessageBusInterface::class, static::class, get_debug_type($this->messageBus)));
  39.             }
  41.             try
  42.             {
  43.                 $envelope = $this->messageBus->dispatch($message);
  44.             }
  45.             catch (HandlerFailedException $handlerFailedException)
  46.             {
  48.                 $current = \current($handlerFailedException->getNestedExceptions());
  50.                 if($current->getPrevious()?->getPrevious() instanceof \Exception)
  51.                 {
  52.                     throw $current->getPrevious()->getPrevious();
  53.                 }
  55.                 if($current->getPrevious() instanceof \Exception)
  56.                 {
  57.                     throw $current->getPrevious();
  58.                 }
  60.                 throw $current;
  61.             }
  63.             /** @var HandledStamp[] $handledStamps */
  64.             $handledStamps = $envelope->all(HandledStamp::class);
  66.             if (!$handledStamps) {
  67.                 throw new LogicException(sprintf('Message of type "%s" was handled zero times. Exactly one handler is expected when using "%s::%s()".', get_debug_type($envelope->getMessage()), static::class, __FUNCTION__));
  68.             }
  70.             if (\count($handledStamps) > 1) {
  71.                 $handlers = implode(', ', array_map(function (HandledStamp $stamp): string {
  72.                     return sprintf('"%s"', $stamp->getHandlerName());
  73.                 }, $handledStamps));
  75.                 throw new LogicException(sprintf('Message of type "%s" was handled multiple times. Only one handler is expected when using "%s::%s()", got %d: %s.', get_debug_type($envelope->getMessage()), static::class, __FUNCTION__, \count($handledStamps), $handlers));
  76.             }
  78.             return $handledStamps[0]->getResult();
  79.         }
  81.         /**
  82.          * @param object $message
  83.          *
  84.          * @return \Symfony\Component\Messenger\Envelope
  85.          */
  86.         public function dispatch(object $message): \Symfony\Component\Messenger\Envelope
  87.         {
  88.             return $this->messageBus->dispatch($message);
  89.         }
  90.     }