src/Messenger/EventListener/StopWorkerIfRebuildStartedListener.php line 47

Open in your IDE?
  1. <?php
  3. /**
  4.  * Copyright (c) 2011-present Qualiteam software Ltd. All rights reserved.
  5.  * See https://www.x-cart.com/license-agreement.html for license details.
  6.  */
  8. namespace XCart\Messenger\EventListener;
  10. use Psr\Log\LoggerInterface;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. use Symfony\Component\Messenger\Event\WorkerRunningEvent;
  13. use Symfony\Component\Messenger\Event\WorkerStartedEvent;
  15. final class StopWorkerIfRebuildStartedListener implements EventSubscriberInterface
  16. {
  17.     private RebuildFlag $rebuildFlag;
  19.     private ?LoggerInterface $logger;
  21.     public function __construct(RebuildFlag $rebuildFlag, LoggerInterface $logger = null)
  22.     {
  23.         $this->rebuildFlag = $rebuildFlag;
  24.         $this->logger      = $logger;
  25.     }
  27.     public static function getSubscribedEvents()
  28.     {
  29.         return [
  30.             WorkerStartedEvent::class => 'onWorkerStarted',
  31.             WorkerRunningEvent::class => 'onWorkerRunning', // Bulletproofing, rebuild will request workers stop itself
  32.         ];
  33.     }
  35.     public function onWorkerStarted(WorkerStartedEvent $event): void
  36.     {
  37.         try {
  38.             $this->rebuildFlag->check();
  39.         } catch (RebuildInProgressException $e) {
  40.             if ($this->logger) {
  41.                 $this->logger->warning('Rebuild in progress, stopping');
  42.             }
  43.             $event->getWorker()->stop();
  44.         }
  45.     }
  47.     public function onWorkerRunning(WorkerRunningEvent $event): void
  48.     {
  49.         try {
  50.             $this->rebuildFlag->check();
  51.         } catch (RebuildInProgressException $e) {
  52.             if ($this->logger) {
  53.                 $this->logger->warning('Rebuild in progress, stopping');
  54.             }
  55.             $event->getWorker()->stop();
  56.         }
  57.     }
  58. }