src/Messenger/EventListener/StopWorkerIfRebuildStartedListener.php line 38

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.     /**
  28.      * @return array<string, string>
  29.      */
  30.     public static function getSubscribedEvents()
  31.     {
  32.         return [
  33.             WorkerStartedEvent::class => 'onWorkerStarted',
  34.             WorkerRunningEvent::class => 'onWorkerRunning', // Bulletproofing, rebuild will request workers stop itself
  35.         ];
  36.     }
  38.     public function onWorkerStarted(WorkerStartedEvent $event): void
  39.     {
  40.         try {
  41.             $this->rebuildFlag->check();
  42.         } catch (RebuildInProgressException $e) {
  43.             if ($this->logger) {
  44.                 $this->logger->warning('Rebuild in progress, stopping');
  45.             }
  46.             $event->getWorker()->stop();
  47.         }
  48.     }
  50.     public function onWorkerRunning(WorkerRunningEvent $event): void
  51.     {
  52.         try {
  53.             $this->rebuildFlag->check();
  54.         } catch (RebuildInProgressException $e) {
  55.             if ($this->logger) {
  56.                 $this->logger->warning('Rebuild in progress, stopping');
  57.             }
  58.             $event->getWorker()->stop();
  59.         }
  60.     }
  61. }