vendor/ibexa/cron/src/bundle/Registry/CronJobsRegistry.php line 53

Open in your IDE?
  1. <?php
  3. /**
  4. * @copyright Copyright (C) Ibexa AS. All rights reserved.
  5. * @license For full copyright and license information view LICENSE file distributed with this source code.
  6. */
  7. namespace Ibexa\Bundle\Cron\Registry;
  9. use Cron\Job\ShellJob;
  10. use Cron\Schedule\CrontabSchedule;
  11. use Ibexa\Core\MVC\Symfony\SiteAccess;
  12. use Symfony\Component\Console\Command\Command;
  13. use Symfony\Component\Process\PhpExecutableFinder;
  15. class CronJobsRegistry
  16. {
  17. public const DEFAULT_CATEGORY = 'default';
  19. /**
  20. * @var array
  21. */
  22. protected $cronJobs = [];
  24. /**
  25. * @var false|string
  26. */
  27. protected $executable;
  29. /**
  30. * @var string
  31. */
  32. protected $environment;
  34. /**
  35. * @var \Ibexa\Core\MVC\Symfony\SiteAccess
  36. */
  37. protected $siteaccess;
  39. /**
  40. * @var string
  41. */
  42. protected $options;
  44. public function __construct(string $environment, SiteAccess $siteaccess)
  45. {
  46. $finder = new PhpExecutableFinder();
  48. $this->executable = $finder->find();
  49. $this->environment = $environment;
  50. $this->siteaccess = $siteaccess;
  51. }
  53. public function addCronJob(Command $command, string $schedule = null, string $category = self::DEFAULT_CATEGORY, string $options = ''): void
  54. {
  55. $command = sprintf(
  56. '%s %s %s %s --siteaccess=%s --env=%s',
  57. $this->executable,
  58. $_SERVER['SCRIPT_NAME'],
  59. $command->getName(),
  60. $options,
  61. $this->siteaccess->name,
  62. $this->environment
  63. );
  65. $job = new ShellJob();
  66. $job->setSchedule(new CrontabSchedule($schedule));
  67. $job->setCommand($command);
  69. $this->cronJobs[$category][] = $job;
  70. }
  72. /**
  73. * @return \Cron\Job\ShellJob[]
  74. */
  75. public function getCategoryCronJobs(string $category): array
  76. {
  77. if (!isset($this->cronJobs[$category])) {
  78. return [];
  79. }
  81. return $this->cronJobs[$category];
  82. }
  83. }
  85. class_alias(CronJobsRegistry::class, 'EzSystems\EzPlatformCronBundle\Registry\CronJobsRegistry');