BaseService::publish() - Code Metrics - Inspection of "improve handler" - contamobi/CmobiRabbitmqBundle - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( e91c7a...7c1ddd )

by Daniel

created 2016-03-14 22:29 UTC

BaseService::publish() A

↳ Parent: BaseService

Complexity

Conditions	1
Paths	1

Size

Total Lines	11
Code Lines	7

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
c	1
b	0
f	0
dl	0
loc	11
rs	9.4285
cc	1
eloc	7
nc	1
nop	2

<?php

namespace Cmobi\RabbitmqBundle\Rpc;

use Cmobi\RabbitmqBundle\Rpc\Exception\InvalidBodyAMQPMessageException;
use Cmobi\RabbitmqBundle\Rpc\Exception\RpcInternalErrorException;
use Cmobi\RabbitmqBundle\Rpc\Exception\RpcInvalidResponseException;
use Cmobi\RabbitmqBundle\Rpc\Response\RpcResponse;
use Cmobi\RabbitmqBundle\Rpc\Response\RpcResponseCollection;
use Cmobi\RabbitmqBundle\Rpc\Response\RpcResponseCollectionInterface;
use PhpAmqpLib\Message\AMQPMessage;

class BaseService implements RpcServiceInterface
{
    private $queueName;
    private $rpcHandler;
    private $rpcMessager;

    /** @var array */
    protected $queueOptions = [
        'name'                  => null,
        'passive'               => false,
        'durable'               => true,
        'exclusive'             => false,
        'auto_delete'           => false, //Em caso de falha no serviço a filha se mantém para que outro processe.
        'nowait'                => false,
        'arguments'             => null,
        'ticket'                => null
    ];

    public function __construct(Handler $handler, RpcMessager $messager, array $queueOptions, array $parameters = null)

    {
        $this->rpcHandler = $handler;
        $this->rpcMessager = $messager;
        $this->queueName = $queueOptions['name'];
        $this->queueOptions = array_merge($this->queueOptions, $queueOptions);
    }

    /**
     * @return \Closure
     * @throws InvalidBodyAMQPMessageException
     */
    public function createCallback()
    {
        $callback = function (AMQPMessage $message) {
            try {
                $requestCollection = $this->rpcMessager->parseAMQPMessage($message);
                $responseCollection = $this->getHandler()->handle($requestCollection);
            } catch (\Exception $e) {
                $responseCollection = new RpcResponseCollection();
                $exception = new RpcInternalErrorException();
                $response = new RpcResponse(null, [], $exception);
                $responseCollection->add($response);
            }
            $messageResponse = $this->buildResponseMessage($responseCollection, $message);
            $this->publish($message, $messageResponse);
        };

        return $callback;
    }

    /**
     * @param RpcResponseCollectionInterface $responses
     * @param AMQPMessage $requestMessage
     * @return AMQPMessage
     * @throws RpcInvalidResponseException
     */
    public function buildResponseMessage(RpcResponseCollectionInterface $responses, AMQPMessage $requestMessage)
    {
        $rpcResponse = [];
        /**
         * @var RpcResponse $response
         */
        foreach ($responses->all() as $response) {

            if (is_null($response->id)) {
                $response->id = $requestMessage->get('correlation_id');
            }
            $rpcResponse[] = $response->toArray();
        }
        try {
            $rpcResponse = json_encode($rpcResponse);
        } catch (\Exception $e) {
            throw new RpcInvalidResponseException($e);
        }
        $amqpResponse = new AMQPMessage(
            (string)$rpcResponse,
            ['correlation_id' => $requestMessage->get('correlation_id')]
        );

        return $amqpResponse;
    }

    /**
     * @param AMQPMessage $message
     * @param $content
     */
    public function publish(AMQPMessage $message, $content)
    {
        $message->delivery_info['channel']->basic_publish(
            $content,
            '',
            $message->get('reply_to')
        );
        $message->delivery_info['channel']->basic_ack(
            $message->delivery_info['delivery_tag']
function acceptsInteger($int) { }

$x = '123'; // string "123"

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);
        );
    }

    public function getQueueName()
    {
        return $this->queueName;
    }

    /**
     * @return array
     */
    public function getQueueOptions()
    {
        return $this->queueOptions;
    }

    /**
     * @return Handler
     */
    public function getHandler()
    {
        return $this->rpcHandler;
    }

    /**
     * @return RpcMessager
     */
    public function getMessager()
    {
        return $this->rpcMessager;
    }
}

1			<?php
2
3			namespace Cmobi\RabbitmqBundle\Rpc;
4
5			use Cmobi\RabbitmqBundle\Rpc\Exception\InvalidBodyAMQPMessageException;
6			use Cmobi\RabbitmqBundle\Rpc\Exception\RpcInternalErrorException;
7			use Cmobi\RabbitmqBundle\Rpc\Exception\RpcInvalidResponseException;
8			use Cmobi\RabbitmqBundle\Rpc\Response\RpcResponse;
9			use Cmobi\RabbitmqBundle\Rpc\Response\RpcResponseCollection;
10			use Cmobi\RabbitmqBundle\Rpc\Response\RpcResponseCollectionInterface;
11			use PhpAmqpLib\Message\AMQPMessage;
12
13			class BaseService implements RpcServiceInterface
14			{
15			private $queueName;
16			private $rpcHandler;
17			private $rpcMessager;
18
19			/** @var array */
20			protected $queueOptions = [
21			'name' => null,
22			'passive' => false,
23			'durable' => true,
24			'exclusive' => false,
25			'auto_delete' => false, //Em caso de falha no serviço a filha se mantém para que outro processe.
26			'nowait' => false,
27			'arguments' => null,
28			'ticket' => null
29			];
30
31			public function __construct(Handler $handler, RpcMessager $messager, array $queueOptions, array $parameters = null)
			0 ignored issues – show Unused Code introduced 2016-02-26 20:24 UTC by Report Bug Copy Issue Report The parameter `$parameters` is not used and could be removed. This check looks from parameters that have been defined for a function or method, but which are not used in the method body. Loading history...
32			{
33			$this->rpcHandler = $handler;
34			$this->rpcMessager = $messager;
35			$this->queueName = $queueOptions['name'];
36			$this->queueOptions = array_merge($this->queueOptions, $queueOptions);
37			}
38
39			/**
40			* @return \Closure
41			* @throws InvalidBodyAMQPMessageException
42			*/
43			public function createCallback()
44			{
45			$callback = function (AMQPMessage $message) {
46			try {
47			$requestCollection = $this->rpcMessager->parseAMQPMessage($message);
48			$responseCollection = $this->getHandler()->handle($requestCollection);
49			} catch (\Exception $e) {
50			$responseCollection = new RpcResponseCollection();
51			$exception = new RpcInternalErrorException();
52			$response = new RpcResponse(null, [], $exception);
53			$responseCollection->add($response);
54			}
55			$messageResponse = $this->buildResponseMessage($responseCollection, $message);
56			$this->publish($message, $messageResponse);
57			};
58
59			return $callback;
60			}
61
62			/**
63			* @param RpcResponseCollectionInterface $responses
64			* @param AMQPMessage $requestMessage
65			* @return AMQPMessage
66			* @throws RpcInvalidResponseException
67			*/
68			public function buildResponseMessage(RpcResponseCollectionInterface $responses, AMQPMessage $requestMessage)
69			{
70			$rpcResponse = [];
71			/**
72			* @var RpcResponse $response
73			*/
74			foreach ($responses->all() as $response) {
75
76			if (is_null($response->id)) {
77			$response->id = $requestMessage->get('correlation_id');
78			}
79			$rpcResponse[] = $response->toArray();
80			}
81			try {
82			$rpcResponse = json_encode($rpcResponse);
83			} catch (\Exception $e) {
84			throw new RpcInvalidResponseException($e);
85			}
86			$amqpResponse = new AMQPMessage(
87			(string)$rpcResponse,
88			['correlation_id' => $requestMessage->get('correlation_id')]
89			);
90
91			return $amqpResponse;
92			}
93
94			/**
95			* @param AMQPMessage $message
96			* @param $content
97			*/
98			public function publish(AMQPMessage $message, $content)
99			{
100			$message->delivery_info['channel']->basic_publish(
101			$content,
102			'',
103			$message->get('reply_to')
104			);
105			$message->delivery_info['channel']->basic_ack(
106			$message->delivery_info['delivery_tag']
			0 ignored issues – show Documentation introduced 2016-03-09 22:20 UTC by Report Bug Copy Issue Report `$message->delivery_info['delivery_tag']` is of type `object<PhpAmqpLib\Channel\AMQPChannel>`, but the function expects a `string`. It seems like the type of the argument is not accepted by the function/method which you are calling. In some cases, in particular if PHP’s automatic type-juggling kicks in this might be fine. In other cases, however this might be a bug. We suggest to add an explicit type cast like in the following example: function acceptsInteger($int) { } $x = '123'; // string "123" // Instead of acceptsInteger($x); // we recommend to use acceptsInteger((integer) $x); Loading history...
107			);
108			}
109
110			public function getQueueName()
111			{
112			return $this->queueName;
113			}
114
115			/**
116			* @return array
117			*/
118			public function getQueueOptions()
119			{
120			return $this->queueOptions;
121			}
122
123			/**
124			* @return Handler
125			*/
126			public function getHandler()
127			{
128			return $this->rpcHandler;
129			}
130
131			/**
132			* @return RpcMessager
133			*/
134			public function getMessager()
135			{
136			return $this->rpcMessager;
137			}
138			}

contamobi / CmobiRabbitmqBundle

Push — master ( e91c7a...7c1ddd )

BaseService::publish() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like