Micro\Cache\Drivers\RedisDriver

Complexity

Total Complexity

21

Size/Duplication

Total Lines	129
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes	1
Bugs	0	Features	0

11 Methods

Rating	Name	Duplication	Size	Complexity
B	__construct()	0	23	6
A	check()	0	4	2
A	__destruct()	0	6	2
A	set()	0	4	2
A	delete()	0	4	2
A	clean()	0	4	1
A	info()	0	4	1
A	getMeta()	0	8	2
A	get()	0	4	1
A	increment()	0	4	1
A	decrement()	0	4	1

<?php /** MicroRedisDriver */

namespace Micro\Cache\Drivers;

use Micro\Base\Exception;

/**
 * Class RedisDriver
 *
 * @author Oleg Lunegov <testuser@mail.linpax.org>
 * @link https://github.com/linpax/microphp-framework
 * @copyright Copyright (c) 2013 Oleg Lunegov
 * @license https://github.com/linpax/microphp-framework/blob/master/LICENSE
 * @package Micro
 * @subpackage Cache\Driver
 * @version 1.0
 * @since 1.0
 */
class RedisDriver extends CacheDriver
{
    /** @var \Redis $driver driver redis */
    protected $driver;


    /**
     * Constructor
     *
     * @access public
     *
     * @param array $config config array
     *
     * @result void
     * @throws Exception
     */
    public function __construct(array $config = [])
    {
        parent::__construct($config);

        if (!$this->check()) {
            throw new Exception('Redis not installed on system');
        }
        $this->driver = new \Redis;

        try {
            if (!empty($config['socket_type']) && $config['socket_type'] === 'unix') {
                $result = $this->driver->connect($config['socket']);
            } else {
                $result = $this->driver->connect($config['host'], $config['port'], $config['duration']);
            }
        } catch (\RedisException $e) {

The class RedisException does not exist. Did you forget a USE statement, or did you not list all dependencies?

            throw new Exception((string)$e);
        }

        if (!$result) {
            throw new Exception('Redis configuration failed');
        }
    }

    /**
     * @inheritdoc
     */
    public function check()
    {
        return extension_loaded('redis') && $this->driver->ping();
    }

    /**
     * Destructor
     *
     * @access public
     * @result void
     */
    public function __destruct()
    {
        if ($this->driver) {
            $this->driver->close();
        }
    }

    /**
     * @inheritdoc
     */
    public function set($name, $value, $duration = 0)
    {
        return $duration ? $this->driver->setex($name, $duration, $value) : $this->driver->set($name, $value);
    }

    /**
     * @inheritdoc
     */
    public function delete($name)
    {
        return ($this->driver->delete($name) !== 1) ?: true;
    }

    /**
     * @inheritdoc
     */
    public function clean()
    {
        return $this->driver->flushDB();
    }

    /**
     * @inheritdoc
     */
    public function info()
    {
        return $this->driver->info();
    }

    /**
     * @inheritdoc
     */
    public function getMeta($id)
    {
        if ($value = $this->get($id)) {
            return ['expire' => time() + $this->driver->ttl($id), 'data' => $value];
        }

        return false;
    }

    /**
     * @inheritdoc
     */
    public function get($name)
    {
        return $this->driver->get($name);
    }

    /**
     * @inheritdoc
     */
    public function increment($name, $offset = 1)
    {
        return $this->driver->incrBy($name, $offset);
    }

    /**
     * @inheritdoc
     */
    public function decrement($name, $offset = 1)
    {
        return $this->driver->decrBy($name, $offset);
    }
}