Genkgo\Mail\Protocol\Smtp\Server

Complexity

Total Complexity

13

Size/Duplication

Total Lines	94
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	9

Test Coverage

Coverage

97.3%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	13	1
D	start()	0	35	9
A	handleCommand()	0	13	3

<?php
declare(strict_types=1);

namespace Genkgo\Mail\Protocol\Smtp;

use Genkgo\Mail\Exception\ConnectionBrokenException;
use Genkgo\Mail\Exception\ConnectionTimeoutException;
use Genkgo\Mail\Exception\ConnectionClosedException;
use Genkgo\Mail\Exception\UnknownSmtpCommandException;
use Genkgo\Mail\Protocol\AppendCrlfConnection;
use Genkgo\Mail\Protocol\ConnectionInterface;
use Genkgo\Mail\Protocol\ConnectionListenerInterface;
use Genkgo\Mail\Protocol\Smtp\Capability\EhloCapability;
use Genkgo\Mail\Protocol\Smtp\Capability\QuitCapability;
use Genkgo\Mail\Protocol\Smtp\Capability\ResetCapability;
use Genkgo\Mail\Protocol\TrimCrlfConnection;

final class Server
{
    /**
     * @var ConnectionListenerInterface
     */
    private $listener;
    /**
     * @var CapabilityInterface[]
     */
    private $capabilities = [];
    /**
     * @var string
     */
    private $serverName;

    /**
     * Client constructor.
     * @param ConnectionListenerInterface $connection
     * @param array $capabilities
     * @param string $serverName
     */
    public function __construct(ConnectionListenerInterface $connection, array $capabilities, string $serverName) {
        $this->listener = $connection;
        $this->serverName = $serverName;

        $this->capabilities = array_merge(

It seems like array_merge($capabilities, array(new \Genkgo\Mail\Protocol\Smtp\Capability\EhloCapability($this->serverName, $capabilities), new \Genkgo\Mail\Protocol\Smtp\Capability\QuitCapability(), new \Genkgo\Mail\Protocol\Smtp\Capability\ResetCapability())) of type array is incompatible with the declared type array<integer,object<Genkgo\Mail\Protocol\Smtp\CapabilityInterface>> of property $capabilities.

            $capabilities,
            [
                new EhloCapability($this->serverName, $capabilities),
                new QuitCapability(),
                new ResetCapability()
            ]
        );
    }

    /**
     *
     */
    public function start(): void
    {
        while ($connection = $this->listener->listen()) {
            $connection = new TrimCrlfConnection(new AppendCrlfConnection($connection));
            $connection->send('220 Welcome to Genkgo Mail Server');

            try {
                $session = new Session();

                while ($session = $session->withCommand($connection->receive())) {
                    try {
                        $session = $this->handleCommand($connection, $session);
                    } catch (UnknownSmtpCommandException $e) {
                        $connection->send('500 unrecognized command');
                    }

                    if ($session->getState() === Session::STATE_DISCONNECT) {
                        break;
                    }
                }
            } catch (ConnectionTimeoutException $e) {
                $connection->send('421 command timeout - closing connection');
                $connection->disconnect();
            } catch (ConnectionBrokenException $e) {
                try {
                    $connection->send('554 transaction failed, unexpected value - closing connection');
                } catch (\Exception $e) {

Consider adding a comment why this CATCH block is empty.

                }

                $connection->disconnect();
            } catch (ConnectionClosedException $e) {
                $connection->disconnect();
            }
        }
    }

    /**
     * @param ConnectionInterface $connection
     * @param Session $session
     * @return Session
     * @throws UnknownSmtpCommandException
     */
    private function handleCommand(ConnectionInterface $connection, Session $session): Session
    {
        $command = $session->getCommand();

        foreach ($this->capabilities as $capability) {
            $advertised = $capability->advertise();
            if (substr($command, 0, strlen($advertised)) === $advertised) {
                return $capability->manifest($connection, $session);
            }
        }

        throw new UnknownSmtpCommandException('Cannot handle command');
    }
}