MGDigital\BusQue\Redis\Predis\PredisAdapter

Complexity

Total Complexity

15

Size/Duplication

Total Lines	97
Duplicated Lines	100 %

Coupling/Cohesion

Components	1
Dependencies	1

Test Coverage

Coverage

95.35%

Importance

Changes

0

13 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	4	4	1
A	ping()	6	6	1
A	bRPopLPush()	6	6	1
A	hGet()	6	6	1
A	sAdd()	6	6	1
A	sRem()	6	6	1
A	sIsMember()	6	6	1
A	sMembers()	6	6	1
A	lLen()	6	6	1
A	lRange()	6	6	1
A	zScore()	7	7	2
A	evalLua()	6	6	1
A	tryCatch()	8	8	2

<?php

namespace MGDigital\BusQue\Redis\Predis;

use MGDigital\BusQue\Exception\RedisException;
use MGDigital\BusQue\Redis\RedisAdapterInterface;
use Predis\ClientInterface;
use Predis\Connection\ConnectionException;

class PredisAdapter implements RedisAdapterInterface

This class seems to be duplicated in your project.

{

    private $client;

    public function __construct(ClientInterface $client)
    {
        $this->client = $client;
    }

    public function ping()
    {
        $this->tryCatch(function () {
            $this->client->ping();
        });
    }

    public function bRPopLPush(string $source, string $destination, int $timeout)
    {
        return $this->tryCatch(function () use ($source, $destination, $timeout) {
            return $this->client->brpoplpush($source, $destination, $timeout);
        });
    }

    public function hGet(string $key, string $field)
    {
        return $this->tryCatch(function () use ($key, $field) {
            return $this->client->hget($key, $field);
        });
    }

    public function sAdd(string $key, array $members)
    {
        $this->tryCatch(function () use ($key, $members) {
            $this->client->sadd($key, $members);
        });
    }

    public function sRem(string $key, array $members)
    {
        $this->tryCatch(function () use ($key, $members) {
            $this->client->srem($key, $members);
        });
    }

    public function sIsMember(string $key, string $value): bool
    {
        return $this->tryCatch(function () use ($key, $value) {
            return $this->client->sismember($key, $value);
        });
    }

    public function sMembers(string $key): array
    {
        return $this->tryCatch(function () use ($key) {
            return $this->client->smembers($key);
        });
    }

    public function lLen(string $key): int
    {
        return $this->tryCatch(function () use ($key) {
            return $this->client->llen($key);
        });
    }

    public function lRange(string $key, int $offset = 0, int $limit = 10): array
    {
        return $this->tryCatch(function () use ($key, $offset, $limit) {
            return $this->client->lrange($key, $offset, $limit);
        });
    }

    public function zScore(string $key, string $value)
    {
        $score = $this->tryCatch(function () use ($key, $value) {
            return $this->client->zscore($key, $value);
        });
        return $score === null ? $score : intval($score);
    }

    public function evalLua(string $lua, array $args)
    {
        return $this->tryCatch(function () use ($lua, $args) {
            return $this->client->eval($lua, 0, ...$args);
        });
    }

    private function tryCatch(callable $callable)
    {
        try {
            return $callable();
        } catch (ConnectionException $e) {
            throw new RedisException($e->getMessage(), 0, $e);
        }
    }
}