Chris@0: <?php
Chris@0: 
Chris@0: namespace Drupal\aggregator;
Chris@0: 
Chris@0: use Drupal\aggregator\Plugin\AggregatorPluginManager;
Chris@0: use Drupal\Component\Plugin\Exception\PluginException;
Chris@0: use Drupal\Core\Config\ConfigFactoryInterface;
Chris@0: use Psr\Log\LoggerInterface;
Chris@0: 
Chris@0: /**
Chris@0:  * Defines an importer of aggregator items.
Chris@0:  */
Chris@0: class ItemsImporter implements ItemsImporterInterface {
Chris@0: 
Chris@0:   /**
Chris@0:    * The aggregator fetcher manager.
Chris@0:    *
Chris@0:    * @var \Drupal\aggregator\Plugin\AggregatorPluginManager
Chris@0:    */
Chris@0:   protected $fetcherManager;
Chris@0: 
Chris@0:   /**
Chris@0:    * The aggregator processor manager.
Chris@0:    *
Chris@0:    * @var \Drupal\aggregator\Plugin\AggregatorPluginManager
Chris@0:    */
Chris@0:   protected $processorManager;
Chris@0: 
Chris@0:   /**
Chris@0:    * The aggregator parser manager.
Chris@0:    *
Chris@0:    * @var \Drupal\aggregator\Plugin\AggregatorPluginManager
Chris@0:    */
Chris@0:   protected $parserManager;
Chris@0: 
Chris@0:   /**
Chris@0:    * The aggregator.settings config object.
Chris@0:    *
Chris@0:    * @var \Drupal\Core\Config\Config
Chris@0:    */
Chris@0:   protected $config;
Chris@0: 
Chris@0:   /**
Chris@0:    * A logger instance.
Chris@0:    *
Chris@0:    * @var \Psr\Log\LoggerInterface
Chris@0:    */
Chris@0:   protected $logger;
Chris@0: 
Chris@0:   /**
Chris@0:    * Constructs an Importer object.
Chris@0:    *
Chris@0:    * @param \Drupal\Core\Config\ConfigFactoryInterface $config_factory
Chris@0:    *   The factory for configuration objects.
Chris@0:    * @param \Drupal\aggregator\Plugin\AggregatorPluginManager $fetcher_manager
Chris@0:    *   The aggregator fetcher plugin manager.
Chris@0:    * @param \Drupal\aggregator\Plugin\AggregatorPluginManager $parser_manager
Chris@0:    *   The aggregator parser plugin manager.
Chris@0:    * @param \Drupal\aggregator\Plugin\AggregatorPluginManager $processor_manager
Chris@0:    *   The aggregator processor plugin manager.
Chris@0:    * @param \Psr\Log\LoggerInterface $logger
Chris@0:    *   A logger instance.
Chris@0:    */
Chris@0:   public function __construct(ConfigFactoryInterface $config_factory, AggregatorPluginManager $fetcher_manager, AggregatorPluginManager $parser_manager, AggregatorPluginManager $processor_manager, LoggerInterface $logger) {
Chris@0:     $this->fetcherManager = $fetcher_manager;
Chris@0:     $this->processorManager = $processor_manager;
Chris@0:     $this->parserManager = $parser_manager;
Chris@0:     $this->config = $config_factory->get('aggregator.settings');
Chris@0:     $this->logger = $logger;
Chris@0:   }
Chris@0: 
Chris@0:   /**
Chris@0:    * {@inheritdoc}
Chris@0:    */
Chris@0:   public function delete(FeedInterface $feed) {
Chris@0:     foreach ($this->processorManager->getDefinitions() as $id => $definition) {
Chris@0:       $this->processorManager->createInstance($id)->delete($feed);
Chris@0:     }
Chris@0:   }
Chris@0: 
Chris@0:   /**
Chris@0:    * {@inheritdoc}
Chris@0:    */
Chris@0:   public function refresh(FeedInterface $feed) {
Chris@0:     // Store feed URL to track changes.
Chris@0:     $feed_url = $feed->getUrl();
Chris@0: 
Chris@0:     // Fetch the feed.
Chris@0:     try {
Chris@0:       $success = $this->fetcherManager->createInstance($this->config->get('fetcher'))->fetch($feed);
Chris@0:     }
Chris@0:     catch (PluginException $e) {
Chris@0:       $success = FALSE;
Chris@0:       watchdog_exception('aggregator', $e);
Chris@0:     }
Chris@0: 
Chris@17:     // Store instances in an array so we don't have to instantiate new objects.
Chris@0:     $processor_instances = [];
Chris@0:     foreach ($this->config->get('processors') as $processor) {
Chris@0:       try {
Chris@0:         $processor_instances[$processor] = $this->processorManager->createInstance($processor);
Chris@0:       }
Chris@0:       catch (PluginException $e) {
Chris@0:         watchdog_exception('aggregator', $e);
Chris@0:       }
Chris@0:     }
Chris@0: 
Chris@0:     // We store the hash of feed data in the database. When refreshing a
Chris@0:     // feed we compare stored hash and new hash calculated from downloaded
Chris@0:     // data. If both are equal we say that feed is not updated.
Chris@0:     $hash = hash('sha256', $feed->source_string);
Chris@0:     $has_new_content = $success && ($feed->getHash() != $hash);
Chris@0: 
Chris@0:     if ($has_new_content) {
Chris@0:       // Parse the feed.
Chris@0:       try {
Chris@0:         if ($this->parserManager->createInstance($this->config->get('parser'))->parse($feed)) {
Chris@0:           if (!$feed->getWebsiteUrl()) {
Chris@0:             $feed->setWebsiteUrl($feed->getUrl());
Chris@0:           }
Chris@0:           $feed->setHash($hash);
Chris@0:           // Update feed with parsed data.
Chris@0:           $feed->save();
Chris@0: 
Chris@0:           // Log if feed URL has changed.
Chris@0:           if ($feed->getUrl() != $feed_url) {
Chris@0:             $this->logger->notice('Updated URL for feed %title to %url.', ['%title' => $feed->label(), '%url' => $feed->getUrl()]);
Chris@0:           }
Chris@0: 
Chris@0:           $this->logger->notice('There is new syndicated content from %site.', ['%site' => $feed->label()]);
Chris@0: 
Chris@0:           // If there are items on the feed, let enabled processors process them.
Chris@0:           if (!empty($feed->items)) {
Chris@0:             foreach ($processor_instances as $instance) {
Chris@0:               $instance->process($feed);
Chris@0:             }
Chris@0:           }
Chris@0:         }
Chris@0:       }
Chris@0:       catch (PluginException $e) {
Chris@0:         watchdog_exception('aggregator', $e);
Chris@0:       }
Chris@0:     }
Chris@0: 
Chris@0:     // Processing is done, call postProcess on enabled processors.
Chris@0:     foreach ($processor_instances as $instance) {
Chris@0:       $instance->postProcess($feed);
Chris@0:     }
Chris@0: 
Chris@0:     return $has_new_content;
Chris@0:   }
Chris@0: 
Chris@0: }