Borobudur\EventSourcing\Storage\AbstractStorageManager

Complexity

Total Complexity

6

Size/Duplication

Total Lines	72
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes	1
Bugs	0	Features	1

4 Methods

Rating	Name	Duplication	Size	Complexity
A	instance()	0	8	2
A	buildInstance()	0	8	2
A	supportEngines()	0	4	1
A	buildEngine()	0	4	1

<?php

namespace Borobudur\EventSourcing\Storage;

use Borobudur\EventSourcing\Exception\InvalidArgumentException;
use Borobudur\EventSourcing\Exception\RuntimeException;
use Borobudur\EventSourcing\Snapshot\SnapshotInterface;

/**
 * @author      Iqbal Maulana <iq.bluejack@gmail.com>
 * @created     8/22/16
 */
abstract class AbstractStorageManager
{
    /**
     * @var StorageInterface|SnapshotInterface[]
     */
    protected static $instances = array();

    /**
     * Build or get an engine if already built.
     *
     * @param string      $engine
     * @param string      $database
     * @param string|null $host
     * @param string|null $user
     * @param string|null $pass
     * @param int|null    $port
     *
     * @return StorageInterface|SnapshotInterface
     */
    final public static function instance($engine, $database, $host = null, $user = null, $pass = null, $port = null)
    {
        if (!isset(static::$instances[$engine])) {
            static::buildInstance($engine, $host, $port, $database, $user, $pass);
        }

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

    /**
     * Build and register the engine.
     *
     * @param string $engine
     * @param string $host
     * @param int    $port
     * @param string $database
     * @param string $user
     * @param string $pass
     *
     * @throws InvalidArgumentException
     */
    protected static function buildInstance($engine, $host, $port, $database, $user, $pass)
    {
        if (in_array($engine, static::supportEngines())) {
            static::$instances[$engine] = static::buildEngine($engine, $host, $port, $database, $user, $pass);
        } else {
            throw new InvalidArgumentException(sprintf('Storage engine "%s" not found.', $engine));
        }
    }

    /**
     * @return array
     */
    protected static function supportEngines()
    {
        return array();
    }

    /**
     * @param string $engine
     * @param string $host
     * @param int    $port
     * @param string $database
     * @param string $user
     * @param string $pass
     *
     * @return mixed
     */
    protected static function buildEngine($engine, $host, $port, $database, $user, $pass)
    {
        throw new RuntimeException('There are no implement of build engine.');
    }
}