Uxmp\Core\Component\Io\IoFactory

Complexity

Total Complexity

5

Size/Duplication

Total Lines	52
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	1
Bugs	0	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	createFfmpegTranscoder()	0	9	1
A	createSimpleFileStreamable()	0	4	1
A	createTranscodingStreamable()	0	6	1
A	__construct()	0	6	1
A	createPumpStream()	0	10	1

<?php

declare(strict_types=1);

namespace Uxmp\Core\Component\Io;

use Closure;
use GuzzleHttp\Psr7\PumpStream;
use Nyholm\Psr7\Factory\Psr17Factory;
use Psr\Http\Message\StreamInterface;
use Psr\Log\LoggerInterface;
use Uxmp\Core\Component\Config\ConfigProviderInterface;
use Uxmp\Core\Component\Io\Lib\PopenWrapperInterface;
use Uxmp\Core\Component\Io\Transcoder\FfmpegTranscoder;
use Uxmp\Core\Component\Io\Transcoder\TranscoderInterface;
use Uxmp\Core\Component\Io\Transcoder\TranscodingHandler;

final class IoFactory implements IoFactoryInterface
{
    public function __construct(
        private readonly Psr17Factory $psr17Factory,
        private readonly ConfigProviderInterface $configProvider,
        private readonly PopenWrapperInterface $popenWrapper,
        private readonly LoggerInterface $logger,
    ) {
    }

    public function createSimpleFileStreamable(): StreamableInterface
    {
        return new SimpleFileStreamable(
            $this->psr17Factory
        );
    }

    public function createTranscodingStreamable(
        Transcoder\TranscoderInterface $transcoder
    ): StreamableInterface {
        return new TranscodingStreamable(
            $this,
            $transcoder
        );
    }

    public function createPumpStream(
        TranscoderInterface $transcoder
    ): StreamInterface {
        /** @var callable $handler */
        $handler = new TranscodingHandler(
            $this->logger,
            $transcoder
        );

        return new PumpStream($handler);
    }

    /**
     * Creates a ffmpeg transcoder
     *
     * If the given transcoding options aren't allowed, the default config will be used
     */
    public function createFfmpegTranscoder(
        string $codec,
        int $bitrate,
    ): Transcoder\TranscoderInterface {
        return new FfmpegTranscoder(
            $this->configProvider,
            $this->popenWrapper,
            $codec,
            $bitrate,
        );
    }
}