src/EventSubscriber/CommandSignalEventSubscriber.php line 57

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber;
  5. use App\Command\Impl\AbstractCronCommand;
  6. use App\Entity\CronLog;
  7. use App\Service\CronJobService;
  8. use App\Service\Utils\CommandLocker;
  9. use App\Service\Utils\CommandUniquenessKeyGenerator;
  10. use App\Service\Utils\FlushService;
  11. use Doctrine\Persistence\ManagerRegistry;
  12. use Exception;
  13. use Psr\Log\LoggerInterface;
  14. use Symfony\Component\Console\ConsoleEvents;
  15. use Symfony\Component\Console\Event\ConsoleSignalEvent;
  16. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  17. use Symfony\Component\HttpFoundation\Response;
  18. use Symfony\Component\HttpFoundation\Session\SessionInterface;
  19. use Symfony\Component\HttpKernel\Event\ResponseEvent;
  20. use Symfony\Component\HttpKernel\KernelEvents;
  22. /**
  23.  * Auto flushes objects before HTTP responses
  24.  */
  25. class CommandSignalEventSubscriber implements EventSubscriberInterface {
  27.     /** @var CronJobService $cronJobService The logger for commands */
  28.     private CronJobService $cronJobService;
  30.     /** @var SessionInterface $session */
  31.     private SessionInterface $session;
  33.     private CommandLocker $commandLocker;
  35.     private LoggerInterface $logger;
  37.     /**
  38.      * @param CronJobService $cronJobService
  39.      * @param SessionInterface $session
  40.      * @param CommandLocker $commandLocker
  41.      */
  42.     public function __construct(LoggerInterface $logger, CronJobService $cronJobService, SessionInterface $session, CommandLocker $commandLocker)
  43.     {
  44.         $this->cronJobService = $cronJobService;
  45.         $this->session = $session;
  46.         $this->commandLocker = $commandLocker;
  47.         $this->logger = $logger;
  48.     }
  50.     /** @inheritdoc */
  51.     public static function getSubscribedEvents() {
  52.         return [
  53.             ConsoleEvents::SIGNAL => ['commandSignal', 1024]
  54.         ];
  55.     }
  57.     public function commandSignal(ConsoleSignalEvent $event): void
  58.     {
  59.         if ($event->getCommand() instanceof AbstractCronCommand) {
  61.             // gets the signal number
  62.             $signal = $event->getHandlingSignal();
  64.             if (SIGINT === $signal || SIGTERM === $signal) {
  65.                 $uniquenessKey = CommandUniquenessKeyGenerator::generate();
  66.                 $log = $this->cronJobService->findById($this->session->get($uniquenessKey, -1));
  68.                 $this->cronJobService->closeLog($log, CronLog::INTERRUPTED);
  70.                 $this->commandLocker->releaseCommand();
  71.             }
  72.         }
  74.     }
  76. }