Graze\DataFile\Modify\Contract\MergeFiles

Complexity

Total Complexity

14

Size/Duplication

Total Lines	102
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	9

Test Coverage

Coverage

100%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
B	canContract()	0	16	6
B	contract()	0	24	2
B	runCommand()	0	29	6

<?php
/**
 * This file is part of graze/data-file
 *
 * Copyright (c) 2016 Nature Delivered Ltd. <https://www.graze.com>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 *
 * @license https://github.com/graze/data-file/blob/master/LICENSE.md
 * @link    https://github.com/graze/data-file
 */

namespace Graze\DataFile\Modify\Contract;

use DirectoryIterator;
use Graze\DataFile\Helper\Builder\BuilderAwareInterface;
use Graze\DataFile\Helper\GetOptionTrait;
use Graze\DataFile\Helper\OptionalLoggerTrait;
use Graze\DataFile\Helper\Process\ProcessTrait;
use Graze\DataFile\Modify\Compress\CompressionFactory;
use Graze\DataFile\Modify\MakeDirectory;
use Graze\DataFile\Node\FileNode;
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, BuilderAwareInterface
{
    use GetOptionTrait;
    use OptionalLoggerTrait;
    use ProcessTrait;

    /**
     * @param FileNodeCollectionInterface $files
     * @param FileNodeInterface           $target
     *
     * @return bool
     */
    public function canContract(FileNodeCollectionInterface $files, FileNodeInterface $target)
    {
        if (!($target instanceof LocalFile)) {
            return false;
        }

        foreach ($files->getIterator() as $file) {
            if (!($file instanceof LocalFile) ||
                !($file->exists()) ||
                ($file->getCompression() != CompressionFactory::TYPE_NONE)
            ) {
                return false;
            }
        }
        return true;
    }

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

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

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

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

        return $this->runCommand($files, $target, $cmd, $this->getOption('keepOldFiles', true));
    }

    /**
     * @param FileNodeCollectionInterface $files
     * @param FileNodeInterface           $target
     * @param string                      $cmd
     * @param bool                        $keepOld
     *
     * @return FileNodeInterface
     * @throws \Graze\DataFile\Modify\Exception\MakeDirectoryFailedException
     */
    private function runCommand(FileNodeCollectionInterface $files, FileNodeInterface $target, $cmd, $keepOld = true)
    {
        if ($target instanceof FileNode) {
            $maker = new MakeDirectory();
            $maker->makeDirectory($target);
        }

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

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

        if (!$keepOld) {
            $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 $target;
    }
}