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

Complexity

Total Complexity

2

Size/Duplication

Total Lines	39
Duplicated Lines	100 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

0%

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	8	8	1
A	handle()	7	7	1

<?php

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

use Doctrine\Common\Persistence\ManagerRegistry;
use Illuminate\Console\Command;
use Shippinno\Job\Application\Messaging\RequeueAbandonedJobMessageService;
use Shippinno\Job\Infrastructure\Persistence\Doctrine\ManagerRegistryAwareTrait;

class JobAbandonedRequeue extends Command

This class seems to be duplicated in your project.

{
    use ManagerRegistryAwareTrait;

    /**
     * {@inheritdoc}
     */
    protected $signature = 'job:abandoned:requeue {id}';

    /**
     * @var RequeueAbandonedJobMessageService
     */
    private $requeueAbandonedJobMessageService;

    /**
     * @param RequeueAbandonedJobMessageService $requeueAbandonedJobMessageService
     * @param ManagerRegistry|null $managerRegistry
     */
    public function __construct(
        RequeueAbandonedJobMessageService $requeueAbandonedJobMessageService,
        ManagerRegistry $managerRegistry = null
    ) {
        parent::__construct();
        $this->requeueAbandonedJobMessageService = $requeueAbandonedJobMessageService;
        $this->setManagerRegistry($managerRegistry);
    }

    /**
     * @throws \Shippinno\Job\Domain\Model\AbandonedJobMessageFailedToRequeueException
     * @throws \Shippinno\Job\Domain\Model\AbandonedJobMessageNotFoundException
     */
    public function handle()
    {
        $id = intval($this->argument('id'));
        $this->requeueAbandonedJobMessageService->execute($id);
        $this->flush();
        $this->info('Message has been successfully enqueued and the abandoned has been deleted.');
    }
}