Furious\HttpRunner\StreamRunner

Complexity

Total Complexity

19

Size/Duplication

Total Lines	98
Duplicated Lines	0 %

Importance

Changes	2
Bugs	0	Features	0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	emitBodyRange()	0	20	3
A	run()	0	19	3
A	emitBody()	0	15	4
A	emitBodyRemaining()	0	10	5
A	__construct()	0	5	1
A	parseContentRange()	0	11	3

<?php

declare(strict_types=1);

namespace Furious\HttpRunner;

use Psr\Http\Message\ResponseInterface;
use Psr\Http\Message\StreamInterface;
use function flush;

final class StreamRunner implements RunnerInterface
{
    private Checker $checker;
    private Emitter $emitter;
    private int $maxBufferLength;

    public function __construct(int $maxBufferLength = 8192)
    {
        $this->checker = new Checker();
        $this->emitter = new Emitter();
        $this->maxBufferLength = $maxBufferLength;
    }

    public function run(ResponseInterface $response) : bool
    {
        $this->checker->checkHeadersAlreadySent();
        $this->checker->checkOutputAlreadyWrote();

        $this->emitter->emitHeaders($response);
        $this->emitter->emitStatusLine($response);

        flush();

        $range = $this->parseContentRange($response->getHeaderLine('Content-Range'));

        if (null === $range or 'bytes' !== $range[0]) {
            $this->emitBody($response);
            return true;
        }

        $this->emitBodyRange($range, $response);
        return true;
    }

    private function emitBody(ResponseInterface $response) : void
    {
        $body = $response->getBody();

        if ($body->isSeekable()) {
            $body->rewind();
        }

        if (!$body->isReadable()) {
            echo $body;
            return;
        }

        while (!$body->eof()) {
            echo $body->read($this->maxBufferLength);
        }
    }

    private function emitBodyRange(array $range, ResponseInterface $response): void
    {
        list($unit, $first, $last, $length) = $range;

        $body = $response->getBody();
        $length = $last - $first + 1;

        if ($body->isSeekable()) {
            $body->seek($first);
            $first = 0;
        }

        if (!$body->isReadable()) {
            echo substr($body->getContents(), $first, $length);
            return;
        }

        $remaining = $length;

        $this->emitBodyRemaining($body, $remaining);
    }

    private function emitBodyRemaining(StreamInterface $body, int $remaining): void
    {
        while ($remaining >= $this->maxBufferLength and !$body->eof()) {
            $contents = $body->read($this->maxBufferLength);
            $remaining -= strlen($contents);
            echo $contents;
        }

        if ($remaining > 0 and !$body->eof()) {
            echo $body->read($remaining);
        }
    }

    private function parseContentRange(string $header) : ?array
    {
        if (!preg_match('/(?P<unit>[\w]+)\s+(?P<first>\d+)-(?P<last>\d+)\/(?P<length>\d+|\*)/', $header, $matches)) {
            return null;
        }

        return [
            $matches['unit'],
            (int) $matches['first'],
            (int) $matches['last'],
            $matches['length'] === '*' ? '*' : (int) $matches['length'],
        ];
    }
}