Tubee\Rest\Middlewares\QueryDecoder

Complexity

Total Complexity

13

Size/Duplication

Total Lines	52
Duplicated Lines	15.38 %

Coupling/Cohesion

Components	0
Dependencies	1

Test Coverage

Coverage

0%

Importance

Changes

0

1 Method

Rating	Name	Duplication	Size	Complexity
C	process()	8	46	13

<?php

declare(strict_types=1);

/**
 * tubee.io
 *
 * @copyright   Copryright (c) 2017-2019 gyselroth GmbH (https://gyselroth.com)
 * @license     GPL-3.0 https://opensource.org/licenses/GPL-3.0
 */

namespace Tubee\Rest\Middlewares;

use function MongoDB\BSON\fromJSON;
use function MongoDB\BSON\toPHP;
use Psr\Http\Message\ResponseInterface;
use Psr\Http\Message\ServerRequestInterface;
use Psr\Http\Server\MiddlewareInterface;
use Psr\Http\Server\RequestHandlerInterface;
use Tubee\Rest\Exception;
use Zend\Diactoros\Response;

class QueryDecoder implements MiddlewareInterface
{
    /**
     * Process a server request and return a response.
     */
    public function process(ServerRequestInterface $request, RequestHandlerInterface $handler): ResponseInterface
    {
        $query = $request->getQueryParams();

        if (isset($query['offset'])) {
            $query['offset'] = (int) $query['offset'];
        }

        if (isset($query['limit'])) {
            $query['limit'] = (int) $query['limit'];
        }

        if (isset($query['watch']) && !empty($query['watch']) && $query['watch'] !== 'false') {

This code seems to be duplicated across your project.

            $query['watch'] = true;
        } else {
            $query['watch'] = null;
        }

        if (isset($query['query'])) {
            $query['query'] = toPHP(fromJSON($query['query']), [
                'root' => 'array',
                'document' => 'array',
                'array' => 'array',
            ]);
        } else {
            $query['query'] = [];
        }

        if (isset($query['stream']) && $query['stream'] !== 'false' && !empty($query['stream']) && !isset($query['limit'])) {

This code seems to be duplicated across your project.

            $query['limit'] = null;
        }

        if (isset($query['sort'])) {
            $query['sort'] = json_decode(htmlspecialchars_decode($query['sort']), true);

            if (json_last_error()) {
                throw new Exception\InvalidInput('failed to decode provided sort: '.json_last_error_msg().', sort needs to be valid json');
            }
        } else {
            $query['sort'] = [];
        }

        $request = $request->withQueryParams($query);

        return $handler->handle($request);
    }
}