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

Open in your IDE?
  1. <?php
  3. namespace Shapecode\Bundle\CronBundle\EventListener;
  5. use Shapecode\Bundle\CronBundle\Event\LoadJobsEvent;
  6. use Shapecode\Bundle\CronBundle\Model\CronJobMetadata;
  7. use Symfony\Component\Console\Command\Command;
  8. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  10. /**
  11.  * Class ServiceJobLoaderListener
  12.  *
  13.  * @package Shapecode\Bundle\CronBundle\EventListener
  14.  * @author  Nikita Loges
  15.  */
  16. class ServiceJobLoaderListener implements EventSubscriberInterface
  17. {
  19.     /** @var CronJobMetadata[] */
  20.     protected $jobs = [];
  22.     /**
  23.      * @param string      $expression
  24.      * @param Command     $command
  25.      * @param null|string $arguments
  26.      */
  27.     public function addCommand(string $expression, Command $command, ?string $arguments = null): void
  28.     {
  29.         $this->jobs[] = CronJobMetadata::createByCommand($expression, $command, $arguments);
  30.     }
  32.     /**
  33.      * @inheritdoc
  34.      */
  35.     public static function getSubscribedEvents()
  36.     {
  37.         return [
  38.             LoadJobsEvent::NAME => 'onLoadJobs'
  39.         ];
  40.     }
  42.     /**
  43.      * @param LoadJobsEvent $event
  44.      */
  45.     public function onLoadJobs(LoadJobsEvent $event): void
  46.     {
  47.         foreach ($this->jobs as $job) {
  48.             $event->addJob($job);
  49.         }
  50.     }
  51. }