modules/quanthub_core/src/AllowedContentManager.php

<?php

namespace Drupal\quanthub_core;

use Drupal\Component\Datetime\Time;
use Drupal\Core\Cache\Cache;
use Drupal\Core\Cache\CacheBackendInterface;
use Drupal\Core\Language\LanguageManager;
use Drupal\Core\Session\AccountProxy;
use Drupal\quanthub_sdmx_sync\QuanthubSdmxClient;

/**
 * The Manager for allowed content.
 *
 * Getting allowed datasets and storing to the cache default.
 */
class AllowedContentManager implements QuanthubCoreInterface {

  /**
   * Name of user data argument for datasets.
   */
  const USER_DATA_DATASETS = 'allowed_datasets';

  /**
   * The 15 minutes cache time.
   */
  const CACHE_TIME = 900;

  /**
   * SDMX client.
   *
   * @var \Drupal\quanthub_sdmx_sync\QuanthubSdmxClient
   */
  protected $quanthubSdmxClient;

  /**
   * The time service.
   *
   * @var \Drupal\Component\Datetime\Time
   */
  protected $time;

  /**
   * The current user service.
   *
   * @var \Drupal\Core\Session\AccountProxy
   */
  protected $currentUser;

  /**
   * The cache default service.
   *
   * @var \Drupal\Core\Cache\CacheBackendInterface
   */
  protected $cache;

  /**
   * The language manager service.
   *
   * @var \Drupal\Core\Language\LanguageManager
   */
  protected $languageManager;

  /**
   * Dataset List.
   *
   * @var array
   */
  protected $datasets = [];

  /**
   * {@inheritDoc}
   */
  public function __construct(
    QuanthubSdmxClient $quanthubSdmxClient,
    AccountProxy $current_user,
    CacheBackendInterface $cache,
    LanguageManager $language_manager,
    Time $time,
  ) {
    $this->quanthubSdmxClient = $quanthubSdmxClient;
    $this->currentUser = $current_user;
    $this->cache = $cache;
    $this->languageManager = $language_manager;
    $this->time = $time;
  }

  /**
   * Get Datasets IDs from cache if not existed updated this by request to wso2.
   */
  public function getAllowedDatasetList() {
    // For admin, editor and publisher, show all content related to datasets.
    // @todo remove publisher and content_editor when entitlements released.
    if (
      $this->currentUser->id() == 1 ||
      in_array('content_editor', $this->currentUser->getRoles()) ||
      in_array('publisher', $this->currentUser->getRoles())
    ) {
      return [];
    }

    // Check that user authenticated and is not admin.
    // Check that dataset list is not already saved to cache.
    if ($cache = $this->cache->get($this->getCacheCid())) {
      if (!empty($cache->data)) {
        $this->datasets = $cache->data;
      }
      else {
        $this->datasets = [];
      }
    }
    else {
      $this->datasets = $this->getUserDatasetList();

      // Update datasets in cache.
      if ($this->datasets) {
        $this->cache->set(
          $this->getCacheCid(),
          $this->datasets,
          $this->time->getCurrentTime() + $this::CACHE_TIME
        );

        // Invalidating cache tags for updating views
        // with datasets and publications.
        Cache::invalidateTags(['allowed_content_tag:' . $this->currentUser->id()]);
      }
    }

    return $this->datasets;
  }

  /**
   * Get cache cid.
   *
   * @return string
   *   Cid string for cache.
   */
  public function getCacheCid() {
    return $this::MODULE_NAME . ':allowed_datasets_list:' . $this->currentUser->id();
  }

  /**
   * Get User's Dataset List.
   */
  public function getUserDatasetList() {
    return $this->quanthubSdmxClient->getDatasetList();
  }

}