UpdateCronHooks.php

<?php

declare (strict_types=1);
namespace Drupal\update\Hook;

use Drupal\Component\Datetime\TimeInterface;
use Drupal\Core\Config\ConfigFactoryInterface;
use Drupal\Core\Extension\ModuleHandlerInterface;
use Drupal\Core\Extension\Requirement\RequirementSeverity;
use Drupal\Core\Hook\Attribute\Hook;
use Drupal\Core\State\StateInterface;
use Drupal\update\MailHandler;
use Drupal\update\UpdateManagerInterface;
use Drupal\update\UpdateProcessorInterface;
use Symfony\Component\DependencyInjection\Attribute\AutowireServiceClosure;

/**
 * Hook implementations for update.
 */
class UpdateCronHooks {
  public function __construct(protected readonly ConfigFactoryInterface $configFactory, protected readonly ModuleHandlerInterface $moduleHandler, protected readonly StateInterface $state, protected readonly TimeInterface $time, #[AutowireServiceClosure(MailHandler::class)] protected readonly \Closure $mailHandler, #[AutowireServiceClosure(UpdateManagerInterface::class)] protected readonly \Closure $updateManager, #[AutowireServiceClosure(UpdateProcessorInterface::class)] protected readonly \Closure $updateProcessor) {
  }
  
  /**
   * Implements hook_cron().
   */
  public function cron() : void {
    $update_config = $this->configFactory
      ->get('update.settings');
    $frequency = $update_config->get('check.interval_days');
    $interval = 60 * 60 * 24 * $frequency;
    $last_check = $this->state
      ->get('update.last_check', 0);
    $request_time = $this->time
      ->getRequestTime();
    if ($request_time - $last_check > $interval) {
      // If the configured update interval has elapsed, we want to invalidate
      // the data for all projects, attempt to re-fetch, and trigger any
      // configured notifications about the new status.
      ($this->updateManager)()
        ->refreshUpdateData();
      ($this->updateProcessor)()
        ->fetchData();
    }
    else {
      // Otherwise, see if any individual projects are now stale or still
      // missing data, and if so, try to fetch the data.
      update_get_available(TRUE);
    }
    $last_email_notice = $this->state
      ->get('update.last_email_notification', 0);
    if ($request_time - $last_email_notice > $interval) {
      // If configured time between notifications elapsed, send email about
      // updates possibly available.
      if ($this->notify()) {
        // Track when the last mail was successfully sent to avoid sending
        // too many emails.
        $this->state
          ->set('update.last_email_notification', $request_time);
      }
    }
  }
  
  /**
   * Performs any notifications that should be done once cron fetches new data.
   *
   * This method checks the status of the site using the new data and, depending
   * on the configuration of the site, notifies administrators via email if
   * there are new releases or missing security updates.
   *
   * @return bool
   *   TRUE if any notifications were sent, otherwise FALSE.
   *
   * @see Drupal\update\Hook\UpdateRequirements::runtime()
   */
  protected function notify() : bool {
    $update_config = $this->configFactory
      ->get('update.settings');
    $notify_all = $update_config->get('notification.threshold') == 'all';
    $recipients = $update_config->get('notification.emails');
    if (empty($recipients)) {
      return FALSE;
    }
    $status = $this->moduleHandler
      ->invoke('update', 'runtime_requirements');
    $items = [];
    foreach ([
      'core',
      'contrib',
    ] as $report_type) {
      $type = 'update_' . $report_type;
      if (isset($status[$type]['severity']) && ($status[$type]['severity'] == RequirementSeverity::Error || $notify_all && $status[$type]['reason'] == UpdateManagerInterface::NOT_CURRENT)) {
        $items[$report_type] = $status[$type]['reason'];
      }
    }
    if (empty($items)) {
      return FALSE;
    }
    return ($this->mailHandler)()
      ->sendUpdateNotifications($recipients, $items);
  }

}