MediaExpireService.php in Media Expire 8

Namespace

Drupal\media_expire

File

src/MediaExpireService.php

<?php

namespace Drupal\media_expire;

use Drupal\Core\Entity\EntityTypeManagerInterface;
use Drupal\Core\Entity\Query\QueryFactory;
use Drupal\media_entity\Entity\Media;

/**
 * Contains the media unpublish logic.
 *
 * @package Drupal\media_expire
 */
class MediaExpireService {

  /**
   * The entity type manager.
   *
   * @var \Drupal\Core\Entity\EntityTypeManagerInterface
   */
  protected $entityTypeManager;

  /**
   * The query factory.
   *
   * @var \Drupal\Core\Entity\Query\QueryFactory
   */
  protected $queryFactory;

  /**
   * Constructs the MediaExpireService.
   *
   * @param \Drupal\Core\Entity\EntityTypeManagerInterface $entity_type_manager
   *   The entity type manager service.
   * @param \Drupal\Core\Entity\Query\QueryFactory $queryFactory
   *   The query factory service.
   */
  public function __construct(EntityTypeManagerInterface $entity_type_manager, QueryFactory $queryFactory) {
    $this->entityTypeManager = $entity_type_manager;
    $this->queryFactory = $queryFactory;
  }

  /**
   * Unpublishes already expired media elements.
   */
  public function unpublishExpiredMedia() {

    /** @var \Drupal\media_entity\Entity\MediaBundle[] $bundles */
    $bundles = $this->entityTypeManager
      ->getStorage('media_bundle')
      ->loadMultiple();
    foreach ($bundles as $bundle) {
      if ($bundle
        ->getThirdPartySetting('media_expire', 'enable_expiring')) {
        $expireField = $bundle
          ->getThirdPartySetting('media_expire', 'expire_field');
        $query = $this->queryFactory
          ->get('media', 'AND');
        $query
          ->condition('status', 1);
        $query
          ->condition('bundle', $bundle
          ->id());
        $query
          ->condition($expireField, date("Y-m-d\\TH:i:s"), '<');
        $entityIds = $query
          ->execute();

        /** @var \Drupal\media_entity\Entity\Media[] $medias */
        $medias = $this->entityTypeManager
          ->getStorage('media')
          ->loadMultiple($entityIds);
        foreach ($medias as $media) {
          $media
            ->setPublished(Media::NOT_PUBLISHED);
          $media->{$expireField}
            ->removeItem(0);
          $media
            ->save();
        }
      }
    }
  }

}

Classes

Name	Description
MediaExpireService	Contains the media unpublish logic.