Graze\DataFile\Modify\Contract\MergeFiles

Complexity

Total Complexity

11

Size/Duplication

Total Lines	81
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	9

Test Coverage

Coverage

97.06%

Importance

Changes	1
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
B	canContract()	0	12	5
B	contract()	0	47	6

<?php

namespace Graze\DataFile\Modify\Contract;

use DirectoryIterator;
use Graze\DataFile\Helper\GetOptionTrait;
use Graze\DataFile\Helper\OptionalLoggerTrait;
use Graze\DataFile\Helper\Process\ProcessFactoryAwareInterface;
use Graze\DataFile\Helper\Process\ProcessTrait;
use Graze\DataFile\Modify\Compress\CompressionType;
use Graze\DataFile\Modify\MakeDirectory;
use Graze\DataFile\Node\FileNodeCollectionInterface;
use Graze\DataFile\Node\FileNodeInterface;
use Graze\DataFile\Node\LocalFile;
use Psr\Log\LoggerAwareInterface;
use Psr\Log\LogLevel;
use Symfony\Component\Process\Exception\ProcessFailedException;

class MergeFiles implements FileContractorInterface, LoggerAwareInterface, ProcessFactoryAwareInterface
{
    use GetOptionTrait;
    use OptionalLoggerTrait;
    use ProcessTrait;

    /**
     * @param FileNodeCollectionInterface $files
     *
     * @return bool
     */
    public function canContract(FileNodeCollectionInterface $files)
    {
        foreach ($files->getIterator() as $file) {
            if (!($file instanceof LocalFile) ||
                !($file->exists()) ||
                ($file->getCompression() != CompressionType::NONE)
            ) {
                return false;
            }
        }
        return true;
    }

    /**
     * Do the expansion and return a collection
     *
     * @param FileNodeCollectionInterface $files
     * @param FileNodeInterface           $file
     * @param array                       $options :keepOldFiles <bool> (Default: true) Keep the old files after merging
     *
     * @return FileNodeInterface
     */
    public function contract(
        FileNodeCollectionInterface $files,
        FileNodeInterface $file,
        array $options = []
    ) {
        $this->options = $options;
        if (!$this->canContract($files)) {
            throw new \InvalidArgumentException("The supplied files are not valid");
        }

        $this->log(LogLevel::INFO, "Merging files in collection $files into: {$file}");

        $filePaths = $files->map(function (LocalFile $item) {
            return $item->getPath();
        });

        $cmd = sprintf(
            'cat %s > %s',
            implode(' ', $filePaths),
            $file->getPath()
        );

        $maker = new MakeDirectory();
        $maker->makeDirectory($file);

$file of type object<Graze\DataFile\Node\FileNodeInterface> is not a sub-type of object<Graze\DataFile\Node\LocalFile>. It seems like you assume a concrete implementation of the interface Graze\DataFile\Node\FileNodeInterface to be always present.

        $process = $this->getProcess($cmd);
        $process->run();

        if (!$process->isSuccessful()) {
            throw new ProcessFailedException($process);
        }

        if (!$this->getOption('keepOldFiles', true)) {
            $this->log(LogLevel::DEBUG, "Deleting old files in collection $files");
            $files->map(function (LocalFile $item) {
                if ($item->exists()) {
                    $item->delete();
                }
                $count = iterator_count(new DirectoryIterator($item->getDirectory()));
                if ($count == 2) {
                    rmdir($item->getDirectory());
                }
            });
        }

        return $file;
    }
}