final class ResourceWarmer in JSON:API Boost 2.x

Same name and namespace in other branches

8 src/Plugin/warmer/ResourceWarmer.php \Drupal\jsonapi_boost\Plugin\warmer\ResourceWarmer

Warms JSON:API resources.

Plugin annotation


@Warmer(
  id = "jsonapi",
  label = @Translation("JSON:API Resources"),
  description = @Translation("Warms normalizations of JSON:API resources."),
)

Hierarchy

class \Drupal\Component\Plugin\PluginBase implements DerivativeInspectionInterface, PluginInspectionInterface
- class \Drupal\Core\Plugin\PluginBase uses DependencySerializationTrait, MessengerTrait, StringTranslationTrait
  - class \Drupal\warmer\Plugin\WarmerPluginBase implements ConfigurableInterface, DependentPluginInterface, ContainerFactoryPluginInterface, PluginFormInterface, WarmerInterface
    class \Drupal\jsonapi_boost\Plugin\warmer\ResourceWarmer

Expanded class hierarchy of ResourceWarmer

File

src/Plugin/warmer/ResourceWarmer.php, line 23

Namespace

Drupal\jsonapi_boost\Plugin\warmer

View source

final class ResourceWarmer extends WarmerPluginBase {

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

  /**
   * The resource type repository.
   *
   * @var \Drupal\jsonapi\ResourceType\ResourceTypeRepositoryInterface
   */
  private $resourceTypeRepository;

  /**
   * The entity to JSON:API service.
   *
   * @var \Drupal\jsonapi_extras\EntityToJsonApi
   */
  private $entityToJsonapi;

  /**
   * The list of all item IDs for all entities in the system.
   *
   * Consists of <entity-type-id>:<entity-id>.
   *
   * @var array
   */
  private $iids = [];

  /**
   * {@inheritdoc}
   */
  public static function create(ContainerInterface $container, array $configuration, $plugin_id, $plugin_definition) {

    /** @var \Drupal\jsonapi_boost\Plugin\warmer\ResourceWarmer $instance */
    $instance = parent::create($container, $configuration, $plugin_id, $plugin_definition);
    $instance
      ->setEntityTypeManager($container
      ->get('entity_type.manager'));
    $instance
      ->setResourceTypeRepository($container
      ->get('jsonapi.resource_type.repository'));
    $instance
      ->setEntityToJsonapi($container
      ->get('jsonapi_extras.entity.to_jsonapi'));
    return $instance;
  }

  /**
   * Injects the entity type manager.
   *
   * @param \Drupal\Core\Entity\EntityTypeManagerInterface $entity_type_manager
   *   The entity type manager.
   */
  public function setEntityTypeManager(EntityTypeManagerInterface $entity_type_manager) {
    $this->entityTypeManager = $entity_type_manager;
  }

  /**
   * Injects the resource type repository.
   *
   * @param \Drupal\jsonapi\ResourceType\ResourceTypeRepositoryInterface $resource_type_repository
   *   The entity type manager.
   */
  public function setResourceTypeRepository(ResourceTypeRepositoryInterface $resource_type_repository) {
    $this->resourceTypeRepository = $resource_type_repository;
  }

  /**
   * Injects the entity to JSON:API service.
   *
   * @param \Drupal\jsonapi_extras\EntityToJsonApi $entitity_to_jsonapi
   *   The entity type manager.
   */
  public function setEntityToJsonapi(EntityToJsonApi $entitity_to_jsonapi) {
    $this->entityToJsonapi = $entitity_to_jsonapi;
  }

  /**
   * {@inheritdoc}
   */
  public function loadMultiple(array $ids = []) {
    $ids_per_type = array_reduce($ids, function ($carry, $id) {
      list($entity_type_id, $entity_id, ) = explode(':', $id);
      if (empty($carry[$entity_type_id])) {
        $carry[$entity_type_id] = [];
      }
      $carry[$entity_type_id][] = $entity_id;
      return $carry;
    }, []);
    $output = [];
    foreach ($ids_per_type as $entity_type_id => $entity_ids) {
      $output += $this->entityTypeManager
        ->getStorage($entity_type_id)
        ->loadMultiple($entity_ids);
    }
    return $output;
  }

  /**
   * {@inheritdoc}
   */
  public function warmMultiple(array $items = []) {
    $normalizations = array_map([
      $this->entityToJsonapi,
      'normalize',
    ], $items);
    count($normalizations);
  }

  /**
   * {@inheritdoc}
   */
  public function buildIdsBatch($cursor) {
    $configuration = $this
      ->getConfiguration();
    if (empty($this->iids) && !empty($configuration['resource_types'])) {
      $resource_config_ids = array_filter(array_values($configuration['resource_types']));
      sort($resource_config_ids);
      $this->iids = array_reduce($resource_config_ids, function ($iids, $resource_config_id) {
        $resource_config = $this->entityTypeManager
          ->getStorage('jsonapi_resource_config')
          ->load($resource_config_id);
        $resource_type_name = $resource_config instanceof JsonapiResourceConfig ? $resource_config
          ->get('resourceType') : $resource_config_id;
        $resource_type = $this->resourceTypeRepository
          ->getByTypeName($resource_type_name);
        $entity_type_id = $resource_type
          ->getEntityTypeId();
        $entity_type = $this->entityTypeManager
          ->getDefinition($entity_type_id);
        $bundle_key = $entity_type
          ->getKey('bundle');
        $id_key = $entity_type
          ->getKey('id');
        $query = $this->entityTypeManager
          ->getStorage($entity_type_id)
          ->getQuery();
        if ($id_key) {
          $query
            ->sort($id_key);
        }
        if ($bundle_key) {
          $query
            ->condition($bundle_key, $resource_type
            ->getBundle());
        }
        $results = $query
          ->execute();
        $entity_ids = array_filter((array) array_values($results));
        return array_unique(array_merge($iids, array_map(function ($id) use ($resource_config_id, $entity_type_id) {
          return sprintf('%s:%s:%s', $entity_type_id, $id, $resource_config_id);
        }, $entity_ids)));
      }, []);
    }
    $cursor_position = is_null($cursor) ? -1 : array_search($cursor, $this->iids);
    if ($cursor_position === FALSE) {
      return [];
    }
    return array_slice($this->iids, $cursor_position + 1, (int) $this
      ->getBatchSize());
  }

  /**
   * {@inheritdoc}
   */
  public function addMoreConfigurationFormElements(array $form, SubformStateInterface $form_state) {
    $options = [];
    foreach ($this->resourceTypeRepository
      ->all() as $resource_type) {

      /** @var \Drupal\jsonapi_extras\ResourceType\ConfigurableResourceType $resource_type */
      $key = $resource_type
        ->getJsonapiResourceConfig()
        ->id();
      $options[$key] = $resource_type
        ->getPath();
    }
    $configuration = $this
      ->getConfiguration();
    $form['resource_types'] = [
      '#type' => 'checkboxes',
      '#title' => $this
        ->t('Resource Types'),
      '#description' => $this
        ->t('Enable the JSON:API resource types to warm asynchronously.'),
      '#options' => $options,
      '#default_value' => empty($configuration['resource_types']) ? [] : $configuration['resource_types'],
    ];
    return $form;
  }

}

Members

Name	Modifiers	Type	Description	Overrides
DependencySerializationTrait::$_entityStorages	protected	property
DependencySerializationTrait::$_serviceIds	protected	property
DependencySerializationTrait::__sleep	public	function		2
DependencySerializationTrait::__wakeup	public	function		2
MessengerTrait::$messenger	protected	property	The messenger.	27
MessengerTrait::messenger	public	function	Gets the messenger.	27
MessengerTrait::setMessenger	public	function	Sets the messenger.
PluginBase::$configuration	protected	property	Configuration information passed into the plugin.	1
PluginBase::$pluginDefinition	protected	property	The plugin implementation definition.	1
PluginBase::$pluginId	protected	property	The plugin_id.
PluginBase::DERIVATIVE_SEPARATOR		constant	A string which is used to separate base plugin IDs from the derivative ID.
PluginBase::getBaseId	public	function	Gets the base_plugin_id of the plugin instance. Overrides DerivativeInspectionInterface::getBaseId
PluginBase::getDerivativeId	public	function	Gets the derivative_id of the plugin instance. Overrides DerivativeInspectionInterface::getDerivativeId
PluginBase::getPluginDefinition	public	function	Gets the definition of the plugin implementation. Overrides PluginInspectionInterface::getPluginDefinition	2
PluginBase::getPluginId	public	function	Gets the plugin_id of the plugin instance. Overrides PluginInspectionInterface::getPluginId
PluginBase::isConfigurable	public	function	Determines if the plugin is configurable.
ResourceWarmer::$entityToJsonapi	private	property	The entity to JSON:API service.
ResourceWarmer::$entityTypeManager	private	property	The entity type manager.
ResourceWarmer::$iids	private	property	The list of all item IDs for all entities in the system.
ResourceWarmer::$resourceTypeRepository	private	property	The resource type repository.
ResourceWarmer::addMoreConfigurationFormElements	public	function	Adds additional form elements to the configuration form. Overrides WarmerInterface::addMoreConfigurationFormElements
ResourceWarmer::buildIdsBatch	public	function	Builds the next batch of IDs based on a position cursor. Overrides WarmerInterface::buildIdsBatch
ResourceWarmer::create	public static	function	Creates an instance of the plugin. Overrides WarmerPluginBase::create
ResourceWarmer::loadMultiple	public	function	Loads multiple items based on their IDs. Overrides WarmerInterface::loadMultiple
ResourceWarmer::setEntityToJsonapi	public	function	Injects the entity to JSON:API service.
ResourceWarmer::setEntityTypeManager	public	function	Injects the entity type manager.
ResourceWarmer::setResourceTypeRepository	public	function	Injects the resource type repository.
ResourceWarmer::warmMultiple	public	function	Warms multiple items. Overrides WarmerInterface::warmMultiple
StringTranslationTrait::$stringTranslation	protected	property	The string translation service.	4
StringTranslationTrait::formatPlural	protected	function	Formats a string containing a count of items.
StringTranslationTrait::getNumberOfPlurals	protected	function	Returns the number of plurals supported by a given language.
StringTranslationTrait::getStringTranslation	protected	function	Gets the string translation service.
StringTranslationTrait::setStringTranslation	public	function	Sets the string translation service to use.	2
StringTranslationTrait::t	protected	function	Translates a string to the current language or to a given language.
WarmerPluginBase::$state	protected	property	The state service.
WarmerPluginBase::$time	protected	property	The time service.
WarmerPluginBase::buildConfigurationForm	final public	function	Form constructor. Overrides PluginFormInterface::buildConfigurationForm
WarmerPluginBase::calculateDependencies	public	function	Calculates dependencies for the configured plugin. Overrides DependentPluginInterface::calculateDependencies
WarmerPluginBase::defaultConfiguration	public	function	Gets default configuration for this plugin. Overrides ConfigurableInterface::defaultConfiguration	2
WarmerPluginBase::getBatchSize	public	function	Returns the batch size for the warming operation. Overrides WarmerInterface::getBatchSize
WarmerPluginBase::getConfiguration	public	function	Gets this plugin's configuration. Overrides ConfigurableInterface::getConfiguration
WarmerPluginBase::getFrequency	public	function	Returns the frequency for the warming operation. Overrides WarmerInterface::getFrequency
WarmerPluginBase::isActive	public	function	Checks if the plugin should warm in this particular moment. Overrides WarmerInterface::isActive
WarmerPluginBase::markAsEnqueued	public	function	Marks a warmer as enqueued. Overrides WarmerInterface::markAsEnqueued
WarmerPluginBase::setConfiguration	public	function	Sets the configuration for this plugin instance. Overrides ConfigurableInterface::setConfiguration
WarmerPluginBase::submitConfigurationForm	public	function	Form submission handler. Overrides PluginFormInterface::submitConfigurationForm	2
WarmerPluginBase::validateConfigurationForm	public	function	Form validation handler. Overrides PluginFormInterface::validateConfigurationForm	2
WarmerPluginBase::__construct	public	function	Constructs a \Drupal\Component\Plugin\PluginBase object. Overrides PluginBase::__construct

You are here

final class ResourceWarmer in JSON:API Boost 2.x

Plugin annotation

Hierarchy

File

Namespace

Members

API Navigation