Borobudur\Cqrs\ReadModel\Storage\StorageManager

Complexity

Total Complexity

6

Size/Duplication

Total Lines	85
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes	1
Bugs	0	Features	0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	instance()	0	10	2
A	getEngine()	0	4	1
A	buildStorage()	0	11	2

<?php
/*
 * This file is part of the Borobudur-Cqrs package.
 *
 * (c) Hexacodelabs <http://hexacodelabs.com>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Borobudur\Cqrs\ReadModel\Storage;

use Borobudur\Cqrs\Exception\InvalidArgumentException;
use Borobudur\Cqrs\ReadModel\Storage\Pdo\Pdo;
use Borobudur\Cqrs\ReadModel\Storage\Pdo\PdoConfig;

/**
 * @author      Iqbal Maulana <iq.bluejack@gmail.com>
 * @created     8/19/15
 */
class StorageManager
{
    /**
     * @var array
     */
    private static $pdo = array('mysql', 'pgsql');

    /**
     * @var StorageInterface[]
     */
    private static $instances = array();

    /**
     * @var StorageInterface
     */
    private $engine;

    /**
     * Private constructor.
     *
     * @param string      $engine
     * @param string      $host
     * @param int         $port
     * @param string      $database
     * @param string|null $user
     * @param string|null $pass
     */
    private function __construct($engine, $host, $port, $database, $user = null, $pass = null)
    {
        call_user_func_array(array($this, 'buildStorage'), func_get_args());
    }

    /**
     * Build singleton instance storage engine.
     *
     * @param string      $engine
     * @param string      $host
     * @param int         $port
     * @param string      $database
     * @param string|null $user
     * @param string|null $pass
     *
     * @return StorageInterface
     */
    public static function instance($engine, $host, $port, $database, $user = null, $pass = null)
    {
        if (!isset(self::$instances[$engine])) {
            $engine = new StorageManager($engine, $host, $port, $database, $user, $pass);

            return $engine->getEngine();
        }

        return self::$instances[$engine];
    }

    /**
     * Get storage engine.
     *
     * @return StorageInterface
     */
    public function getEngine()
    {
        return $this->engine;
    }

    /**
     * @param string      $engine
     * @param string      $host
     * @param int         $port
     * @param string      $database
     * @param string|null $user
     * @param string|null $pass
     */
    private function buildStorage($engine, $host, $port, $database, $user, $pass)
    {
        if (in_array($engine, self::$pdo)) {
            $config = new PdoConfig($engine, $host, $port, $database, $user, $pass);
            self::$instances[$engine] = $this->engine = new Pdo($config);

            return;
        }

        throw new InvalidArgumentException(sprintf('Storage engine "%s" not found.', $engine));
    }
}