Portiny\GraphQL\GraphQL\RequestProcessor

Complexity

Total Complexity

10

Size/Duplication

Total Lines	93
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

94.12%

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	createQueryObject()	0	7	1
A	__construct()	0	4	1
A	setMutationFieldsProvider()	0	4	1
A	setQueryFieldsProvider()	0	4	1
B	process()	0	26	2
A	createSchema()	0	7	1
A	createMutationObject()	0	7	1
A	isDebug()	0	4	2

<?php

declare(strict_types=1);

namespace Portiny\GraphQL\GraphQL;

use GraphQL\Error\Debug;
use GraphQL\GraphQL;
use GraphQL\Type\Definition\ObjectType;
use GraphQL\Type\Schema;
use Portiny\GraphQL\Contract\Http\Request\RequestParserInterface;
use Portiny\GraphQL\Contract\Provider\MutationFieldsProviderInterface;
use Portiny\GraphQL\Contract\Provider\QueryFieldsProviderInterface;
use Throwable;
use Tracy\Debugger;

final class RequestProcessor
{
	/**
	 * @var RequestParserInterface
	 */
	private $requestParser;

	/**
	 * @var MutationFieldsProviderInterface
	 */
	private $mutationFieldsProvider;

	/**
	 * @var QueryFieldsProviderInterface
	 */
	private $queryFieldsProvider;

	public function __construct(RequestParserInterface $requestParser)
	{
		$this->requestParser = $requestParser;
	}

	public function setMutationFieldsProvider(MutationFieldsProviderInterface $mutationFieldsProvider): void
	{
		$this->mutationFieldsProvider = $mutationFieldsProvider;
	}

	public function setQueryFieldsProvider(QueryFieldsProviderInterface $queryFieldsProvider): void
	{
		$this->queryFieldsProvider = $queryFieldsProvider;
	}

	/**
	 * @param mixed|null $context
	 * @param array|null $allowedQueries
	 * @param array|null $allowedMutations
	 */
	public function process(
		array $rootValue = [],
		$context = NULL,
		?array $allowedQueries = NULL,
		?array $allowedMutations = NULL
	): array {
		try {
			$result = GraphQL::executeQuery(
				$this->createSchema($allowedQueries, $allowedMutations),
				$this->requestParser->getQuery(),
				$rootValue,
				$context,
				$this->requestParser->getVariables()
			);

			$output = $result->toArray($this->isDebug());
		} catch (Throwable $exception) {
			$output = [
				'error' => [
					'message' => $exception->getMessage(),
				],
			];
		}

		return $output;
	}

	private function createSchema(?array $allowedQueries = NULL, ?array $allowedMutations = NULL): Schema
	{
		return new Schema([
			'query' => $this->createQueryObject($allowedQueries),
			'mutation' => $this->createMutationObject($allowedMutations),
		]);
	}

	private function createQueryObject(?array $allowedQueries = NULL): ObjectType
	{
		return new ObjectType([
			'name' => 'Query',
			'fields' => $this->queryFieldsProvider->convertFieldsToArray($allowedQueries),
		]);
	}

	private function createMutationObject(?array $allowedMutations = NULL): ObjectType
	{
		return new ObjectType([
			'name' => 'Mutation',
			'fields' => $this->mutationFieldsProvider->convertFieldsToArray($allowedMutations),
		]);
	}

	private function isDebug(): int
	{
		return ! Debugger::$productionMode ? Debug::INCLUDE_DEBUG_MESSAGE | Debug::INCLUDE_TRACE : 0;
	}
}