Queryr\Replicator\Cli\Install\InstallerTrait

Complexity

Total Complexity

6

Size/Duplication

Total Lines	62
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

0%

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	writeProgress()	0	3	1
A	writeProgressEnd()	0	3	1
A	writeError()	0	3	1
A	tryTask()	0	13	2
A	establishDatabaseConnection()	0	17	1

<?php

namespace Queryr\Replicator\Cli\Install;

use Doctrine\DBAL\DriverManager;
use Queryr\Replicator\DatabaseConfigFile;
use Queryr\Replicator\ServiceFactory;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Output\OutputInterface;

/**
 * @licence GNU GPL v2+
 * @author Jeroen De Dauw < jeroendedauw@gmail.com >
 */
trait InstallerTrait {

	/**
	 * @var InputInterface
	 */
	private $input;

	/**
	 * @var OutputInterface
	 */
	private $output;

	/**
	 * @var ServiceFactory
	 */
	private $factory;

	private function writeProgress( $message ) {
		$this->output->write( "<comment>$message... </comment>" );
	}

	private function writeProgressEnd( $message = 'done.' ) {
		$this->output->writeln( "<comment>$message</comment>" );
	}

	private function writeError( $message ) {
		$this->output->writeln( "<error>$message</error>" );
	}

	private function tryTask( $message, $task ) {
		$this->writeProgress( $message );

		try {
			$returnValue = call_user_func( $task );
		}
		catch ( \Exception $ex ) {
			throw new InstallationException( $ex->getMessage(), 0, $ex );
		}

		$this->writeProgressEnd();
		return $returnValue;
	}

	private function establishDatabaseConnection() {
		$config = $this->tryTask(
			'Reading database configuration file (config/db.json)',
			function() {
				return DatabaseConfigFile::newInstance()->read();
			}
		);

		$connection = $this->tryTask(
			'Establishing database connection',
			function() use ( $config ) {
				return DriverManager::getConnection( $config );
			}
		);

		$this->factory = ServiceFactory::newFromConnection( $connection );
	}

}