Merge pull request #11 from innoflash/add-streaming-events

Add streaming events

Author: imanghafoori1

src/Events/VideoStreamEnded.php

@@ -0,0 +1,50 @@
+<?php
+
+namespace Iman\Streamer\Events;
+
+use Illuminate\Broadcasting\Channel;
+use Illuminate\Broadcasting\InteractsWithSockets;
+use Illuminate\Broadcasting\PresenceChannel;
+use Illuminate\Broadcasting\PrivateChannel;
+use Illuminate\Contracts\Broadcasting\ShouldBroadcast;
+use Illuminate\Foundation\Events\Dispatchable;
+use Illuminate\Queue\SerializesModels;
+use Iman\Streamer\Video;
+
+class VideoStreamEnded
+{
+    use Dispatchable, InteractsWithSockets, SerializesModels;
+    /**
+     * @var Video
+     */
+    private $video;
+
+    /**
+     * Create a new event instance.
+     *
+     * @param  Video  $video
+     */
+    public function __construct(Video $video)
+    {
+        $this->video = $video;
+    }
+
+    /**
+     * @return Video
+     */
+    public function getVideo(): Video
+    {
+        return $this->video;
+    }
+
+
+    /**
+     * Get the channels the event should broadcast on.
+     *
+     * @return \Illuminate\Broadcasting\Channel|array
+     */
+    public function broadcastOn()
+    {
+        return new PrivateChannel('channel-name');
+    }
+}

src/Events/VideoStreamStarted.php

@@ -0,0 +1,51 @@
+<?php
+
+namespace Iman\Streamer\Events;
+
+use Illuminate\Broadcasting\Channel;
+use Illuminate\Broadcasting\InteractsWithSockets;
+use Illuminate\Broadcasting\PresenceChannel;
+use Illuminate\Broadcasting\PrivateChannel;
+use Illuminate\Contracts\Broadcasting\ShouldBroadcast;
+use Illuminate\Foundation\Events\Dispatchable;
+use Illuminate\Queue\SerializesModels;
+use Iman\Streamer\Video;
+
+class VideoStreamStarted
+{
+    use Dispatchable, InteractsWithSockets, SerializesModels;
+    /**
+     * @var Video
+     */
+    private $video;
+
+    /**
+     * Create a new event instance.
+     *
+     * @param  Video  $video
+     */
+    public function __construct(Video $video)
+    {
+        $this->video = $video;
+        info('video ended');
+    }
+
+    /**
+     * @return Video
+     */
+    public function getVideo(): Video
+    {
+        return $this->video;
+    }
+
+
+    /**
+     * Get the channels the event should broadcast on.
+     *
+     * @return \Illuminate\Broadcasting\Channel|array
+     */
+    public function broadcastOn()
+    {
+        return new PrivateChannel('channel-name');
+    }
+}

src/Video.php

@@ -0,0 +1,102 @@
+<?php
+
+namespace Iman\Streamer;
+
+class Video
+{
+    /**
+     * Video path.
+     *
+     * @var string
+     */
+    private $path;
+
+    /**
+     * Video MIME type.
+     *
+     * @var string
+     */
+    private $mime;
+
+    /**
+     * Video size.
+     *
+     * @var int
+     */
+    private $size;
+
+    /**
+     * Video progress.
+     *
+     * @var int
+     */
+    private $progress;
+
+    /**
+     * @return string
+     */
+    public function getPath(): string
+    {
+        return $this->path;
+    }
+
+    /**
+     * @return string
+     */
+    public function getMime(): string
+    {
+        return $this->mime;
+    }
+
+    /**
+     * @return int
+     */
+    public function getSize(): int
+    {
+        return $this->size;
+    }
+
+    /**
+     * @param  string  $path
+     */
+    public function setPath(string $path): void
+    {
+        $this->path = $path;
+
+        $this->setMime(mime_content_type($path));
+
+        $this->setSize(filesize($path));
+    }
+
+    /**
+     * @param  string  $mime
+     */
+    private function setMime(string $mime): void
+    {
+        $this->mime = $mime;
+    }
+
+    /**
+     * @param  int  $size
+     */
+    private function setSize(int $size): void
+    {
+        $this->size = $size;
+    }
+
+    /**
+     * @return int
+     */
+    public function getProgress(): int
+    {
+        return $this->progress;
+    }
+
+    /**
+     * @param  int  $progress
+     */
+    public function setProgress(int $progress): void
+    {
+        $this->progress = $progress;
+    }
+}

src/VideoStreamer.php

@@ -2,6 +2,9 @@
 
 namespace Iman\Streamer;
 
+use Iman\Streamer\Events\VideoStreamEnded;
+use Iman\Streamer\Events\VideoStreamStarted;
+
 class VideoStreamer
 {
     private $path = '';
@@ -18,11 +21,19 @@ class VideoStreamer
 
     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);
     }
 
     /**
@@ -87,6 +98,7 @@ private function setHeader()
     private function end()
     {
         fclose($this->stream);
+        event(new VideoStreamEnded($this->video));
         exit;
     }
 
@@ -95,9 +107,15 @@ private function end()
      */
     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;