Overblog\GraphQLBundle\Request\BatchParser

Complexity

Total Complexity

7

Size/Duplication

Total Lines	60
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

0%

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	parse()	0	19	4
A	getParsedBody()	0	17	3

<?php

/*
 * This file is part of the OverblogGraphQLBundle package.
 *
 * (c) Overblog <http://github.com/overblog/>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Overblog\GraphQLBundle\Request;

use Symfony\Component\HttpFoundation\Request;
use Symfony\Component\HttpKernel\Exception\BadRequestHttpException;

class BatchParser implements ParserInterface
{
    const PARAM_ID = 'id';

    private static $queriesDefaultValue = [
        self::PARAM_ID => null,
        self::PARAM_QUERY => null,
        self::PARAM_VARIABLES => null,
    ];

    /**
     * @param Request $request
     *
     * @return array
     */
    public function parse(Request $request)
    {
        // Extracts the GraphQL request parameters
        $queries = $this->getParsedBody($request);

        if (empty($queries)) {
            throw new BadRequestHttpException('Must provide at least one valid query.');
        }

        foreach ($queries as $i => &$query) {
            $query = array_filter($query) + self::$queriesDefaultValue;

            if (!is_string($query[static::PARAM_QUERY])) {
                throw new BadRequestHttpException(sprintf('%s is not a valid query', json_encode($query[static::PARAM_QUERY])));
            }
        }

        return $queries;
    }

    /**
     * Gets the body from the request.
     *
     * @param Request $request
     *
     * @return array
     */
    private function getParsedBody(Request $request)
    {
        $type = explode(';', $request->headers->get('content-type'))[0];

        // JSON object
        if ($type !== static::CONTENT_TYPE_JSON) {
            throw new BadRequestHttpException(sprintf('Only request with content type "%s" is accepted.', static::CONTENT_TYPE_JSON));
        }

        $parsedBody = json_decode($request->getContent(), true);

        if (JSON_ERROR_NONE !== json_last_error()) {
            throw new BadRequestHttpException('POST body sent invalid JSON');
        }

        return $parsedBody;
    }
}