vendor/dachcom-digital/dynamic-search/src/DynamicSearchBundle/EventSubscriber/DataProcessingEventSubscriber.php line 40

Open in your IDE?
  1. <?php
  3. namespace DynamicSearchBundle\EventSubscriber;
  5. use DynamicSearchBundle\Builder\ContextDefinitionBuilderInterface;
  6. use DynamicSearchBundle\DynamicSearchEvents;
  7. use DynamicSearchBundle\Event\NewDataEvent;
  8. use DynamicSearchBundle\Logger\LoggerInterface;
  9. use DynamicSearchBundle\Processor\ResourceModificationProcessorInterface;
  10. use DynamicSearchBundle\Provider\DataProviderInterface;
  11. use DynamicSearchBundle\Validator\ResourceValidatorInterface;
  12. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  14. class DataProcessingEventSubscriber implements EventSubscriberInterface
  15. {
  16.     protected LoggerInterface $logger;
  17.     protected ContextDefinitionBuilderInterface $contextDefinitionBuilder;
  18.     protected ResourceModificationProcessorInterface $resourceModificationProcessor;
  19.     protected ResourceValidatorInterface $resourceValidator;
  21.     public function __construct(
  22.         LoggerInterface $logger,
  23.         ContextDefinitionBuilderInterface $contextDefinitionBuilder,
  24.         ResourceModificationProcessorInterface $resourceModificationProcessor,
  25.         ResourceValidatorInterface $resourceValidator
  26.     ) {
  27.         $this->logger = $logger;
  28.         $this->contextDefinitionBuilder = $contextDefinitionBuilder;
  29.         $this->resourceModificationProcessor = $resourceModificationProcessor;
  30.         $this->resourceValidator = $resourceValidator;
  31.     }
  33.     public static function getSubscribedEvents(): array
  34.     {
  35.         return [
  36.             DynamicSearchEvents::NEW_DATA_AVAILABLE => ['dispatchResourceModification'],
  37.         ];
  38.     }
  40.     public function dispatchResourceModification(NewDataEvent $event): void
  41.     {
  42.         $contextDefinition = $this->contextDefinitionBuilder->buildContextDefinition($event->getContextName(), $event->getContextDispatchType());
  44.         try {
  45.             // validate and allow rewriting resource based on current data behaviour
  46.             $isImmutableResource = $event->getProviderBehaviour() === DataProviderInterface::PROVIDER_BEHAVIOUR_SINGLE_DISPATCH;
  47.             $resourceCandidate = $this->resourceValidator->validateResource($event->getContextName(), $event->getContextDispatchType(), false, $isImmutableResource, $event->getData());
  48.         } catch (\Throwable $e) {
  49.             $this->logger->error(
  50.                 sprintf(
  51.                     'Error while validate resource candidate: %s',
  52.                     $e->getMessage()), $contextDefinition->getDataProviderName(), $event->getContextName()
  53.             );
  55.             return;
  56.         }
  58.         if ($resourceCandidate->getResource() === null) {
  59.             $this->logger->debug(
  60.                 sprintf(
  61.                     'Resource has been removed due to validation. Skipping...'),
  62.                 $contextDefinition->getDataProviderName(), $contextDefinition->getName()
  63.             );
  65.             return;
  66.         }
  68.         if ($event->getProviderBehaviour() === DataProviderInterface::PROVIDER_BEHAVIOUR_FULL_DISPATCH) {
  69.             $this->resourceModificationProcessor->process($contextDefinition, $resourceCandidate->getResource());
  70.         } elseif ($event->getProviderBehaviour() === DataProviderInterface::PROVIDER_BEHAVIOUR_SINGLE_DISPATCH) {
  71.             $this->resourceModificationProcessor->processByResourceMeta($contextDefinition, $event->getResourceMeta(), $event->getData());
  72.         } else {
  73.             $this->logger->error(
  74.                 sprintf('Invalid provider behaviour "%s". Cannot dispatch resource processor', $event->getProviderBehaviour()),
  75.                 $contextDefinition->getDataProviderName(), $event->getContextName()
  76.             );
  77.         }
  78.     }
  79. }