vendor/3slab/vdm-library-bundle/EventSubscriber/PrintMessage/PrintMessageSubscriber.php line 78

Open in your IDE?
  1. <?php
  3. /**
  4.  * @package    3slab/VdmLibraryBundle
  5.  * @copyright  2020 Suez Smart Solutions 3S.lab
  6.  * @license    https://github.com/3slab/VdmLibraryBundle/blob/master/LICENSE
  7.  */
  9. namespace Vdm\Bundle\LibraryBundle\EventSubscriber\PrintMessage;
  11. use Psr\Log\LoggerInterface;
  12. use Psr\Log\NullLogger;
  13. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. use Symfony\Component\Messenger\Envelope;
  15. use Symfony\Component\Messenger\Event\SendMessageToTransportsEvent;
  16. use Symfony\Component\Messenger\Event\WorkerMessageReceivedEvent;
  17. use Vdm\Bundle\LibraryBundle\Event\CollectWorkerMessageReceivedEvent;
  19. /**
  20.  * Class PrintMessageSubscriber
  21.  * @package Vdm\Bundle\LibraryBundle\EventSubscriber\PrintMessage
  22.  */
  23. class PrintMessageSubscriber implements EventSubscriberInterface
  24. {
  25.     /**
  26.      * @var bool
  27.      */
  28.     protected $printMsg;
  30.     /**
  31.      * @var bool
  32.      */
  33.     protected $logMsg;
  35.     /**
  36.      * @var LoggerInterface
  37.      */
  38.     protected $logger;
  40.     /**
  41.      * PrintMessageSubscriber constructor.
  42.      * @param bool $printMsg
  43.      * @param bool $logMsg
  44.      * @param LoggerInterface|null $vdmLogger
  45.      */
  46.     public function __construct(bool $printMsg = false, bool $logMsg = false, LoggerInterface $vdmLogger = null)
  47.     {
  48.         $this->printMsg = $printMsg;
  49.         $this->logMsg = $logMsg;
  50.         $this->logger = $vdmLogger ?? new NullLogger();
  51.     }
  53.     /**
  54.      * Method executed on CollectWorkerMessageReceivedEvent event
  55.      *
  56.      * @param CollectWorkerMessageReceivedEvent $event
  57.      */
  58.     public function onCollectWorkerMessageReceivedEvent(CollectWorkerMessageReceivedEvent $event)
  59.     {
  60.         $this->printMessageInEnvelope($event->getEnvelope(), 'message_received');
  61.     }
  63.     /**
  64.      * Method executed on WorkerMessageReceivedEvent event
  65.      *
  66.      * @param WorkerMessageReceivedEvent $event
  67.      */
  68.     public function onWorkerMessageReceivedEvent(WorkerMessageReceivedEvent $event)
  69.     {
  70.         $this->printMessageInEnvelope($event->getEnvelope(), 'message_received');
  71.     }
  73.     /**
  74.      * Method executed on SendMessageToTransportsEvent event
  75.      *
  76.      * @param SendMessageToTransportsEvent $event
  77.      */
  78.     public function onSendMessageToTransportEvent(SendMessageToTransportsEvent $event)
  79.     {
  80.         $this->printMessageInEnvelope($event->getEnvelope(), 'message_sent');
  81.     }
  83.     /**
  84.      * @param Envelope $envelope
  85.      * @param string|null $eventName
  86.      */
  87.     public function printMessageInEnvelope(Envelope $envelope, string $eventName)
  88.     {
  89.         $message = $envelope->getMessage();
  91.         $headerTitle = '---- dumping message ' . $eventName . ' ----';
  92.         $dashLine = '';
  93.         for ($i = 0; $i < strlen($headerTitle); $i++) {
  94.             $dashLine .= '-';
  95.         }
  97.         if ($this->printMsg) {
  98.             echo PHP_EOL;
  99.             echo $dashLine . PHP_EOL;
  100.             echo $headerTitle . PHP_EOL;
  101.             echo $dashLine . PHP_EOL;
  102.             dump($message);
  103.             echo $dashLine . PHP_EOL;
  104.             echo $dashLine . PHP_EOL;
  105.             echo PHP_EOL;
  106.         }
  108.         if ($this->logMsg) {
  109.             $this->logger->debug('{message}', ['message' => $message]);
  110.         }
  111.     }
  113.     /**
  114.      * {@inheritDoc}
  115.      * @codeCoverageIgnore
  116.      */
  117.     public static function getSubscribedEvents(): array
  118.     {
  119.         // Ensure that this subscriber run before/after all the others
  120.         return [
  121.             CollectWorkerMessageReceivedEvent::class => ['onCollectWorkerMessageReceivedEvent', 9999],
  122.             WorkerMessageReceivedEvent::class => ['onWorkerMessageReceivedEvent', 9999],
  123.             SendMessageToTransportsEvent::class => ['onSendMessageToTransportEvent', -9999],
  124.         ];
  125.     }
  126. }