vendor/zenstruck/schedule-bundle/src/EventListener/TaskConfigurationSubscriber.php line 44

Open in your IDE?
  1. <?php
  3. /*
  4.  * This file is part of the zenstruck/schedule-bundle package.
  5.  *
  6.  * (c) Kevin Bond <kevinbond@gmail.com>
  7.  *
  8.  * For the full copyright and license information, please view the LICENSE
  9.  * file that was distributed with this source code.
  10.  */
  12. namespace Zenstruck\ScheduleBundle\EventListener;
  14. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  15. use Zenstruck\ScheduleBundle\Event\BuildScheduleEvent;
  16. use Zenstruck\ScheduleBundle\Schedule;
  17. use Zenstruck\ScheduleBundle\Schedule\Task;
  18. use Zenstruck\ScheduleBundle\Schedule\Task\CommandTask;
  19. use Zenstruck\ScheduleBundle\Schedule\Task\CompoundTask;
  20. use Zenstruck\ScheduleBundle\Schedule\Task\PingTask;
  21. use Zenstruck\ScheduleBundle\Schedule\Task\ProcessTask;
  23. /**
  24.  * @author Kevin Bond <kevinbond@gmail.com>
  25.  */
  26. final class TaskConfigurationSubscriber implements EventSubscriberInterface
  27. {
  28.     private const PROCESS_TASK_PREFIX = 'bash:';
  29.     private const PING_TASK_PREFIX = 'ping:';
  31.     /** @var array */
  32.     private $config;
  34.     public function __construct(array $config)
  35.     {
  36.         $this->config = $config;
  37.     }
  39.     public static function getSubscribedEvents(): array
  40.     {
  41.         return [BuildScheduleEvent::class => 'configureTasks'];
  42.     }
  44.     public function configureTasks(BuildScheduleEvent $event): void
  45.     {
  46.         foreach ($this->config as $taskConfig) {
  47.             $this->addTask($event->getSchedule(), $taskConfig);
  48.         }
  49.     }
  51.     private function addTask(Schedule $schedule, array $config): void
  52.     {
  53.         $task = $this->createTask($config['task']);
  55.         $task->cron($config['frequency']);
  57.         if ($config['description']) {
  58.             $task->description($config['description']);
  59.         }
  61.         if ($config['timezone']) {
  62.             $task->timezone($config['timezone']);
  63.         }
  65.         if ($config['without_overlapping']['enabled']) {
  66.             $task->withoutOverlapping($config['without_overlapping']['ttl']);
  67.         }
  69.         if ($config['only_between']['enabled']) {
  70.             $task->onlyBetween($config['only_between']['start'], $config['only_between']['end']);
  71.         }
  73.         if ($config['unless_between']['enabled']) {
  74.             $task->unlessBetween($config['unless_between']['start'], $config['unless_between']['end']);
  75.         }
  77.         if ($config['ping_before']['enabled']) {
  78.             $task->pingBefore($config['ping_before']['url'], $config['ping_before']['method'], $config['ping_before']['options']);
  79.         }
  81.         if ($config['ping_after']['enabled']) {
  82.             $task->pingAfter($config['ping_after']['url'], $config['ping_after']['method'], $config['ping_after']['options']);
  83.         }
  85.         if ($config['ping_on_success']['enabled']) {
  86.             $task->pingOnSuccess($config['ping_on_success']['url'], $config['ping_on_success']['method'], $config['ping_on_success']['options']);
  87.         }
  89.         if ($config['ping_on_failure']['enabled']) {
  90.             $task->pingOnFailure($config['ping_on_failure']['url'], $config['ping_on_failure']['method'], $config['ping_on_failure']['options']);
  91.         }
  93.         if ($config['email_after']['enabled']) {
  94.             $task->emailAfter($config['email_after']['to'], $config['email_after']['subject']);
  95.         }
  97.         if ($config['email_on_failure']['enabled']) {
  98.             $task->emailOnFailure($config['email_on_failure']['to'], $config['email_on_failure']['subject']);
  99.         }
  101.         $schedule->add($task);
  102.     }
  104.     private function createTask(array $commands): Task
  105.     {
  106.         if (1 === \count($commands)) {
  107.             return self::createSingleTask(\array_values($commands)[0]);
  108.         }
  110.         $task = new CompoundTask();
  112.         foreach ($commands as $description => $command) {
  113.             $subTask = self::createSingleTask($command);
  115.             if (!\is_numeric($description)) {
  116.                 $subTask->description($description);
  117.             }
  119.             $task->add($subTask);
  120.         }
  122.         return $task;
  123.     }
  125.     private static function createSingleTask(string $command): Task
  126.     {
  127.         if (0 === \mb_strpos($command, self::PROCESS_TASK_PREFIX)) {
  128.             return new ProcessTask(self::removePrefix($command, self::PROCESS_TASK_PREFIX));
  129.         }
  131.         if (0 === \mb_strpos($command, self::PING_TASK_PREFIX)) {
  132.             return new PingTask(self::removePrefix($command, self::PING_TASK_PREFIX));
  133.         }
  135.         return new CommandTask($command);
  136.     }
  138.     private static function removePrefix(string $value, string $prefix): string
  139.     {
  140.         return \trim(\mb_substr($value, \mb_strlen($prefix)));
  141.     }
  142. }