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

Open in your IDE?
  1. <?php
  3. namespace DsWebCrawlerBundle\EventSubscriber;
  5. use DsWebCrawlerBundle\DsWebCrawlerBundle;
  6. use DsWebCrawlerBundle\DsWebCrawlerEvents;
  7. use DynamicSearchBundle\DynamicSearchEvents;
  8. use DynamicSearchBundle\Event\ErrorEvent;
  9. use DynamicSearchBundle\EventDispatcher\DynamicSearchEventDispatcherInterface;
  10. use DynamicSearchBundle\Logger\LoggerInterface;
  11. use DynamicSearchBundle\Normalizer\Resource\ResourceMetaInterface;
  12. use Symfony\Contracts\EventDispatcher\Event;
  13. use Symfony\Component\EventDispatcher\GenericEvent;
  14. use VDB\Spider\Event\SpiderEvents;
  16. class AbortEventSubscriber implements EventSubscriberInterface
  17. {
  18.     protected bool $dispatched;
  19.     protected string $contextName;
  20.     protected string $contextDispatchType;
  21.     protected string $crawlType;
  22.     protected ?ResourceMetaInterface $resourceMeta = null;
  23.     protected LoggerInterface $logger;
  24.     protected DynamicSearchEventDispatcherInterface $eventDispatcher;
  26.     public function __construct(DynamicSearchEventDispatcherInterface $eventDispatcher)
  27.     {
  28.         $this->dispatched = false;
  29.         $this->eventDispatcher = $eventDispatcher;
  30.     }
  32.     public function setContextName(string $contextName): void
  33.     {
  34.         $this->contextName = $contextName;
  35.     }
  37.     public function setContextDispatchType(string $contextDispatchType): void
  38.     {
  39.         $this->contextDispatchType = $contextDispatchType;
  40.     }
  42.     public function setCrawlType(string $crawlType): void
  43.     {
  44.         $this->crawlType = $crawlType;
  45.     }
  47.     public function setResourceMeta(?ResourceMetaInterface $resourceMeta): void
  48.     {
  49.         $this->resourceMeta = $resourceMeta;
  50.     }
  52.     public function setLogger(LoggerInterface $logger): void
  53.     {
  54.         $this->logger = $logger;
  55.     }
  57.     public static function getSubscribedEvents(): array
  58.     {
  59.         return [
  60.             SpiderEvents::SPIDER_CRAWL_USER_STOPPED  => 'stoppedCrawler',
  61.             DsWebCrawlerEvents::DS_WEB_CRAWLER_ERROR => 'errorCrawler',
  62.         ];
  63.     }
  65.     public function stoppedCrawler(Event $event): void
  66.     {
  67.         // only trigger once.
  68.         if ($this->dispatched === true) {
  69.             return;
  70.         }
  72.         $this->dispatched = true;
  73.         $newDataEvent = new ErrorEvent($this->contextName, 'crawler has been stopped by user', DsWebCrawlerBundle::PROVIDER_NAME);
  74.         $this->eventDispatcher->dispatch($newDataEvent, DynamicSearchEvents::ERROR_DISPATCH_ABORT);
  75.     }
  77.     public function errorCrawler(GenericEvent $event): void
  78.     {
  79.         // only trigger once.
  80.         if ($this->dispatched === true) {
  81.             return;
  82.         }
  84.         $this->dispatched = true;
  85.         $errorEvent = new ErrorEvent($this->contextName, $event->getArgument('message'), DsWebCrawlerBundle::PROVIDER_NAME, $event->getArgument('exception'));
  86.         $this->eventDispatcher->dispatch($errorEvent, DynamicSearchEvents::ERROR_DISPATCH_CRITICAL);
  87.     }
  88. }