RabbitServiceProvider::loadMultipleConsumers() - Code Metrics - Inspection of "[Feature/29475] HAproxy fix" - etna-alternance/composer-rabbitmq-service-provider - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Pull Request — master (#12)

by Thierry

created 2016-06-13 14:35 UTC

RabbitServiceProvider::loadMultipleConsumers() C

↳ Parent: RabbitServiceProvider

Complexity

Conditions	7
Paths	1

Size

Total Lines	37
Code Lines	21

Duplication

Lines	7
Ratio	18.92 %

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
c	1
b	0
f	0
dl	7
loc	37
rs	6.7272
cc	7
eloc	21
nc	1
nop	1

<?php

namespace ETNA\Silex\Provider\RabbitMQ;

use Pimple\ServiceProviderInterface;
use Pimple\Container;
use Symfony\Component\Routing\Generator\UrlGenerator;
use OldSound\RabbitMqBundle\RabbitMq\Producer;
use OldSound\RabbitMqBundle\RabbitMq\Consumer;
.
|-- OtherDir
|   |-- Bar.php
|   `-- Foo.php
`-- SomeDir
    `-- Foo.php
use OldSound\RabbitMqBundle\RabbitMq\AnonConsumer;
use OldSound\RabbitMqBundle\RabbitMq\MultipleConsumer;
use OldSound\RabbitMqBundle\RabbitMq\RpcClient;
use OldSound\RabbitMqBundle\RabbitMq\RpcServer;
use PhpAmqpLib\Connection\AMQPConnection;
use PhpAmqpLib\Connection\AMQPLazyConnection;
use PhpAmqpLib\Connection\AMQPSSLConnection;

/**
 * Code repris de fiunchinho/rabbitmq-service-provider en attendant la compatibilité
 * avec silex 2
 */
class RabbitServiceProvider implements ServiceProviderInterface
{
    const DEFAULT_CONNECTION = 'default';

    public function register(Container $app)
    {
        $this->loadConnections($app);
class User
{
    private $email;

    public function getEmail()
    {
        return $this->email;
    }

    public function setEmail($email)
    {
        $this->email = $email;
    }
}
        $this->loadProducers($app);
class User
{
    private $email;

    public function getEmail()
    {
        return $this->email;
    }

    public function setEmail($email)
    {
        $this->email = $email;
    }
}
        $this->loadConsumers($app);
class User
{
    private $email;

    public function getEmail()
    {
        return $this->email;
    }

    public function setEmail($email)
    {
        $this->email = $email;
    }
}
        $this->loadAnonymousConsumers($app);
class User
{
    private $email;

    public function getEmail()
    {
        return $this->email;
    }

    public function setEmail($email)
    {
        $this->email = $email;
    }
}
        $this->loadMultipleConsumers($app);
class User
{
    private $email;

    public function getEmail()
    {
        return $this->email;
    }

    public function setEmail($email)
    {
        $this->email = $email;
    }
}
        $this->loadRpcClients($app);
class User
{
    private $email;

    public function getEmail()
    {
        return $this->email;
    }

    public function setEmail($email)
    {
        $this->email = $email;
    }
}
        $this->loadRpcServers($app);
class User
{
    private $email;

    public function getEmail()
    {
        return $this->email;
    }

    public function setEmail($email)
    {
        $this->email = $email;
    }
}
    }

    /**
     * Return the name of the connection to use.
     *
     * @param  array     $options     Options for the Producer or Consumer.
     * @param  array     $connections Connections defined in the config file.
     * @return string                 The connection name that will be used
     */
    private function getConnection($app, $options, $connections)
    {
        $connection_name = @$options['connection']?: self::DEFAULT_CONNECTION;

        if (!isset($connections[$connection_name])) {
            throw new \InvalidArgumentException('Configuration for connection [' . $connection_name . '] not found');
        }

        return $app['rabbit.connection'][$connection_name];
    }

    /**
     * @param Container $app
     */
    private function loadConnections($app)
    {
        $app['rabbit.connection'] = function ($app) {
            if (!isset($app['rabbit.connections'])) {
                throw new \InvalidArgumentException('You need to specify at least a connection in your configuration.');
            }

            $connections = [];
            foreach ($app["rabbit.connections"] as $name => $options) {
                $options    = $app["rabbit.connections"][$name];
                $amqp_class = (isset($options["ssl"]) && true === $options["ssl"]) ?
                    "PhpAmqpLib\Connection\AMQPSSLConnection" :
                    "PhpAmqpLib\Connection\AMQPConnection";

                $connection = new $amqp_class(
                    $options["host"],
                    $options["port"],
                    $options["user"],
                    $options["password"],
                    $options["vhost"],
                    $options["connection_opt"],
                    [
                        'read_write_timeout' => 60,
                        'heartbeat'          => 30
                    ]
                );

                $connections[$name] = $connection;
            }

            return $connections;
        };
    }

    /**
     * @param Container $app
     */
    private function loadProducers($app)
    {
        $app['rabbit.producer'] = function ($app) {
            if (!isset($app['rabbit.producers'])) {
                return;
            }
            $producers = [];
            foreach ($app['rabbit.producers'] as $name => $options) {
                $connection = $this->getConnection($app, $options, $app['rabbit.connections']);

                $producer = new Producer($connection);
function acceptsInteger($int) { }

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

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);
                $producer->setExchangeOptions($options['exchange_options']);

                //this producer doesn't define a queue
                if (!isset($options['queue_options'])) {
                    $options['queue_options']['name'] = null;
                }
                $producer->setQueueOptions($options['queue_options']);

                if ((array_key_exists('auto_setup_fabric', $options)) && (!$options['auto_setup_fabric'])) {
                    $producer->disableAutoSetupFabric();
                }

                $producers[$name] = $producer;
            }

            return $producers;
        };
    }

    /**
     * @param Container $app
     */
    private function loadConsumers($app)
    {
        $app['rabbit.consumer'] = function ($app) {
            if (!isset($app['rabbit.consumers'])) {
                return;
            }

            $consumers = [];
            foreach ($app['rabbit.consumers'] as $name => $options) {
                $connection = $this->getConnection($app, $options, $app['rabbit.connections']);
                $consumer = new Consumer($connection);
function acceptsInteger($int) { }

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

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);
                $consumer->setExchangeOptions($options['exchange_options']);
                $consumer->setQueueOptions($options['queue_options']);
                $consumer->setCallback(array($app[$options['callback']], 'execute'));

                if (array_key_exists('qos_options', $options)) {

                    $consumer->setQosOptions(
                        $options['qos_options']['prefetch_size'],
                        $options['qos_options']['prefetch_count'],
                        $options['qos_options']['global']
                    );
                }

                if (array_key_exists('qos_options', $options)) {
                    $consumer->setIdleTimeout($options['idle_timeout']);
                }

                if ((array_key_exists('auto_setup_fabric', $options)) && (!$options['auto_setup_fabric'])) {
                    $consumer->disableAutoSetupFabric();
                }

                $consumers[$name] = $consumer;
            }

            return $consumers;
        };
    }

    /**
     * @param Container $app
     */
    private function loadAnonymousConsumers($app)
    {
        $app['rabbit.anonymous_consumer'] = function ($app) {
            if (!isset($app['rabbit.anon_consumers'])) {
                return;
            }

            $consumers = [];
            foreach ($app['rabbit.anon_consumers'] as $name => $options) {
                $connection = $this->getConnection($app, $options, $app['rabbit.connections']);
                $consumer = new AnonConsumer($connection);
function acceptsInteger($int) { }

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

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);
                $consumer->setExchangeOptions($options['exchange_options']);
                $consumer->setCallback(array($options['callback'], 'execute'));

                $consumers[$name] = $consumer;
            }

            return $consumers;
        };
    }

    /**
     * @param Container $app
     */
    private function loadMultipleConsumers($app)
    {
        $app['rabbit.multiple_consumer'] = function ($app) {
            if (!isset($app['rabbit.multiple_consumers'])) {
                return;
            }

            $consumers = [];
            foreach ($app['rabbit.multiple_consumers'] as $name => $options) {
                $connection = $this->getConnection($app, $options, $app['rabbit.connections']);
                $consumer = new MultipleConsumer($connection);
function acceptsInteger($int) { }

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

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);
                $consumer->setExchangeOptions($options['exchange_options']);
                $consumer->setQueues($options['queues']);

                if (array_key_exists('qos_options', $options)) {

                    $consumer->setQosOptions(
                        $options['qos_options']['prefetch_size'],
                        $options['qos_options']['prefetch_count'],
                        $options['qos_options']['global']
                    );
                }

                if (array_key_exists('qos_options', $options)) {
                    $consumer->setIdleTimeout($options['idle_timeout']);
                }

                if ((array_key_exists('auto_setup_fabric', $options)) && (!$options['auto_setup_fabric'])) {
                    $consumer->disableAutoSetupFabric();
                }

                $consumers[$name] = $consumer;
            }

            return $consumers;
        };

    }

    /**
     * @param Container $app
     */
    private function loadRpcClients($app)
    {
        $app['rabbit.rpc_client'] = function ($app) {
            if (!isset($app['rabbit.rpc_clients'])) {
                return;
            }

            $clients = [];
            foreach ($app['rabbit.rpc_clients'] as $name => $options) {
                $connection = $this->getConnection($app, $options, $app['rabbit.connections']);
                $client = new RpcClient($connection);
function acceptsInteger($int) { }

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

// Instead of
acceptsInteger($x);

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

                if (array_key_exists('expect_serialized_response', $options)) {
                    $client->initClient($options['expect_serialized_response']);
                }

                $clients[$name] = $client;
            }

            return $clients;
        };
    }

    /**
     * @param Container $app
     */
    private function loadRpcServers($app)
    {
        $app['rabbit.rpc_server'] = function ($app) {
            if (!isset($app['rabbit.rpc_servers'])) {
                return;
            }

            $servers = [];
            foreach ($app['rabbit.rpc_servers'] as $name => $options) {
                $connection = $this->getConnection($app, $options, $app['rabbit.connections']);
                $server = new RpcServer($connection);
function acceptsInteger($int) { }

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

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);
                $server->initServer($name);
                $server->setCallback(array($options['callback'], 'execute'));

                if (array_key_exists('qos_options', $options)) {

                    $server->setQosOptions(
                        $options['qos_options']['prefetch_size'],
                        $options['qos_options']['prefetch_count'],
                        $options['qos_options']['global']
                    );
                }

                $servers[$name] = $server;
            }

            return $servers;
        };
    }
}


1			<?php
2
3			namespace ETNA\Silex\Provider\RabbitMQ;
4
5			use Pimple\ServiceProviderInterface;
6			use Pimple\Container;
7			use Symfony\Component\Routing\Generator\UrlGenerator;
8			use OldSound\RabbitMqBundle\RabbitMq\Producer;
9			use OldSound\RabbitMqBundle\RabbitMq\Consumer;
			0 ignored issues – show Bug introduced 2016-03-14 15:50 UTC by Report Bug Copy Issue Report This use statement conflicts with another class in this namespace, `ETNA\Silex\Provider\RabbitMQ\Consumer`. Let’s assume that you have a directory layout like this: . \|-- OtherDir \| \|-- Bar.php \| `-- Foo.php `-- SomeDir `-- Foo.php and let’s assume the following content of `Bar.php`: // Bar.php namespace OtherDir; use SomeDir\Foo; // This now conflicts the class OtherDir\Foo If both files `OtherDir/Foo.php` and `SomeDir/Foo.php` are loaded in the same runtime, you will see a PHP error such as the following: PHP Fatal error: Cannot use SomeDir\Foo as Foo because the name is already in use in OtherDir/Foo.php However, as `OtherDir/Foo.php` does not necessarily have to be loaded and the error is only triggered if it is loaded before `OtherDir/Bar.php`, this problem might go unnoticed for a while. In order to prevent this error from surfacing, you must import the namespace with a different alias: // Bar.php namespace OtherDir; use SomeDir\Foo as SomeDirFoo; // There is no conflict anymore. Loading history...
10			use OldSound\RabbitMqBundle\RabbitMq\AnonConsumer;
11			use OldSound\RabbitMqBundle\RabbitMq\MultipleConsumer;
12			use OldSound\RabbitMqBundle\RabbitMq\RpcClient;
13			use OldSound\RabbitMqBundle\RabbitMq\RpcServer;
14			use PhpAmqpLib\Connection\AMQPConnection;
15			use PhpAmqpLib\Connection\AMQPLazyConnection;
16			use PhpAmqpLib\Connection\AMQPSSLConnection;
17
18			/**
19			* Code repris de fiunchinho/rabbitmq-service-provider en attendant la compatibilité
20			* avec silex 2
21			*/
22			class RabbitServiceProvider implements ServiceProviderInterface
23			{
24			const DEFAULT_CONNECTION = 'default';
25
26			public function register(Container $app)
27			{
28			$this->loadConnections($app);
			0 ignored issues – show Unused Code introduced 2016-03-14 15:50 UTC by Report Bug Copy Issue Report The call to the method `ETNA\Silex\Provider\Rabb...ider::loadConnections()` seems un-needed as the method has no side-effects. PHP Analyzer performs a side-effects analysis of your code. A side-effect is basically anything that might be visible after the scope of the method is left. Let’s take a look at an example: class User { private $email; public function getEmail() { return $this->email; } public function setEmail($email) { $this->email = $email; } } If we look at the `getEmail()` method, we can see that it has no side-effect. Whether you call this method or not, no future calls to other methods are affected by this. As such code as the following is useless: $user = new User(); $user->getEmail(); // This line could safely be removed as it has no effect. On the hand, if we look at the `setEmail()`, this method _has_ side-effects. In the following case, we could not remove the method call: $user = new User(); $user->setEmail('email@domain'); // This line has a side-effect (it changes an // instance variable). Loading history...
29			$this->loadProducers($app);
			0 ignored issues – show Unused Code introduced 2016-03-14 15:50 UTC by Report Bug Copy Issue Report The call to the method `ETNA\Silex\Provider\Rabb...ovider::loadProducers()` seems un-needed as the method has no side-effects. PHP Analyzer performs a side-effects analysis of your code. A side-effect is basically anything that might be visible after the scope of the method is left. Let’s take a look at an example: class User { private $email; public function getEmail() { return $this->email; } public function setEmail($email) { $this->email = $email; } } If we look at the `getEmail()` method, we can see that it has no side-effect. Whether you call this method or not, no future calls to other methods are affected by this. As such code as the following is useless: $user = new User(); $user->getEmail(); // This line could safely be removed as it has no effect. On the hand, if we look at the `setEmail()`, this method _has_ side-effects. In the following case, we could not remove the method call: $user = new User(); $user->setEmail('email@domain'); // This line has a side-effect (it changes an // instance variable). Loading history...
30			$this->loadConsumers($app);
			0 ignored issues – show Unused Code introduced 2016-03-14 15:50 UTC by Report Bug Copy Issue Report The call to the method `ETNA\Silex\Provider\Rabb...ovider::loadConsumers()` seems un-needed as the method has no side-effects. PHP Analyzer performs a side-effects analysis of your code. A side-effect is basically anything that might be visible after the scope of the method is left. Let’s take a look at an example: class User { private $email; public function getEmail() { return $this->email; } public function setEmail($email) { $this->email = $email; } } If we look at the `getEmail()` method, we can see that it has no side-effect. Whether you call this method or not, no future calls to other methods are affected by this. As such code as the following is useless: $user = new User(); $user->getEmail(); // This line could safely be removed as it has no effect. On the hand, if we look at the `setEmail()`, this method _has_ side-effects. In the following case, we could not remove the method call: $user = new User(); $user->setEmail('email@domain'); // This line has a side-effect (it changes an // instance variable). Loading history...
31			$this->loadAnonymousConsumers($app);
			0 ignored issues – show Unused Code introduced 2016-03-14 15:50 UTC by Report Bug Copy Issue Report The call to the method `ETNA\Silex\Provider\Rabb...oadAnonymousConsumers()` seems un-needed as the method has no side-effects. PHP Analyzer performs a side-effects analysis of your code. A side-effect is basically anything that might be visible after the scope of the method is left. Let’s take a look at an example: class User { private $email; public function getEmail() { return $this->email; } public function setEmail($email) { $this->email = $email; } } If we look at the `getEmail()` method, we can see that it has no side-effect. Whether you call this method or not, no future calls to other methods are affected by this. As such code as the following is useless: $user = new User(); $user->getEmail(); // This line could safely be removed as it has no effect. On the hand, if we look at the `setEmail()`, this method _has_ side-effects. In the following case, we could not remove the method call: $user = new User(); $user->setEmail('email@domain'); // This line has a side-effect (it changes an // instance variable). Loading history...
32			$this->loadMultipleConsumers($app);
			0 ignored issues – show Unused Code introduced 2016-03-14 15:50 UTC by Report Bug Copy Issue Report The call to the method `ETNA\Silex\Provider\Rabb...loadMultipleConsumers()` seems un-needed as the method has no side-effects. PHP Analyzer performs a side-effects analysis of your code. A side-effect is basically anything that might be visible after the scope of the method is left. Let’s take a look at an example: class User { private $email; public function getEmail() { return $this->email; } public function setEmail($email) { $this->email = $email; } } If we look at the `getEmail()` method, we can see that it has no side-effect. Whether you call this method or not, no future calls to other methods are affected by this. As such code as the following is useless: $user = new User(); $user->getEmail(); // This line could safely be removed as it has no effect. On the hand, if we look at the `setEmail()`, this method _has_ side-effects. In the following case, we could not remove the method call: $user = new User(); $user->setEmail('email@domain'); // This line has a side-effect (it changes an // instance variable). Loading history...
33			$this->loadRpcClients($app);
			0 ignored issues – show Unused Code introduced 2016-03-14 15:50 UTC by Report Bug Copy Issue Report The call to the method `ETNA\Silex\Provider\Rabb...vider::loadRpcClients()` seems un-needed as the method has no side-effects. PHP Analyzer performs a side-effects analysis of your code. A side-effect is basically anything that might be visible after the scope of the method is left. Let’s take a look at an example: class User { private $email; public function getEmail() { return $this->email; } public function setEmail($email) { $this->email = $email; } } If we look at the `getEmail()` method, we can see that it has no side-effect. Whether you call this method or not, no future calls to other methods are affected by this. As such code as the following is useless: $user = new User(); $user->getEmail(); // This line could safely be removed as it has no effect. On the hand, if we look at the `setEmail()`, this method _has_ side-effects. In the following case, we could not remove the method call: $user = new User(); $user->setEmail('email@domain'); // This line has a side-effect (it changes an // instance variable). Loading history...

etna-alternance / composer-rabbitmq-service-provider

Pull Request — master (#12)

RabbitServiceProvider::loadMultipleConsumers() C

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like