Drupal\graphql\Routing\QueryRouteEnhancer

Complexity

Total Complexity

25

Size/Duplication

Total Lines	175
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	3	1
A	applies()	0	3	1
A	enhance()	0	21	4
A	enhanceBatch()	0	22	3
B	enhanceSingle()	0	18	5
A	extractQueryFromParameterBag()	0	7	3
B	extractParams()	0	17	8

<?php

namespace Drupal\graphql\Routing;

use Drupal\Core\Routing\Enhancer\RouteEnhancerInterface;
use Drupal\graphql\QueryProvider\QueryProviderInterface;
use Symfony\Component\HttpFoundation\Request;
use Symfony\Component\Routing\Route;

class QueryRouteEnhancer implements RouteEnhancerInterface {

  const SINGLE = 'single';
  const BATCH = 'batch';

  /**
   * The query provider service.
   *
   * @var \Drupal\graphql\QueryProvider\QueryProviderInterface
   */
  protected $queryProvider;

  /**
   * QueryRouteEnhancer constructor.
   *
   * @param \Drupal\graphql\QueryProvider\QueryProviderInterface $queryProvider
   *   The query provider service.
   */
  public function __construct(QueryProviderInterface $queryProvider) {
    $this->queryProvider = $queryProvider;
  }


  /**
   * {@inheritdoc}
   */
  public function applies(Route $route) {
    return $route->hasDefault('_graphql');
  }

  /**
   * {@inheritdoc}
   */
  public function enhance(array $defaults, Request $request) {
    if (!empty($defaults['_controller'])) {
      return $defaults;
    }

    $params = $this->extractParams($request);
    if ($enhanced = $this->enhanceSingle($defaults, $params, $request)) {
      return $enhanced;
    }

    if ($enhanced = $this->enhanceBatch($defaults, $params, $request)) {
      return $enhanced;
    }

    // By default we assume a 'single' request. This is going to fail in the
    // graphql processor due to a missing query string but at least provides
    // the right format for the client to act upon.
    return $defaults + [
      '_controller' => $defaults['_graphql']['single'],
    ];
  }

  /**
   * Attempts to enhance the request as a batch query.
   *
   * @param array $defaults
   *   The controller defaults.
   * @param array $params
   *   The query parameters.
   * @param \Symfony\Component\HttpFoundation\Request $request
   *   The request object.
   *
   * @return array|bool
   *   The enhanced controller defaults.
   */
  protected function enhanceBatch(array $defaults, array $params, Request $request) {
    // PHP 5.5.x does not yet support the ARRAY_FILTER_USE_KEYS constant.
    $keys = array_filter(array_keys($params), function($index) {
      return is_numeric($index);
    });

    $queries = array_intersect_key($params, array_flip($keys));
    if (!isset($queries[0])) {
      return FALSE;
    }

    if (array_keys($queries) !== range(0, count($queries) - 1)) {
      // If this is not a continuously numeric array, don't do anything.
      return FALSE;
    }

    return $defaults + [
      '_controller' => $defaults['_graphql']['multiple'],
      'queries' => $queries,
      'type' => static::BATCH,
    ];
  }

  /**
   * Attempts to enhance the request as a single query.
   *
   * @param array $defaults
   *   The controller defaults.
   * @param array $params
   *   The query parameters.
   * @param \Symfony\Component\HttpFoundation\Request $request
   *   The request object.
   *
   * @return array|boolean
   *   The enhanced controller defaults.
   */
  protected function enhanceSingle(array $defaults, array $params, Request $request) {
    $values = $params + [
      'query' => empty($params['query']) ? $this->queryProvider->getQuery($params) : $params['query'],
      'variables' => [],
    ];

    if (empty($values['query'])) {
      return FALSE;
    }

    return $defaults + [
      '_controller' => $defaults['_graphql']['single'],
      'query' => $values['query'] ?: '',
      'variables' => $values['variables'] ?: [],
      'persisted' => empty($params['query']),
      'type' => static::SINGLE,
    ];
  }

  /**
   * Extract the query from the parameter bag
   *
   * Search the parameter bag array for a query
   *
   * @param array $parameters
   *   The parameter bag array.
   *
   * @return string
   *   The query
   */
  protected function extractQueryFromParameterBag(array $parameters){
    foreach ($parameters as $key => $value){
      if (strpos($value, 'query')){
        return $value;
      }
    }
  }

  /**
   * Extract an associative array of query parameters from the request.
   *
   * If the given request does not have any POST body content check for a POST
   * query parameter otherwise use the GET query parameters instead. The additional
   * check for the ParametersBag query is necessary when sending FormData such as
   * needed when sending files along with the query from the client.
   *
   * @param \Symfony\Component\HttpFoundation\Request $request
   *   The request object.
   *
   * @return array
   *   An associative array of query parameters.
   */
  protected function extractParams(Request $request) {

    $values = ($content = $request->getContent()) ? json_decode($content, TRUE) : $request->query->all();
    $parameters = $request->request->all();
    if (count($parameters) > 0){
      $values = isset($request->request) ? json_decode($this->extractQueryFromParameterBag($request->request->all()), TRUE): $request->query->all();
    }

    return array_map(function($value) {
      if (!is_string($value)) {
        return $value;
      }

      $decoded = json_decode($value, TRUE);
      return ($decoded != $value) && $decoded ? $decoded : $value;
    }, $values ?: []);
  }

}