DeleteAllCommand::handle() - Code Metrics - sofwar/laravel-rabbitmq - Measure and Improve Code Quality continuously with Scrutinizer

DeleteAllCommand::handle() A
last analyzed 2025-05-22 16:33 UTC

↳ Parent: DeleteAllCommand

Complexity

Conditions	5
Paths	16

Size

Total Lines	51
Code Lines	34

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
cc	5
eloc	34
nc	16
nop	0
dl	0
loc	51
rs	9.0648
c	0
b	0
f	0

How to fix Long Method

<?php
namespace NeedleProject\LaravelRabbitMq\Command;

use Illuminate\Console\Command;
use NeedleProject\LaravelRabbitMq\Container;
use NeedleProject\LaravelRabbitMq\Entity\QueueEntity;
use NeedleProject\LaravelRabbitMq\PublisherInterface;

/**
 * Class DeleteAllCommand
 *
 * @package NeedleProject\LaravelRabbitMq\Commad
 * @author  Adrian Tilita <[email protected]>
 */
class DeleteAllCommand extends Command
{
    /**
     * The name and signature of the console command.
     *
     * @var string
     */
    protected $signature = 'rabbitmq:delete-all';

    /**
     * The console command description.
     *
     * @var string
     */
    protected $description = 'Delete all queues, exchanges and binds that are defined in entities AND referenced to' .
    ' either a publisher or a consumer';

    /**
     * @var Container
     */
    private $container;

    /**
     * CreateEntitiesCommand constructor.
     *
     * @param Container $container
     */
    public function __construct(Container $container)
    {
        $this->container = $container;
        parent::__construct();
    }

    /**
     * Execute the console command.
     */
    public function handle()
    {
        $hasErrors = false;
        /** @var PublisherInterface $entity */
        foreach ($this->container->getPublishers() as $publisherName => $entity) {
            try {
                $entity->delete();
                $this->output->writeln(
                    sprintf(
                        "Deleted entity <info>%s</info> for publisher [<fg=yellow>%s</>]",
                        (string)$entity->getAliasName(),
                        (string)$publisherName
                    )
                );
            } catch (\Exception $e) {
                $hasErrors = true;
                $this->output->error(
                    sprintf(
                        "Could not delete entity %s for publisher [%s], got:\n%s",
                        (string)$entity->getAliasName(),
                        (string)$publisherName,
                        (string)$e->getMessage()
                    )
                );
            }
        }

        foreach ($this->container->getConsumers() as $consumerAliasName => $entity) {
            try {
                /** @var QueueEntity $entity */
                $entity->delete();
                $this->output->writeln(
                    sprintf(
                        "Deleted entity <info>%s</info> for consumer [<fg=yellow>%s</>]",
                        (string)$entity->getAliasName(),
                        (string)$consumerAliasName
                    )
                );
            } catch (\Exception $e) {
                $hasErrors = true;
                $this->output->error(
                    sprintf(
                        "Could not delete entity %s for consumer [%s], got:\n%s",
                        (string)$entity->getAliasName(),
                        (string)$consumerAliasName,
                        (string)$e->getMessage()
                    )
                );
            }
        }
        return (int)$hasErrors;
    }
}


1			<?php
2			namespace NeedleProject\LaravelRabbitMq\Command;
3
4			use Illuminate\Console\Command;
5			use NeedleProject\LaravelRabbitMq\Container;
6			use NeedleProject\LaravelRabbitMq\Entity\QueueEntity;
7			use NeedleProject\LaravelRabbitMq\PublisherInterface;
8
9			/**
10			* Class DeleteAllCommand
11			*
12			* @package NeedleProject\LaravelRabbitMq\Commad
13			* @author Adrian Tilita <[email protected]>
14			*/
15			class DeleteAllCommand extends Command
16			{
17			/**
18			* The name and signature of the console command.
19			*
20			* @var string
21			*/
22			protected $signature = 'rabbitmq:delete-all';
23
24			/**
25			* The console command description.
26			*
27			* @var string
28			*/
29			protected $description = 'Delete all queues, exchanges and binds that are defined in entities AND referenced to' .
30			' either a publisher or a consumer';
31
32			/**
33			* @var Container
34			*/
35			private $container;
36
37			/**
38			* CreateEntitiesCommand constructor.
39			*
40			* @param Container $container
41			*/
42			public function __construct(Container $container)
43			{
44			$this->container = $container;
45			parent::__construct();
46			}
47
48			/**
49			* Execute the console command.
50			*/
51			public function handle()
52			{
53			$hasErrors = false;
54			/** @var PublisherInterface $entity */
55			foreach ($this->container->getPublishers() as $publisherName => $entity) {
56			try {
57			$entity->delete();
58			$this->output->writeln(
59			sprintf(
60			"Deleted entity <info>%s</info> for publisher [<fg=yellow>%s</>]",
61			(string)$entity->getAliasName(),
62			(string)$publisherName
63			)
64			);
65			} catch (\Exception $e) {
66			$hasErrors = true;
67			$this->output->error(
68			sprintf(
69			"Could not delete entity %s for publisher [%s], got:\n%s",
70			(string)$entity->getAliasName(),
71			(string)$publisherName,
72			(string)$e->getMessage()
73			)
74			);
75			}
76			}
77
78			foreach ($this->container->getConsumers() as $consumerAliasName => $entity) {
79			try {
80			/** @var QueueEntity $entity */
81			$entity->delete();
82			$this->output->writeln(
83			sprintf(
84			"Deleted entity <info>%s</info> for consumer [<fg=yellow>%s</>]",
85			(string)$entity->getAliasName(),
86			(string)$consumerAliasName
87			)
88			);
89			} catch (\Exception $e) {
90			$hasErrors = true;
91			$this->output->error(
92			sprintf(
93			"Could not delete entity %s for consumer [%s], got:\n%s",
94			(string)$entity->getAliasName(),
95			(string)$consumerAliasName,
96			(string)$e->getMessage()
97			)
98			);
99			}
100			}
101			return (int)$hasErrors;
102			}
103			}
104

sofwar / laravel-rabbitmq

DeleteAllCommand::handle() A last analyzed 2025-05-22 16:33 UTC

Complexity

Size

Duplication

Importance

How to fix Long Method

Long Method

Duplication Side-by-Side

Filter issues like

DeleteAllCommand::handle() A
last analyzed 2025-05-22 16:33 UTC