vendor/3slab/vdm-library-bundle/EventSubscriber/Trace/TraceAddExitSubscriber.php line 47

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 Vdm\Bundle\LibraryBundle\Model\Trace;
  12. use Psr\Log\LoggerInterface;
  13. use Psr\Log\NullLogger;
  14. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  15. use Symfony\Component\Messenger\Event\SendMessageToTransportsEvent;
  16. use Vdm\Bundle\LibraryBundle\Model\TraceableMessageInterface;
  18. class TraceAddExitSubscriber implements EventSubscriberInterface
  19. {
  20.     /**
  21.      * @var string
  22.      */
  23.     private $appName;
  25.     /**
  26.      * @var LoggerInterface|null
  27.      */
  28.     private $logger;
  30.     /**
  31.      * TraceAddExitSubscriber constructor.
  32.      *
  33.      * @param string $appName
  34.      * @param LoggerInterface|null $vdmLogger
  35.      */
  36.     public function __construct(string $appName, LoggerInterface $vdmLogger = null)
  37.     {
  38.         $this->appName = $appName;
  39.         $this->logger = $vdmLogger ?? new NullLogger();
  40.     }
  42.     /**
  43.      * Method executed on SendMessageToTransportsEvent event
  44.      *
  45.      * @param SendMessageToTransportsEvent $event
  46.      */
  47.     public function onSendMessageToTransportEvent(SendMessageToTransportsEvent $event)
  48.     {
  49.         $message = $event->getEnvelope()->getMessage();
  50.         if (!$message instanceof TraceableMessageInterface) {
  51.             $this->logger->debug(
  52.                 'Trace {traceType} not added as message does not implement TraceableMessageInterface',
  53.                 ['traceType' => Trace::ENTER]
  54.             );
  55.             return;
  56.         }
  58.         $message->addTrace(new Trace($this->appName, Trace::EXIT));
  60.         $this->logger->debug('Trace {traceType} added to message with name {traceName}', [
  61.             'traceName' => $this->appName,
  62.             'traceType' => Trace::EXIT
  63.         ]);
  64.     }
  66.     /**
  67.      * {@inheritDoc}
  68.      * @codeCoverageIgnore
  69.      */
  70.     public static function getSubscribedEvents()
  71.     {
  72.         return [
  73.             SendMessageToTransportsEvent::class => 'onSendMessageToTransportEvent',
  74.         ];
  75.     }
  76. }