Uxmp\Core\Component\Io\Transcoder\FfmpegTranscoder

Complexity

Total Complexity

10

Size/Duplication

Total Lines	69
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	setFilePath()	0	4	1
A	getHandle()	0	31	5
A	__construct()	0	6	1
A	__invoke()	0	9	3

<?php

declare(strict_types=1);

namespace Uxmp\Core\Component\Io\Transcoder;

use RuntimeException;
use Uxmp\Core\Component\Config\ConfigProviderInterface;
use Uxmp\Core\Component\Io\Lib\PopenWrapperInterface;

final class FfmpegTranscoder implements TranscoderInterface
{
    /** @var null|resource  */
    private $handle;

    private ?string $file_path = null;

    public function __construct(
        private readonly ConfigProviderInterface $configProvider,
        private readonly PopenWrapperInterface $popenWrapper,
        private string $codec,
        private int $bitrate,
    ) {
    }

    public function setFilePath(string $file_path): self
    {
        $this->file_path = $file_path;
        return $this;
    }

    /**
     * @return resource
     */
    private function getHandle()
    {
        if ($this->handle === null) {
            $transcodingConfig = $this->configProvider->getTranscodingConfig();

            if (!in_array($this->bitrate, $transcodingConfig['allowed_bitrates'], true)) {
                $this->bitrate = $transcodingConfig['bitrate'];
            }

            if (!in_array($this->codec, $transcodingConfig['allowed_codecs'], true)) {
                $this->codec = $transcodingConfig['codec'];
            }

            $command = sprintf(
                'ffmpeg -i %s -vn -nostats -ar 44100 -ac 2 -b:a %dk -f %s pipe:1 2>/dev/null',
                escapeshellarg((string)$this->file_path),
                $this->bitrate,
                escapeshellarg($this->codec),
            );

            $handle = $this->popenWrapper->run($command);

            if ($handle === null) {
                // throw dedicated exception
                throw new RuntimeException();
            }

            $this->handle = $handle;
        }

        return $this->handle;
    }

    /**
     * @param int<0, max> $length
     */
    public function __invoke(int $length): string|false
    {
        $chunk = fread($this->getHandle(), $length);

        if ($chunk !== false && $chunk !== '') {
            return $chunk;
        }

        return false;
    }
}