Soluble\MediaTools\Cli\Command\ConvertDirCommand::execute()

Complexity

Conditions	10
Paths	76

Size

Total Lines	137
Code Lines	72

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	5
CRAP Score	89.248

Importance

Changes

0

<?php
    protected function execute(InputInterface $input, OutputInterface $output): int
    {
        $helper = $this->getHelper('question');

        // ########################
        // Step 1: Check directory
        // ########################

        $directory = $input->getOption('dir');
        Assert::stringNotEmpty($directory);
        Assert::directory($directory);

        // ########################
        // Step 2: Init preset
        // ########################

        Assert::stringNotEmpty($input->getOption('preset'));
        $preset = $this->getPreset($input->getOption('preset'));

        // ########################
        // Step 3: Output dir
        // ########################

        if ($input->getOption('output') !== null) {
            $outputDir = $input->getOption('output');
            Assert::directory($outputDir);
            Assert::writable($outputDir);
        } else {
            $outputDir = $directory;
        }
        Assert::stringNotEmpty($outputDir);

        // ########################
        // Step 4: Extensions
        // ########################

        if ($input->getOption('exts') !== null) {
            $tmp = $input->getOption('exts');
            Assert::stringNotEmpty($tmp);
            $exts = array_filter(
                array_map(
                    'trim',
                    explode(',', $tmp)

It seems like $tmp can also be of type string[]; however, parameter $string of explode() does only seem to accept string, maybe add an additional type check?

                )
            );
            Assert::minCount($exts, 1);
        } else {
            $exts = FileExtensions::BUILTIN_EXTENSIONS;
        }

        $recursive = $input->getOption('recursive') === true;

        // ########################
        // Step 5: Scanning dir
        // ########################

        $output->writeln(sprintf('* Scanning %s for media files...', $directory));

It seems like $directory can also be of type string[]; however, parameter $args of sprintf() does only seem to accept string, maybe add an additional type check?

        // Get the videos in path
        $files = (new DirectoryScanner())->findFiles($directory, $exts, $recursive);

        $output->writeln('* Reading metadata...');

        $readProgress = new ProgressBar($output, count($files));
        $readProgress->start();

        $medias = (new MediaScanner($this->mediaTools->getReader()))->getMedias($files, function () use ($readProgress): void {
            $readProgress->advance();
        });

        $readProgress->finish();

        // Ask confirmation
        ScanCommand::renderMediaInTable($output, $medias['rows'], $medias['totalSize']);

        $question = new ConfirmationQuestion('Convert files ?', false);

        if (!$helper->ask($input, $output, $question)) {
            return 0;
        }

        $converter = $this->mediaTools->getConverter();

        /* @var \SplFileInfo $file */
        foreach ($medias['rows'] as $row) {
            $file = $row['file'];
            try {
                $outputFile = sprintf(
                    '%s/%s%s',
                    $outputDir,
                    $file->getBasename($file->getExtension()),
                    $preset->getFileExtension()
                );

                $tmpFile = sprintf('%s.tmp', $outputFile);

                if (realpath($outputFile) === realpath((string) $file)) {
                    throw new \RuntimeException(sprintf('Conversion error, input and output files are the same: %s', $outputFile));
                }

                if (!file_exists($outputFile)) {
                    $progress    = new FFMpegProgress();
                    $progressBar = new ProgressBar($output, (int) $row['total_time']);
                    $params      = $preset->getParams($file->getPathname());

                    $output->writeln(sprintf('Convert %s to %s', $file->getBasename(), $outputFile));

                    $converter->convert((string) $file, $tmpFile, $params, function ($stdOut, $stdErr) use ($progressBar, $progress): void {
                        $info = $progress->getProgress($stdErr);
                        if ($info === null) {
                            return;
                        }

                        $progressBar->setProgress((int) $info['time']);
                    });
                    $progressBar->finish();
                    $success = rename($tmpFile, $outputFile);
                    if (!$success) {
                        throw new \RuntimeException(sprintf(
                            'Cannot rename temp file %s to %s',
                            basename($tmpFile),
                            $outputFile
                        ));
                    }

                    $output->writeln(sprintf('<fg=green>- Converted:</> %s.', $file));
                } else {
                    $output->writeln(sprintf('<fg=yellow>- Skipped:</> %s : Output file already exists (%s).', (string) $file, $outputFile));
                }
            } catch (ProcessException $e) {
                $output->writeln(sprintf('<fg=red>- Skipped:</> %s : Not a valid media file.', (string) $file));
            }
        }

        $output->writeln('');

        return 0;
    }