InMemoryList\Infrastructure\Drivers\RedisDriver

Complexity

Total Complexity

17

Size/Duplication

Total Lines	127
Duplicated Lines	0 %

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	getInstance()	0	3	1
A	clear()	0	3	1
A	connect()	0	20	4
A	__construct()	0	8	2
B	setConfig()	0	36	7
A	check()	0	7	2

<?php
/**
 * This file is part of the InMemoryList package.
 *
 * (c) Mauro Cassani<https://github.com/mauretto78>
 *
 *  For the full copyright and license information, please view the LICENSE
 *  file that was distributed with this source code.
 */

namespace InMemoryList\Infrastructure\Drivers;

use InMemoryList\Infrastructure\Drivers\Contracts\DriverInterface;
use InMemoryList\Infrastructure\Drivers\Exceptions\RedisDriverCheckException;
use InMemoryList\Infrastructure\Drivers\Exceptions\RedisMalformedConfigException;
use Predis\Client as Redis;

class RedisDriver implements DriverInterface
{
    /**
     * @var
     */
    private $config;

    /**
     * @var Redis
     */
    private $instance;

    /**
     * RedisDriver constructor.
     *
     * @codeCoverageIgnore
     *
     * @param array $config
     *
     * @throws RedisDriverCheckException
     */
    public function __construct(array $config = [])
    {
        $this->setConfig($config);
        if (!$this->check()) {
            throw new RedisDriverCheckException('PRedis Client is not loaded.');
        }

        $this->connect();
    }

    /**
     * @param $config
     *
     * @throws RedisMalformedConfigException
     */
    private function setConfig($config)
    {
        $allowedConfigKeys = [
            'alias',
            'async',
            'database',
            'host',
            'iterable_multibulk',
            'options',
            'password',
            'path',
            'port',
            'persistent',
            'profile',
            'timeout',
            'read_write_timeout',
            'scheme',
            'throw_errors',
            'weight',
        ];

        foreach ($config as $param => $server) {
            if (is_array($server)) {
                foreach (array_keys($server) as $key) {
                    if (!in_array($key, $allowedConfigKeys)) {
                        throw new RedisMalformedConfigException();
                    }
                }
            }

            if (!is_array($server) && !in_array($param, $allowedConfigKeys)) {
                throw new RedisMalformedConfigException();
            }
        }

        $this->config = $config;
    }

    /**
     * @codeCoverageIgnore
     *
     * @return bool
     */
    public function check()
    {
        if (extension_loaded('Redis')) {
            trigger_error('The native Redis extension is installed, you should use Redis instead of Predis to increase performances', E_USER_NOTICE);
        }

        return class_exists('Predis\Client');
    }

    /**
     * @return mixed
     */
    public function clear()
    {
        $this->instance->flushall();
    }

    /**
     * @return bool
     */
    public function connect()
    {
        $servers = $this->config ?: [];

        if (count($servers) === 1) {
            $servers = $servers[0];
        }

        if (count($servers) === 0) {
            $servers = [
                'host' => '127.0.0.1',
                'port' => 6379,
                'password' => null,
                'database' => null,
            ];
        }

        $this->instance = new Redis($servers);

        return true;
    }

    /**
     * @return mixed
     */
    public function getInstance()
    {
        return $this->instance;
    }
}