class CronHookHandler in Entity Share Cron 3.0.x

Hook handler for the cron() hook.

@package Drupal\entity_share_cron\HookHandler

Hierarchy

• class \Drupal\entity_share_cron\HookHandler\CronHookHandler implements ContainerInjectionInterface

3 files declare their use of CronHookHandler

EntityShareCronFunctionalTest.php in tests/src/Functional/EntityShareCronFunctionalTest.php

entity_share_cron.install in ./entity_share_cron.install

entity_share_cron.module in ./entity_share_cron.module

File

src/HookHandler/CronHookHandler.php, line 19

Namespace

Drupal\entity_share_cron\HookHandler

class CronHookHandler implements ContainerInjectionInterface {

  /**
   * The state ID.
   */
  const STATE_ID = 'entity_share_cron.cron_last_run';

  /**
   * The config factory.
   *
   * @var \Drupal\Core\Config\ConfigFactoryInterface
   */
  protected $configFactory;

  /**
   * The state service.
   *
   * @var \Drupal\Core\State\StateInterface
   */
  protected $state;

  /**
   * Logger.
   *
   * @var \Psr\Log\LoggerInterface
   */
  protected $logger;

  /**
   * The entity share cron service.
   *
   * @var \Drupal\entity_share_cron\EntityShareCronServiceInterface
   */
  protected $entityShareCron;

  /**
   * CronHookHandler constructor.
   *
   * @param \Drupal\Core\Config\ConfigFactoryInterface $config_factory
   *   The config factory.
   * @param \Drupal\Core\State\StateInterface $state
   *   The state service.
   * @param \Psr\Log\LoggerInterface $logger
   *   The logger service.
   * @param \Drupal\entity_share_cron\EntityShareCronServiceInterface $entity_share_cron
   *   The entity share cron service.
   */
  public function __construct(ConfigFactoryInterface $config_factory, StateInterface $state, LoggerInterface $logger, EntityShareCronServiceInterface $entity_share_cron) {
    $this->configFactory = $config_factory;
    $this->state = $state;
    $this->logger = $logger;
    $this->entityShareCron = $entity_share_cron;
  }

  /**
   * {@inheritdoc}
   */
  public static function create(ContainerInterface $container) {
    return new static($container
      ->get('config.factory'), $container
      ->get('state'), $container
      ->get('logger.channel.entity_share_cron'), $container
      ->get('entity_share_cron'));
  }

  /**
   * Enqueue channels for import if the new execution interval is reached.
   */
  public function process() {
    $config = $this->configFactory
      ->get('entity_share_cron.settings');
    $now = time();
    $interval = $config
      ->get('cron_interval');
    $last_run = $this->state
      ->get(self::STATE_ID) ? $this->state
      ->get(self::STATE_ID) : -99999;

    // Checks the interval since the last synchronization.
    if ($now < $last_run + $interval) {
      return;
    }

    // Enqueues enabled remotes and channels for synchronization.
    $remotes_config = $config
      ->get('remotes');
    if (is_array($remotes_config)) {
      foreach ($remotes_config as $remote_id => $remote_config) {

        // Checks if synchronization of this remote is enabled.
        if (empty($remote_config['enabled'])) {
          continue;
        }
        $channels_config = isset($remote_config['channels']) ? $remote_config['channels'] : [];
        foreach ($channels_config as $channel_id => $channel_config) {

          // Checks if synchronization of this channel is enabled.
          if ($channel_config['enabled']) {

            // Enqueues the channel for synchronization.
            $this->logger
              ->info('Enqueuing channel %channel_id from remote %remote_id for synchronization.', [
              '%channel_id' => $channel_id,
              '%remote_id' => $remote_id,
            ]);
            $this->entityShareCron
              ->enqueue($remote_id, $channel_id, NULL);
          }
        }
      }
    }

    // Updates last run timestamp.
    $this->state
      ->set(self::STATE_ID, $now);
  }

}

Members

Name	Modifiers	Type	Description	Overrides
CronHookHandler::$configFactory	protected	property	The config factory.
CronHookHandler::$entityShareCron	protected	property	The entity share cron service.
CronHookHandler::$logger	protected	property	Logger.
CronHookHandler::$state	protected	property	The state service.
CronHookHandler::create	public static	function	Instantiates a new instance of this class. Overrides ContainerInjectionInterface::create
CronHookHandler::process	public	function	Enqueue channels for import if the new execution interval is reached.
CronHookHandler::STATE_ID		constant	The state ID.
CronHookHandler::__construct	public	function	CronHookHandler constructor.