Yoanm\JsonRpcServer\App\Handler\JsonRpcRequestHandler

Complexity

Total Complexity

11

Size/Duplication

Total Lines	110
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	createResponse()	0	9	2
A	setMethodParamsValidator()	0	3	1
A	__construct()	0	4	1
A	resolveMethod()	0	9	2
A	processJsonRpcRequest()	0	17	2
A	validateParamList()	0	7	3

<?php
namespace Yoanm\JsonRpcServer\App\Handler;

use Yoanm\JsonRpcServer\App\Creator\ResponseCreator;
use Yoanm\JsonRpcServer\App\Dispatcher\JsonRpcServerDispatcherAwareTrait;
use Yoanm\JsonRpcServer\Domain\Event\Action as ActionEvent;
use Yoanm\JsonRpcServer\Domain\Exception\JsonRpcInvalidParamsException;
use Yoanm\JsonRpcServer\Domain\Exception\JsonRpcMethodNotFoundException;
use Yoanm\JsonRpcServer\Domain\JsonRpcMethodInterface;
use Yoanm\JsonRpcServer\Domain\JsonRpcMethodParamsValidatorInterface;
use Yoanm\JsonRpcServer\Domain\JsonRpcMethodResolverInterface;
use Yoanm\JsonRpcServer\Domain\Model\JsonRpcRequest;
use Yoanm\JsonRpcServer\Domain\Model\JsonRpcResponse;

/**
 * Class JsonRpcRequestHandler
 */
class JsonRpcRequestHandler
{
    use JsonRpcServerDispatcherAwareTrait;

    /** @var JsonRpcMethodResolverInterface */
    private $methodResolver;
    /** @var ResponseCreator */
    private $responseCreator;
    /** @var JsonRpcMethodParamsValidatorInterface|null */
    private $methodParamsValidator = null;

    /**
     * @param JsonRpcMethodResolverInterface $methodResolver
     * @param ResponseCreator                $responseCreator
     */
    public function __construct(JsonRpcMethodResolverInterface $methodResolver, ResponseCreator $responseCreator)
    {
        $this->methodResolver = $methodResolver;
        $this->responseCreator = $responseCreator;
    }

    /**
     * @param JsonRpcMethodParamsValidatorInterface $methodParamsValidator
     *
     * @return void
     */
    public function setMethodParamsValidator(JsonRpcMethodParamsValidatorInterface $methodParamsValidator) : void
    {
        $this->methodParamsValidator = $methodParamsValidator;
    }

    /**
     * @param JsonRpcRequest $jsonRpcRequest
     *
     * @return JsonRpcResponse
     *
     * @throws JsonRpcInvalidParamsException
     * @throws JsonRpcMethodNotFoundException
     */
    public function processJsonRpcRequest(JsonRpcRequest $jsonRpcRequest) : JsonRpcResponse
    {
        $method = $this->resolveMethod($jsonRpcRequest);

        $this->validateParamList($jsonRpcRequest, $method);

        try {
            $result = $method->apply($jsonRpcRequest->getParamList());

            $event = new ActionEvent\OnMethodSuccessEvent($result, $method, $jsonRpcRequest);
        } catch (\Exception $exception) {
            $event = new ActionEvent\OnMethodFailureEvent($exception, $method, $jsonRpcRequest);
        }

        $this->dispatchJsonRpcEvent($event::EVENT_NAME, $event);

        return $this->createResponse($event);
    }

    /**
     * @param JsonRpcRequest $jsonRpcRequest
     *
     * @return JsonRpcMethodInterface
     *
     * @throws JsonRpcMethodNotFoundException
     */
    private function resolveMethod(JsonRpcRequest $jsonRpcRequest) : JsonRpcMethodInterface
    {
        $method = $this->methodResolver->resolve($jsonRpcRequest->getMethod());

        if (!$method instanceof JsonRpcMethodInterface) {
            throw new JsonRpcMethodNotFoundException($jsonRpcRequest->getMethod());
        }

        return $method;
    }

    /**
     *
     * @param JsonRpcRequest $jsonRpcRequest
     * @param JsonRpcMethodInterface $method
     *
     * @return void
     *
     * @throws JsonRpcInvalidParamsException
     */
    private function validateParamList(JsonRpcRequest $jsonRpcRequest, JsonRpcMethodInterface $method) : void
    {
        if (null !== $this->methodParamsValidator) {
            $violationList = $this->methodParamsValidator->validate($jsonRpcRequest, $method);

            if (count($violationList)) {
                throw new JsonRpcInvalidParamsException($violationList);
            }
        }
    }

    /**
     * @param ActionEvent\AbstractOnMethodEvent $event
     *
     * @return JsonRpcResponse
     */
    protected function createResponse(ActionEvent\AbstractOnMethodEvent $event) : JsonRpcResponse
    {
        if ($event instanceof ActionEvent\OnMethodSuccessEvent) {
            return $this->responseCreator->createResultResponse($event->getResult(), $event->getJsonRpcRequest());
        } else {
            /** @var $event ActionEvent\OnMethodFailureEvent */
            return $this->responseCreator->createErrorResponse(
                $event->getException(),
                $event->getJsonRpcRequest()
            );
        }
    }
}