MGDigital\BusQue\Redis\PHPRedis\PHPRedisAdapter

Complexity

Total Complexity

15

Size/Duplication

Total Lines	97
Duplicated Lines	100 %

Coupling/Cohesion

Components	1
Dependencies	1

Test Coverage

Coverage

100%

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\PHPRedis;

use MGDigital\BusQue\Exception\RedisException;
use MGDigital\BusQue\Redis\RedisAdapterInterface;

class PHPRedisAdapter implements RedisAdapterInterface

This class seems to be duplicated in your project.

{

    private $redis;

    public function __construct(\Redis $redis)
    {
        $this->redis = $redis;
    }

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

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

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

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

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

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

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

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

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

    public function zScore(string $key, string $value)
    {
        $score = $this->tryCatch(function () use ($key, $value) {
            return $this->redis->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->redis->evaluate($lua, $args, 0);
        });
    }

    private function tryCatch(callable $callable)
    {
        try {
            return $callable();
        } catch (\RedisException $e) {

The class RedisException does not exist. Is this class maybe located in a folder that is not analyzed, or in a newer version of your dependencies than listed in your composer.lock/composer.json?

            throw new RedisException($e->getMessage(), 0, $e);
        }
    }
}