vendor/3slab/vdm-library-bundle/EventSubscriber/Monitoring/MonitoringWorkerStoppedSubscriber.php line 64

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\Monitoring;
  11. use Psr\Log\NullLogger;
  12. use Symfony\Component\Messenger\Event\WorkerStoppedEvent;
  13. use Vdm\Bundle\LibraryBundle\Event\CollectWorkerStoppedEvent;
  14. use Vdm\Bundle\LibraryBundle\Monitoring\Model\RunningStat;
  15. use Vdm\Bundle\LibraryBundle\Service\Monitoring\Monitoring;
  16. use Vdm\Bundle\LibraryBundle\Service\Monitoring\MonitoringService;
  17. use Psr\Log\LoggerInterface;
  18. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  20. /**
  21.  * Class MonitoringWorkerStoppedSubscriber
  22.  *
  23.  * @package Vdm\Bundle\LibraryBundle\EventSubscriber\Monitoring
  24.  */
  25. class MonitoringWorkerStoppedSubscriber implements EventSubscriberInterface
  26. {
  27.     /**
  28.      * @var MonitoringService
  29.      */
  30.     protected $monitoring;
  32.     /**
  33.      * @var LoggerInterface
  34.      */
  35.     protected $logger;
  37.     /**
  38.      * MonitoringWorkerTerminateSubscriber constructor.
  39.      *
  40.      * @param MonitoringService $monitoring
  41.      * @param LoggerInterface|null $vdmLogger
  42.      */
  43.     public function __construct(MonitoringService $monitoring, LoggerInterface $vdmLogger = null)
  44.     {
  45.         $this->monitoring = $monitoring;
  46.         $this->logger = $vdmLogger ?? new NullLogger();
  47.     }
  49.     /**
  50.      * Method executed on ConsoleTerminateEvent event
  51.      *
  52.      * @param WorkerStoppedEvent $event
  53.      */
  54.     public function onWorkerStoppedEvent(WorkerStoppedEvent $event)
  55.     {
  56.         $this->handleMonitoring();
  57.     }
  59.     /**
  60.      * Method executed on CollectWorkerStoppedEvent event
  61.      *
  62.      * @param WorkerStoppedEvent $event
  63.      */
  64.     public function onCollectWorkerStoppedEvent(CollectWorkerStoppedEvent $event)
  65.     {
  66.         $this->handleMonitoring();
  67.     }
  69.     /**
  70.      * Set worker stopped state and flush monitoring stat to storage
  71.      */
  72.     protected function handleMonitoring()
  73.     {
  74.         $this->monitoring->update(Monitoring::RUNNING_STAT, 0);
  75.         $this->logger->debug('worker stopped metric sent');
  77.         $this->monitoring->flush();
  78.         $this->logger->debug('metric storage flushed');
  79.     }
  81.     /**
  82.      * {@inheritDoc}
  83.      * @codeCoverageIgnore
  84.      */
  85.     public static function getSubscribedEvents(): array
  86.     {
  87.         return [
  88.             WorkerStoppedEvent::class => 'onWorkerStoppedEvent',
  89.             CollectWorkerStoppedEvent::class => 'onCollectWorkerStoppedEvent',
  90.         ];
  91.     }
  92. }