ConnectionContainer::__construct() - Code Metrics - umbrellio/php-table-sync - Measure and Improve Code Quality continuously with Scrutinizer

ConnectionContainer::__construct() A
last analyzed 2023-03-17 08:45 UTC

↳ Parent: ConnectionContainer

Complexity

Conditions	1
Paths	1

Size

Total Lines	19
Code Lines	9

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	2

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
eloc	9
c	1
b	0
f	0
dl	0
loc	19
ccs	0
cts	10
cp	0
rs	9.9666
cc	1
nc	1
nop	7
crap	2

<?php

declare(strict_types=1);

namespace Umbrellio\TableSync\Rabbit;

use ErrorException;
use PhpAmqpLib\Connection\AbstractConnection;
use PhpAmqpLib\Connection\AMQPSSLConnection;

class ConnectionContainer
{
    private const DEFAULT_WAIT_BEFORE_RECONNECT_MICROSECONDS = 1000000;

    private $host;
    private $port;
    private $user;
    private $pass;
    private $vhost;
    private $sslOptions;
    private $options;
    private $waitBeforeReconnectMicroseconds;

    /**
     * @var AbstractConnection|null
     */
    private $connection;

    public function __construct(
        string $host,
        string $port,
        string $user,
        string $pass,
        string $vhost = '/',
        array $sslOptions = [],
        array $options = []
    ) {
        $this->host = $host;
        $this->port = $port;
        $this->user = $user;
        $this->pass = $pass;
        $this->vhost = $vhost;
        $this->sslOptions = $sslOptions;
        $this->options = $options;

        $this->waitBeforeReconnectMicroseconds = $options['wait_before_reconnect_microseconds']
            ?? self::DEFAULT_WAIT_BEFORE_RECONNECT_MICROSECONDS;
    }

    public function __destruct()
    {
        $this->close();
    }

    public function connection(): AbstractConnection
    {
        if ($this->connection === null) {
            $this->reconnect(false);
        }

        return $this->connection;
    }

    public function reconnect(bool $wait = true): void
    {
        $this->close();

        if ($wait) {
            usleep($this->waitBeforeReconnectMicroseconds);
        }

        $this->connection = new AMQPSSLConnection(
            $this->host,
            $this->port,
            /** @scrutinizer ignore-type */ $this->port,
            $this->user,
            $this->pass,
            $this->vhost,
            $this->sslOptions,
            $this->options
        );
    }

    public function close(): void
    {
        try {
            if ($this->connection === null) {
                return;
            }

            $this->connection->close();
            $this->connection = null;
        } catch (ErrorException $errorException) {
            // @todo Finish later
        }
    }
}


umbrellio / php-table-sync

ConnectionContainer::__construct() A last analyzed 2023-03-17 08:45 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

ConnectionContainer::__construct() A
last analyzed 2023-03-17 08:45 UTC