Alchemy\Queue\Amqp\AmqpConfiguration

Complexity

Total Complexity

13

Size/Duplication

Total Lines	168
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	0

Test Coverage

Coverage

100%

Importance

Changes	4
Bugs	0	Features	2

12 Methods

Rating	Name	Duplication	Size	Complexity
A	parse()	0	22	1
A	extractValueOrDefault()	0	4	2
A	getHost()	0	4	1
A	getVhost()	0	4	1
A	getPort()	0	4	1
A	getUser()	0	4	1
A	getPassword()	0	4	1
A	getDeadLetterExchange()	0	4	1
A	getExchange()	0	4	1
A	getQueue()	0	4	1
A	getTimeout()	0	4	1
A	toConnectionArray()	0	10	1

<?php

namespace Alchemy\Queue\Amqp;

class AmqpConfiguration
{
    /**
     * @param array $parameters
     * @return AmqpConfiguration
     */
    public static function parse(array $parameters)
    {
        $configuration = new self();

        $configuration->host = self::extractValueOrDefault($parameters, 'host', $configuration->host);
        $configuration->vhost = self::extractValueOrDefault($parameters, 'vhost', $configuration->vhost);
        $configuration->port = self::extractValueOrDefault($parameters, 'port', $configuration->port);
        $configuration->user = self::extractValueOrDefault($parameters, 'user', $configuration->user);
        $configuration->password = self::extractValueOrDefault($parameters, 'password', $configuration->password);
        $configuration->exchange = self::extractValueOrDefault($parameters, 'exchange', $configuration->exchange);
        $configuration->timeout = self::extractValueOrDefault($parameters, 'timeout', $configuration->timeout);

        $configuration->deadLetterExchange = self::extractValueOrDefault(
            $parameters,
            'dead-letter-exchange',
            $configuration->deadLetterExchange
        );

        $configuration->queue = self::extractValueOrDefault($parameters, 'queue', $configuration->queue);

        return $configuration;
    }

    /**
     * @param array $parameters
     * @param string $key
     * @param mixed|null $default
     * @return mixed Value set in array or default value
     */
    private static function extractValueOrDefault(array $parameters, $key, $default = null)
    {
        return isset($parameters[$key]) ? $parameters[$key] : $default;
    }

    /**
     * @var string
     */
    private $host = 'localhost';

    /**
     * @var string
     */
    private $vhost = '/';

    /**
     * @var int
     */
    private $port = 5672;

    /**
     * @var string
     */
    private $user = 'guest';

    /**
     * @var string
     */
    private $password = 'guest';

    /**
     * @var string
     */
    private $deadLetterExchange = '';

    /**
     * @var string
     */
    private $exchange = 'alchemy-exchange';

    /**
     * @var string
     */
    private $queue = 'alchemy-queue';

    /**
     * @var int
     */
    private $timeout = 0;

    /**
     * @return string
     */
    public function getHost()
    {
        return $this->host;
    }

    /**
     * @return string
     */
    public function getVhost()
    {
        return $this->vhost;
    }

    /**
     * @return int
     */
    public function getPort()
    {
        return $this->port;
    }

    /**
     * @return string
     */
    public function getUser()
    {
        return $this->user;
    }

    /**
     * @return string
     */
    public function getPassword()
    {
        return $this->password;
    }

    /**
     * @return string
     */
    public function getDeadLetterExchange()
    {
        return $this->deadLetterExchange;
    }

    /**
     * @return string
     */
    public function getExchange()
    {
        return $this->exchange;
    }

    /**
     * @return string
     */
    public function getQueue()
    {
        return $this->queue;
    }

    /**
     * @return int
     */
    public function getTimeout()
    {
        return $this->timeout;
    }

    public function toConnectionArray()
    {
        return [
            'host' => $this->host,
            'port' => $this->port,
            'vhost' => $this->vhost,
            'login' => $this->user,
            'password' => $this->password
        ];
    }
}