for testing and deploying your application
for finding and fixing issues
for empowering human code reviews
<?php
namespace Cmobi\RabbitmqBundle\Rpc\Request;
use Cmobi\RabbitmqBundle\Rpc\Exception\JsonRpcInvalidParamsException;
use Cmobi\RabbitmqBundle\Rpc\Exception\JsonRpcUnsupportedProtocolException;
class JsonRpcRequestFactory
{
private $requiredFields = ['id', 'jsonrpc', 'method'];
public function factory(array $request)
$this->validateRequiredFields($request);
$request = new JsonRpcRequest($request['params']);
$request->setId($request['id']);
$request->setMethod($request['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'] !== JsonRpcRequest::VERSION) {
throw new JsonRpcUnsupportedProtocolException();
contamobi /
CmobiRabbitmqBundle
