ETNA\Silex\Provider\RabbitMQ\RabbitMQServiceProvider

Complexity

Total Complexity

13

Size/Duplication

Total Lines	108
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	4

Importance

Changes	1
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	boot()	0	5	3
D	register()	0	99	10

<?php

namespace ETNA\Silex\Provider\RabbitMQ;

use Silex\Application;
use Silex\ServiceProviderInterface;

/**
 *
 */
class RabbitMQServiceProvider implements ServiceProviderInterface
{
    public function boot(Application $app)
    {
        isset($app['amqp.exchanges.options']) || $app['amqp.exchanges.options'] = [];
        isset($app['amqp.queues.options'])    || $app['amqp.queues.options']    = [];
    }

    public function register(Application $app)
    {
        $app["amqp.chan"] = $app->share(
            function (Application $app) {
                return $app["amqp.chans"]["default"];
            }
        );

        $app["amqp.chans"] = $app->share(
            function (Application $app) {
                $chans = new \Pimple();

                foreach ($app['amqp.chans.options'] as $name => $options) {
                    $chans[$name] = $app->share(
                        function () use ($app, $name, $options) {
                            $amqp_args = [
                                $options["host"],
                                $options["port"],
                                $options["user"],
                                $options["password"],
                                $options["vhost"]
                            ];

                            if (isset($options["ssl"]) && $options["ssl"] === true) {
                                $amqp_class  = 'PhpAmqpLib\Connection\AMQPSSLConnection';
                                $amqp_args[] = [ 'verify_peer' => false, 'verify_peer_name' => false ];
                            } else {
                                $amqp_class = 'PhpAmqpLib\Connection\AMQPConnection';
                            }

                            $reflection = new \ReflectionClass($amqp_class);
                            $connection = $reflection->newInstanceArgs($amqp_args);

                            $channel = $connection->channel();
                            register_shutdown_function(function ($channel, $connection) use ($name) {
                                $channel->close();
                                $connection->close();
                            }, $channel, $connection);
                            return $channel;
                        }
                    );
                }

                return $chans;
            }
        );

        $app["amqp.exchanges"] = $app->share(
            function (Application $app) {
                $exchanges = new \Pimple();

                $exchanges["default"] = $app->share(
                    function () use ($app) {
                        return new Exchange("", $app["amqp.chan"], []);
                    }
                );

                foreach ($app['amqp.exchanges.options'] as $name => $options) {
                    if ($name == 'default') {
                        throw new \Exception("'default' is a reserved Exchange. You can't override it.");
                    }
                    $exchanges[$name] = $app->share(
                        function () use ($app, $name, $options) {
                            $channel = (isset($options["channel"])) ? $options["channel"] : "default";
                            return new Exchange($name, $app["amqp.chans"][$channel], $options);
                        }
                    );
                }

                return $exchanges;
            }
        );

        $app["amqp.queues"] = $app->share(
            function (Application $app) {
                $queues = new \Pimple();

                $queues[""] = $app->share(
                    function () use ($app) {
                        return new Queue("", $app["amqp.exchanges"]["default"], $app["amqp.exchanges"]["default"]->getChannel());

The call to Queue::__construct() misses a required argument $options.

This line exceeds maximum limit of 120 characters; contains 129 characters

                    }
                );

                foreach ($app['amqp.queues.options'] as $name => $options) {
                    if ($name == "") {
                        throw new \Exception("Unamed queue is a reserved Queue. You can't override it.");
                    }
                    $queues[$name] = $app->share(
                        function () use ($app, $name, $options) {
                            $exchange = (isset($options["exchange"])) ? $options["exchange"] : "default";
                            return new Queue($name, $app["amqp.exchanges"][$exchange], $app["amqp.exchanges"][$exchange]->getChannel(), $options);

This line exceeds maximum limit of 120 characters; contains 146 characters

                        }
                    );
                }

                return $queues;
            }
        );
    }
}