Genkgo\Mail\Protocol\AutomaticConnection

Complexity

Total Complexity

15

Size/Duplication

Total Lines	124
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Test Coverage

Coverage

100%

Importance

Changes

0

10 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	addListener()	0	4	1
A	connect()	0	12	2
A	disconnect()	0	5	1
A	send()	0	5	1
A	receive()	0	5	1
A	upgrade()	0	4	1
A	timeout()	0	4	1
A	getMetaData()	0	4	1
B	connectIfNotConnected()	0	12	5

<?php
declare(strict_types=1);

namespace Genkgo\Mail\Protocol;

final class AutomaticConnection implements ConnectionInterface
{
    /**
     * @var ConnectionInterface
     */
    private $decoratedConnection;
    /**
     * @var \DateTimeImmutable|null
     */
    private $connectedAt;
    /**
     * @var \DateInterval
     */
    private $interval;
    /**
     * @var bool
     */
    private $connecting = false;

    /**
     * AppendCrlfConnection constructor.
     * @param ConnectionInterface $decoratedConnection
     * @param \DateInterval $interval
     */
    public function __construct(ConnectionInterface $decoratedConnection, \DateInterval $interval)
    {
        $this->decoratedConnection = $decoratedConnection;
        $this->interval = $interval;
    }

    /**
     * @param string $name
     * @param \Closure $callback
     */
    public function addListener(string $name, \Closure $callback): void
    {
        $this->decoratedConnection->addListener($name, $callback);
    }

    /**
     * @return void
     */
    public function connect(): void
    {
        if ($this->connecting === false) {
            try {
                $this->connecting = true;
                $this->decoratedConnection->connect();
                $this->connectedAt = new \DateTimeImmutable('now');
            } finally {
                $this->connecting = false;
            }
        }
    }

    /**
     * @return void
     */
    public function disconnect(): void
    {
        $this->decoratedConnection->disconnect();
        $this->connectedAt = null;
    }

    /**
     * @param string $request
     * @return int
     */
    public function send(string $request): int
    {
        $this->connectIfNotConnected();
        return $this->decoratedConnection->send($request);
    }

    /**
     * @return string
     */
    public function receive(): string
    {
        $this->connectIfNotConnected();
        return $this->decoratedConnection->receive();
    }

    /**
     * @param int $type
     */
    public function upgrade(int $type): void
    {
        $this->decoratedConnection->upgrade($type);
    }

    /**
     * @param float $timeout
     */
    public function timeout(float $timeout): void
    {
        $this->decoratedConnection->timeout($timeout);
    }

    /**
     * @param array $keys
     * @return array
     */
    public function getMetaData(array $keys = []): array
    {
        return $this->decoratedConnection->getMetaData($keys);
    }

    /**
     *
     */
    private function connectIfNotConnected(): void
    {
        if ($this->connectedAt === null) {
            $this->connect();
        }

        $now = new \DateTimeImmutable();
        if ($this->connecting === false && $this->connectedAt && $this->connectedAt->add($this->interval) < $now) {
            $this->disconnect();
            $this->connect();
        }
    }
}