M180222000000WorkerPing::up() - Code Metrics - Inspection of "Stoppable workers" - zhuravljov/yii2-queue-monitor - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — master ( 1d1c44...e0e6c6 )

by Roman

created 2018-03-04 16:37 UTC

M180222000000WorkerPing::up() A

↳ Parent: M180222000000WorkerPing

Complexity

Conditions	3
Paths	2

Size

Total Lines	21
Code Lines	14

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
dl	0
loc	21
rs	9.3142
c	0
b	0
f	0
cc	3
eloc	14
nc	2
nop	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\migrations;

use yii\db\Migration;
use yii\db\Query;
use zhuravljov\yii\queue\monitor\Env;

/**
 * Storage of worker events
 *
 * @author Roman Zhuravlev <[email protected]>
 */
class M180222000000WorkerPing extends Migration
{
    /**
     * @var Env
     */
    protected $env;

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

    /**
     * @inheritdoc
     */
    public function up()
    {
        $this->addColumn(
            $this->env->workerTableName,
            'pinged_at',
            $this->integer()->notNull()->after('started_at')
        );

        $query = (new Query())->from($this->env->workerTableName);
        foreach ($query->all() as $row) {
            $this->update(
                $this->env->workerTableName,
                ['pinged_at' => $row['finished_at'] ?: time()],
                ['id' => $row['id']]
            );
        }

        $this->addColumn(
            $this->env->workerTableName,
            'stopped_at',
            $this->integer()->after('pinged_at')
        );
    }

    /**
     * @inheritdoc
     */
    public function down()
    {
        $this->dropColumn($this->env->workerTableName, 'stopped_at');
        $this->dropColumn($this->env->workerTableName, 'pinged_at');
    }
}


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\migrations;
9
10			use yii\db\Migration;
11			use yii\db\Query;
12			use zhuravljov\yii\queue\monitor\Env;
13
14			/**
15			* Storage of worker events
16			*
17			* @author Roman Zhuravlev <[email protected]>
18			*/
19			class M180222000000WorkerPing extends Migration
20			{
21			/**
22			* @var Env
23			*/
24			protected $env;
25
26			/**
27			* @param Env $env
28			* @inheritdoc
29			*/
30			public function __construct(Env $env, $config = [])
31			{
32			$this->env = $env;
33			parent::__construct($config);
34			}
35
36			/**
37			* @inheritdoc
38			*/
39			public function up()
40			{
41			$this->addColumn(
42			$this->env->workerTableName,
43			'pinged_at',
44			$this->integer()->notNull()->after('started_at')
45			);
46
47			$query = (new Query())->from($this->env->workerTableName);
48			foreach ($query->all() as $row) {
49			$this->update(
50			$this->env->workerTableName,
51			['pinged_at' => $row['finished_at'] ?: time()],
52			['id' => $row['id']]
53			);
54			}
55
56			$this->addColumn(
57			$this->env->workerTableName,
58			'stopped_at',
59			$this->integer()->after('pinged_at')
60			);
61			}
62
63			/**
64			* @inheritdoc
65			*/
66			public function down()
67			{
68			$this->dropColumn($this->env->workerTableName, 'stopped_at');
69			$this->dropColumn($this->env->workerTableName, 'pinged_at');
70			}
71			}
72

zhuravljov / yii2-queue-monitor

Push — master ( 1d1c44...e0e6c6 )

M180222000000WorkerPing::up() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like