PHPDaemon\Clients\Redis\AutoScan

Complexity

Total Complexity

18

Size/Duplication

Total Lines	98
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
B	__construct()	0	24	9
B	doIteration()	0	24	6
A	freeze()	0	4	1
A	run()	0	5	1
A	reset()	0	5	1

<?php
namespace PHPDaemon\Clients\Redis;

use PHPDaemon\Core\CallbackWrapper;

/**
 * @package    NetworkClients
 * @subpackage RedisClient
 * @author     Efimenko Dmitriy <ezheg89@gmail.com>
 */
class AutoScan
{
    use \PHPDaemon\Traits\ClassWatchdog;
    use \PHPDaemon\Traits\StaticObjectWatchdog;

    protected $conn;

    protected $cmd;

    protected $cursor = 0;

    protected $args;

    protected $limit = false;

    protected $num = 0;

    protected $isFreeze = false;

    protected $cb;

    protected $cbEnd;

    /**
     * Constructor
     * @param  Pool $pool Redis pool or connection
     * @param  string $cmd Command
     * @param  array $args Arguments
     * @param  cllable $cbEnd Callback

Should the type for parameter $cbEnd not be cllable|null?

     * @param  integer $limit Limit

Should the type for parameter $limit not be false|integer?

     */
    public function __construct($pool, $cmd, $args = [], $cbEnd = null, $limit = false)
    {
        $this->conn = $pool;
        $this->cmd = $cmd;
        $this->args = empty($args) ? [] : $args;
        $this->limit = $limit;

It seems like $limit can also be of type integer. However, the property $limit is declared as type boolean. Maybe add an additional type check?

        if (is_numeric($this->args[0])) {
            array_shift($this->args);
        }
        for ($i = sizeof($this->args) - 1; $i >= 0; --$i) {
            $a = $this->args[$i];
            if ((is_array($a) || is_object($a)) && is_callable($a)) {
                $this->cb = CallbackWrapper::wrap($a);
                $this->args = array_slice($this->args, 0, $i);
                break;
            } elseif ($a !== null) {
                break;
            }
        }
        if ($cbEnd !== null) {
            $this->cbEnd = CallbackWrapper::wrap($cbEnd);
        }
        $this->doIteration();
    }

    protected function doIteration()
    {
        if ($this->isFreeze) {
            return;
        }

        $args = $this->args;
        array_unshift($args, $this->cursor);
        $args[] = function ($redis) {
            $this->conn = $redis;
            $this->cursor = $redis->result[0];
            $func = $this->cb;
            $func($redis);

            if (!is_numeric($redis->result[0]) || !$redis->result[0] || ($this->limit && ++$this->num > $this->limit)) {
                $func = $this->cbEnd;
                $func($redis, $this);
                return;
            }
            $this->doIteration();
        };
        $func = [$this->conn, $this->cmd];
        $func(... $args);
    }

    public function freeze()
    {
        $this->isFreeze = true;
    }

    public function run()
    {
        $this->isFreeze = false;
        $this->doIteration();
    }

    public function reset()
    {
        $this->num = 0;
        $this->isFreeze = false;
    }
}