Graze\DataFile\Modify\Compress\Gzip

Complexity

Total Complexity

8

Size/Duplication

Total Lines	102
Duplicated Lines	100 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

94.12%

Importance

Changes	2
Bugs	0	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	compress()	7	7	2
A	gzip()	23	23	2
A	decompress()	7	7	2
B	gunzip()	24	24	2

<?php

namespace Graze\DataFile\Modify\Compress;

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\FileProcessTrait;
use Graze\DataFile\Node\FileNodeInterface;
use Graze\DataFile\Node\LocalFile;
use InvalidArgumentException;
use Psr\Log\LoggerAwareInterface;
use Psr\Log\LogLevel;
use Symfony\Component\Process\Exception\ProcessFailedException;

class Gzip implements CompressorInterface, DeCompressorInterface, LoggerAwareInterface, ProcessFactoryAwareInterface

This class seems to be duplicated in your project.

{
    use OptionalLoggerTrait;
    use FileProcessTrait;
    use GetOptionTrait;

    /**
     * Compress a file and return the new file
     *
     * @param FileNodeInterface $node
     * @param array             $options
     *
     * @return FileNodeInterface
     */
    public function compress(FileNodeInterface $node, array $options = [])
    {
        if (!($node instanceof LocalFile)) {
            throw new InvalidArgumentException("Node: $node should be a LocalFile");
        }
        return $this->gzip($node, $options);
    }

    /**
     * @param LocalFile $file
     * @param array     $options -keepOldFile <bool> (Default: true)
     *
     * @return LocalFile
     * @throws ProcessFailedException
     */
    public function gzip(LocalFile $file, array $options = [])
    {
        $this->options = $options;
        $pathInfo = pathinfo($file->getPath());

        if (!$file->exists()) {
            throw new InvalidArgumentException("The file: $file does not exist");
        }

        $outputFile = $file->getClone()
                           ->setPath($pathInfo['dirname'] . '/' . $pathInfo['filename'] . '.gz')
                           ->setCompression(CompressionType::GZIP);

        $this->log(LogLevel::INFO, "Compressing file: {file} into {target} using {compression}", [
            'file'        => $file,
            'target'      => $outputFile,
            'compression' => CompressionType::GZIP,
        ]);

        $cmd = "gzip -c {$file->getPath()} > {$outputFile->getPath()}";

        return $this->processFile($file, $outputFile, $cmd, $this->getOption('keepOldFile', true));
    }

    /**
     * Decompress a file and return the decompressed file
     *
     * @param FileNodeInterface $node
     * @param array             $options
     *
     * @return FileNodeInterface
     */
    public function decompress(FileNodeInterface $node, array $options = [])
    {
        if (!($node instanceof LocalFile)) {
            throw new InvalidArgumentException("Node: $node should be a LocalFile");
        }
        return $this->gunzip($node, $options);
    }

    /**
     * @extend Graze\DataFile\Node\File\LocalFile
     *
     * @param LocalFile $file
     * @param array     $options
     *
     * @return LocalFile
     */
    public function gunzip(LocalFile $file, array $options = [])
    {
        $this->options = $options;
        $pathInfo = pathinfo($file->getPath());

        if (!$file->exists()) {
            throw new InvalidArgumentException("The file: $file does not exist");
        }

        $outputFile = $file->getClone()
                           ->setPath($pathInfo['dirname'] . '/' . $pathInfo['filename'])
                           ->setCompression(CompressionType::NONE);

        $this->log(LogLevel::INFO, "DeCompressing file: {file} into {target} using {compression}", [
            'file'        => $file,
            'target'      => $outputFile,
            'compression' => CompressionType::GZIP,
        ]);

        $cmd = "gunzip -c {$file->getPath()} > {$outputFile->getPath()}";


        return $this->processFile($file, $outputFile, $cmd, $this->getOption('keepOldFile', true));
    }
}