Chris@0: <?php
Chris@0: /**
Chris@12:  * @see       https://github.com/zendframework/zend-diactoros for the canonical source repository
Chris@16:  * @copyright Copyright (c) 2015-2018 Zend Technologies USA Inc. (http://www.zend.com)
Chris@0:  * @license   https://github.com/zendframework/zend-diactoros/blob/master/LICENSE.md New BSD License
Chris@0:  */
Chris@0: 
Chris@0: namespace Zend\Diactoros\Response;
Chris@0: 
Chris@0: use Psr\Http\Message\ResponseInterface;
Chris@0: 
Chris@16: use function is_array;
Chris@16: use function preg_match;
Chris@16: use function strlen;
Chris@16: use function substr;
Chris@16: 
Chris@16: /**
Chris@16:  * @deprecated since 1.8.0. The package zendframework/zend-httphandlerrunner
Chris@16:  *     now provides this functionality.
Chris@16:  */
Chris@0: class SapiStreamEmitter implements EmitterInterface
Chris@0: {
Chris@0:     use SapiEmitterTrait;
Chris@0: 
Chris@0:     /**
Chris@0:      * Emits a response for a PHP SAPI environment.
Chris@0:      *
Chris@0:      * Emits the status line and headers via the header() function, and the
Chris@0:      * body content via the output buffer.
Chris@0:      *
Chris@0:      * @param ResponseInterface $response
Chris@0:      * @param int $maxBufferLength Maximum output buffering size for each iteration
Chris@0:      */
Chris@0:     public function emit(ResponseInterface $response, $maxBufferLength = 8192)
Chris@0:     {
Chris@12:         $this->assertNoPreviousOutput();
Chris@12:         $this->emitHeaders($response);
Chris@0:         $this->emitStatusLine($response);
Chris@0: 
Chris@0:         $range = $this->parseContentRange($response->getHeaderLine('Content-Range'));
Chris@0: 
Chris@0:         if (is_array($range) && $range[0] === 'bytes') {
Chris@0:             $this->emitBodyRange($range, $response, $maxBufferLength);
Chris@0:             return;
Chris@0:         }
Chris@0: 
Chris@0:         $this->emitBody($response, $maxBufferLength);
Chris@0:     }
Chris@0: 
Chris@0:     /**
Chris@0:      * Emit the message body.
Chris@0:      *
Chris@0:      * @param ResponseInterface $response
Chris@0:      * @param int $maxBufferLength
Chris@0:      */
Chris@0:     private function emitBody(ResponseInterface $response, $maxBufferLength)
Chris@0:     {
Chris@0:         $body = $response->getBody();
Chris@0: 
Chris@0:         if ($body->isSeekable()) {
Chris@0:             $body->rewind();
Chris@0:         }
Chris@0: 
Chris@0:         if (! $body->isReadable()) {
Chris@0:             echo $body;
Chris@0:             return;
Chris@0:         }
Chris@0: 
Chris@0:         while (! $body->eof()) {
Chris@0:             echo $body->read($maxBufferLength);
Chris@0:         }
Chris@0:     }
Chris@0: 
Chris@0:     /**
Chris@0:      * Emit a range of the message body.
Chris@0:      *
Chris@0:      * @param array $range
Chris@0:      * @param ResponseInterface $response
Chris@0:      * @param int $maxBufferLength
Chris@0:      */
Chris@0:     private function emitBodyRange(array $range, ResponseInterface $response, $maxBufferLength)
Chris@0:     {
Chris@0:         list($unit, $first, $last, $length) = $range;
Chris@0: 
Chris@0:         $body = $response->getBody();
Chris@0: 
Chris@0:         $length = $last - $first + 1;
Chris@0: 
Chris@0:         if ($body->isSeekable()) {
Chris@0:             $body->seek($first);
Chris@0: 
Chris@0:             $first = 0;
Chris@0:         }
Chris@0: 
Chris@0:         if (! $body->isReadable()) {
Chris@0:             echo substr($body->getContents(), $first, $length);
Chris@0:             return;
Chris@0:         }
Chris@0: 
Chris@0:         $remaining = $length;
Chris@0: 
Chris@0:         while ($remaining >= $maxBufferLength && ! $body->eof()) {
Chris@0:             $contents   = $body->read($maxBufferLength);
Chris@0:             $remaining -= strlen($contents);
Chris@0: 
Chris@0:             echo $contents;
Chris@0:         }
Chris@0: 
Chris@0:         if ($remaining > 0 && ! $body->eof()) {
Chris@0:             echo $body->read($remaining);
Chris@0:         }
Chris@0:     }
Chris@0: 
Chris@0:     /**
Chris@0:      * Parse content-range header
Chris@0:      * http://www.w3.org/Protocols/rfc2616/rfc2616-sec14.html#sec14.16
Chris@0:      *
Chris@0:      * @param string $header
Chris@0:      * @return false|array [unit, first, last, length]; returns false if no
Chris@0:      *     content range or an invalid content range is provided
Chris@0:      */
Chris@0:     private function parseContentRange($header)
Chris@0:     {
Chris@0:         if (preg_match('/(?P<unit>[\w]+)\s+(?P<first>\d+)-(?P<last>\d+)\/(?P<length>\d+|\*)/', $header, $matches)) {
Chris@0:             return [
Chris@0:                 $matches['unit'],
Chris@0:                 (int) $matches['first'],
Chris@0:                 (int) $matches['last'],
Chris@0:                 $matches['length'] === '*' ? '*' : (int) $matches['length'],
Chris@0:             ];
Chris@0:         }
Chris@0:         return false;
Chris@0:     }
Chris@0: }