Cmobi\RabbitmqBundle\Rpc\Handler

Complexity

Total Complexity

6

Size/Duplication

Total Lines	50
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	6

Importance

Changes	5
Bugs	1	Features	2

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	getResolver()	0	4	1
A	getContainer()	0	4	1
A	handle()	0	22	3

<?php

namespace Cmobi\RabbitmqBundle\Rpc;

use Cmobi\RabbitmqBundle\Rpc\Controller\RpcControllerResolver;
use Cmobi\RabbitmqBundle\Rpc\Exception\InvalidBodyAMQPMessageException;
use Cmobi\RabbitmqBundle\Rpc\Exception\JsonRpcInternalErrorException;
use Cmobi\RabbitmqBundle\Rpc\Request\RpcRequestCollectionInterface;
use Cmobi\RabbitmqBundle\Rpc\Response\JsonRpcResponse;
use Cmobi\RabbitmqBundle\Rpc\Response\JsonRpcResponseCollection;
use Cmobi\RabbitmqBundle\Rpc\Response\RpcResponseCollectionInterface;
use Symfony\Component\DependencyInjection\ContainerAwareTrait;

class Handler
{
    use ContainerAwareTrait;

    private $resolver;

    public function __construct()
    {
        $this->resolver = new RpcControllerResolver();
    }

    public function handle(RpcRequestCollectionInterface $requests, RpcResponseCollectionInterface $responses)
    {
        foreach ($requests as $request) {

The expression $requests of type object<Cmobi\RabbitmqBundle\Rpc\Request\RpcRequestCollectionInterface> is not traversable.

            $controller = $this->getResolver()->getController($request);
            $arguments = $this->getResolver()->getArguments($request, $controller);
            $response = call_user_func_array($controller, $arguments);

            if (!is_array($response)) {
                $previous = new InvalidBodyAMQPMessageException('Invalid Body: Content should be array.');
                $exception = new JsonRpcInternalErrorException($previous);
                $error = new JsonRpcResponse([], $exception);
                $error->setId($request->id);
                $error->setMethod($request->method);
                $responses->add($error);
            } else {
                $response = new JsonRpcResponse($response);
                $response->setId($request->id);
                $response->setMethod($request->method);
                $responses->add($response);
            }
        }
    }

    /**
     * @return RpcControllerResolver
     */
    public function getResolver()
    {
        return $this->resolver;
    }

    /**
     * @return \Symfony\Component\DependencyInjection\ContainerInterface
     */
    public function getContainer()
    {
        return $this->container;
    }
}