Cmobi\RabbitmqBundle\Rpc\Handler::handle()

Complexity

Conditions	4
Paths	4

Size

Total Lines	33
Code Lines	23

Duplication

Lines	0
Ratio	0 %

Importance

Changes	6
Bugs	1	Features	2

<?php
    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;
    }

}