Cmobi\RabbitmqBundle\Rpc\Request\RpcRequestFactory

Complexity

Total Complexity

4

Size/Duplication

Total Lines	28
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes	1
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	factory()	0	10	1
A	validateRequiredFields()	0	12	3

<?php

namespace Cmobi\RabbitmqBundle\Rpc\Request;

use Cmobi\RabbitmqBundle\Rpc\Exception\JsonRpcInvalidParamsException;
use Cmobi\RabbitmqBundle\Rpc\Exception\JsonRpcUnsupportedProtocolException;

class RpcRequestFactory
{
    private $requiredFields = ['id', 'jsonrpc', 'method'];

    public function factory(array $requestMessage)
    {
        $this->validateRequiredFields($requestMessage);

        $request = new RpcRequest($requestMessage['params']);
        $request->setId($requestMessage['id']);
        $request->setMethod($requestMessage['method']);

        return $request;
    }

    public function validateRequiredFields(array $parameters)
    {
        $keys = array_intersect_key($parameters, array_flip($this->requiredFields));

        if (count($this->requiredFields) !=  count($keys)) {
            throw new JsonRpcInvalidParamsException();
        }

        if ($parameters['jsonrpc'] !== RpcRequest::VERSION) {
            throw new JsonRpcUnsupportedProtocolException();
        }
    }
}