Shippinno\Job\Infrastructure\Ui\Console\Laravel\Command\JobConsume

Complexity

Total Complexity

10

Size/Duplication

Total Lines	85
Duplicated Lines	17.65 %

Coupling/Cohesion

Components	1
Dependencies	6

Test Coverage

Coverage

73.52%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	10	10	2
A	handle()	5	29	5
A	queueName()	0	9	2
A	terminate()	0	5	1

<?php

namespace Shippinno\Job\Infrastructure\Ui\Console\Laravel\Command;

use Doctrine\Common\Persistence\ManagerRegistry;
use Illuminate\Console\Command;
use LogicException;
use Psr\Log\LoggerAwareTrait;
use Psr\Log\LoggerInterface;
use Psr\Log\NullLogger;
use Shippinno\Job\Application\Messaging\ConsumeStoredJobService;
use Shippinno\Job\Infrastructure\Persistence\Doctrine\ManagerRegistryAwareTrait;
use Throwable;

class JobConsume extends Command
{
    use ManagerRegistryAwareTrait;
    use LoggerAwareTrait;

    /**
     * {@inheritdoc}
     */
    protected $signature = 'job:consume';

    /**
     * @var ConsumeStoredJobService
     */
    private $consumeStoredJobService;

    /**
     * @var bool
     */
    private $terminating = false;

    /**
     * @param ConsumeStoredJobService $consumeStoredJobService
     * @param ManagerRegistry|null $managerRegistry
     * @param LoggerInterface|null $logger
     */
    public function __construct(

This method seems to be duplicated in your project.

        ConsumeStoredJobService $consumeStoredJobService,
        ManagerRegistry $managerRegistry = null,
        LoggerInterface $logger = null
    ) {
        parent::__construct();
        $this->consumeStoredJobService = $consumeStoredJobService;
        $this->setManagerRegistry($managerRegistry);
        $this->setLogger(null !== $logger ? $logger : new NullLogger);
    }

    public function handle()
    {
        if (extension_loaded('pcntl')) {

This code seems to be duplicated across your project.

            pcntl_async_signals(true);
            pcntl_signal(SIGTERM, [$this, 'terminate']);
            pcntl_signal(SIGINT, [$this, 'terminate']);
        }

        $queueName = $this->queueName();
        $forever = !env('JOB_TESTING', false);
        do {
            $this->clear();
            $this->consumeStoredJobService->execute(
                $queueName,
                function () {
                    try {
                        $this->flush();
                    } catch (Throwable $e) {
                        return false;
                    }
                    return true;
                },
                function () {
                    $this->clear();
                }
            );

Blank line found at end of control structure

        } while ($forever && !$this->terminating);
    }

    /**
     * @return string
     */
    private function queueName(): string
    {
        $queueName = env('JOB_CONSUME_QUEUE');
        if (!$queueName) {
            throw new LogicException('The env JOB_CONSUME_QUEUE is not defined');
        }

        return $queueName;
    }

    public function terminate()
    {
        $this->logger->info('Terminating job:consume.');
        $this->terminating = true;
    }
}