Koded\Caching\Client\PredisClient

Complexity

Total Complexity

11

Size/Duplication

Total Lines	62
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes	2
Bugs	0	Features	0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	delete()	0	7	2
A	clear()	0	3	1
A	set()	0	16	4
A	get()	0	5	2
A	__construct()	0	5	1
A	has()	0	5	1

<?php

/*
 * This file is part of the Koded package.
 *
 * (c) Mihail Binev <mihail@kodeart.com>
 *
 * Please view the LICENSE distributed with this source code
 * for the full copyright and license information.
 *
 */

namespace Koded\Caching\Client;

use Koded\Caching\Cache;
use Koded\Stdlib\Interfaces\Serializer;
use Predis\Client;
use function Koded\Caching\verify_key;

/**
 * Class PredisClient uses the Predis library.
 *
 * @property Client client
 */
final class PredisClient implements Cache
{
    use ClientTrait, MultiplesTrait;

    private $serializer;

    public function __construct(Client $client, Serializer $serializer, int $ttl = null)
    {
        $this->client = $client;
        $this->serializer = $serializer;
        $this->ttl = $ttl;
    }


    public function get($key, $default = null)
    {
        return $this->has($key)
            ? $this->serializer->unserialize($this->client->get($key))
            : $default;
    }


    public function set($key, $value, $ttl = null)
    {
        verify_key($key);
        $expiration = $this->secondsWithGlobalTtl($ttl);

        if (null === $ttl && 0 === $expiration) {
            return 'OK' === $this->client->set($key, $this->serializer->serialize($value))->getPayload();
        }

        if ($expiration > 0) {
            return 'OK' === $this->client->setex($key, $expiration, $this->serializer->serialize($value))->getPayload();
        }

        $this->client->del($key);

        return true;
    }


    public function delete($key)
    {
        if (false === $this->has($key)) {
            return true;
        }

        return 1 === $this->client->del($key);
    }


    public function clear()
    {
        return 'OK' === $this->client->flushdb()->getPayload();
    }


    public function has($key)
    {
        verify_key($key);

        return 1 === $this->client->exists($key);
    }
}