Yiisoft\Yii\Web\Emitter\SapiEmitter

Complexity

Total Complexity

15

Size/Duplication

Total Lines	76
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	5
Bugs	0	Features	1

4 Methods

Rating	Name	Duplication	Size	Complexity
A	emitBody()	0	19	6
A	shouldOutputBody()	0	3	1
B	emit()	0	38	7
A	__construct()	0	3	1

<?php declare(strict_types=1);

namespace Yiisoft\Yii\Web\Emitter;

use Psr\Http\Message\ResponseInterface;

/**
 * SapiEmitter sends a response using PHP Server API
 */
final class SapiEmitter implements EmitterInterface
{
    private const NO_BODY_RESPONSE_CODES = [204, 205, 304];
    private $partSize;

    public function __construct(int $partSize = 8388608)
    {
        $this->partSize = $partSize;
    }

    public function emit(ResponseInterface $response, bool $withoutBody = false): bool
    {
        $status = $response->getStatusCode();

        header_remove();
        foreach ($response->getHeaders() as $header => $values) {
            foreach ($values as $value) {
                header(sprintf(
                    '%s: %s',
                    $header,
                    $value
                ), $header !== 'Set-Cookie', $status);
            }
        }

        $reason = $response->getReasonPhrase();

        header(sprintf(
            'HTTP/%s %d %s',
            $response->getProtocolVersion(),
            $status,
            $reason
        ), true, $status);

        if ($withoutBody === false && $this->shouldOutputBody($response)) {
            $contentLength = $response->getBody()->getSize();
            if ($response->hasHeader('Content-Length')) {
                $contentLengthHeader = $response->getHeader('Content-Length');
                $contentLength = array_shift($contentLengthHeader);
            }
            if ($contentLength !== null) {
                header(sprintf('Content-Length: %s', $contentLength), true, $status);
            }

            $this->emitBody($response);
        }

        return true;
    }

    private function emitBody(ResponseInterface $response): void
    {
        $body = $response->getBody();
        if ($body->isSeekable()) {
            $body->rewind();
        }
        $bytesToSend = $response->getBody()->getSize();
        if ($bytesToSend > 0) {
            while ($bytesToSend > 0 && !$body->eof()) {
                $toRead = \min($this->partSize, $bytesToSend);
                $data = $body->read($toRead);
                echo $data;
                $bytesToSend -= \strlen($data);
                \flush();
            }
        } else {
            while (!$body->eof()) {
                echo $body->read($this->partSize);
                \flush();
            }
        }
    }

    private function shouldOutputBody(ResponseInterface $response): bool
    {
        return !\in_array($response->getStatusCode(), self::NO_BODY_RESPONSE_CODES, true);
    }
}