vendor/contao/core-bundle/src/EventListener/CommandSchedulerListener.php line 61

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. /*
  6.  * This file is part of Contao.
  7.  *
  8.  * (c) Leo Feyer
  9.  *
  10.  * @license LGPL-3.0-or-later
  11.  */
  13. namespace Contao\CoreBundle\EventListener;
  15. use Contao\Config;
  16. use Contao\CoreBundle\Cron\Cron;
  17. use Contao\CoreBundle\Framework\ContaoFramework;
  18. use Doctrine\DBAL\Connection;
  19. use Doctrine\DBAL\Exception\DriverException;
  20. use Psr\Container\ContainerInterface;
  21. use Symfony\Component\HttpFoundation\Request;
  22. use Symfony\Component\HttpKernel\Event\TerminateEvent;
  23. use Symfony\Contracts\Service\ServiceSubscriberInterface;
  25. /**
  26.  * @internal
  27.  */
  28. class CommandSchedulerListener implements ServiceSubscriberInterface
  29. {
  30.     /**
  31.      * @var ContainerInterface
  32.      */
  33.     private $locator;
  35.     /**
  36.      * @var ContaoFramework
  37.      */
  38.     private $framework;
  40.     /**
  41.      * @var Connection
  42.      */
  43.     private $connection;
  45.     /**
  46.      * @var string
  47.      */
  48.     private $fragmentPath;
  50.     public function __construct(ContainerInterface $locator, ContaoFramework $framework, Connection $connection, string $fragmentPath = '_fragment')
  51.     {
  52.         $this->locator = $locator;
  53.         $this->framework = $framework;
  54.         $this->connection = $connection;
  55.         $this->fragmentPath = $fragmentPath;
  56.     }
  58.     /**
  59.      * Runs the command scheduler.
  60.      */
  61.     public function __invoke(TerminateEvent $event): void
  62.     {
  63.         if ($this->framework->isInitialized() && $this->canRunCron($event->getRequest())) {
  64.             $this->locator->get(Cron::class)->run(Cron::SCOPE_WEB);
  65.         }
  66.     }
  68.     /**
  69.      * Lazy-load services to prevent issues with MySQL server_version.
  70.      *
  71.      * @see https://github.com/contao/contao/pull/3623
  72.      *
  73.      * @return array<string>
  74.      */
  75.     public static function getSubscribedServices(): array
  76.     {
  77.         return [Cron::class];
  78.     }
  80.     private function canRunCron(Request $request): bool
  81.     {
  82.         $pathInfo = $request->getPathInfo();
  84.         // Skip the listener in the install tool and upon fragment URLs
  85.         if (preg_match('~(?:^|/)(?:contao/install$|'.preg_quote($this->fragmentPath, '~').'/)~', $pathInfo)) {
  86.             return false;
  87.         }
  89.         /** @var Config $config */
  90.         $config = $this->framework->getAdapter(Config::class);
  92.         return $config->isComplete() && !$config->get('disableCron') && $this->canRunDbQuery();
  93.     }
  95.     /**
  96.      * Checks if a database connection can be established and the table exist.
  97.      */
  98.     private function canRunDbQuery(): bool
  99.     {
  100.         try {
  101.             return $this->connection->isConnected()
  102.                 && $this->connection->getSchemaManager()->tablesExist(['tl_cron_job']);
  103.         } catch (DriverException $e) {
  104.             return false;
  105.         }
  106.     }
  107. }