[Laracasts] Full Dump, April 17, 2026 - Part 2

<?php
namespace App\Mux;
use App\Console\Commands\LC;
use Illuminate\Support\Number;
use Illuminate\Support\Str;
class MuxDownloader
{
    public function __construct(protected LC $command)
    {
        //
    }
    public function download(array $episode, string $filepath, int $episodeNumber = 0): void
    {
        $query = http_build_query([
            'token' => $episode['muxTokens']['playback'],
        ]);
        $masterUrl = "https://stream.mux.com/{$episode['muxPlaybackId']}.m3u8?$query";
        $resolved = $this->resolveVariant($masterUrl);
        $this->downloadVideo(
            $resolved['video'],
            $resolved['audio'],
            $this->command->disk->path($filepath),
            $episode['length'] ?? 0,
            $episodeNumber
        );
        // $this->downloadCaptions($episode['transcriptSegments'] ?? [], $filepath);
    }
    private function resolveVariant(string $masterUrl): array
    {
        $quality = (int) config('lc.quality');
        if (! $quality) {
            return [
                'video' => $masterUrl,
                'audio' => null,
            ];
        }
        $playlist = @file_get_contents($masterUrl);
        if (! $playlist) {
            return [
                'video' => $masterUrl,
                'audio' => null,
            ];
        }
        $baseUrl = dirname($masterUrl);
        $lines = explode("\n", trim($playlist));
        $best = null;
        $audioUrl = null;
        // Find audio stream
        foreach ($lines as $line) {
            if (preg_match('/^#EXT-X-MEDIA:.*TYPE=AUDIO.*URI="([^"]+)"/', $line, $m)) {
                $audioUrl = str_starts_with($m[1], 'http') ? $m[1] : "$baseUrl/$m[1]";
                break;
            }
        }
        // Find best video variant
        for ($i = 0; $i < count($lines); $i++) {
            if (preg_match('/^#EXT-X-STREAM-INF:.*RESOLUTION=(\d+)x(\d+)/', $lines[$i], $m)) {
                $height = (int) $m[2];
                if ($height <= $quality && (! $best || $height > $best['height'])) {
                    $best = [
                        'height' => $height,
                        'url' => $lines[$i + 1],
                    ];
                }
            }
        }
        if (! $best) {
            return [
                'video' => $masterUrl,
                'audio' => null,
            ];
        }
        $videoUrl = str_starts_with($best['url'], 'http') ? $best['url'] : "$baseUrl/{$best['url']}";
        $this->command->comment("Selected {$best['height']}p variant");
        return [
            'video' => $videoUrl,
            'audio' => $audioUrl,
        ];
    }
    private function downloadVideo(
        string $videoUrl,
        ?string $audioUrl,
        string $outputPath,
        int $duration,
        int $episodeNumber
    ): void {
        $maxAttempts = 3;
        for ($attempt = 1; $attempt <= $maxAttempts; $attempt++) {
            if ($attempt > 1) {
                $this->command->warn("Retrying download (attempt $attempt/$maxAttempts)...");
            } else {
                $this->command->warn('Downloading video...');
            }
            $inputs = "-i \"$videoUrl\"";
            if ($audioUrl) {
                $inputs .= " -i \"$audioUrl\"";
            }
            $command = "export PATH=\"/opt/homebrew/bin:/usr/local/bin:\$PATH\" && ffmpeg $inputs -c copy -bsf:a aac_adtstoasc \"$outputPath\"";
            $process = proc_open(
                $command,
                [
                    0 => [
                        'file',
                        '/dev/null',
                        'r',
                    ],
                    1 => [
                        'pipe',
                        'w',
                    ],
                    2 => [
                        'pipe',
                        'w',
                    ],
                ],
                $pipes
            );
            if (is_resource($process)) {
                stream_set_blocking($pipes[2], false);
                fclose($pipes[1]);
                $buffer = '';
                while (proc_get_status($process)['running']) {
                    $buffer .= fread($pipes[2], 8192);
                    $this->parseProgress($buffer, $duration);
                    usleep(2e5);
                }
                $buffer .= stream_get_contents($pipes[2]);
                $this->parseProgress($buffer, $duration);
                fclose($pipes[2]);
                $code = proc_close($process);
                if ($code == 0) {
                    $this->command->success("\nVideo has been downloaded");
                    return;
                }
                $hadProgress = (bool) preg_match('/size=\s*\d+\w*\s+time=/', $buffer);
                $this->command->error(
                    ($hadProgress ? "\n" : '')."Failed to download video (attempt $attempt/$maxAttempts)"
                );
                $this->command->failedDownloads[] = [
                    'episode_label' => $episodeNumber,
                    'attempt' => $attempt,
                    'max_attempts' => $maxAttempts,
                ];
            }
        }
    }
    private function parseProgress(string $buffer, int $duration): void
    {
        if (preg_match_all('/size=\s*(\d+)\w*\s+time=(\d+):(\d+):(\d+\.\d+)/', $buffer, $matches, PREG_SET_ORDER)) {
            $last = end($matches);
            $size = (int) $last[1] * 1024;
            $time = $last[2] * 3600 + $last[3] * 60 + (float) $last[4];
            if ($duration > 0 && $time > 0) {
                $estimatedTotal = $size * $duration / $time;
                printf("Downloaded ~%s of ~%s (~%s)       \r",
                    Number::fileSize($size, 2),
                    Number::fileSize($estimatedTotal, 2),
                    Number::percentage($time * 100 / $duration, 1)
                );
            } else {
                printf("Downloaded %s       \r", Number::fileSize($size, 2));
            }
        }
    }
    private function downloadCaptions(array $segments, string $filepath): void
    {
        if (empty($segments)) {
            $this->command->comment("This episode doesn't have captions\n");
            return;
        }
        $this->command->comment('Downloading captions...');
        $vtt = "WEBVTT\n\n";
        foreach ($segments as $i => $segment) {
            $text = strip_tags($segment['text']);
            $start = $segment['startTime'];
            $end = data_get($segments, ($i + 1).'.startTime', $segment['endTime']);
            $vtt .= sprintf(
                "%s --> %s\n%s\n\n",
                $this->formatTimestamp($start),
                $this->formatTimestamp($end),
                $text
            );
        }
        $this->command->disk->put(
            Str::replaceLast('.mp4', '.vtt', $filepath),
            $vtt
        );
        $this->command->success("Captions has been downloaded\n");
    }
    private function formatTimestamp(float $seconds): string
    {
        return sprintf(
            '%02d:%02d:%06.3f',
            (int) ($seconds / 3600),
            (int) (($seconds % 3600) / 60),
            fmod($seconds, 60)
        );
    }
}