floor12\backup\logic\processors\DbProcessor

Complexity

Total Complexity

15

Size/Duplication

Total Lines	79
Duplicated Lines	0 %

Importance

Changes	1
Bugs	0	Features	1

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	9	1
A	backup()	0	2	1
A	restore()	0	2	1
A	checkBinary()	0	4	3
A	init()	0	2	1
B	parseDsn()	0	17	8

<?php


namespace floor12\backup\logic\processors;


use floor12\backup\Exceptions\BinaryNotFoundException;

The type floor12\backup\Exceptions\BinaryNotFoundException was not found. Maybe you did not declare it correctly or list all dependencies?

use floor12\backup\Exceptions\DsnParseException;
use floor12\backup\models\IOPriority;
use floor12\backup\Module;
use Yii;
use yii\db\Connection;

abstract class  DbProcessor
{
    /**
     * @var Connection
     */
    protected $connection;
    /**
     * @var array
     */
    protected $parsedDsn;
    /**
     * @var string
     */
    protected $backupFilePath;
    /**
     * @var Module
     */
    protected $module;
    protected $username;
    protected $database;
    protected $host;
    protected $port;
    protected $io;
    protected $password;


    /**
     * DbProcessor constructor.
     * @param string $backupFilePath
     * @param Connection $connection
     */
    public function __construct(string $backupFilePath, Connection $connection, $io = IOPriority::IDLE)
    {
        $this->parseDsn($connection->dsn);
        $this->backupFilePath = $backupFilePath;
        $this->username = $connection->username;
        $this->password = $connection->password;
        $this->module = Yii::$app->getModule('backup');
        $this->io = $io;
        $this->init();
    }

    protected function parseDsn(string $dsn)
    {
        $dsn = substr($dsn, strpos($dsn, ':') + 1);
        $dsnParts = explode(';', $dsn);

        if (empty($dsnParts))
            throw new DsnParseException();

        foreach ($dsnParts as $part) {
            $row = explode('=', $part);
            if (isset($row[0]) && isset($row[1]))
                $this->parsedDsn[$row[0]] = $row[1];
        }

        $this->host = $this->parsedDsn['host'] ?: null;
        $this->port = !empty($this->parsedDsn['port']) ? $this->parsedDsn['port'] : null;
        $this->database = $this->parsedDsn['dbname'] ?: null;
    }

    protected function checkBinary(string $binary)
    {
        if (!file_exists($binary) || !is_executable($binary))
            throw new BinaryNotFoundException($binary);
    }

    public function backup()
    {

    }

    public function restore()
    {

    }

    public function init()
    {

    }
}