vendor/shapecode/cron-bundle/src/EventListener/AnnotationJobLoaderListener.php line 40

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace Shapecode\Bundle\CronBundle\EventListener;
  7. use Doctrine\Common\Annotations\Reader;
  8. use ReflectionClass;
  9. use Shapecode\Bundle\CronBundle\Annotation\CronJob;
  10. use Shapecode\Bundle\CronBundle\Event\LoadJobsEvent;
  11. use Shapecode\Bundle\CronBundle\Model\CronJobMetadata;
  12. use Symfony\Bundle\FrameworkBundle\Console\Application;
  13. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. use Symfony\Component\HttpKernel\KernelInterface;
  16. final class AnnotationJobLoaderListener implements EventSubscriberInterface
  17. {
  18.     /** @var Application */
  19.     private $application;
  21.     /** @var Reader */
  22.     private $reader;
  24.     public function __construct(KernelInterface $kernel, Reader $reader)
  25.     {
  26.         $this->application = new Application($kernel);
  27.         $this->reader      = $reader;
  28.     }
  30.     /**
  31.      * @inheritDoc
  32.      */
  33.     public static function getSubscribedEvents() : array
  34.     {
  35.         return [
  36.             LoadJobsEvent::NAME => 'onLoadJobs',
  37.         ];
  38.     }
  40.     public function onLoadJobs(LoadJobsEvent $event) : void
  41.     {
  42.         foreach ($this->application->all() as $command) {
  43.             // Check for an @CronJob annotation
  44.             $reflClass = new ReflectionClass($command);
  46.             foreach ($this->reader->getClassAnnotations($reflClass) as $annotation) {
  47.                 if (! ($annotation instanceof CronJob)) {
  48.                     continue;
  49.                 }
  51.                 $schedule     = $annotation->value;
  52.                 $arguments    = $annotation->arguments;
  53.                 $maxInstances = $annotation->maxInstances;
  55.                 $meta = CronJobMetadata::createByCommand($schedule, $command, $arguments, $maxInstances);
  56.                 $event->addJob($meta);
  57.             }
  58.         }
  59.     }
  60. }