mtolhuijs\LDS\Commands\Synchronise

Complexity

Total Complexity

7

Size/Duplication

Total Lines	67
Duplicated Lines	0 %

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	handle()	0	20	2
A	getSkipTables()	0	4	2
A	getLimit()	0	3	1
A	getTables()	0	4	2

<?php

namespace mtolhuijs\LDS\Commands;

use Illuminate\Console\Command;
use mtolhuijs\LDS\DatabaseSynchronizer;
use mtolhuijs\LDS\Exceptions\DatabaseConnectionException;

class Synchronise extends Command
{
    /**
     * The name and signature of the console command.
     *
     * @var string
     */
    protected $signature = '
        db:sync
        { --from= : Synchronize data from this database instead of the one specified in config }
        { --to= : Synchronize data to this database instead of the one specified in config }
        { --t|tables=* : Only run for given table(s) }
        { --st|skip-tables=* : Skip given table(s) }
        { --l|limit= : Limit query rows (defaults to 5000) }
        { --m|migrate : Run migrations before synchronization }
        { --truncate : Truncate before inserting data }
    ';

    /**
     * The console command description.
     *
     * @var string
     */
    protected $description = 'Synchronizes your \'from\' database with your \'to\' database';

    /**
     * Execute the console command.
     *
     * @return mixed
     */
    public function handle()
    {
        try {
            (new DatabaseSynchronizer(
                $this->option('from') ?? config('database-synchronizer.from'),
                $this->option('to') ?? config('database-synchronizer.to'),
                $this
            ))
                ->setTables($this->getTables())
                ->setSkipTables($this->getSkipTables())
                ->setLimit((int) $this->getLimit())
                ->setOptions($this->options())
                ->run();
        } catch (DatabaseConnectionException $e) {
            $this->error($e->getMessage());

            return;
        }

        $this->info(PHP_EOL.'Synchronization done!');
    }

    private function getTables()
    {
        return empty($this->option('tables')) ?
            config('database-synchronizer.tables') : $this->option('tables');
    }

    private function getSkipTables()
    {
        return empty($this->option('skip-tables')) ?
            config('database-synchronizer.skip_tables') : $this->option('skip-tables');
    }

    private function getLimit()
    {
        return $this->option('limit') ?? config('database-synchronizer.limit', DatabaseSynchronizer::DEFAULT_LIMIT);
    }
}