matecat / simple-s3

src/Components/Cache/RedisCache.php

<?php

namespace Matecat\SimpleS3\Components\Cache;

use Predis\Client as Redis;
use Matecat\SimpleS3\Helpers\File;

class RedisCache implements CacheInterface
{
    /**
     * @var string
     */
    private $prefixSeparator = DIRECTORY_SEPARATOR;

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

    /**
     * RedisCache constructor.
     *
     * @param Redis $redisClient
     */
    public function __construct(Redis $redisClient)
    {
        $this->redisClient = $redisClient;
    }

    /**
     * @return bool
     */
    public function flushAll()
    {
        $flush = $this->redisClient->flushall();

        if ($flush->getPayload() === 'OK') {
            return true;
        }

        return false;
    }

    /**
     * @param string $bucket
     * @param string $keyname
     * @param null $version

Are you sure the doc-type for parameter $version is correct as it would always require null to be passed?

     *
     * @return array|mixed
     */
    public function get($bucket, $keyname, $version = null)
    {
        if (null != $version) {

The condition null != $version is always false.

            $keyname .= '<VERSION_ID:'.$version.'>';
        }

        return unserialize($this->redisClient->hget($this->getHashPrefix($bucket, $keyname), $keyname));
    }

    /**
     * @param string $bucket
     * @param string $keyname
     * @param null $version

Are you sure the doc-type for parameter $version is correct as it would always require null to be passed?

     *
     * @return bool
     */
    public function has($bucket, $keyname, $version = null)
    {
        if (null != $version) {

The condition null != $version is always false.

            $keyname .= '<VERSION_ID:'.$version.'>';
        }

        return (1 === $this->redisClient->hexists($this->getHashPrefix($bucket, $keyname), $keyname)) ? true : false;
    }

    /**
     * @param string $bucket
     * @param string $keyname
     * @param null $version

Are you sure the doc-type for parameter $version is correct as it would always require null to be passed?

     */
    public function remove($bucket, $keyname, $version = null)
    {
        if (null != $version) {

The condition null != $version is always false.

            $keyname .= '<VERSION_ID:'.$version.'>';
        }

        $this->redisClient->hdel($this->getHashPrefix($bucket, $keyname), [$keyname]);
    }

    /**
     * @param string $bucket
     * @param string $keyname
     *
     * @return array
     */
    public function search($bucket, $keyname)
    {
        return $this->redisClient->hkeys($this->getHashPrefix($bucket, $keyname));
    }

    /**
     * @param string $bucket
     * @param string $keyname
     * @param mixed  $content
     * @param null   $version

Are you sure the doc-type for parameter $version is correct as it would always require null to be passed?

     * @param null   $ttl

Are you sure the doc-type for parameter $ttl is correct as it would always require null to be passed?

     */
    public function set($bucket, $keyname, $content, $version = null, $ttl = null)
    {
        if (null != $version) {

The condition null != $version is always false.

            $keyname .= '<VERSION_ID:'.$version.'>';
        }

        $this->redisClient->hset($this->getHashPrefix($bucket, $keyname), $keyname, serialize($content));

        if ($this->ttl($bucket, $keyname) === -1) {
            $this->redisClient->expire($this->getHashPrefix($bucket, $keyname), (null != $ttl) ? $ttl * 60 : self::TTL_STANDARD);

The condition null != $ttl is always false.

        }
    }

    /**
     * @param string $separator
     */
    public function setPrefixSeparator($separator)
    {
        $this->prefixSeparator = $separator;
    }

    /**
     * @param string $bucket
     * @param string $keyname
     * @param null $version

Are you sure the doc-type for parameter $version is correct as it would always require null to be passed?

     *
     * @return int
     */
    public function ttl($bucket, $keyname, $version = null)
    {
        if (null != $version) {

The condition null != $version is always false.

            $keyname .= '<VERSION_ID:'.$version.'>';
        }

        return $this->redisClient->ttl($this->getHashPrefix($bucket, $keyname));
    }

    /**
     * @param string $bucketName
     * @param string $keyName
     *
     * @return string
     */
    private function getHashPrefix($bucketName, $keyName)
    {
        return hash(self::HASH_ALGORITHM, $bucketName . self::HASH_SAFE_SEPARATOR . $this->getDirName($keyName));
    }

    /**
     * @param string $item
     *
     * @return string
     */
    private function getDirName($item)
    {
        if (File::endsWith($item, $this->prefixSeparator)) {
            return $item;
        }

        $fileInfo = File::getPathInfo($item);

        return $fileInfo['dirname'] . $this->prefixSeparator;
    }
}