WorkerQuery::active() - Code Metrics - Inspection of "Stat page were removed temporary" - zhuravljov/yii2-queue-monitor - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — master ( b313ea...47c9db )

by Roman

created 2018-08-08 16:26 UTC

WorkerQuery::active() A

↳ Parent: WorkerQuery

Complexity

Conditions	1
Paths	1

Size

Total Lines	9
Code Lines	7

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
cc	1
eloc	7
nc	1
nop	0
dl	0
loc	9
rs	10
c	0
b	0
f	0

<?php
/**
 * @link https://github.com/zhuravljov/yii2-queue-monitor
 * @copyright Copyright (c) 2017 Roman Zhuravlev
 * @license http://opensource.org/licenses/BSD-3-Clause
 */

namespace zhuravljov\yii\queue\monitor\records;

use yii\db\ActiveQuery;
use zhuravljov\yii\queue\monitor\Env;

/**
 * Worker Query
 *
 * @author Roman Zhuravlev <[email protected]>
 */
class WorkerQuery extends ActiveQuery
{
    /**
     * @var Env
     */
    private $env;

    /**
     * @param string $modelClass
     * @param Env $env
     * @param array $config
     * @inheritdoc
     */
    public function __construct($modelClass, Env $env, array $config = [])
    {
        $this->env = $env;
        parent::__construct($modelClass, $config);
    }

    /**
     * @inheritdoc
     */
    public function init()
    {
        parent::init();
        $this->alias('worker');
    }

    /**
     * @param string $host
     * @param int $pid
     * @return $this
     */
    public function byEvent($host, $pid)
    {
        return $this->andWhere([
            'worker.host' => $host,
            'worker.pid' => $pid,
        ]);
    }

    /**
     * @return $this
     */
    public function active()
    {
        return $this
            ->andWhere(['worker.finished_at' => null])
            ->leftJoin(['exec' => ExecRecord::tableName()], '{{exec}}.[[id]] = {{worker}}.[[last_exec_id]]')
            ->andWhere([
                'or',
                ['>', 'worker.pinged_at', time() - $this->env->workerPingInterval - 5],
                ['exec.finished_at' => null],
            ]);
    }

    /**
     * @inheritdoc
     * @return WorkerRecord[]|array
     */
    public function all($db = null)
    {
        return parent::all($db);
    }

    /**
     * @inheritdoc
     * @return WorkerRecord|array|null
     */
    public function one($db = null)
    {
        return parent::one($db);

    }
}


1			<?php
2			/**
3			* @link https://github.com/zhuravljov/yii2-queue-monitor
4			* @copyright Copyright (c) 2017 Roman Zhuravlev
5			* @license http://opensource.org/licenses/BSD-3-Clause
6			*/
7
8			namespace zhuravljov\yii\queue\monitor\records;
9
10			use yii\db\ActiveQuery;
11			use zhuravljov\yii\queue\monitor\Env;
12
13			/**
14			* Worker Query
15			*
16			* @author Roman Zhuravlev <[email protected]>
17			*/
18			class WorkerQuery extends ActiveQuery
19			{
20			/**
21			* @var Env
22			*/
23			private $env;
24
25			/**
26			* @param string $modelClass
27			* @param Env $env
28			* @param array $config
29			* @inheritdoc
30			*/
31			public function __construct($modelClass, Env $env, array $config = [])
32			{
33			$this->env = $env;
34			parent::__construct($modelClass, $config);
35			}
36
37			/**
38			* @inheritdoc
39			*/
40			public function init()
41			{
42			parent::init();
43			$this->alias('worker');
44			}
45
46			/**
47			* @param string $host
48			* @param int $pid
49			* @return $this
50			*/
51			public function byEvent($host, $pid)
52			{
53			return $this->andWhere([
54			'worker.host' => $host,
55			'worker.pid' => $pid,
56			]);
57			}
58
59			/**
60			* @return $this
61			*/
62			public function active()
63			{
64			return $this
65			->andWhere(['worker.finished_at' => null])
66			->leftJoin(['exec' => ExecRecord::tableName()], '{{exec}}.[[id]] = {{worker}}.[[last_exec_id]]')
67			->andWhere([
68			'or',
69			['>', 'worker.pinged_at', time() - $this->env->workerPingInterval - 5],
70			['exec.finished_at' => null],
71			]);
72			}
73
74			/**
75			* @inheritdoc
76			* @return WorkerRecord[]\|array
77			*/
78			public function all($db = null)
79			{
80			return parent::all($db);
81			}
82
83			/**
84			* @inheritdoc
85			* @return WorkerRecord\|array\|null
86			*/
87			public function one($db = null)
88			{
89			return parent::one($db);
			0 ignored issues – show Bug Best Practice introduced 2018-01-05 23:19 UTC by Report Bug Copy Issue Report The expression `return parent::one($db)` also could return the type `yii\db\ActiveRecord` which is incompatible with the return type mandated by `yii\db\QueryInterface::one()` of `boolean\|array`. Loading history...
90			}
91			}
92

zhuravljov / yii2-queue-monitor

Push — master ( b313ea...47c9db )

WorkerQuery::active() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like