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

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. use function assert;
  17. use function is_string;
  19. final class AnnotationJobLoaderListener implements EventSubscriberInterface
  20. {
  21.     private Application $application;
  23.     private Reader $reader;
  25.     public function __construct(KernelInterface $kernel, Reader $reader)
  26.     {
  27.         $this->application = new Application($kernel);
  28.         $this->reader      = $reader;
  29.     }
  31.     /**
  32.      * @inheritdoc
  33.      */
  34.     public static function getSubscribedEvents(): array
  35.     {
  36.         return [LoadJobsEvent::NAME => 'onLoadJobs'];
  37.     }
  39.     public function onLoadJobs(LoadJobsEvent $event): void
  40.     {
  41.         foreach ($this->application->all() as $command) {
  42.             // Check for an @CronJob annotation
  43.             $reflectionClass = new ReflectionClass($command);
  45.             foreach ($this->reader->getClassAnnotations($reflectionClass) as $annotation) {
  46.                 if (! ($annotation instanceof CronJob)) {
  47.                     continue;
  48.                 }
  50.                 $arguments    = $annotation->arguments;
  51.                 $maxInstances = $annotation->maxInstances;
  52.                 $schedule     = $annotation->value;
  53.                 assert(is_string($schedule));
  55.                 $meta = CronJobMetadata::createByCommand($schedule, $command, $arguments, $maxInstances);
  56.                 $event->addJob($meta);
  57.             }
  58.         }
  59.     }
  60. }