Iman\Streamer\VideoStreamer

Complexity

Total Complexity

19

Size/Duplication

Total Lines	139
Duplicated Lines	0 %

Importance

Changes	10
Bugs	5	Features	2

6 Methods

Rating	Name	Duplication	Size	Complexity
B	setHeader()	0	51	10
A	__construct()	0	8	1
A	end()	0	5	1
A	stream()	0	18	4
A	start()	0	5	1
A	streamFile()	0	8	2

<?php

namespace Iman\Streamer;

use Iman\Streamer\Events\VideoStreamEnded;
use Iman\Streamer\Events\VideoStreamStarted;

class VideoStreamer
{
    private $path = '';

    private $stream = '';

    private $buffer = 102400;

    private $start = -1;

    private $end = -1;

    private $size = 0;

    private $mime = '';

    /**
     * @var Video
     */
    private $video;

    public function __construct($filePath, $stream)
    {
        $this->path = $filePath;
        $this->stream = $stream;
        $this->mime = mime_content_type($filePath);

        $this->video = new Video();
        $this->video->setPath($this->path);
    }

    /**
     * Set proper header to serve the video content.
     */
    private function setHeader()
    {
        ob_get_clean();
        header('Content-Type: '.$this->mime);
        header('Cache-Control: max-age=2592000, public');
        header('Expires: '.gmdate('D, d M Y H:i:s', time() + 2592000).' GMT');
        header('Last-Modified: '.gmdate('D, d M Y H:i:s', @filemtime($this->path)).' GMT');

It seems like @filemtime($this->path) can also be of type false; however, parameter $timestamp of gmdate() does only seem to accept integer|null, maybe add an additional type check?

        $this->start = 0;
        $this->size = filesize($this->path);
        $this->end = $this->size - 1;
        header('Accept-Ranges: 0-'.$this->end);

        if (! isset($_SERVER['HTTP_RANGE'])) {
            header('Content-Length: '.$this->size);

            return;
        }

        $c_end = $this->end;
        [
            ,
            $range,
        ] = explode('=', $_SERVER['HTTP_RANGE'], 2);

        if (strpos($range, ',') !== false) {
            header('HTTP/1.1 416 Requested Range Not Satisfiable');
            header("Content-Range: bytes $this->start-$this->end/$this->size");
            exit;
        }

        if ($range == '-') {
            $c_start = $this->size - substr($range, 1);
        } else {
            $range = explode('-', $range);
            $c_start = $range[0];

            $c_end = (isset($range[1]) && is_numeric($range[1])) ? $range[1] : $c_end;
        }
        $c_end = ($c_end > $this->end) ? $this->end : $c_end;
        if ($c_start > $c_end || $c_start > $this->size - 1 || $c_end >= $this->size) {
            header('HTTP/1.1 416 Requested Range Not Satisfiable');
            header("Content-Range: bytes $this->start-$this->end/$this->size");
            exit;
        }
        $this->start = $c_start;
        $this->end = $c_end;
        $length = $this->end - $this->start + 1;
        fseek($this->stream, $this->start);

It seems like $this->start can also be of type string; however, parameter $offset of fseek() does only seem to accept integer, maybe add an additional type check?

        header('HTTP/1.1 206 Partial Content');
        header('Content-Length: '.$length);
        header("Content-Range: bytes $this->start-$this->end/".$this->size);
    }

    /**
     * close curretly opened stream.
     */
    private function end()
    {
        fclose($this->stream);
        event(new VideoStreamEnded($this->video));
        exit;

Using exit here is not recommended.

    }

    /**
     * perform the streaming of calculated range.
     */
    private function stream()
    {
        $this->video->setProgress($this->start);
        event(new VideoStreamStarted($this->video));

        $i = $this->start;
        set_time_limit(0);
        while (! feof($this->stream) && $i <= $this->end) {
            $this->video->setProgress($i);

            $bytesToRead = $this->buffer;
            if (($i + $bytesToRead) > $this->end) {
                $bytesToRead = $this->end - $i + 1;
            }
            $data = fread($this->stream, $bytesToRead);
            echo $data;
            flush();
            $i += $bytesToRead;
        }
    }

    /**
     * Start streaming video content.
     */
    public function start()
    {
        $this->setHeader();
        $this->stream();
        $this->end();
    }

    public static function streamFile($path)
    {
        $stream = fopen($path, 'rb');
        if (! $stream) {

$stream is of type resource, thus it always evaluated to false.

            throw new \Exception('File not found in: '.$path, 6542);
        }

        (new static($path, $stream))->start();
    }
}