Semaphoro\Storages\Redis

Complexity

Total Complexity

7

Size/Duplication

Total Lines	89
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	remove()	0	3	1
A	addPrefix()	0	3	1
A	getValue()	0	3	1
A	getKeys()	0	6	1
A	save()	0	5	1
A	__construct()	0	4	1
A	removePrefix()	0	6	1

<?php

namespace Semaphoro\Storages;


use Predis\Client;

class Redis implements StorageInterface
{
    /**
     * @var \Predis\Client
     */
    private $redisClient;

    /**
     * @var string
     */
    private $prefixKey;

    /**
     * Redis constructor.
     *
     * @param Client $redis The redis instance
     * @param string $prefix
     */
    public function __construct(Client $redis, string $prefix = 'semaphoro')
    {
        $this->redisClient = $redis;
        $this->prefixKey = $prefix;
    }

    /**
     * @param string $key
     * @return array
     */
    public function getKeys(string $key): array
    {
        $keys = $this->redisClient->keys($this->addPrefix($key));

        return array_filter($keys, function ($key) {
            return $this->removePrefix($key);
        });
    }

    /**
     * @param string $key
     * @return string
     */
    public function getValue(string $key): string
    {
        return $this->redisClient->get($this->addPrefix($key));
    }

    /**
     * @param string $key
     * @param string $value
     * @return bool
     */
    public function save(string $key, string $value): bool
    {
        return (bool)$this->redisClient->set(
            $this->addPrefix($key),
            $value
        );
    }

    /**
     * @param string $key
     * @return bool
     */
    public function remove(string $key): bool
    {
        return (bool)$this->redisClient->del([$this->addPrefix($key)]);
    }


    /**
     * @param string $key
     * @return string
     */
    private function removePrefix(string $key): string
    {
        return str_replace(
            sprintf('%s:', $this->prefixKey),
            '',
            $key
        );
    }

    /**
     * @param string $key
     * @return string
     */
    private function addPrefix(string $key): string
    {
        return sprintf('%s:%s', $this->prefixKey, $key);
    }
}