CodexShaper\Dumper\Dumper

Complexity

Total Complexity

49

Size/Duplication

Total Lines	134
Duplicated Lines	0 %

Test Coverage

Coverage

72.72%

Importance

Changes	2
Bugs	0	Features	0

12 Methods

Rating	Name	Duplication	Size	Complexity
A	run()	0	15	3
A	__construct()	0	5	3
A	create()	0	3	1
A	prepareProcessCommand()	0	5	1
A	prepareDatabase()	0	8	6
A	prepareCreateTables()	0	7	5
A	prepareSocket()	0	5	3
A	prepareUserName()	0	7	5
A	preparePort()	0	7	5
A	prepareIgnoreTables()	0	11	6
A	prepareHost()	0	7	5
A	prepareIncludeTables()	0	8	6

<?php

namespace CodexShaper\Dumper;

use CodexShaper\Dumper\Contracts\Dumper as DumperContract;
use CodexShaper\Dumper\Traits\DumperTrait;
use Symfony\Component\Process\Exception\ProcessFailedException;
use Symfony\Component\Process\Process;

abstract class Dumper implements DumperContract
{
    use DumperTrait;

    public function __construct(array $options = [])
    {
        foreach ($options as $option => $value) {
            if (property_exists($this, $option)) {
                $this->{$option} = $value;
            }
        }
    }
    /**
     * @return $this
     */
    public static function create(array $options = [])
    {
        return new static($options);
    }
    /**
     * @return \Symfony\Component\Process\Process
     */
    protected function prepareProcessCommand()
    {
        $process = Process::fromShellCommandline($this->command);
        $process->setTimeout($this->timeout);
        return $process;
    }
    /**
     * @return \Symfony\Component\Process\Process
     */
    protected function run()
    {
        try {

            $process = Process::fromShellCommandline($this->command);
            $process->setTimeout($this->timeout);

            if ($this->debug) {
                return $process->mustRun();
            }

            return $process->run();

The expression return $process->run() returns the type integer which is incompatible with the documented return type Symfony\Component\Process\Process.

        } catch (ProcessFailedException $e) {
            throw new \Exception($e->getMessage());

        }
    }

    abstract public function dump();
    abstract public function restore();

    public function prepareHost()
    {
        switch (strtolower($this->getDumperClassName())) {
            case 'pgsqldumper':
                return ($this->socket !== '') ? $this->socket : $this->host;
            case 'mongodumper';
                return !empty($this->host) ? "--host {$this->host}" : "";
        }
    }

    public function preparePort()
    {
        switch (strtolower($this->getDumperClassName())) {
            case 'pgsqldumper':
                return !empty($this->port) ? '-p ' . $this->port : '';
            case 'mongodumper':
                return !empty($this->port) ? "--port {$this->port}" : "";
        }
    }

    public function prepareSocket()
    {
        switch (strtolower($this->getDumperClassName())) {
            case 'mysqldumper':
                return ($this->socket !== '') ? "--socket={$this->socket}" : '';
        }
    }

    public function prepareDatabase()
    {
        switch (strtolower($this->getDumperClassName())) {
            case 'mysqldumper':
            case 'pgsqldumper':
                return !empty($this->dbName) ? $this->dbName : "";
            case 'mongodumper';
                return !empty($this->dbName) ? "--db {$this->dbName}" : "";
        }
    }

    public function prepareUserName()
    {
        switch (strtolower($this->getDumperClassName())) {
            case 'pgsqldumper':
                return !empty($this->username) ? $this->username : "";
            case 'mongodumper';
                return !empty($this->username) ? "--username {$this->username}" : "";
        }
    }

    public function prepareIncludeTables()
    {
        switch (strtolower($this->getDumperClassName())) {
            case 'mysqldumper':
                $includeTables = (count($this->tables) > 0) ? implode(' ', $this->tables) : '';
                return !empty($includeTables) ? "--tables {$includeTables}" : '';
            case 'pgsqldumper':
                return (count($this->tables) > 0) ? '-t ' . implode(' -t ', $this->tables) : "";
        }
    }

    public function prepareIgnoreTables()
    {
        switch (strtolower($this->getDumperClassName())) {
            case 'mysqldumper':
                $ignoreTablesArgs = [];
                foreach ($this->ignoreTables as $tableName) {
                    $ignoreTablesArgs[] = "--ignore-table={$this->dbName}.{$tableName}";
                }
                return (count($ignoreTablesArgs) > 0) ? implode(' ', $ignoreTablesArgs) : '';
            case 'pgsqldumper';
                return (count($this->ignoreTables) > 0) ? '-T ' . implode(' -T ', $this->ignoreTables) : '';
        }
    }

    public function prepareCreateTables()
    {
        switch (strtolower($this->getDumperClassName())) {
            case 'mysqldumper':
                return !$this->createTables ? '--no-create-info' : '';
            case 'pgsqldumper':
                return (!$this->createTables) ? '--data-only' : '';
        }
    }
}