Genkgo\Mail\Protocol\Imap\Negotiation\ForceTlsUpgradeNegotiation

Complexity

Total Complexity

5

Size/Duplication

Total Lines	60
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	9

Test Coverage

Coverage

100%

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	7	1
A	negotiate()	0	31	4

<?php
declare(strict_types=1);

namespace Genkgo\Mail\Protocol\Imap\Negotiation;

use Genkgo\Mail\Exception\ConnectionInsecureException;
use Genkgo\Mail\Protocol\ConnectionInterface;
use Genkgo\Mail\Protocol\Imap\Client;
use Genkgo\Mail\Protocol\Imap\NegotiationInterface;
use Genkgo\Mail\Protocol\Imap\Request\CapabilityCommand;
use Genkgo\Mail\Protocol\Imap\Request\StartTlsCommand;
use Genkgo\Mail\Protocol\Imap\Response\Command\CapabilityCommandResponse;
use Genkgo\Mail\Protocol\Imap\Response\CompletionResult;

final class ForceTlsUpgradeNegotiation implements NegotiationInterface
{
    /**
     * @var ConnectionInterface
     */
    private $connection;

    /**
     * @var int
     */
    private $crypto;

    /**
     * @param ConnectionInterface $connection
     * @param int $crypto
     */
    public function __construct(
        ConnectionInterface $connection,
        int $crypto
    ) {
        $this->connection = $connection;
        $this->crypto = $crypto;
    }

    /**
     * @param Client $client
     * @throws ConnectionInsecureException
     */
    public function negotiate(Client $client): void
    {
        if (!empty($this->connection->getMetaData(['crypto']))) {
            return;
        }

        $responseList = $client->emit(new CapabilityCommand($client->newTag()));

        $capabilities = CapabilityCommandResponse::fromString($responseList->first()->getBody());

        $responseList
            ->last()
            ->assertCompletion(CompletionResult::ok())
            ->assertTagged();

        if ($capabilities->isAdvertising('STARTTLS')) {
            $client
                ->emit(new StartTlsCommand($client->newTag()))
                ->last()
                ->assertCompletion(CompletionResult::ok())
                ->assertTagged();

            $this->connection->upgrade($this->crypto);
        }

        if (empty($this->connection->getMetaData(['crypto']))) {
            throw new ConnectionInsecureException(
                'Server does not support STARTTLS. Use imaps:// or to allow insecure connections use imap-starttls://'
            );
        }
    }
}