tomzx\IRCStats\DatabaseProxy

Complexity

Total Complexity

15

Size/Duplication

Total Lines	128
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

85.11%

Importance

Changes	3
Bugs	0	Features	1

10 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	__destruct()	0	6	2
A	setCapsule()	0	6	1
A	getCapsule()	0	10	2
A	setDatabaseSchema()	0	6	1
A	getConnection()	0	5	1
A	getDatabaseSchema()	0	8	2
A	bootDatabase()	0	11	2
A	setupDatabase()	0	4	1
A	configurePragma()	0	13	2

<?php

namespace tomzx\IRCStats;

use Illuminate\Database\Capsule\Manager as Capsule;
use Illuminate\Database\Connection;

class DatabaseProxy {
	/**
	 * @var array
	 */
	protected $configuration = [];
	/**
	 * @var \Illuminate\Database\Capsule\Manager
	 */
	protected $capsule;
	/**
	 * @var \tomzx\IRCStats\DatabaseSchema
	 */
	protected $databaseSchema;
	/**
	 * @var bool
	 */
	protected $booted = false;

	/**
	 * @param array $configuration
	 */
	public function __construct(array $configuration)
	{
		$this->configuration = $configuration;
	}

	public function __destruct()
	{
		if ($this->capsule) {
			$this->getConnection()->disconnect();
		}
	}

	/**
	 * @param \Illuminate\Database\Capsule\Manager $capsule
	 * @return $this
	 */
	public function setCapsule(Capsule $capsule)
	{
		$this->capsule = $capsule;

		return $this;
	}

	/**
	 * @return \Illuminate\Database\Capsule\Manager
	 */
	public function getCapsule()
	{
		if ( ! $this->capsule) {
			$this->capsule = new Capsule;
			$this->capsule->addConnection($this->configuration);
			$this->capsule->setAsGlobal();
		}

		return $this->capsule;
	}

	/**
	 * @return \tomzx\IRCStats\DatabaseSchema
	 */
	public function getDatabaseSchema()
	{
		if ( ! $this->databaseSchema) {
			$this->databaseSchema = new DatabaseSchema();
		}

		return $this->databaseSchema;
	}

	/**
	 * @param \tomzx\IRCStats\DatabaseSchema $databaseSchema
	 * @return $this
	 */
	public function setDatabaseSchema(DatabaseSchema $databaseSchema)
	{
		$this->databaseSchema = $databaseSchema;

		return $this;
	}

	/**
	 * @return \Illuminate\Database\Connection
	 */
	public function getConnection()
	{
		$this->bootDatabase();
		return $this->getCapsule()->connection();
	}

	protected function bootDatabase()
	{
		if ($this->booted) {
			return;
		}

		$this->booted = true;
		$db = $this->getCapsule()->connection();
		$this->configurePragma($db);
		$this->setupDatabase($db);
	}

	/**
	 * @param \Illuminate\Database\Connection $db
	 * @return void
	 */
	protected function setupDatabase(Connection $db)
	{
		$this->getDatabaseSchema()->initialize($db);
	}

	/**
	 * @param \Illuminate\Database\Connection $db
	 */
	protected function configurePragma(Connection $db)
	{
		if ($this->configuration['driver'] !== 'sqlite') {
			return;
		}

		// Enable foreign keys for the current connection/file
		$db->statement('PRAGMA foreign_keys = ON;');
		// Create sqlite-journal in memory only (instead of creating disk files)
		$db->statement('PRAGMA journal_mode = MEMORY;');
		// Do not wait for OS after sending write commands
		$db->statement('PRAGMA synchronous = OFF;');
	}
}