Puli\Manager\Api\Config\Config

Complexity

Total Complexity

97

Size/Duplication

Total Lines	758
Duplicated Lines	5.28 %

Coupling/Cohesion

Components	1
Dependencies	2

Test Coverage

Coverage

92.47%

Importance

Changes	9
Bugs	2	Features	3

28 Methods

Rating	Name	Duplication	Size	Complexity
A	getKeys()	0	4	1
A	__construct()	0	6	1
A	getBaseConfig()	0	4	1
A	get()	0	4	1
B	getRaw()	0	20	10
B	contains()	0	20	8
A	set()	0	21	4
A	merge()	0	6	2
A	replace()	0	5	1
A	remove()	0	14	3
A	clear()	0	4	1
A	toFlatArray()	0	4	1
A	toFlatRawArray()	0	6	3
A	toArray()	0	4	1
A	toRawArray()	0	12	4
A	isEmpty()	0	10	4
C	validate()	0	39	16
A	assertArray()	10	10	3
A	assertNotNull()	0	10	2
A	assertString()	10	10	4
A	assertInteger()	10	10	4
A	assertBoolean()	10	10	4
A	assertNonEmpty()	0	9	2
A	replacePlaceholders()	0	20	4
A	filterByKeyPrefix()	0	15	3
A	containsKeyPrefix()	0	10	3
A	removeByKeyPrefix()	0	10	3
A	addKeyValue()	0	15	3

<?php

/*
 * This file is part of the puli/repository.itory-manager package.
 *
 * (c) Bernhard Schussek <bschussek@gmail.com>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Puli\Manager\Api\Config;

use Puli\Manager\Api\InvalidConfigException;

/**
 * Stores configuration values.
 *
 * Use the methods {@link get()}, {@link set()} and {@link merge()} to retrieve
 * and store values:
 *
 * ```php
 * $config = new Config();
 * $config->set(Config::PULI_DIR, '.puli');
 *
 * echo $config->get(Config::PULI_DIR);
 * // => .puli
 * ```
 *
 * You can customize the value returned by {@link get()} if a key is not set
 * by passing that value in the second parameter:
 *
 * ```php
 * $config = new Config();
 *
 * echo $config->get(Config::PULI_DIR, '.puli');
 * ```
 *
 * A configuration may also inherit default values from another configuration:
 *
 * ```php
 * $defaultConfig = new Config();
 * $defaultConfig->set(Config::PULI_DIR, '.puli');
 *
 * $config = new Config($defaultConfig);
 *
 * $config->get(Config::PULI_DIR);
 * // => .puli
 * ```
 *
 * You can disable the fallback to the default value by passing `false` to
 * {@link get()}:
 *
 * ```php
 * $defaultConfig = new Config();
 * $defaultConfig->set(Config::PULI_DIR, '.puli');
 *
 * $config = new Config($defaultConfig);
 *
 * $config->get(Config::PULI_DIR, null, false);
 * // => null
 * ```
 *
 * Configuration values support placeholders for other values in the format
 * `{$<key>}`. These placeholders will be replaced by the actual values of the
 * referenced keys when the values are accessed:
 *
 * ```php
 * $config = new Config();
 * $config->set(Config::PULI_DIR, '.puli');
 * $config->set(Config::FACTORY_FILE, '{$puli-dir}/PuliFactory.php');
 *
 * echo $config->get(Config::FACTORY_FILE);
 * // => .puli/PuliRegistry.php
 * ```
 *
 * @since  1.0
 *
 * @author Bernhard Schussek <bschussek@gmail.com>
 */
class Config
{
    const PULI_DIR = 'puli-dir';

    const BOOTSTRAP_FILE = 'bootstrap-file';

    const FACTORY = 'factory';

    const FACTORY_AUTO_GENERATE = 'factory.auto-generate';

    const FACTORY_IN = 'factory.in';

    const FACTORY_IN_CLASS = 'factory.in.class';

    const FACTORY_IN_FILE = 'factory.in.file';

    const FACTORY_OUT = 'factory.out';

    const FACTORY_OUT_CLASS = 'factory.out.class';

    const FACTORY_OUT_FILE = 'factory.out.file';

    const REPOSITORY = 'repository';

    const REPOSITORY_TYPE = 'repository.type';

    const REPOSITORY_PATH = 'repository.path';

    const REPOSITORY_SYMLINK = 'repository.symlink';

    const REPOSITORY_OPTIMIZE = 'repository.optimize';

    const REPOSITORY_STORE = 'repository.store';

    const REPOSITORY_STORE_TYPE = 'repository.store.type';

    const REPOSITORY_STORE_PATH = 'repository.store.path';

    const REPOSITORY_STORE_HOST = 'repository.store.host';

    const REPOSITORY_STORE_PORT = 'repository.store.port';

    const REPOSITORY_STORE_BUCKET = 'repository.store.bucket';

    const REPOSITORY_STORE_CACHE = 'repository.store.cache';

    const CHANGE_STREAM = 'change-stream';

    const CHANGE_STREAM_TYPE = 'change-stream.type';

    const CHANGE_STREAM_PATH = 'change-stream.path';

    const CHANGE_STREAM_STORE = 'change-stream.store';

    const CHANGE_STREAM_STORE_TYPE = 'change-stream.store.type';

    const CHANGE_STREAM_STORE_PATH = 'change-stream.store.path';

    const CHANGE_STREAM_STORE_HOST = 'change-stream.store.host';

    const CHANGE_STREAM_STORE_PORT = 'change-stream.store.port';

    const CHANGE_STREAM_STORE_BUCKET = 'change-stream.store.bucket';

    const CHANGE_STREAM_STORE_CACHE = 'change-stream.store.cache';

    const DISCOVERY = 'discovery';

    const DISCOVERY_TYPE = 'discovery.type';

    const DISCOVERY_PATH = 'discovery.path';

    const DISCOVERY_STORE = 'discovery.store';

    const DISCOVERY_STORE_TYPE = 'discovery.store.type';

    const DISCOVERY_STORE_PATH = 'discovery.store.path';

    const DISCOVERY_STORE_HOST = 'discovery.store.host';

    const DISCOVERY_STORE_PORT = 'discovery.store.port';

    const DISCOVERY_STORE_BUCKET = 'discovery.store.bucket';

    const DISCOVERY_STORE_CACHE = 'discovery.store.cache';

    const CACHE_FILE = 'cache-file';

    /**
     * The accepted config keys.
     *
     * @var bool[]
     */
    private static $keys = array(
        self::PULI_DIR => true,
        self::BOOTSTRAP_FILE => true,
        self::FACTORY_AUTO_GENERATE => true,
        self::FACTORY_IN_CLASS => true,
        self::FACTORY_IN_FILE => true,
        self::FACTORY_OUT_CLASS => true,
        self::FACTORY_OUT_FILE => true,
        self::REPOSITORY_TYPE => true,
        self::REPOSITORY_PATH => true,
        self::REPOSITORY_SYMLINK => true,
        self::REPOSITORY_OPTIMIZE => true,
        self::REPOSITORY_STORE_TYPE => true,
        self::REPOSITORY_STORE_PATH => true,
        self::REPOSITORY_STORE_HOST => true,
        self::REPOSITORY_STORE_PORT => true,
        self::REPOSITORY_STORE_BUCKET => true,
        self::REPOSITORY_STORE_CACHE => true,
        self::CHANGE_STREAM_TYPE => true,
        self::CHANGE_STREAM_PATH => true,
        self::CHANGE_STREAM_STORE_TYPE => true,
        self::CHANGE_STREAM_STORE_PATH => true,
        self::CHANGE_STREAM_STORE_HOST => true,
        self::CHANGE_STREAM_STORE_PORT => true,
        self::CHANGE_STREAM_STORE_BUCKET => true,
        self::CHANGE_STREAM_STORE_CACHE => true,
        self::DISCOVERY_TYPE => true,
        self::DISCOVERY_PATH => true,
        self::DISCOVERY_STORE_TYPE => true,
        self::DISCOVERY_STORE_PATH => true,
        self::DISCOVERY_STORE_HOST => true,
        self::DISCOVERY_STORE_PORT => true,
        self::DISCOVERY_STORE_BUCKET => true,
        self::DISCOVERY_STORE_CACHE => true,
        self::CACHE_FILE => true,
    );

    private static $compositeKeys = array(
        self::FACTORY => true,
        self::FACTORY_IN => true,
        self::FACTORY_OUT => true,
        self::REPOSITORY => true,
        self::REPOSITORY_STORE => true,
        self::CHANGE_STREAM => true,
        self::CHANGE_STREAM_STORE => true,
        self::DISCOVERY => true,
        self::DISCOVERY_STORE => true,
    );

    /**
     * The configuration values.
     *
     * @var array
     */
    private $values = array();

    /**
     * The configuration to fall back to.
     *
     * @var Config
     */
    private $baseConfig;

    /**
     * Returns all valid configuration keys.
     *
     * @return string[] The config keys.

Should the return type not be integer[]?

     */
    public static function getKeys()
    {
        return array_keys(self::$keys);
    }

    /**
     * Creates a new configuration.
     *
     * @param Config|null $baseConfig The configuration to fall back to if a value is
     *                                not set in here.
     * @param array       $values     The values to initially set in the configuration.
     */
    public function __construct(Config $baseConfig = null, array $values = array())
    {
        $this->baseConfig = $baseConfig;

        $this->merge($values);
    }

    /**
     * Returns the base configuration.
     *
     * @return Config The base configuration or `null` if none is set.
     */
    public function getBaseConfig()
    {
        return $this->baseConfig;
    }

    /**
     * Returns the value of a configuration key.
     *
     * If fallback is enabled, the value of the base configuration is returned
     * if the key was not set.
     *
     * You can also pass a default value in the second parameter. This default
     * value is returned if the configuration key was neither found in this nor
     * in its fallback configuration.
     *
     * @param string $key      The configuration key.
     * @param mixed  $default  The value to return if the key was not set.
     * @param bool   $fallback Whether to return the value of the base
     *                         configuration if the key was not set.
     *
     * @return mixed The value of the configuration key.

Consider making the return type a bit more specific; maybe use array|object|integer|double|null|boolean|string.

     *
     * @throws NoSuchConfigKeyException If the configuration key is invalid.
     */
    public function get($key, $default = null, $fallback = true)
    {
        return $this->replacePlaceholders($this->getRaw($key, $default, $fallback), $fallback);
    }

    /**
     * Returns the raw value of a configuration key.
     *
     * Unlike {@link get()}, this method does not resolve placeholders:
     *
     * ```php
     * $config = new Config();
     * $config->set(Config::PULI_DIR, '.puli');
     * $config->set(Config::INSTALL_FILE, '{$puli-dir}/install-file.json');
     *
     * echo $config->get(Config::PULI_DIR);
     * // => .puli/install-file.json
     *
     * echo $config->getRaw(Config::PULI_DIR);
     * // => {$puli-dir}/install-file.json
     * ```
     *
     * @param string $key      The configuration key.
     * @param mixed  $default  The value to return if the key was not set.
     * @param bool   $fallback Whether to return the value of the base
     *                         configuration if the key was not set.
     *
     * @return mixed The value of the configuration key.
     *
     * @throws NoSuchConfigKeyException If the configuration key is invalid.
     */
    public function getRaw($key, $default = null, $fallback = true)
    {
        if (isset(self::$compositeKeys[$key])) {
            return array_replace_recursive(
                is_array($default) ? $default : array(),
                $fallback && $this->baseConfig ? $this->baseConfig->getRaw($key) : array(),
                $this->filterByKeyPrefix($key.'.')
            );
        }

        if (!isset(self::$keys[$key])) {
            throw NoSuchConfigKeyException::forKey($key);
        }

        if (!array_key_exists($key, $this->values) && $fallback && $this->baseConfig) {
            return $this->baseConfig->getRaw($key, $default);
        }

        return isset($this->values[$key]) ? $this->values[$key] : $default;
    }

    /**
     * Returns whether a configuration key is set.
     *
     * @param string $key      The configuration key to search.
     * @param bool   $fallback Whether to check the base configuration if the
     *                         key is not found.
     *
     * @return bool Returns `true` if the configuration key is set.
     *
     * @throws NoSuchConfigKeyException If the configuration key is invalid.
     */
    public function contains($key, $fallback = true)
    {
        if (!isset(self::$compositeKeys[$key]) && !isset(self::$keys[$key])) {
            throw NoSuchConfigKeyException::forKey($key);
        }

        if (array_key_exists($key, $this->values)) {
            return true;
        }

        if (isset(self::$compositeKeys[$key]) && $this->containsKeyPrefix($key.'.')) {
            return true;
        }

        if ($fallback && $this->baseConfig) {
            return $this->baseConfig->contains($key);
        }

        return false;
    }

    /**
     * Sets the value of a configuration key.
     *
     * @param string $key   The configuration key.
     * @param mixed  $value The value to set.
     *
     * @throws NoSuchConfigKeyException If the configuration key is invalid.
     * @throws InvalidConfigException   If the value is invalid.
     */
    public function set($key, $value)
    {
        if (isset(self::$compositeKeys[$key])) {
            $this->assertArray($key, $value);
            $this->removeByKeyPrefix($key.'.');

            foreach ($value as $k => $v) {
                $this->set($key.'.'.$k, $v);
            }

            return;
        }

        if (!isset(self::$keys[$key])) {
            throw NoSuchConfigKeyException::forKey($key);
        }

        $this->validate($key, $value);

        $this->values[$key] = $value;
    }

    /**
     * Sets a list of configuration values.
     *
     * @param array $values The values to set.
     *
     * @throws NoSuchConfigKeyException If a configuration key is invalid.
     * @throws InvalidConfigException   If a value is invalid.
     */
    public function merge(array $values)
    {
        foreach ($values as $key => $value) {
            $this->set($key, $value);
        }
    }

    /**
     * Replaces the configuration with a list of configuration values.
     *
     * @param array $values The values to set.
     *
     * @throws NoSuchConfigKeyException If a configuration key is invalid.
     * @throws InvalidConfigException   If a value is invalid.
     */
    public function replace(array $values)
    {
        $this->clear();
        $this->merge($values);
    }

    /**
     * Removes a configuration key.
     *
     * If the configuration has a base configuration, the default value will
     * be returned by {@link get()} after removing the key.
     *
     * @param string $key The configuration key to remove.
     *
     * @throws NoSuchConfigKeyException If the configuration key is invalid.
     */
    public function remove($key)
    {
        if (isset(self::$compositeKeys[$key])) {
            $this->removeByKeyPrefix($key.'.');

            return;
        }

        if (!isset(self::$keys[$key])) {
            throw NoSuchConfigKeyException::forKey($key);
        }

        unset($this->values[$key]);
    }

    /**
     * Removes all configuration keys.
     *
     * If the configuration has a base configuration, the default values will
     * be returned by {@link get()} after removing the keys.
     */
    public function clear()
    {
        $this->values = array();
    }

    /**
     * Returns all configuration values as flat array.
     *
     * @param bool $includeFallback Whether to include values set in the base
     *                              configuration passed to {@link __construct()}.
     *
     * @return array The configuration values.

Should the return type not be array|object|integer|double|null|boolean|string? Also, consider making the array more specific, something like array<String>, or String[].

     */
    public function toFlatArray($includeFallback = true)
    {
        return $this->replacePlaceholders($this->toFlatRawArray($includeFallback), $includeFallback);
    }

    /**
     * Returns all raw configuration values as flat array.
     *
     * Unlike {@link toFlatArray()}, this method does not resolve placeholders:
     *
     * ```php
     * $config = new Config();
     * $config->set(Config::PULI_DIR, '.puli');
     * $config->set(Config::REGISTRY_FILE, '{$puli-dir}/ServiceRegistry.php');
     *
     * print_r($config->toFlatArray());
     * // Array(
     * //   'puli-dir' => '.puli',
     * //   'registry-file' => '.puli/ServiceRegistry.php',
     * // )
     *
     * print_r($config->toFlatRawArray());
     * // Array(
     * //   'puli-dir' => '.puli',
     * //   'registry-file' => '{$puli-dir}/ServiceRegistry.php',
     * // )
     * ```
     *
     * @param bool $includeFallback Whether to include values set in the base
     *                              configuration passed to {@link __construct()}.
     *
     * @return array The raw configuration values.
     */
    public function toFlatRawArray($includeFallback = true)
    {
        return $includeFallback && $this->baseConfig
            ? array_replace($this->baseConfig->toFlatRawArray(), $this->values)
            : $this->values;
    }

    /**
     * Returns all configuration values as nested array.
     *
     * @param bool $includeFallback Whether to include values set in the base
     *                              configuration passed to {@link __construct()}.
     *
     * @return array The configuration values.

Should the return type not be array|object|integer|double|null|boolean|string? Also, consider making the array more specific, something like array<String>, or String[].

     */
    public function toArray($includeFallback = true)
    {
        return $this->replacePlaceholders($this->toRawArray($includeFallback), $includeFallback);
    }

    /**
     * Returns all raw configuration values as nested array.
     *
     * Unlike {@link toArray()}, this method does not resolve placeholders:
     *
     * ```php
     * $config = new Config();
     * $config->set(Config::PULI_DIR, '.puli');
     * $config->set(Config::REPO_STORAGE_DIR, '{$puli-dir}/repository');
     *
     * print_r($config->toArray());
     * // Array(
     * //     'puli-dir' => '.puli',
     * //     'repository. => array(
     * //         'storage-dir' => '.puli/repository',
     * //      ),
     * // )
     *
     * print_r($config->toRawArray());
     * // Array(
     * //     'puli-dir' => '.puli',
     * //     'repository. => array(
     * //         'storage-dir' => '{$puli-dir}/repository',
     * //      ),
     * // )
     * ```
     *
     * @param bool $includeFallback Whether to include values set in the base
     *                              configuration passed to {@link __construct()}.
     *
     * @return array The raw configuration values.
     */
    public function toRawArray($includeFallback = true)
    {
        $values = array();

        foreach ($this->values as $key => $value) {
            $this->addKeyValue($key, $value, $values);
        }

        return $includeFallback && $this->baseConfig
            ? array_replace_recursive($this->baseConfig->toRawArray(), $values)
            : $values;
    }

    /**
     * Returns whether the configuration is empty.
     *
     * @param bool $includeFallback Whether to include values set in the base
     *                              configuration passed to {@link __construct()}.
     *
     * @return bool Returns `true` if no key is set and `false` otherwise.
     */
    public function isEmpty($includeFallback = true)
    {
        if (!empty($this->values)) {
            return false;
        }

        return $includeFallback && $this->baseConfig
            ? $this->baseConfig->isEmpty(true)
            : true;
    }

    /**
     * @param string $key
     * @param mixed  $value
     */
    private function validate($key, $value)
    {
        switch ($key) {
            case self::FACTORY_AUTO_GENERATE:
            case self::REPOSITORY_SYMLINK:
            case self::REPOSITORY_OPTIMIZE:
            case self::REPOSITORY_STORE_CACHE:
            case self::CHANGE_STREAM_STORE_CACHE:
            case self::DISCOVERY_STORE_CACHE:
                $this->assertNotNull($key, $value);
                $this->assertBoolean($key, $value);
                break;

            case self::REPOSITORY_STORE_PORT:
            case self::CHANGE_STREAM_STORE_PORT:
            case self::DISCOVERY_STORE_PORT:
                $this->assertNotNull($key, $value);
                $this->assertInteger($key, $value);
                break;

            case self::BOOTSTRAP_FILE:
            case self::FACTORY_IN_FILE:
            case self::REPOSITORY_STORE_TYPE:
            case self::CHANGE_STREAM_STORE_TYPE:
            case self::DISCOVERY_STORE_TYPE:
                if (null !== $value) {
                    $this->assertString($key, $value);
                    $this->assertNonEmpty($key, $value);
                }
                break;

            default:
                $this->assertNotNull($key, $value);
                $this->assertNonEmpty($key, $value);
                $this->assertString($key, $value);

                break;
        }
    }

    /**
     * @param string $key
     * @param mixed  $value
     *
     * @throws InvalidConfigException If the config value isn't an array.
     */
    private function assertArray($key, $value)

This method seems to be duplicated in your project.

    {
        if (!is_array($value)) {
            throw new InvalidConfigException(sprintf(
                'The config key "%s" must be an array. Got: %s',
                $key,
                is_object($value) ? get_class($value) : gettype($value)
            ));
        }
    }

    /**
     * @param string $key
     * @param mixed  $value
     *
     * @throws InvalidConfigException If the config value is null.
     */
    private function assertNotNull($key, $value)
    {
        if (null === $value) {
            throw new InvalidConfigException(sprintf(
                'The config key "%s" must not be null. Use remove() to unset '.
                'keys.',
                $key
            ));
        }
    }

    /**
     * @param string $key
     * @param mixed  $value
     *
     * @throws InvalidConfigException If the config value isn't a string.
     */
    private function assertString($key, $value)

This method seems to be duplicated in your project.

    {
        if (!is_string($value) && null !== $value) {
            throw new InvalidConfigException(sprintf(
                'The config key "%s" must be a string. Got: %s',
                $key,
                is_object($value) ? get_class($value) : gettype($value)
            ));
        }
    }

    /**
     * @param string $key
     * @param mixed  $value
     *
     * @throws InvalidConfigException If the config value isn't an integer.
     */
    private function assertInteger($key, $value)

This method seems to be duplicated in your project.

    {
        if (!is_int($value) && null !== $value) {
            throw new InvalidConfigException(sprintf(
                'The config key "%s" must be an integer. Got: %s',
                $key,
                is_object($value) ? get_class($value) : gettype($value)
            ));
        }
    }

    /**
     * @param string $key
     * @param mixed  $value
     *
     * @throws InvalidConfigException If the config value isn't a boolean.
     */
    private function assertBoolean($key, $value)

This method seems to be duplicated in your project.

    {
        if (!is_bool($value) && null !== $value) {
            throw new InvalidConfigException(sprintf(
                'The config key "%s" must be a bool. Got: %s',
                $key,
                is_object($value) ? get_class($value) : gettype($value)
            ));
        }
    }

    /**
     * @param string $key
     * @param mixed  $value
     *
     * @throws InvalidConfigException If the config value is an empty string.
     */
    private function assertNonEmpty($key, $value)
    {
        if ('' === $value) {
            throw new InvalidConfigException(sprintf(
                'The value of the config key "%s" must not be empty.',
                $key
            ));
        }
    }

    /**
     * @param mixed $raw
     * @param bool  $fallback
     *
     * @return mixed

Consider making the return type a bit more specific; maybe use array|object|integer|double|null|boolean|string.

     */
    private function replacePlaceholders($raw, $fallback = true)
    {
        if (is_array($raw)) {
            foreach ($raw as $key => $value) {
                $raw[$key] = $this->replacePlaceholders($value, $fallback);
            }

            return $raw;
        }

        if (!is_string($raw)) {
            return $raw;
        }

        $config = $this;

        return preg_replace_callback('~\{\$(.+)\}~', function ($matches) use ($config, $fallback) {
            return $config->get($matches[1], null, $fallback);
        }, $raw);
    }

    /**
     * @param string $keyPrefix
     *
     * @return array
     */
    private function filterByKeyPrefix($keyPrefix)
    {
        $values = array();
        $offset = strlen($keyPrefix);

        foreach ($this->values as $k => $v) {
            if (0 !== strpos($k, $keyPrefix)) {
                continue;
            }

            $this->addKeyValue(substr($k, $offset), $v, $values);
        }

        return $values;
    }

    /**
     * @param string $keyPrefix
     *
     * @return bool
     */
    private function containsKeyPrefix($keyPrefix)
    {
        foreach ($this->values as $k => $v) {
            if (0 === strpos($k, $keyPrefix)) {
                return true;
            }
        }

        return false;
    }

    /**
     * @param string $keyPrefix
     */
    private function removeByKeyPrefix($keyPrefix)
    {
        foreach ($this->values as $k => $v) {
            if (0 !== strpos($k, $keyPrefix)) {
                continue;
            }

            unset($this->values[$k]);
        }
    }

    /**
     * @param string $key
     * @param mixed  $value
     * @param array  $values
     */
    private function addKeyValue($key, $value, array &$values)
    {
        $target = &$values;
        $keyParts = explode('.', $key);

        for ($i = 0, $l = count($keyParts) - 1; $i < $l; ++$i) {
            if (!isset($target[$keyParts[$i]])) {
                $target[$keyParts[$i]] = array();
            }

            $target = &$target[$keyParts[$i]];
        }

        $target[$keyParts[$l]] = $value;
    }
}