class ScheduledPublishCron in Scheduled Publish 8

Class ScheduledPublishCron

@package Drupal\scheduled_publish\Service

Hierarchy

• class \Drupal\scheduled_publish\Service\ScheduledPublishCron

2 files declare their use of ScheduledPublishCron

CommonTest.php in tests/src/Kernel/CommonTest.php

scheduled_publish.module in ./scheduled_publish.module

Contains scheduled_publish.module.

1 string reference to 'ScheduledPublishCron'

scheduled_publish.services.yml in ./scheduled_publish.services.yml

scheduled_publish.services.yml

1 service uses ScheduledPublishCron

scheduled_publish.update in ./scheduled_publish.services.yml

Drupal\scheduled_publish\Service\ScheduledPublishCron

File

src/Service/ScheduledPublishCron.php, line 19

Namespace

Drupal\scheduled_publish\Service

class ScheduledPublishCron {

  /**
   * @var EntityTypeBundleInfo
   */
  private $entityBundleInfoService;

  /**
   * @var EntityFieldManager
   */
  private $entityFieldManager;

  /**
   * @var EntityTypeManager
   */
  private $entityTypeManager;

  /**
   * @var Time
   */
  private $dateTime;
  public function __construct(EntityTypeBundleInfoInterface $entityBundleInfo, EntityFieldManagerInterface $entityFieldManager, EntityTypeManagerInterface $entityTypeManager, TimeInterface $dateTime) {
    $this->entityBundleInfoService = $entityBundleInfo;
    $this->entityFieldManager = $entityFieldManager;
    $this->entityTypeManager = $entityTypeManager;
    $this->dateTime = $dateTime;
  }
  public function doUpdate() : void {
    $bundles = $this->entityBundleInfoService
      ->getBundleInfo('node');
    foreach ($bundles as $bundleName => $value) {
      $scheduledFields = $this
        ->getScheduledFields($bundleName);
      if (\count($scheduledFields) > 0) {
        $query = $this->entityTypeManager
          ->getStorage('node')
          ->getQuery('AND');
        $query
          ->condition('type', $bundleName);
        $nodes = $query
          ->execute();
        foreach ($nodes as $nodeId) {

          /** @var \Drupal\node\Entity\Node $node */
          $node = Node::load($nodeId);
          foreach ($scheduledFields as $scheduledField) {
            $this
              ->updateNodeField($node, $scheduledField);
          }
        }
      }
    }
  }
  private function getScheduledFields(string $bundleName) : array {
    $scheduledFields = [];
    $fields = $this->entityFieldManager
      ->getFieldDefinitions('node', $bundleName);
    foreach ($fields as $fieldName => $field) {

      /** @var FieldConfig $field */
      if (strpos($fieldName, 'field_') !== FALSE) {
        if ($field
          ->getType() === 'scheduled_publish') {
          $scheduledFields[] = $fieldName;
        }
      }
    }
    return $scheduledFields;
  }
  private function updateNodeField(Node $node, string $scheduledField) : void {

    /** @var FieldItemList $scheduledEntity */
    $scheduledEntity = $node
      ->get($scheduledField);
    $scheduledValue = $scheduledEntity
      ->getValue();
    if (empty($scheduledValue)) {
      return;
    }
    $currentModerationState = $node
      ->get('moderation_state')
      ->getValue()[0]['value'];
    $scheduledEntityStore = $scheduledValue;
    if ($currentModerationState === $scheduledEntityStore[0]['moderation_state']) {
      $this
        ->updateNode($node, $scheduledEntityStore[0]['moderation_state'], $scheduledField);
      return;
    }
    $timestamp = $this
      ->getTimestampFromIso8601($scheduledEntityStore[0]['value']);
    if ($timestamp - $this->dateTime
      ->getCurrentTime() <= 0) {
      $this
        ->updateNode($node, $scheduledEntityStore[0]['moderation_state'], $scheduledField);
    }
  }
  private function getTimestampFromIso8601(string $dateIso8601) : int {
    $datetime = new DateTime($dateIso8601, new DateTimeZone(drupal_get_user_timezone()));
    return $datetime
      ->getTimestamp();
  }
  private function updateNode(Node $node, string $moderationState, string $scheduledPublishField) : void {
    $node
      ->set($scheduledPublishField, NULL);
    $node
      ->set('moderation_state', $moderationState);
    $node
      ->save();
  }

}

Members

Name	Modifiers	Type	Description	Overrides
ScheduledPublishCron::$dateTime	private	property
ScheduledPublishCron::$entityBundleInfoService	private	property
ScheduledPublishCron::$entityFieldManager	private	property
ScheduledPublishCron::$entityTypeManager	private	property
ScheduledPublishCron::doUpdate	public	function
ScheduledPublishCron::getScheduledFields	private	function
ScheduledPublishCron::getTimestampFromIso8601	private	function
ScheduledPublishCron::updateNode	private	function
ScheduledPublishCron::updateNodeField	private	function
ScheduledPublishCron::__construct	public	function