src/EventSubscriber/CommandStartEventSubscriber.php line 59

Open in your IDE?
  1. <?php
  3. namespace App\EventSubscriber;
  5. use App\Command\Impl\AbstractCronCommand;
  6. use App\Entity\CronJob;
  7. use App\Entity\CronLog;
  8. use App\Exception\CommandRuntimeException;
  9. use App\Service\CronJobService;
  10. use App\Service\Utils\CommandLocker;
  11. use App\Service\Utils\CommandUniquenessKeyGenerator;
  12. use Doctrine\Persistence\ManagerRegistry;
  13. use Exception;
  14. use Psr\Log\LoggerInterface;
  15. use Symfony\Component\Console\Command\LockableTrait;
  16. use Symfony\Component\Console\ConsoleEvents;
  17. use Symfony\Component\Console\Event\ConsoleCommandEvent;
  18. use Symfony\Component\Console\Style\SymfonyStyle;
  19. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  20. use Symfony\Component\HttpFoundation\Response;
  21. use Symfony\Component\HttpFoundation\Session\SessionInterface;
  22. use Symfony\Component\HttpKernel\Event\ResponseEvent;
  23. use Symfony\Component\HttpKernel\KernelEvents;
  25. /**
  26.  * Auto flushes objects before HTTP responses
  27.  */
  28. class CommandStartEventSubscriber implements EventSubscriberInterface
  29. {
  31.     /** @var CronJobService $cronLogger The logger for commands */
  32.     private CronJobService $cronLogger;
  33.     /** @var SessionInterface $session */
  34.     private SessionInterface $session;
  35.     /** @var CommandLocker $commandLocker */
  36.     private CommandLocker $commandLocker;
  38.     /**
  39.      * @param CronJobService $cronLogger
  40.      * @param SessionInterface $session
  41.      * @param CommandLocker $commandLocker
  42.      */
  43.     public function __construct(CronJobService $cronLogger, SessionInterface $session, CommandLocker $commandLocker)
  44.     {
  45.         $this->cronLogger = $cronLogger;
  46.         $this->session = $session;
  47.         $this->commandLocker = $commandLocker;
  48.     }
  51.     /** @inheritdoc */
  52.     public static function getSubscribedEvents()
  53.     {
  54.         return [
  55.             ConsoleEvents::COMMAND => ['commandStart', 1024]
  56.         ];
  57.     }
  59.     public function commandStart(ConsoleCommandEvent $event): void
  60.     {
  61.         if ($event->getCommand() instanceof AbstractCronCommand) {
  62.             $this->session->set(CommandUniquenessKeyGenerator::generateForStartTime(), microtime(true));
  64.             $inputString = $event->getInput()->__toString();
  66.             $log = $this->cronLogger->openLog($event->getCommand(), $inputString);
  67.             $this->session->set(CommandUniquenessKeyGenerator::generate(), $log->getId());
  70.             if (false === $this->commandLocker->lockCommand($inputString)) {
  71.                 throw new CommandRuntimeException('Command already running !', CronLog::SKIPPED);
  72.             }
  74.             $io = new SymfonyStyle($event->getInput(), $event->getOutput());
  75.             $io->info(sprintf('Command %s at %s', $inputString, (new \DateTime())->format('y-m-d H:i:s.u')));
  76.         }
  77.     }
  78. }