drupal-graphql / graphql

src/Controller/RequestController.php

<?php

namespace Drupal\graphql\Controller;

use Drupal\Core\Cache\CacheableJsonResponse;

The type Drupal\Core\Cache\CacheableJsonResponse was not found. Maybe you did not declare it correctly or list all dependencies?

use Drupal\Core\DependencyInjection\ContainerInjectionInterface;

The type Drupal\Core\DependencyInjection\ContainerInjectionInterface was not found. Maybe you did not declare it correctly or list all dependencies?

use Drupal\graphql\GraphQL\Execution\QueryProcessor;
use Symfony\Component\DependencyInjection\ContainerInterface;

The type Symfony\Component\DependencyInjection\ContainerInterface was not found. Maybe you did not declare it correctly or list all dependencies?

/**
 * 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.
   *
   * @throws \Drupal\Component\Plugin\Exception\PluginException
   */
  public function handleRequest($schema, $operations) {
    if (is_array($operations)) {
      return $this->handleBatch($schema, $operations);
    }

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

  /**
   * @param $schema
   * @param $operations
   * @param array $globals
   *
   * @return \Drupal\Core\Cache\CacheableJsonResponse
   * @throws \Drupal\Component\Plugin\Exception\PluginException
   */
  protected function handleSingle($schema, $operations) {
    $result = $this->processor->processQuery($schema, $operations);
    $response = new CacheableJsonResponse($result);
    $response->addCacheableDependency($result);
    return $response;
  }

  /**
   * @param $schema
   * @param $operations
   * @param array $globals
   *
   * @return \Drupal\Core\Cache\CacheableJsonResponse
   * @throws \Drupal\Component\Plugin\Exception\PluginException
   */
  protected function handleBatch($schema, $operations) {
    $result = $this->processor->processQuery($schema, $operations);
    $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) {
      $response->addCacheableDependency($dependency);
    }

    return $response;
  }

}