Genkgo\Mail\Protocol\Smtp\Request\DataRequest

Complexity

Total Complexity

6

Size/Duplication

Total Lines	38
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Test Coverage

Coverage

100%

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
B	execute()	0	17	5

<?php
declare(strict_types=1);

namespace Genkgo\Mail\Protocol\Smtp\Request;

use Genkgo\Mail\Protocol\ConnectionInterface;
use Genkgo\Mail\Protocol\Smtp\RequestInterface;
use Genkgo\Mail\StreamInterface;

final class DataRequest implements RequestInterface
{
    /**
     * @var StreamInterface
     */
    private $stream;

    /**
     * DataRequest constructor.
     * @param StreamInterface $stream
     */
    public function __construct(StreamInterface $stream)
    {
        $this->stream = $stream;
    }

    /**
     * @param ConnectionInterface $connection
     * @return void
     */
    public function execute(ConnectionInterface $connection)
    {
        while (!$this->stream->eof()) {
            $bytes = $this->stream->read(1000);
            $lines = explode("\r\n", $bytes);
            foreach ($lines as $line) {
                $line = rtrim($line, "\r");
                if (isset($line[0]) && $line[0] === '.') {
                    $line = '.' . $line;
                }

                $connection->send($line . "\r\n");
            }
        }

        $connection->send(".\r\n");
    }
}