Broadcast: Mensagens via Websocket para Informativos dos Processos do Video

Author: NandoKstroNet

app/Events/VideoFlix/EncodeVideoFinished.php

@@ -0,0 +1,44 @@
+<?php
+
+namespace App\Events\VideoFlix;
+
+use Illuminate\Broadcasting\Channel;
+use Illuminate\Broadcasting\InteractsWithSockets;
+use Illuminate\Broadcasting\PresenceChannel;
+use Illuminate\Broadcasting\PrivateChannel;
+use Illuminate\Contracts\Broadcasting\ShouldBroadcast;
+use Illuminate\Contracts\Broadcasting\ShouldBroadcastNow;
+use Illuminate\Foundation\Events\Dispatchable;
+use Illuminate\Queue\SerializesModels;
+
+class EncodeVideoFinished implements ShouldBroadcastNow
+{
+    use Dispatchable, InteractsWithSockets, SerializesModels;
+
+    /**
+     * Create a new event instance.
+     */
+    public function __construct(private int $videoId)
+    {
+        //
+    }
+
+    public function broadcastWith(): array
+    {
+        return [
+            'videoId' => $this->videoId
+        ];
+    }
+
+    /**
+     * Get the channels the event should broadcast on.
+     *
+     * @return array<int, \Illuminate\Broadcasting\Channel>
+     */
+    public function broadcastOn(): array
+    {
+        return [
+            new Channel('videos'),
+        ];
+    }
+}

app/Events/VideoFlix/EncodeVideoProgress.php

@@ -0,0 +1,45 @@
+<?php
+
+namespace App\Events\VideoFlix;
+
+use Illuminate\Broadcasting\Channel;
+use Illuminate\Broadcasting\InteractsWithSockets;
+use Illuminate\Broadcasting\PresenceChannel;
+use Illuminate\Broadcasting\PrivateChannel;
+use Illuminate\Contracts\Broadcasting\ShouldBroadcast;
+use Illuminate\Contracts\Broadcasting\ShouldBroadcastNow;
+use Illuminate\Foundation\Events\Dispatchable;
+use Illuminate\Queue\SerializesModels;
+
+class EncodeVideoProgress implements ShouldBroadcastNow
+{
+    use Dispatchable, InteractsWithSockets, SerializesModels;
+
+    /**
+     * Create a new event instance.
+     */
+    public function __construct(private int $videoId, private int $progress)
+    {
+        //
+    }
+
+    public function broadcastWith(): array
+    {
+        return [
+            'videoId' => $this->videoId,
+            'progress' => $this->progress
+        ];
+    }
+
+    /**
+     * Get the channels the event should broadcast on.
+     *
+     * @return array<int, \Illuminate\Broadcasting\Channel>
+     */
+    public function broadcastOn(): array
+    {
+        return [
+            new Channel('videos'),
+        ];
+    }
+}

app/Events/VideoFlix/EncodeVideoStarted.php

@@ -0,0 +1,44 @@
+<?php
+
+namespace App\Events\VideoFlix;
+
+use Illuminate\Broadcasting\Channel;
+use Illuminate\Broadcasting\InteractsWithSockets;
+use Illuminate\Broadcasting\PresenceChannel;
+use Illuminate\Broadcasting\PrivateChannel;
+use Illuminate\Contracts\Broadcasting\ShouldBroadcast;
+use Illuminate\Contracts\Broadcasting\ShouldBroadcastNow;
+use Illuminate\Foundation\Events\Dispatchable;
+use Illuminate\Queue\SerializesModels;
+
+class EncodeVideoStarted implements ShouldBroadcastNow
+{
+    use Dispatchable, InteractsWithSockets, SerializesModels;
+
+    /**
+     * Create a new event instance.
+     */
+    public function __construct(private int $videoId)
+    {
+        //
+    }
+
+    public function broadcastWith(): array
+    {
+        return [
+            'videoId' => $this->videoId
+        ];
+    }
+
+    /**
+     * Get the channels the event should broadcast on.
+     *
+     * @return array<int, \Illuminate\Broadcasting\Channel>
+     */
+    public function broadcastOn(): array
+    {
+        return [
+            new Channel('videos'),
+        ];
+    }
+}

app/Events/VideoFlix/VideoThumbGenerated.php

@@ -0,0 +1,45 @@
+<?php
+
+namespace App\Events\VideoFlix;
+
+use Illuminate\Broadcasting\Channel;
+use Illuminate\Broadcasting\InteractsWithSockets;
+use Illuminate\Broadcasting\PresenceChannel;
+use Illuminate\Broadcasting\PrivateChannel;
+use Illuminate\Contracts\Broadcasting\ShouldBroadcast;
+use Illuminate\Contracts\Broadcasting\ShouldBroadcastNow;
+use Illuminate\Foundation\Events\Dispatchable;
+use Illuminate\Queue\SerializesModels;
+
+class VideoThumbGenerated implements ShouldBroadcastNow
+{
+    use Dispatchable, InteractsWithSockets, SerializesModels;
+
+    /**
+     * Create a new event instance.
+     */
+    public function __construct(private int $videoId, private string $thumb)
+    {
+        //
+    }
+
+    public function broadcastWith(): array
+    {
+        return [
+            'videoId' => $this->videoId,
+            'thumb' => $this->thumb
+        ];
+    }
+
+    /**
+     * Get the channels the event should broadcast on.
+     *
+     * @return array<int, \Illuminate\Broadcasting\Channel>
+     */
+    public function broadcastOn(): array
+    {
+        return [
+            new Channel('videos'),
+        ];
+    }
+}

app/Http/Controllers/Media/VideosController.php

@@ -4,6 +4,7 @@
 
 use App\Http\Controllers\Controller;
 use App\Jobs\VideoEncodingJob;
+use App\Jobs\VideoThumbGenerateJob;
 use App\Models\Content;
 use Illuminate\Http\Request;
 use Illuminate\Http\UploadedFile;
@@ -68,6 +69,7 @@ public function processChunck(Content $content, $video, Request $request)
                 'video' => $save->getFile()->storeAs('', str()->uuid(), 'videos')
             ]);
 
+            dispatch(new VideoThumbGenerateJob($video));
             dispatch(new VideoEncodingJob($video));
         }
 

app/Jobs/VideoEncodingJob.php

@@ -2,6 +2,9 @@
 
 namespace App\Jobs;
 
+use App\Events\VideoFlix\EncodeVideoFinished;
+use App\Events\VideoFlix\EncodeVideoProgress;
+use App\Events\VideoFlix\EncodeVideoStarted;
 use App\Models\Video;
 use FFMpeg\Format\Video\X264;
 use Illuminate\Contracts\Queue\ShouldQueue;
@@ -26,7 +29,7 @@ public function __construct(private Video $video)
      */
     public function handle(): void
     {
-        //Dispararia um evento de inicializacao do encoding
+        event(new EncodeVideoStarted($this->video->id));
 
         $videoNewName = str_replace(strrchr($this->video->video, '.'), '', $this->video->video) . '.m3u8';
 
@@ -42,7 +45,7 @@ public function handle(): void
             ->addFormat($mid)
             ->addFormat($high)
             ->onProgress(function($progress){
-                //Dispararia um evento via broadcast com as infos do progresso
+                event(new EncodeVideoProgress($this->video->id, $progress));
             })
             ->toDisk('videos_encoded')
             ->save($this->video->code . '/' . $videoNewName);
@@ -54,6 +57,6 @@ public function handle(): void
             'is_processed' => true
         ]);
 
-        //Dispararia um evento de finalizacao do encoding
+        event(new EncodeVideoFinished($this->video->id));
     }
 }

app/Jobs/VideoThumbGenerateJob.php

@@ -0,0 +1,43 @@
+<?php
+
+namespace App\Jobs;
+
+use App\Events\VideoFlix\VideoThumbGenerated;
+use App\Models\Video;
+use Illuminate\Contracts\Queue\ShouldQueue;
+use Illuminate\Foundation\Queue\Queueable;
+use ProtoneMedia\LaravelFFMpeg\Support\FFMpeg;
+
+class VideoThumbGenerateJob implements ShouldQueue
+{
+    use Queueable;
+
+    /**
+     * Create a new job instance.
+     */
+    public function __construct(private Video $video)
+    {
+        //
+    }
+
+    /**
+     * Execute the job.
+     */
+    public function handle(): void
+    {
+        $thumb = 'thumbs/' . $this->video->code . '/thumb.png';
+
+        FFMpeg::fromDisk('videos')
+            ->open($this->video->video)
+            ->getFrameFromSeconds(5)
+            ->export()
+            ->toDisk('public')
+            ->save($thumb);
+
+        $this->video->update([
+            'thumb' => $thumb
+        ]);
+
+        event(new VideoThumbGenerated($this->video->id, $thumb));
+    }
+}

bootstrap/app.php

@@ -11,6 +11,7 @@
     ->withRouting(
         web: __DIR__.'/../routes/web.php',
         commands: __DIR__.'/../routes/console.php',
+        channels: __DIR__.'/../routes/channels.php',
         health: '/up',
     )
     ->withMiddleware(function (Middleware $middleware) {

composer.json

@@ -13,6 +13,7 @@
         "inertiajs/inertia-laravel": "^2.0",
         "laravel/fortify": "^1.30",
         "laravel/framework": "^12.0",
+        "laravel/reverb": "^1.0",
         "laravel/tinker": "^2.10.1",
         "laravel/wayfinder": "^0.1.9",
         "pbmedia/laravel-ffmpeg": "^8.7",