Railt\Adapters\Webonyx\Repository

Complexity

Total Complexity

6

Size/Duplication

Total Lines	67
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	fetch()	0	20	4
A	invoke()	0	11	1

<?php
/**
 * This file is part of Railt package.
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */
declare(strict_types=1);

namespace Railt\Adapters\Webonyx;

use GraphQL\Type\Definition\ResolveInfo;
use Railt\Adapters\InputInterface;
use Railt\Reflection\Abstraction\DefinitionInterface;
use Railt\Reflection\Abstraction\ObjectTypeInterface;
use Railt\Reflection\Abstraction\Type\TypeInterface;
use Railt\Routing\Contracts\RouteInterface;
use Railt\Routing\Contracts\RouterInterface;
use Railt\Routing\Route;
use Railt\Routing\Router;

/**
 * Class Repository
 * @package Railt\Adapters\Webonyx
 */
class Repository
{
    /**
     * @var Router|RouterInterface
     */
    private $router;

    /**
     * @var DefinitionInterface|TypeInterface
     */
    private $type;

    /**
     * Repository constructor.
     * @param RouterInterface $router
     * @param ObjectTypeInterface $type
     */
    public function __construct(RouterInterface $router, ObjectTypeInterface $type)
    {
        $this->router = $router;
        $this->type   = $type;
    }

    /**
     * @param InputInterface $input
     * @param mixed $parent
     * @return mixed
     */
    public function fetch(InputInterface $input, $parent)
    {
        $result = $parent;

        if ($this->router->has($input->getPath())) {
            $routes = $this->router->get($input->getPath());

            foreach ($routes as $route) {
                //
                // Allows invocation for only same matched query type:
                //      "mutation", "query" or "subscription"

56% of this comment could be valid code. Did you maybe forget this after debugging?

                //
                if ($route->matchMethod($input->getQueryType())) {
                    $result = $this->invoke($route, $input, $result);
                }
            }
        }

        return $result;
    }

    /**
     * @param RouteInterface|Route $route
     * @param InputInterface $input
     * @param $parent
     * @return mixed
     */
    private function invoke(RouteInterface $route, InputInterface $input, $parent)
    {
        $output = new Output($parent, $parent);

        return (object)$route->call($this->router->getContainer(), [
            'route'  => $route,
            'input'  => $input,
            'output' => $output,
            'type'   => $this->type,
        ]);
    }
}