ConsoleHelpers\CodeInsight\KnowledgeBase\DatabaseManager

Complexity

Total Complexity

9

Size/Duplication

Total Lines	82
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	2

Test Coverage

Coverage

100%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	9	2
B	getDatabase()	0	26	6
A	runMigrations()	0	4	1

<?php
/**
 * This file is part of the Code-Insight library.
 * For the full copyright and license information, please view
 * the LICENSE file that was distributed with this source code.
 *
 * @copyright Alexander Obuhovich <aik.bold@gmail.com>
 * @link      https://github.com/console-helpers/code-insight
 */

namespace ConsoleHelpers\CodeInsight\KnowledgeBase;


use Aura\Sql\ExtendedPdo;
use Aura\Sql\ExtendedPdoInterface;
use ConsoleHelpers\DatabaseMigration\MigrationManager;
use ConsoleHelpers\DatabaseMigration\MigrationContext;

class DatabaseManager
{

	/**
	 * Migration manager.
	 *
	 * @var MigrationManager
	 */
	private $_migrationManager;

	/**
	 * Database directory.
	 *
	 * @var string
	 */
	private $_databaseDirectory;

	/**
	 * Database manager constructor.
	 *
	 * @param MigrationManager $migration_manager Migration manager.
	 * @param string           $working_directory Working directory.
	 */
	public function __construct(MigrationManager $migration_manager, $working_directory)
	{
		$this->_migrationManager = $migration_manager;
		$this->_databaseDirectory = $working_directory . '/databases';

		if ( !file_exists($this->_databaseDirectory) ) {
			mkdir($this->_databaseDirectory);
		}
	}

	/**
	 * Returns db for given project.
	 *
	 * @param string      $project_path Project path.
	 * @param string|null $fork         Fork name.
	 *
	 * @return ExtendedPdoInterface
	 * @throws \InvalidArgumentException When relative project path is given.
	 */
	public function getDatabase($project_path, $fork = null)
	{
		if ( substr($project_path, 0, 1) !== '/' ) {
			throw new \InvalidArgumentException('The "$project_path" argument must contain absolute path.');
		}

		$project_path = $this->_databaseDirectory . $project_path;

		if ( !file_exists($project_path) ) {
			mkdir($project_path, 0777, true);
		}

		$db_file = $project_path . '/code_insight.sqlite';

		if ( !strlen($fork) ) {
			return new ExtendedPdo('sqlite:' . $db_file);
		}

		$fork_db_file = $project_path . '/code_insight-' . $fork . '.sqlite';

		if ( !file_exists($fork_db_file) && file_exists($db_file) ) {
			copy($db_file, $fork_db_file);
		}

		return new ExtendedPdo('sqlite:' . $fork_db_file);
	}

	/**
	 * Runs outstanding migrations on the database.
	 *
	 * @param MigrationContext $context Context.
	 *
	 * @return void
	 */
	public function runMigrations(MigrationContext $context)
	{
		$this->_migrationManager->run($context);
	}

}