Drupal\graphql\Controller\RequestController

Complexity

Total Complexity

11

Size/Duplication

Total Lines	109
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	create()	0	6	1
A	__construct()	0	4	1
A	handleRequest()	0	10	2
A	handleSingle()	0	9	1
A	handleBatch()	0	15	3
A	logErrors()	0	7	3

<?php

namespace Drupal\graphql\Controller;

use Drupal\Core\Cache\CacheableJsonResponse;
use Drupal\Core\DependencyInjection\ContainerInjectionInterface;
use Drupal\graphql\GraphQL\Execution\QueryProcessor;
use Symfony\Component\DependencyInjection\ContainerInterface;

/**
 * Handles GraphQL requests.
 */
class RequestController implements ContainerInjectionInterface {

  /**
   * The query processor.
   *
   * @var \Drupal\graphql\GraphQL\Execution\QueryProcessor
   */
  protected $processor;

  /**
   * The service configuration parameters.
   *
   * @var array
   */
  protected $parameters;

  /**
   * {@inheritdoc}
   */
  public static function create(ContainerInterface $container) {
    return new static(
      $container->get('graphql.query_processor'),
      $container->getParameter('graphql.config')
    );
  }

  /**
   * RequestController constructor.
   *
   * @param \Drupal\graphql\GraphQL\Execution\QueryProcessor $processor
   *   The query processor.
   * @param array $parameters
   *   The service configuration parameters.
   */
  public function __construct(QueryProcessor $processor, array $parameters) {
    $this->processor = $processor;
    $this->parameters = $parameters;
  }

  /**
   * Handles graphql requests.
   *
   * @param string $schema
   *   The name of the schema.
   * @param \GraphQL\Server\OperationParams|\GraphQL\Server\OperationParams[] $operations
   *   The graphql operation(s) to execute.
   *
   * @return \Drupal\Core\Cache\CacheableJsonResponse
   *   The JSON formatted response.
   */
  public function handleRequest($schema, $operations) {
    $development = !empty($this->parameters['development']);
    $globals = ['development' => $development];

    if (is_array($operations)) {
      return $this->handleBatch($schema, $operations, $globals);
    }

    return $this->handleSingle($schema, $operations, $globals);
  }

  /**
   * @param $schema
   * @param $operations
   * @param array $globals
   *
   * @return \Drupal\Core\Cache\CacheableJsonResponse
   */
  protected function handleSingle($schema, $operations, $globals) {
    $result = $this->processor->processQuery($schema, $operations, $globals);

    $this->logErrors($result, $globals);

    $response = new CacheableJsonResponse($result);
    $response->addCacheableDependency($result);
    return $response;
  }

  /**
   * @param $schema
   * @param $operations
   * @param array $globals
   *
   * @return \Drupal\Core\Cache\CacheableJsonResponse
   */
  protected function handleBatch($schema, $operations, $globals) {
    $result = $this->processor->processQuery($schema, $operations, $globals);

    $this->logErrors($result, $globals);

    $response = new CacheableJsonResponse($result);

    // In case of a batch request, the result is an array.
    $dependencies = is_array($operations) ? $result : [$result];
    foreach ($dependencies as $dependency) {

The expression $dependencies of type object<Exception>|object<Throwable>|array<integer,object<Exception>|object<Throwable>,{"0":"object<Exception>|object<Throwable>"}> is not guaranteed to be traversable. How about adding an additional type check?

      $response->addCacheableDependency($dependency);
    }

    return $response;
  }

  protected function logErrors($result, $globals) {
    if ($globals['development']) {
      if (!empty($result->errors)) {
        \Drupal::logger('graphql')->warning($result->errors[0]->message);
      }
    }
  }
}