Cmobi\RabbitmqBundle\Rpc\Handler

Complexity

Total Complexity

7

Size/Duplication

Total Lines	65
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	6

Importance

Changes	6
Bugs	1	Features	2

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
B	handle()	0	33	4
A	getResolver()	0	4	1
A	getContainer()	0	4	1

<?php

namespace Cmobi\RabbitmqBundle\Rpc;

use Cmobi\RabbitmqBundle\Rpc\Controller\RpcControllerResolver;
use Cmobi\RabbitmqBundle\Rpc\Exception\InvalidBodyAMQPMessageException;
use Cmobi\RabbitmqBundle\Rpc\Exception\RpcInternalErrorException;
use Cmobi\RabbitmqBundle\Rpc\Request\RpcRequestCollectionInterface;
use Cmobi\RabbitmqBundle\Rpc\Response\RpcResponse;
use Cmobi\RabbitmqBundle\Rpc\Response\RpcResponseCollection;
use Symfony\Component\DependencyInjection\ContainerAwareTrait;

class Handler
{
    use ContainerAwareTrait;

    private $resolver;

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

    /**
     * @param RpcRequestCollectionInterface $requests
     * @return RpcResponseCollection
     */
    public function handle(RpcRequestCollectionInterface $requests)
    {
        $responses = new RpcResponseCollection();

        foreach ($requests as $request) {

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

            if (!$request->attributes->get('error')) {

                $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 RpcInternalErrorException($previous);
                    $error = new RpcResponse($request->id, $request->method, $request->attributes, $exception);
                    $responses->add($error);
                } else {
                    $response = new RpcResponse($response);
                    $response->setId($request->id);
                    $response->setMethod($request->method);
                    $responses->add($response);
                }
            } else {
                $error = $request->attributes->get('error');
                $request->attributes->remove('error');
                $response = new RpcResponse($request->id, $request->method, $request, $error);
                $responses->add($response);
            }
        }

        return $responses;
    }

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

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