vendor/shapecode/cron-bundle/src/EventListener/ServiceJobLoaderListener.php line 34

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace Shapecode\Bundle\CronBundle\EventListener;
  7. use Shapecode\Bundle\CronBundle\Event\LoadJobsEvent;
  8. use Shapecode\Bundle\CronBundle\Model\CronJobMetadata;
  9. use Symfony\Component\Console\Command\Command;
  10. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  12. final class ServiceJobLoaderListener implements EventSubscriberInterface
  13. {
  14.     /** @var CronJobMetadata[] */
  15.     private array $jobs = [];
  17.     public function addCommand(
  18.         string $expression,
  19.         Command $command,
  20.         ?string $arguments = null,
  21.         int $maxInstances = 1
  22.     ): void {
  23.         $this->jobs[] = CronJobMetadata::createByCommand($expression, $command, $arguments, $maxInstances);
  24.     }
  26.     /**
  27.      * @return array<string, string>
  28.      */
  29.     public static function getSubscribedEvents(): array
  30.     {
  31.         return [LoadJobsEvent::NAME => 'onLoadJobs'];
  32.     }
  34.     public function onLoadJobs(LoadJobsEvent $event): void
  35.     {
  36.         foreach ($this->jobs as $job) {
  37.             $event->addJob($job);
  38.         }
  39.     }
  40. }