src/Core/Framework/MessageQueue/Subscriber/PluginLifecycleSubscriber.php line 36

  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\Framework\MessageQueue\Subscriber;
  5. use Psr\Cache\CacheItemPoolInterface;
  6. use Shopware\Core\Framework\Log\Package;
  7. use Shopware\Core\Framework\MessageQueue\ScheduledTask\Registry\TaskRegistry;
  8. use Shopware\Core\Framework\Plugin\Event\PluginPostActivateEvent;
  9. use Shopware\Core\Framework\Plugin\Event\PluginPostDeactivateEvent;
  10. use Shopware\Core\Framework\Plugin\Event\PluginPostUpdateEvent;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. use Symfony\Component\Messenger\EventListener\StopWorkerOnRestartSignalListener;
  14. /**
  15.  * @internal
  16.  */
  17. #[Package('system-settings')]
  18. final class PluginLifecycleSubscriber implements EventSubscriberInterface
  19. {
  20.     /**
  21.      * @internal
  22.      */
  23.     public function __construct(private readonly TaskRegistry $registry, private readonly CacheItemPoolInterface $restartSignalCachePool)
  24.     {
  25.     }
  27.     public static function getSubscribedEvents(): array
  28.     {
  29.         return [
  30.             PluginPostActivateEvent::class => 'afterPluginStateChange',
  31.             PluginPostDeactivateEvent::class => 'afterPluginStateChange',
  32.             PluginPostUpdateEvent::class => 'afterPluginStateChange',
  33.         ];
  34.     }
  36.     public function afterPluginStateChange(): void
  37.     {
  38.         $this->registry->registerTasks();
  40.         // signal worker restart
  41.         $cacheItem = $this->restartSignalCachePool->getItem(StopWorkerOnRestartSignalListener::RESTART_REQUESTED_TIMESTAMP_KEY);
  42.         $cacheItem->set(microtime(true));
  43.         $this->restartSignalCachePool->save($cacheItem);
  44.     }
  45. }