vendor/dachcom-digital/dynamic-search-data-provider-crawler/src/DsWebCrawlerBundle/EventSubscriber/NotifyEventSubscriber.php line 60

Open in your IDE?
  1. <?php
  3. namespace DsWebCrawlerBundle\EventSubscriber;
  5. use DsWebCrawlerBundle\DsWebCrawlerEvents;
  6. use DynamicSearchBundle\DynamicSearchEvents;
  7. use DynamicSearchBundle\Event\NewDataEvent;
  8. use DynamicSearchBundle\EventDispatcher\DynamicSearchEventDispatcherInterface;
  9. use DynamicSearchBundle\Logger\LoggerInterface;
  10. use DynamicSearchBundle\Normalizer\Resource\ResourceMetaInterface;
  11. use Symfony\Component\EventDispatcher\GenericEvent;
  12. use VDB\Spider\Resource;
  14. class NotifyEventSubscriber implements EventSubscriberInterface
  15. {
  16.     protected string $contextName;
  17.     protected string $contextDispatchType;
  18.     protected string $crawlType;
  19.     protected ?ResourceMetaInterface $resourceMeta = null;
  20.     protected LoggerInterface $logger;
  21.     protected DynamicSearchEventDispatcherInterface $eventDispatcher;
  23.     public function __construct(DynamicSearchEventDispatcherInterface $eventDispatcher)
  24.     {
  25.         $this->eventDispatcher = $eventDispatcher;
  26.     }
  28.     public function setContextName(string $contextName): void
  29.     {
  30.         $this->contextName = $contextName;
  31.     }
  33.     public function setContextDispatchType(string $contextDispatchType): void
  34.     {
  35.         $this->contextDispatchType = $contextDispatchType;
  36.     }
  38.     public function setCrawlType(string $crawlType): void
  39.     {
  40.         $this->crawlType = $crawlType;
  41.     }
  43.     public function setResourceMeta(?ResourceMetaInterface $resourceMeta): void
  44.     {
  45.         $this->resourceMeta = $resourceMeta;
  46.     }
  48.     public function setLogger(LoggerInterface $logger): void
  49.     {
  50.         $this->logger = $logger;
  51.     }
  53.     public static function getSubscribedEvents(): array
  54.     {
  55.         return [
  56.             DsWebCrawlerEvents::DS_WEB_CRAWLER_VALID_RESOURCE_DOWNLOADED => 'notifyPersisted',
  57.         ];
  58.     }
  60.     public function notifyPersisted(GenericEvent $event): void
  61.     {
  62.         /** @var \SplFileObject $resource */
  63.         $resource = $event->getArgument('resource');
  65.         if (!file_exists($resource->getRealPath())) {
  66.             return;
  67.         }
  69.         $resourceContent = file_get_contents($resource->getRealPath());
  71.         $rawContent = unserialize($resourceContent);
  73.         if (!$rawContent instanceof Resource) {
  74.             return;
  75.         }
  77.         $newDataEvent = new NewDataEvent($this->contextDispatchType, $this->contextName, $rawContent, $this->crawlType, $this->resourceMeta);
  79.         $this->eventDispatcher->dispatch($newDataEvent, DynamicSearchEvents::NEW_DATA_AVAILABLE);
  80.     }
  81. }