Linio\Component\Cache\Adapter\RedisAdapter

Complexity

Total Complexity

31

Size/Duplication

Total Lines	171
Duplicated Lines	16.37 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes

0

<?php
class RedisAdapter extends AbstractAdapter implements AdapterInterface
{
    const EXPIRE_RESOLUTION_EX = 'ex';
    const EXPIRE_RESOLUTION_PX = 'px';

    protected ?Client $client;

This code did not parse for me. Apparently, there is an error somewhere around this line:

Syntax error, unexpected '?', expecting T_FUNCTION or T_CONST

    protected int $ttl = 0;
    protected array $config;

    public function __construct(array $config = [], bool $lazy = true)
    {
        $this->config = $config;

        if (!$lazy) {
            $this->client = $this->getClient();
        }
    }

    protected function getClient(): Client
    {
        if (!$this->client) {
            $this->client = $this->createClient($this->config);
        }

        return $this->client;
    }

    /**
     * @return mixed
     */
    public function get(string $key)
    {
        $value = $this->getClient()->get($key);

        if (empty($value) && $this->getClient()->exists($key) == 0) {
            throw new KeyNotFoundException();
        }

        return $value;
    }

    public function getMulti(array $keys): array
    {
        $result = $this->getClient()->mget($keys);
        $values = [];

        foreach ($keys as $index => $key) {
            if ($result[$index] !== null) {
                $values[$key] = $result[$index];
            }
        }

        return $values;
    }

    /**
     * @param mixed $value
     */
    public function set(string $key, $value): bool
    {
        if ($this->ttl == 0) {
            $result = $this->getClient()->set($key, $value);
        } else {
            $result = $this->getClient()->set($key, $value, static::EXPIRE_RESOLUTION_EX, $this->ttl);
        }

        return $result->getPayload() == 'OK';
    }

    public function setMulti(array $data): bool
    {
        /** @var iterable $responses */
        $responses = $this->getClient()->pipeline(
            /** @var Client $pipe */
            function ($pipe) use ($data): void {
                foreach ($data as $key => $value) {
                    if ($this->ttl == 0) {
                        $pipe->set($key, $value);
                    } else {
                        $pipe->set($key, $value, static::EXPIRE_RESOLUTION_EX, $this->ttl);
                    }
                }
            }
        );

        $result = true;
        foreach ($responses as $response) {
            /** @var \Predis\Response\Status $response */
            $result = $result && ($response->getPayload() == 'OK');
        }

        return $result;
    }

    public function contains(string $key): bool
    {
        return (bool) $this->getClient()->exists($key);
    }

    public function delete(string $key): bool
    {
        $this->getClient()->del([$key]);

        return true;
    }

    public function deleteMulti(array $keys): bool
    {
        $this->getClient()->del($keys);

        return true;
    }

    public function flush(): bool
    {
        $result = $this->getClient()->flushAll();

        return $result->getPayload() == 'OK';
    }

    public function setClient(Client $client): void
    {
        $this->client = $client;
    }

    protected function createClient(array $config): Client
    {
        $this->client = new Client($this->getConnectionParameters($config), ['prefix' => null]);

        if (isset($config['ttl'])) {
            $this->ttl = (int) $config['ttl'];
        }

        if (isset($config['cache_not_found_keys'])) {
            $this->cacheNotFoundKeys = (bool) $config['cache_not_found_keys'];
        }

        return $this->client;
    }

    protected function getConnectionParameters(array $config): array
    {
        $connectionParameters = [];
        $connectionParameters['host'] = $config['host'] ?? '127.0.0.1';
        $connectionParameters['port'] = $config['port'] ?? 6379;
        if (isset($config['database'])) {
            $connectionParameters['database'] = $config['database'];
        }
        if (isset($config['password'])) {
            $connectionParameters['password'] = $config['password'];
        }
        if (isset($config['connection_persistent'])) {
            $connectionParameters['connection_persistent'] = $config['connection_persistent'];
        }

        return $connectionParameters;
    }

    public function setNamespace(string $namespace): void
    {
        $this->getClient()->getOptions()->prefix->setPrefix($namespace . ':');
        parent::setNamespace($namespace);
    }

    public function setTtl(int $ttl): void
    {
        $this->ttl = $ttl;
    }
}