src/Base/EventSubscriber/QuerySubscriber.php line 42

Open in your IDE?
  1. <?php
  3. declare(strict_types=1);
  5. namespace App\Base\EventSubscriber;
  7. use App\Base\Service\AbstractQueryService;
  8. use Doctrine\Common\Collections\ArrayCollection;
  9. use Pimcore\Bundle\DataHubBundle\Event\GraphQL\Model\QueryTypeEvent;
  10. use Pimcore\Bundle\DataHubBundle\Event\GraphQL\QueryEvents;
  11. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  13. class QuerySubscriber implements EventSubscriberInterface
  14. {
  15.     /**
  16.      * @var ArrayCollection|null
  17.      */
  18.     private ArrayCollection|null $serviceContainer;
  20.     /**
  21.      * QuerySubscriber constructor.
  22.      */
  23.     public function __construct()
  24.     {
  25.         $this->serviceContainer = new ArrayCollection();
  26.     }
  28.     /**
  29.      * @return string[]
  30.      */
  31.     public static function getSubscribedEvents()
  32.     {
  33.         return [
  34.             QueryEvents::PRE_BUILD => 'onPreBuild',
  35.         ];
  36.     }
  38.     /**
  39.      * @param QueryTypeEvent $event
  40.      * @throws \Exception
  41.      */
  42.     public function onPreBuild(QueryTypeEvent $event): void
  43.     {
  44.         $config = $event->getConfig();
  46.         foreach ($this->serviceContainer->getValues() as $service) {
  47.             /** @var AbstractQueryService $service */
  48.             $class = new \ReflectionClass($service);
  49.             foreach ($class->getMethods(\ReflectionMethod::IS_PUBLIC) as $method) {
  50.                 $name = $method->getName();
  51.                 if (str_starts_with($name, 'query')) {
  52.                     $queryName = lcfirst(substr($name, 5));
  53.                     $config['fields'][$queryName] = $service->getByName($queryName, $event);
  54.                 }
  55.             }
  56.         }
  58.         $event->setConfig($config);
  59.     }
  60. }