vendor/zenstruck/schedule-bundle/src/EventListener/SelfSchedulingCommandSubscriber.php line 32

Open in your IDE?
  1. <?php
  3. namespace Zenstruck\ScheduleBundle\EventListener;
  5. use Symfony\Component\Console\Command\Command;
  6. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  7. use Zenstruck\ScheduleBundle\Event\BuildScheduleEvent;
  8. use Zenstruck\ScheduleBundle\Schedule\SelfSchedulingCommand;
  9. use Zenstruck\ScheduleBundle\Schedule\Task\CommandTask;
  11. /**
  12.  * @author Kevin Bond <kevinbond@gmail.com>
  13.  */
  14. final class SelfSchedulingCommandSubscriber implements EventSubscriberInterface
  15. {
  16.     /** @var iterable<SelfSchedulingCommand> */
  17.     private $commands;
  19.     /**
  20.      * @param iterable<SelfSchedulingCommand> $commands
  21.      */
  22.     public function __construct(iterable $commands)
  23.     {
  24.         $this->commands = $commands;
  25.     }
  27.     public static function getSubscribedEvents(): array
  28.     {
  29.         return [BuildScheduleEvent::class => 'build'];
  30.     }
  32.     public function build(BuildScheduleEvent $event): void
  33.     {
  34.         foreach ($this->commands as $command) {
  35.             if (!$command instanceof Command) {
  36.                 throw new \InvalidArgumentException(\sprintf('"%s" is not a console command. "%s" can only be used on commands.', \get_class($command), SelfSchedulingCommand::class));
  37.             }
  39.             $task = new CommandTask((string) $command->getName());
  41.             $command->schedule($task);
  43.             $event->getSchedule()->add($task);
  44.         }
  45.     }
  46. }