vendor/3slab/vdm-library-bundle/EventSubscriber/Trace/TraceAddEnterSubscriber.php line 59

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\Trace;
  11. use Symfony\Component\Messenger\Envelope;
  12. use Vdm\Bundle\LibraryBundle\Event\CollectWorkerMessageReceivedEvent;
  13. use Vdm\Bundle\LibraryBundle\Model\Trace;
  14. use Psr\Log\LoggerInterface;
  15. use Psr\Log\NullLogger;
  16. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  17. use Symfony\Component\Messenger\Event\WorkerMessageReceivedEvent;
  18. use Vdm\Bundle\LibraryBundle\Model\TraceableMessageInterface;
  20. class TraceAddEnterSubscriber implements EventSubscriberInterface
  21. {
  22.     /**
  23.      * @var string
  24.      */
  25.     private $appName;
  27.     /**
  28.      * @var LoggerInterface
  29.      */
  30.     private $logger;
  32.     /**
  33.      * TraceAddEnterSubscriber constructor.
  34.      *
  35.      * @param string $appName
  36.      * @param LoggerInterface|null $vdmLogger
  37.      */
  38.     public function __construct(string $appName, LoggerInterface $vdmLogger = null)
  39.     {
  40.         $this->appName = $appName;
  41.         $this->logger = $vdmLogger ?? new NullLogger();
  42.     }
  44.     /**
  45.      * Method executed on WorkerMessageReceivedEvent event
  46.      *
  47.      * @param WorkerMessageReceivedEvent $event
  48.      */
  49.     public function onWorkerMessageReceivedEvent(WorkerMessageReceivedEvent $event)
  50.     {
  51.         $this->addEnterTrace($event->getEnvelope());
  52.     }
  54.     /**
  55.      * Method executed on WorkerMessageReceivedEvent event
  56.      *
  57.      * @param CollectWorkerMessageReceivedEvent $event
  58.      */
  59.     public function onCollectWorkerMessageReceivedEvent(CollectWorkerMessageReceivedEvent $event)
  60.     {
  61.         $this->addEnterTrace($event->getEnvelope());
  62.     }
  64.     /**
  65.      * @param Envelope $envelope
  66.      */
  67.     protected function addEnterTrace(Envelope $envelope)
  68.     {
  69.         $message = $envelope->getMessage();
  70.         if (!$message instanceof TraceableMessageInterface) {
  71.             $this->logger->debug(
  72.                 'Trace {traceType} not added as message does not implement TraceableMessageInterface',
  73.                 ['traceType' => Trace::ENTER]
  74.             );
  75.             return;
  76.         }
  78.         $message->addTrace(new Trace($this->appName, Trace::ENTER));
  80.         $this->logger->debug('Trace {traceType} added to message with name {traceName}', [
  81.             'traceName' => $this->appName,
  82.             'traceType' => Trace::ENTER
  83.         ]);
  84.     }
  86.     /**
  87.      * {@inheritDoc}
  88.      * @codeCoverageIgnore
  89.      */
  90.     public static function getSubscribedEvents(): array
  91.     {
  92.         return [
  93.             CollectWorkerMessageReceivedEvent::class => 'onCollectWorkerMessageReceivedEvent',
  94.             WorkerMessageReceivedEvent::class => 'onWorkerMessageReceivedEvent',
  95.         ];
  96.     }
  97. }