src/Hitso/Bundle/CommonBundle/EventListener/CronListener.php line 87

Open in your IDE?
  1. <?php
  2. declare(strict_types=1);
  3. /**
  4.  * @author Maciej Kaczmarek <maciej.kaczmarek@autentika.pl>
  5.  */
  7. namespace Hitso\Bundle\CommonBundle\EventListener;
  9. use Hitso\Bundle\CommonBundle\Entity\CronLog;
  10. use Hitso\Bundle\CommonBundle\Manager\CronLogManager;
  11. use Symfony\Component\Console\ConsoleEvents;
  12. use Symfony\Component\Console\Event\ConsoleEvent;
  13. use Symfony\Component\Console\Event\ConsoleTerminateEvent;
  14. use Symfony\Component\Console\Input\InputOption;
  15. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  17. class CronListener implements EventSubscriberInterface
  18. {
  19.     /**
  20.      * @var int
  21.      */
  22.     private $startTime;
  24.     /**
  25.      * @var CronLogManager
  26.      */
  27.     private $manager;
  29.     /**
  30.      * @var CronLog
  31.      */
  32.     private $log;
  34.     /**
  35.      * @var string
  36.      */
  37.     private $env;
  39.     /**
  40.      * @var int
  41.      */
  42.     private $ttl;
  44.     public function __construct(CronLogManager $manager, $env, $ttl)
  45.     {
  46.         $this->manager = $manager;
  47.         $this->env     = $env;
  48.         $this->ttl     = $ttl;
  49.     }
  51.     /**
  52.      * {@inheritdoc}
  53.      */
  54.     public static function getSubscribedEvents()
  55.     {
  56.         return [
  57.             ConsoleEvents::COMMAND   => 'onCommand',
  58.             ConsoleEvents::TERMINATE => 'onCommandTerminate',
  59.         ];
  60.     }
  62.     public function onCommand(ConsoleEvent $event)
  63.     {
  64.         $event->getCommand()->addOption(
  65.             'cron',
  66.             null,
  67.             InputOption::VALUE_NONE,
  68.             'Mark as CRON command and log its execution status.'
  69.         );
  71.         $input = $event->getInput();
  73.         if (!$input->hasParameterOption('--cron')) {
  74.             return;
  75.         }
  77.         $log = $this->log = $this->manager->initResource();
  78.         $log->setCommand($input->getFirstArgument());
  79.         $log->setFullCommand((string) $input);
  80.         $log->setEnv($this->env);
  81.         $log->setStartedAt(new \DateTime());
  83.         $this->manager->createResource($log);
  84.         $this->startTime = microtime(true);
  85.     }
  87.     public function onCommandTerminate(ConsoleTerminateEvent $event)
  88.     {
  89.         if (!$event->getInput()->hasOption('cron') || !$event->getInput()->getOption('cron')) {
  90.             return;
  91.         }
  93.         $time   = microtime(true) - $this->startTime;
  94.         $memory = memory_get_peak_usage(true);
  96.         $this->log->setFinishedAt(new \DateTime())->setRunningTime($time)->setMemoryUsage($memory)->setExitCode(
  97.             $event->getExitCode()
  98.         );
  100.         $this->manager->updateResource($this->log);
  101.         $this->manager->getRepository()->gc($this->ttl);
  103.         $this->log       = null;
  104.         $this->startTime = null;
  105.     }
  106. }