Genkgo\Mail\Protocol\Smtp\Request\DataRequest::execute()

Complexity

Conditions	6
Paths	4

Size

Total Lines	25
Code Lines	14

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	15
CRAP Score	6

Importance

Changes

0

<?php
    public function execute(ConnectionInterface $connection): void
    {
        $bytes = '';

        while (!$this->stream->eof()) {
            $bytes .= $this->stream->read(1000);

            $index = 0;
            while (isset($bytes[$index])) {
                if ($bytes[$index] === "\r" && isset($bytes[$index+1]) && $bytes[$index+1] === "\n") {
                    $line = substr($bytes, 0, $index);
                    $bytes = substr($bytes, $index + 2);
                    $index = -1;

                    $this->sendLine($connection, $line);
                }

                $index++;
            }
        }

        $this->sendLine($connection, $bytes);

        $connection->send('.');
    }

}