public function EntityResource::getCollection in Drupal 8

Same name and namespace in other branches

1. 9 core/modules/jsonapi/src/Controller/EntityResource.php \Drupal\jsonapi\Controller\EntityResource::getCollection()

Gets the collection of entities.

Parameters

\Drupal\jsonapi\ResourceType\ResourceType $resource_type: The JSON:API resource type for the request to be served.

\Symfony\Component\HttpFoundation\Request $request: The request object.

Return value

\Drupal\jsonapi\ResourceResponse The response.

Throws

\Drupal\Core\Http\Exception\CacheableBadRequestHttpException Thrown when filtering on a config entity which does not support it.

File

core/modules/jsonapi/src/Controller/EntityResource.php, line 389

Class

EntityResource

Process all entity requests.

Namespace

Drupal\jsonapi\Controller

Code

public function getCollection(ResourceType $resource_type, Request $request) {

  // Instantiate the query for the filtering.
  $entity_type_id = $resource_type
    ->getEntityTypeId();
  $params = $this
    ->getJsonApiParams($request, $resource_type);
  $query_cacheability = new CacheableMetadata();
  $query = $this
    ->getCollectionQuery($resource_type, $params, $query_cacheability);

  // If the request is for the latest revision, toggle it on entity query.
  if ($request
    ->get(ResourceVersionRouteEnhancer::WORKING_COPIES_REQUESTED, FALSE)) {
    $query
      ->latestRevision();
  }
  try {
    $results = $this
      ->executeQueryInRenderContext($query, $query_cacheability);
  } catch (\LogicException $e) {

    // Ensure good DX when an entity query involves a config entity type.
    // For example: getting users with a particular role, which is a config
    // entity type: https://www.drupal.org/project/drupal/issues/2959445.
    // @todo Remove the message parsing in https://www.drupal.org/project/drupal/issues/3028967.
    if (strpos($e
      ->getMessage(), 'Getting the base fields is not supported for entity type') === 0) {
      preg_match('/entity type (.*)\\./', $e
        ->getMessage(), $matches);
      $config_entity_type_id = $matches[1];
      $cacheability = (new CacheableMetadata())
        ->addCacheContexts([
        'url.path',
        'url.query_args:filter',
      ]);
      throw new CacheableBadRequestHttpException($cacheability, sprintf("Filtering on config entities is not supported by Drupal's entity API. You tried to filter on a %s config entity.", $config_entity_type_id));
    }
    else {
      throw $e;
    }
  }
  $storage = $this->entityTypeManager
    ->getStorage($entity_type_id);

  // We request N+1 items to find out if there is a next page for the pager.
  // We may need to remove that extra item before loading the entities.
  $pager_size = $query
    ->getMetaData('pager_size');
  if ($has_next_page = $pager_size < count($results)) {

    // Drop the last result.
    array_pop($results);
  }

  // Each item of the collection data contains an array with 'entity' and
  // 'access' elements.
  $collection_data = $this
    ->loadEntitiesWithAccess($storage, $results, $request
    ->get(ResourceVersionRouteEnhancer::WORKING_COPIES_REQUESTED, FALSE));
  $primary_data = new ResourceObjectData($collection_data);
  $primary_data
    ->setHasNextPage($has_next_page);

  // Calculate all the results and pass into a JSON:API Data object.
  $count_query_cacheability = new CacheableMetadata();
  if ($resource_type
    ->includeCount()) {
    $count_query = $this
      ->getCollectionCountQuery($resource_type, $params, $count_query_cacheability);
    $total_results = $this
      ->executeQueryInRenderContext($count_query, $count_query_cacheability);
    $primary_data
      ->setTotalCount($total_results);
  }
  $response = $this
    ->respondWithCollection($primary_data, $this
    ->getIncludes($request, $primary_data), $request, $resource_type, $params[OffsetPage::KEY_NAME]);
  $response
    ->addCacheableDependency($query_cacheability);
  $response
    ->addCacheableDependency($count_query_cacheability);
  $response
    ->addCacheableDependency((new CacheableMetadata())
    ->addCacheContexts([
    'url.query_args:filter',
    'url.query_args:sort',
    'url.query_args:page',
  ]));
  if ($resource_type
    ->isVersionable()) {
    $response
      ->addCacheableDependency((new CacheableMetadata())
      ->addCacheContexts([
      ResourceVersionRouteEnhancer::CACHE_CONTEXT,
    ]));
  }
  return $response;
}