FFMpegAdapter::getDefaultThreads() - Code Metrics - soluble-io/soluble-mediatools - Measure and Improve Code Quality continuously with Scrutinizer

FFMpegAdapter::getDefaultThreads() A
last analyzed 2020-12-24 09:19 UTC

↳ Parent: FFMpegAdapter

Complexity

Conditions	1
Paths	1

Size

Total Lines	3
Code Lines	1

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	2
CRAP Score	1

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
eloc	1
c	1
b	0
f	0
dl	0
loc	3
ccs	2
cts	2
cp	1
rs	10
cc	1
nc	1
nop	0
crap	1

<?php

declare(strict_types=1);

/**
 * @see       https://github.com/soluble-io/soluble-mediatools for the canonical repository
 *
 * @copyright Copyright (c) 2018-2020 Sébastien Vanvelthem. (https://github.com/belgattitude)
 * @license   https://github.com/soluble-io/soluble-mediatools/blob/master/LICENSE.md MIT
 */

namespace Soluble\MediaTools\Video\Adapter;

use Soluble\MediaTools\Common\Exception\InvalidArgumentException;
use Soluble\MediaTools\Common\Exception\UnsupportedParamException;
use Soluble\MediaTools\Common\Exception\UnsupportedParamValueException;
use Soluble\MediaTools\Common\IO\UnescapedFileInterface;
use Soluble\MediaTools\Video\Adapter\Validator\FFMpegParamValidator;
use Soluble\MediaTools\Video\Config\FFMpegConfigInterface;
use Soluble\MediaTools\Video\Exception\ParamValidationException;
use Soluble\MediaTools\Video\Exception\UnexpectedValueException;
use Soluble\MediaTools\Video\VideoConvertParamsInterface;

final class FFMpegAdapter implements ConverterAdapterInterface
{
    /** @var FFMpegConfigInterface */
    private $ffmpegConfig;

    public function __construct(FFMpegConfigInterface $ffmpegConfig)
    {
        $this->ffmpegConfig = $ffmpegConfig;
    }

    /**
     * @return array<string, array<string, string>>
     */
    public function getParamsOptions(): array
    {
        return [
            VideoConvertParamsInterface::PARAM_OUTPUT_FORMAT => [
                'pattern' => '-f %s',
            ],
            VideoConvertParamsInterface::PARAM_VIDEO_CODEC => [
                'pattern' => '-c:v %s',
            ],
            VideoConvertParamsInterface::PARAM_VIDEO_BITRATE => [
                'pattern' => '-b:v %s',
            ],
            VideoConvertParamsInterface::PARAM_VIDEO_MIN_BITRATE => [
                'pattern' => '-minrate %s',
            ],
            VideoConvertParamsInterface::PARAM_VIDEO_MAX_BITRATE => [
                'pattern' => '-maxrate %s',
            ],
            VideoConvertParamsInterface::PARAM_AUDIO_CODEC => [
                'pattern' => '-c:a %s',
            ],
            VideoConvertParamsInterface::PARAM_AUDIO_BITRATE => [
                'pattern' => '-b:a %s',
            ],
            VideoConvertParamsInterface::PARAM_PIX_FMT => [
                'pattern' => '-pix_fmt %s',
            ],
            VideoConvertParamsInterface::PARAM_PRESET => [
                'pattern' => '-preset %s',
            ],
            VideoConvertParamsInterface::PARAM_SPEED => [
                'pattern' => '-speed %d',
            ],
            VideoConvertParamsInterface::PARAM_THREADS => [
                'pattern' => '-threads %d',
            ],
            VideoConvertParamsInterface::PARAM_KEYFRAME_SPACING => [
                'pattern' => '-g %d',
            ],
            VideoConvertParamsInterface::PARAM_QUALITY => [
                'pattern' => '-quality %s',
            ],
            VideoConvertParamsInterface::PARAM_VIDEO_QUALITY_SCALE => [
                'pattern' => '-qscale:v %d',
            ],
            VideoConvertParamsInterface::PARAM_CRF => [
                'pattern' => '-crf %d',
            ],
            VideoConvertParamsInterface::PARAM_STREAMABLE => [
                'pattern' => '-movflags +faststart',
            ],
            VideoConvertParamsInterface::PARAM_FRAME_PARALLEL => [
                'pattern' => '-frame-parallel %s',
            ],
            VideoConvertParamsInterface::PARAM_TILE_COLUMNS => [
                'pattern' => '-tile-columns %s',
            ],
            VideoConvertParamsInterface::PARAM_TUNE => [
                'pattern' => '-tune %s',
            ],
            VideoConvertParamsInterface::PARAM_VIDEO_FILTER => [
                'pattern' => '-filter:v %s',
            ],
            VideoConvertParamsInterface::PARAM_OVERWRITE => [
                'pattern' => '-y',
            ],
            VideoConvertParamsInterface::PARAM_VIDEO_FRAMES => [
                'pattern' => '-frames:v %d',
            ],
            VideoConvertParamsInterface::PARAM_NOAUDIO => [
                'pattern' => '-an',
            ],
            VideoConvertParamsInterface::PARAM_SEEK_START => [
                'pattern' => '-ss %s',
            ],
            VideoConvertParamsInterface::PARAM_SEEK_END => [
                'pattern' => '-to %s',
            ],
            VideoConvertParamsInterface::PARAM_PASSLOGFILE => [
                'pattern' => '-passlogfile %s',
            ],
            VideoConvertParamsInterface::PARAM_PASS => [
                'pattern' => '-pass %s',
            ],
            VideoConvertParamsInterface::PARAM_AUTO_ALT_REF => [
                'pattern' => '-auto-alt-ref %s',
            ],
            VideoConvertParamsInterface::PARAM_LAG_IN_FRAMES => [
                'pattern' => '-lag-in-frames %s',
            ],
        ];
    }

    /**
     * Return an array version of params suitable for ffmpeg cli.
     *
     * @param bool $validateParams whether to run ffmpeg validation process validation
     *
     * @return array<string, string>
     *
     * @throws UnsupportedParamException
     * @throws UnsupportedParamValueException
     * @throws ParamValidationException
     */
    public function getMappedConversionParams(VideoConvertParamsInterface $conversionParams, bool $validateParams = true): array
    {
        $args             = [];
        $supportedOptions = $this->getParamsOptions();

        // Add default overwrite option if not set
        $overwriteParam = VideoConvertParamsInterface::PARAM_OVERWRITE;
        if (!$conversionParams->hasParam($overwriteParam)) {
            $conversionParams = $conversionParams->withBuiltInParam(
                $overwriteParam,
                true
            );
        }

        foreach ($conversionParams->toArray() as $paramName => $value) {
            if (!array_key_exists($paramName, $supportedOptions)) {
                throw new UnsupportedParamException(
                    sprintf(
                        'FFMpegAdapter does not support param \'%s\'',
                        $paramName
                    )
                );
            }
            $pattern = $supportedOptions[$paramName]['pattern'];
            if (is_bool($value)) {
                $args[$paramName] = $value ? $pattern : '';
            } elseif ($value instanceof FFMpegCLIValueInterface) {
                // Will test also FFMpegVideoFilterInterface
                $cliValue = $value->getFFmpegCLIValue();
                if ($cliValue !== null) {
                    $args[$paramName] = sprintf($pattern, $cliValue);
                }
            } elseif (is_string($value) || is_int($value)) {
                $args[$paramName] = sprintf($pattern, $value);
            } else {
                throw new UnsupportedParamValueException(
                    sprintf(
                        'Param \'%s\' has an unsupported type: \'%s\'',
                        $paramName,
                        is_object($value) ? get_class($value) : gettype($value)
                    )
                );
            }
        }

        // Validation
        if ($validateParams) {
            (new FFMpegParamValidator($conversionParams))->validate();
        }

        return $args;
    }

    /**
     * @param array<string,string>               $arguments        args that will be added
     * @param null|string|UnescapedFileInterface $outputFile
     * @param array<string,string>               $prependArguments args that must be added at the beginning of the command
     *
     * @throws InvalidArgumentException
     *
     * @return array<int|string, string>
     */
    public function getCliCommand(array $arguments, string $inputFile, $outputFile = null, array $prependArguments = []): array
    {
        $outputArg = null;
        if ($outputFile instanceof UnescapedFileInterface) {
            $outputArg = $outputFile->getFile();
        } elseif (is_string($outputFile)) {
            $outputArg = $outputFile;
        }

        if ($outputArg === null) {
            throw new InvalidArgumentException(sprintf(
                'Output file must be either a non empty string, null or PlatformNullFile (type %s)',
                gettype($outputFile)
            ));
        }

        $ffmpegCmd = array_merge(
            [
                $this->ffmpegConfig->getBinary(),
            ],
            $this->getArgsWithExplodedValues($prependArguments),
            ['-i', $inputFile],
            $this->getArgsWithExplodedValues($arguments),
            [$outputArg]
        );

        if (count($ffmpegCmd) < 2) {
            throw new UnexpectedValueException(
                'Cannot generate ffmpeg cli command'
            );
        }

        return $ffmpegCmd;
    }

    /**
     * As we rely on symfony process unescaping, we
     * need to explode options name and values... i.e
     * ['-tune animation'] will become ['-tune', 'animation'].
     *
     * @param array<string, string> $args
     *
     * @return string[]
     */
    private function getArgsWithExplodedValues(array $args): array
    {
        $exploded = [];
        foreach ($args as $key => $value) {
            $elems      = explode(' ', $value);
            $exploded[] = array_shift($elems);
            if (count($elems) <= 0) {
                continue;
            }
            $exploded[] = implode(' ', $elems);
        }

        return $exploded;
    }

    public function getDefaultThreads(): ?int
    {
        return $this->ffmpegConfig->getThreads();
    }
}


1		<?php
2
3		declare(strict_types=1);
4
5		/**
6		* @see https://github.com/soluble-io/soluble-mediatools for the canonical repository
7		*
8		* @copyright Copyright (c) 2018-2020 Sébastien Vanvelthem. (https://github.com/belgattitude)
9		* @license https://github.com/soluble-io/soluble-mediatools/blob/master/LICENSE.md MIT
10		*/
11
12		namespace Soluble\MediaTools\Video\Adapter;
13
14		use Soluble\MediaTools\Common\Exception\InvalidArgumentException;
15		use Soluble\MediaTools\Common\Exception\UnsupportedParamException;
16		use Soluble\MediaTools\Common\Exception\UnsupportedParamValueException;
17		use Soluble\MediaTools\Common\IO\UnescapedFileInterface;
18		use Soluble\MediaTools\Video\Adapter\Validator\FFMpegParamValidator;
19		use Soluble\MediaTools\Video\Config\FFMpegConfigInterface;
20		use Soluble\MediaTools\Video\Exception\ParamValidationException;
21		use Soluble\MediaTools\Video\Exception\UnexpectedValueException;
22		use Soluble\MediaTools\Video\VideoConvertParamsInterface;
23
24		final class FFMpegAdapter implements ConverterAdapterInterface
25		{
26		/** @var FFMpegConfigInterface */
27		private $ffmpegConfig;
28
29	45	public function __construct(FFMpegConfigInterface $ffmpegConfig)
30		{
31	45	$this->ffmpegConfig = $ffmpegConfig;
32	45	}
33
34		/**
35		* @return array<string, array<string, string>>
36		*/
37	42	public function getParamsOptions(): array
38		{
39		return [
40	42	VideoConvertParamsInterface::PARAM_OUTPUT_FORMAT => [
41	42	'pattern' => '-f %s',
42		],
43	42	VideoConvertParamsInterface::PARAM_VIDEO_CODEC => [
44		'pattern' => '-c:v %s',
45		],
46	42	VideoConvertParamsInterface::PARAM_VIDEO_BITRATE => [
47		'pattern' => '-b:v %s',
48		],
49	42	VideoConvertParamsInterface::PARAM_VIDEO_MIN_BITRATE => [
50		'pattern' => '-minrate %s',
51		],
52	42	VideoConvertParamsInterface::PARAM_VIDEO_MAX_BITRATE => [
53		'pattern' => '-maxrate %s',
54		],
55	42	VideoConvertParamsInterface::PARAM_AUDIO_CODEC => [
56		'pattern' => '-c:a %s',
57		],
58	42	VideoConvertParamsInterface::PARAM_AUDIO_BITRATE => [
59		'pattern' => '-b:a %s',
60		],
61	42	VideoConvertParamsInterface::PARAM_PIX_FMT => [
62		'pattern' => '-pix_fmt %s',
63		],
64	42	VideoConvertParamsInterface::PARAM_PRESET => [
65		'pattern' => '-preset %s',
66		],
67	42	VideoConvertParamsInterface::PARAM_SPEED => [
68		'pattern' => '-speed %d',
69		],
70	42	VideoConvertParamsInterface::PARAM_THREADS => [
71		'pattern' => '-threads %d',
72		],
73	42	VideoConvertParamsInterface::PARAM_KEYFRAME_SPACING => [
74		'pattern' => '-g %d',
75		],
76	42	VideoConvertParamsInterface::PARAM_QUALITY => [
77		'pattern' => '-quality %s',
78		],
79	42	VideoConvertParamsInterface::PARAM_VIDEO_QUALITY_SCALE => [
80		'pattern' => '-qscale:v %d',
81		],
82	42	VideoConvertParamsInterface::PARAM_CRF => [
83		'pattern' => '-crf %d',
84		],
85	42	VideoConvertParamsInterface::PARAM_STREAMABLE => [
86		'pattern' => '-movflags +faststart',
87		],
88	42	VideoConvertParamsInterface::PARAM_FRAME_PARALLEL => [
89		'pattern' => '-frame-parallel %s',
90		],
91	42	VideoConvertParamsInterface::PARAM_TILE_COLUMNS => [
92		'pattern' => '-tile-columns %s',
93		],
94	42	VideoConvertParamsInterface::PARAM_TUNE => [
95		'pattern' => '-tune %s',
96		],
97	42	VideoConvertParamsInterface::PARAM_VIDEO_FILTER => [
98		'pattern' => '-filter:v %s',
99		],
100	42	VideoConvertParamsInterface::PARAM_OVERWRITE => [
101		'pattern' => '-y',
102		],
103	42	VideoConvertParamsInterface::PARAM_VIDEO_FRAMES => [
104		'pattern' => '-frames:v %d',
105		],
106	42	VideoConvertParamsInterface::PARAM_NOAUDIO => [
107		'pattern' => '-an',
108		],
109	42	VideoConvertParamsInterface::PARAM_SEEK_START => [
110		'pattern' => '-ss %s',
111		],
112	42	VideoConvertParamsInterface::PARAM_SEEK_END => [
113		'pattern' => '-to %s',
114		],
115	42	VideoConvertParamsInterface::PARAM_PASSLOGFILE => [
116		'pattern' => '-passlogfile %s',
117		],
118	42	VideoConvertParamsInterface::PARAM_PASS => [
119		'pattern' => '-pass %s',
120		],
121	42	VideoConvertParamsInterface::PARAM_AUTO_ALT_REF => [
122		'pattern' => '-auto-alt-ref %s',
123		],
124	42	VideoConvertParamsInterface::PARAM_LAG_IN_FRAMES => [
125		'pattern' => '-lag-in-frames %s',
126		],
127		];
128		}
129
130		/**
131		* Return an array version of params suitable for ffmpeg cli.
132		*
133		* @param bool $validateParams whether to run ffmpeg validation process validation
134		*
135		* @return array<string, string>
136		*
137		* @throws UnsupportedParamException
138		* @throws UnsupportedParamValueException
139		* @throws ParamValidationException
140		*/
141	42	public function getMappedConversionParams(VideoConvertParamsInterface $conversionParams, bool $validateParams = true): array
142		{
143	42	$args = [];
144	42	$supportedOptions = $this->getParamsOptions();
145
146		// Add default overwrite option if not set
147	42	$overwriteParam = VideoConvertParamsInterface::PARAM_OVERWRITE;
148	42	if (!$conversionParams->hasParam($overwriteParam)) {
149	35	$conversionParams = $conversionParams->withBuiltInParam(
150	35	$overwriteParam,
151	35	true
152		);
153		}
154
155	42	foreach ($conversionParams->toArray() as $paramName => $value) {
156	42	if (!array_key_exists($paramName, $supportedOptions)) {
157		throw new UnsupportedParamException(
158		sprintf(
159		'FFMpegAdapter does not support param \'%s\'',
160		$paramName
161		)
162		);
163		}
164	42	$pattern = $supportedOptions[$paramName]['pattern'];
165	42	if (is_bool($value)) {
166	41	$args[$paramName] = $value ? $pattern : '';
167	39	} elseif ($value instanceof FFMpegCLIValueInterface) {
168		// Will test also FFMpegVideoFilterInterface
169	26	$cliValue = $value->getFFmpegCLIValue();
170	26	if ($cliValue !== null) {
171	26	$args[$paramName] = sprintf($pattern, $cliValue);
172		}
173	36	} elseif (is_string($value) \|\| is_int($value)) {
174	35	$args[$paramName] = sprintf($pattern, $value);
175		} else {
176	1	throw new UnsupportedParamValueException(
177	1	sprintf(
178	1	'Param \'%s\' has an unsupported type: \'%s\'',
179		$paramName,
180	1	is_object($value) ? get_class($value) : gettype($value)
181		)
182		);
183		}
184		}
185
186		// Validation
187	41	if ($validateParams) {
188	41	(new FFMpegParamValidator($conversionParams))->validate();
189		}
190
191	40	return $args;
192		}
193
194		/**
195		* @param array<string,string> $arguments args that will be added
196		* @param null\|string\|UnescapedFileInterface $outputFile
197		* @param array<string,string> $prependArguments args that must be added at the beginning of the command
198		*
199		* @throws InvalidArgumentException
200		*
201		* @return array<int\|string, string>
202		*/
203	35	public function getCliCommand(array $arguments, string $inputFile, $outputFile = null, array $prependArguments = []): array
204		{
205	35	$outputArg = null;
206	35	if ($outputFile instanceof UnescapedFileInterface) {
207	6	$outputArg = $outputFile->getFile();
208	31	} elseif (is_string($outputFile)) {
209	29	$outputArg = $outputFile;
210		}
211
212	35	if ($outputArg === null) {
213	2	throw new InvalidArgumentException(sprintf(
214	2	'Output file must be either a non empty string, null or PlatformNullFile (type %s)',
215	2	gettype($outputFile)
216		));
217		}
218
219	33	$ffmpegCmd = array_merge(
220		[
221	33	$this->ffmpegConfig->getBinary(),
222		],
223	33	$this->getArgsWithExplodedValues($prependArguments),
224	33	['-i', $inputFile],
225	33	$this->getArgsWithExplodedValues($arguments),
226	33	[$outputArg]
227		);
228
229	33	if (count($ffmpegCmd) < 2) {
230		throw new UnexpectedValueException(
231		'Cannot generate ffmpeg cli command'
232		);
233		}
234
235	33	return $ffmpegCmd;
236		}
237
238		/**
239		* As we rely on symfony process unescaping, we
240		* need to explode options name and values... i.e
241		* ['-tune animation'] will become ['-tune', 'animation'].
242		*
243		* @param array<string, string> $args
244		*
245		* @return string[]
246		*/
247	33	private function getArgsWithExplodedValues(array $args): array
248		{
249	33	$exploded = [];
250	33	foreach ($args as $key => $value) {
251	33	$elems = explode(' ', $value);
252	33	$exploded[] = array_shift($elems);
253	33	if (count($elems) <= 0) {
254	33	continue;
255		}
256	32	$exploded[] = implode(' ', $elems);
257		}
258
259	33	return $exploded;
260		}
261
262	27	public function getDefaultThreads(): ?int
263		{
264	27	return $this->ffmpegConfig->getThreads();
265		}
266		}
267

soluble-io / soluble-mediatools

FFMpegAdapter::getDefaultThreads() A last analyzed 2020-12-24 09:19 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

FFMpegAdapter::getDefaultThreads() A
last analyzed 2020-12-24 09:19 UTC