phpbu\App\Runner\Backup\Source

Complexity

Total Complexity

17

Size/Duplication

Total Lines	135
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	10

Test Coverage

Coverage

100%

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	run()	0	4	2
A	backup()	0	5	1
A	simulate()	0	7	2
A	compress()	0	8	4
A	handleCompression()	0	9	2
A	compressDirectory()	0	12	3
A	compressFile()	0	5	1
A	executeCompressor()	0	10	2

<?php
namespace phpbu\App\Runner\Backup;

use phpbu\App\Backup\Compressor;
use phpbu\App\Backup\Source as SourceExe;
use phpbu\App\Backup\Source\Simulator;
use phpbu\App\Backup\Source\Status;
use phpbu\App\Backup\Target;
use phpbu\App\Result;

/**
 * Backup Runner
 *
 * @package    phpbu
 * @subpackage app
 * @author     Sebastian Feldmann <sebastian@phpbu.de>
 * @copyright  Sebastian Feldmann <sebastian@phpbu.de>
 * @license    https://opensource.org/licenses/MIT The MIT License (MIT)
 * @link       https://phpbu.de/
 * @since      Class available since Release 3.0.0
 */
class Source extends Abstraction
{
    /**
     * Executes the backup and compression.
     *
     * @param  \phpbu\App\Backup\Source $source
     * @param  \phpbu\App\Backup\Target $target
     * @param  \phpbu\App\Result        $result
     * @throws \phpbu\App\Exception
     */
    public function run(SourceExe $source, Target $target, Result $result)
    {
        $this->isSimulation() ? $this->simulate($source, $target, $result) : $this->backup($source, $target, $result);
    }

    /**
     * Executes the backup and compression.
     *
     * @param  \phpbu\App\Backup\Source $source
     * @param  \phpbu\App\Backup\Target $target
     * @param  \phpbu\App\Result        $result
     * @throws \phpbu\App\Exception
     */
    protected function backup(SourceExe $source, Target $target, Result $result)
    {
        $status = $source->backup($target, $result);
        $this->compress($status, $target, $result);
    }

    /**
     * Simulates the backup.
     *
     * @param  \phpbu\App\Backup\Source $source
     * @param  \phpbu\App\Backup\Target $target
     * @param  \phpbu\App\Result        $result
     * @throws \phpbu\App\Exception
     */
    protected function simulate(SourceExe $source, Target $target, Result $result)
    {
        if ($source instanceof Simulator) {
            $status = $source->simulate($target, $result);
            $this->compress($status, $target, $result);
        }
    }

    /**
     * Compress the backup if the source did not handle the compression.
     *
     * @param  \phpbu\App\Backup\Source\Status $status
     * @param  \phpbu\App\Backup\Target        $target
     * @param  \phpbu\App\Result               $result
     * @throws \phpbu\App\Exception
     */
    protected function compress(Status $status, Target $target, Result $result)
    {
        // if the target is not compressed yet
        // and should be compressed or at least archived (tar)
        if (!$status->handledCompression() && ($target->shouldBeCompressed() || $status->isDirectory())) {
            $this->handleCompression($target, $result, $status);
        }
    }

    /**
     * Handle directory compression for sources which can't handle compression by them self.
     *
     * @param  \phpbu\App\Backup\Target        $target
     * @param  \phpbu\App\Result               $result
     * @param  \phpbu\App\Backup\Source\Status $status
     * @throws \phpbu\App\Exception
     */
    private function handleCompression(Target $target, Result $result, Status $status)
    {
        // is backup data a directory or a file
        if ($status->isDirectory()) {
            $this->compressDirectory($target, $result, $status->getDataPath());
        } else {
            $this->compressFile($target, $result, $status->getDataPath());
        }
    }

    /**
     * Compresses the target if the target is a directory.
     *
     * @param  \phpbu\App\Backup\Target $target
     * @param  \phpbu\App\Result        $result
     * @param  string                   $dataToCompress
     * @throws \phpbu\App\Exception
     */
    private function compressDirectory(Target $target, Result $result, $dataToCompress)
    {
        // archive data
        $dirCompressor = new Compressor\Directory($dataToCompress);
        $archiveFile   = $this->executeCompressor($dirCompressor, $target, $result);

        // if target should be compressed but tar couldn't handle the compression
        // run extra file compression to compress the tar file
        if ($target->shouldBeCompressed() && !$dirCompressor->canCompress($target)) {
            $this->compressFile($target, $result, $archiveFile);
        }
    }

    /**
     * Compresses the target if the target is a single file.
     *
     * @param  \phpbu\App\Backup\Target $target
     * @param  \phpbu\App\Result        $result
     * @param  string                   $dataToCompress
     * @throws \phpbu\App\Exception
     */
    private function compressFile(Target $target, Result $result, $dataToCompress)
    {
        $fileCompressor = new Compressor\File($dataToCompress);
        $this->executeCompressor($fileCompressor, $target, $result);
    }

    /**
     * Execute the compressor.
     * Returns the path to the created archive file.
     *
     * @param  \phpbu\App\Backup\Compressor\Executable $compressor
     * @param  \phpbu\App\Backup\Target                $target
     * @param  \phpbu\App\Result                       $result
     * @return string
     */
    private function executeCompressor(Compressor\Executable $compressor, Target $target, Result $result) : string
    {
        // if this is a simulation just debug the command that would have been executed
        if ($this->isSimulation()) {
            $result->debug($compressor->getExecutable($target)->getCommand());
            return $compressor->getArchiveFile($target);
        } else {
            return $compressor->compress($target, $result);
        }
    }
}