src/EventSubscriber/CommandTerminateEventSubscriber.php line 58

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber;
  5. use App\Command\Impl\AbstractCronCommand;
  6. use App\Entity\CronLog;
  7. use App\Exception\CommandRuntimeException;
  8. use App\Service\CronJobService;
  9. use App\Service\Utils\CommandLocker;
  10. use App\Service\Utils\CommandUniquenessKeyGenerator;
  11. use App\Service\Utils\FlushService;
  12. use Psr\Log\LoggerInterface;
  13. use Symfony\Component\Console\ConsoleEvents;
  14. use Symfony\Component\Console\Event\ConsoleTerminateEvent;
  15. use Symfony\Component\Console\Style\SymfonyStyle;
  16. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  17. use Symfony\Component\HttpFoundation\Session\SessionInterface;
  19. /**
  20.  * Auto flushes objects before HTTP responses
  21.  */
  22. class CommandTerminateEventSubscriber implements EventSubscriberInterface
  23. {
  24.     /** @var CronJobService $cronJobService The logger for commands */
  25.     private CronJobService $cronJobService;
  27.     /** @var FlushService $flushService */
  28.     private FlushService $flushService;
  30.     /** @var SessionInterface $session */
  31.     private SessionInterface $session;
  33.     private CommandLocker $commandLocker;
  35.     /**
  36.      * @param LoggerInterface $logger
  37.      * @param CronJobService $cronJobService
  38.      * @param FlushService $flushService
  39.      * @param SessionInterface $session
  40.      * @param CommandLocker $commandLocker
  41.      */
  42.     public function __construct(CronJobService $cronJobService, FlushService $flushService, SessionInterface $session, CommandLocker $commandLocker)
  43.     {
  44.         $this->cronJobService = $cronJobService;
  45.         $this->flushService = $flushService;
  46.         $this->session = $session;
  47.         $this->commandLocker = $commandLocker;
  48.     }
  50.     /** @inheritdoc */
  51.     public static function getSubscribedEvents()
  52.     {
  53.         return [
  54.             ConsoleEvents::TERMINATE => ['commandTerminate', 1024]
  55.         ];
  56.     }
  58.     public function commandTerminate(ConsoleTerminateEvent $event): void
  59.     {
  60.         if ($event->getCommand() instanceof AbstractCronCommand) {
  62.             $io = new SymfonyStyle($event->getInput(), $event->getOutput());
  64.             $exitCode = $event->getExitCode();
  66.             $flushed = $this->flushService->flushForCommand($event);
  68.             if ($flushed === false) {
  69.                 $event->setExitCode(98);
  70.                 $io->error("Error when flushing.");
  71.             }
  73.             $uniquenessKey = CommandUniquenessKeyGenerator::generate();
  74.             $log = $this->cronJobService->findById($this->session->get($uniquenessKey, -1));
  76.             if ($log === null) {
  77.                 $io->error(sprintf("Cannot find log with key %s", $uniquenessKey));
  78.                 throw new CommandRuntimeException();
  79.             } else {
  80.                 $this->cronJobService->closeLog($log, match ($exitCode) {
  81.                     0 => CronLog::SUCCESS,
  82.                     CronLog::SKIPPED => Cronlog::SKIPPED,
  83.                     CronLog::INTERRUPTED => Cronlog::INTERRUPTED,
  84.                     default => CronLog::FAILURE
  85.                 });
  86.             }
  88.             $uniquenessKeyTime = CommandUniquenessKeyGenerator::generateForStartTime();
  89.             $startTime = $this->session->get($uniquenessKeyTime);
  90.             if (is_null($startTime)) {
  91.                 $io->error(sprintf("Cannot find the start time with key %s", $uniquenessKeyTime));
  92.                 throw new CommandRuntimeException();
  93.             }
  95.             $io->info('Total execution time : ' . number_format((microtime(true) - $startTime), 2) . ' seconds.');
  97.             $this->commandLocker->releaseCommand();
  98.         }
  99.     }
  101. }