averias/phpredis-bloom

<?php
/**
 * @project   phpredis-bloom
 * @author    Rafael Campoy <rafa.campoy@gmail.com>
 * @copyright 2019 Rafael Campoy <rafa.campoy@gmail.com>
 * @license   MIT
 * @link      https://github.com/averias/phpredis-bloom
 *
 * Copyright and license information, is included in
 * the LICENSE file that is distributed with this source code.
 */

namespace Averias\RedisBloom\Adapter;

use Averias\RedisBloom\Connection\ConnectionOptions;
use Averias\RedisBloom\Exception\ConnectionException;
use Redis;
use Exception;

class RedisAdapter implements RedisAdapterInterface
{
    /** @var ConnectionOptions */
    protected $connectionOptions;

    /** @var Redis */
    protected $redis;

    /**
     * @param Redis $redis
     * @param ConnectionOptions $connectionOptions
     * @throws ConnectionException
     */
    public function __construct(Redis $redis, ConnectionOptions $connectionOptions)
    {
        $this->connectionOptions = $connectionOptions;
        $this->redis = $redis;
        $this->setConnection();
    }

    public function getLastError(): ?string
    {
        return $this->redis->getLastError();
    }

    /**
     * @param string $commandName
     * @param mixed ...$arguments
     * @return mixed
     * @throws ConnectionException
     */
    public function rawCommand(string $commandName, ...$arguments)
    {
        $this->checkConnection();
        return $this->redis->rawCommand($commandName, ...$arguments);
    }

    /**
     * @param string $methodName
     * @param array $arguments
     * @return mixed
     * @throws ConnectionException
     */
    public function executeCommandByName(string $methodName, array $arguments = [])
    {
        $this->checkConnection();
        return call_user_func_array([$this->redis, $methodName], $arguments);
    }

    /**
     * @throws ConnectionException
     */
    public function checkConnection(): void
    {
        if (!$this->isConnected()) {
            $this->setConnection();
        }
    }

    /**
     * @throws ConnectionException
     */
    public function setConnection(): void
    {
        if (!$this->connect()) {
            throw new ConnectionException(
                sprintf("connection to Redis server failed, reason: %s", $this->getLastError())
            );
        }

        if ($this->connectionOptions->getDatabase() != 0) {
            $this->redis->select($this->connectionOptions->getDatabase());
        }

        $this->redis->setOption(Redis::OPT_REPLY_LITERAL, 1);
    }

    /**
     * @return bool
     */
    public function connect(): bool
    {
        $connectionValues = $this->connectionOptions->getConnectionValues();
        if ($this->connectionOptions->isPersistent()) {
            return  $this->redis->pconnect(...$connectionValues);
        }

        return $this->redis->connect(...$connectionValues);
    }

    /** Close a persistent connection. If connection is not persistent, it is not connected or there is an error closing
     * the persistence connection, returns false, true if persistent connection was closed successfully
     *
     * @return bool
     */
    public function closeConnection(): bool
    {
        try {
            $disconnected = $this->redis->close();
        } catch (Exception $exception) {
            return false;
        }

        return $disconnected;
    }

    /**
     * @return bool
     */
    public function isConnected(): bool
    {
        return $this->redis->isConnected();
    }

    /**
     * @return string
     */
    public function getConnectionHost(): string
    {
        return $this->connectionOptions->getHost();
    }

    /**
     * @return int
     */
    public function getConnectionPort(): int
    {
        return $this->connectionOptions->getPort();
    }

    /**
     * @return int
     */
    public function getConnectionDatabase(): int
    {
        return $this->connectionOptions->getDatabase();
    }
}