WorkCommand::handle() - Code Metrics - umbrellio/php-table-sync - Measure and Improve Code Quality continuously with Scrutinizer

WorkCommand::handle() A
last analyzed 2023-03-17 08:45 UTC

↳ Parent: WorkCommand

Complexity

Conditions	2
Paths	2

Size

Total Lines	11
Code Lines	6

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	6

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
eloc	6
c	1
b	0
f	0
dl	0
loc	11
ccs	0
cts	7
cp	0
rs	10
cc	2
nc	2
nop	1
crap	6

<?php

declare(strict_types=1);

namespace Umbrellio\TableSync\Integration\Laravel\Console\Commands;

use Umbrellio\TableSync\Integration\Laravel\Console\ProcessManagerCommand;
use Umbrellio\TableSync\Rabbit\Consumer;

class WorkCommand extends ProcessManagerCommand
{
    protected $signature = 'table_sync:work';
    protected $description = 'Run table_sync worker';

    public function __destruct()
    {
        $this->pidManager->removePid();
    }

    public function handle(Consumer $consumer): void
    {
        if ($this->pidManager->pidExists()) {
            $this->warn("Table sync worker already running (PID: {$this->pidManager->readPid()})");
            return;
        }

        $this->pidManager->writePid();
        $this->listenTerminateSignals($consumer);

        $consumer->consume();
    }

    private function listenTerminateSignals(Consumer $consumer): void
    {
        pcntl_async_signals(true);

        pcntl_signal(SIGTERM, function () use ($consumer) {
            $this->line('Shutting down by SIGTERM.');

            $consumer->terminate();
        });

        pcntl_signal(SIGINT, function () use ($consumer) {
            $this->line('Shutting down by SIGINT');

            $consumer->terminate();
        });
    }
}


1			<?php
2
3			declare(strict_types=1);
4
5			namespace Umbrellio\TableSync\Integration\Laravel\Console\Commands;
6
7			use Umbrellio\TableSync\Integration\Laravel\Console\ProcessManagerCommand;
8			use Umbrellio\TableSync\Rabbit\Consumer;
9
10			class WorkCommand extends ProcessManagerCommand
11			{
12			protected $signature = 'table_sync:work';
13			protected $description = 'Run table_sync worker';
14
15			public function __destruct()
16			{
17			$this->pidManager->removePid();
18			}
19
20			public function handle(Consumer $consumer): void
21			{
22			if ($this->pidManager->pidExists()) {
23			$this->warn("Table sync worker already running (PID: {$this->pidManager->readPid()})");
24			return;
25			}
26
27			$this->pidManager->writePid();
28			$this->listenTerminateSignals($consumer);
29
30			$consumer->consume();
31			}
32
33			private function listenTerminateSignals(Consumer $consumer): void
34			{
35			pcntl_async_signals(true);
36
37			pcntl_signal(SIGTERM, function () use ($consumer) {
38			$this->line('Shutting down by SIGTERM.');
39
40			$consumer->terminate();
41			});
42
43			pcntl_signal(SIGINT, function () use ($consumer) {
44			$this->line('Shutting down by SIGINT');
45
46			$consumer->terminate();
47			});
48			}
49			}
50

umbrellio / php-table-sync

WorkCommand::handle() A last analyzed 2023-03-17 08:45 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

WorkCommand::handle() A
last analyzed 2023-03-17 08:45 UTC