kodedphp / cache-simple

Client/PredisJsonClient.php

<?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 function Koded\Caching\verify_key;
use function Koded\Stdlib\json_serialize;

/**
 * RedisJsonClient uses the Predis package.
 *
 * It will create 2 entries in Redis
 * - one as JSON cache item
 * - and other as serialized PHP value
 *
 * The first is useful for other programming languages to use it,
 * and the PHP serialized variant is useful only for PHP applications
 * where the cached item is handled by PHP serialization.
 *
 */
final class PredisJsonClient implements Cache
{
    use ClientTrait, MultiplesTrait;

    private $suffix;
    private $options;
    private $serializer;

    public function __construct(\Predis\Client $client, Serializer $serializer, int $options, int $ttl = null)
    {
        $this->suffix = '__' . $serializer->type() . '__';
        $this->serializer = $serializer;
        $this->options = $options;
        $this->client = $client;
        $this->ttl = $ttl;
    }


    public function get($key, $default = null)
    {
        return $this->has($key)
            ? $this->serializer->unserialize($this->client->get($key . $this->suffix))
            : $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, json_serialize($value, $this->options))->getPayload()
                && 'OK' === $this->client->set($key . $this->suffix, $this->serializer->serialize($value))->getPayload();
        }

        if ($expiration > 0) {
            return 'OK' === $this->client->setex($key, $expiration, json_serialize($value, $this->options))->getPayload()

The method setex() does not exist on Koded\Caching\Client\ShmopClient. Did you maybe mean set()?

                && 'OK' === $this->client->setex($key . $this->suffix, $expiration, $this->serializer->serialize($value))->getPayload();
        }

        $this->client->del([$key, $key . $this->suffix]);

The method del() does not exist on Koded\Caching\Client\ShmopClient.

        return true;
    }


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

        return 2 === $this->client->del([$key, $key . $this->suffix]);
    }


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

The method flushDb() does not exist on Koded\Caching\Client\ShmopClient.

    }


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

        return (bool)$this->client->exists($key)

The method exists() does not exist on Koded\Caching\Client\ShmopClient.

            && (bool)$this->client->exists($key . $this->suffix);
    }
}