DeleteAllCommand::handle() - Code Metrics - yuanxing008/laravel-aliyun-amqp - Measure and Improve Code Quality continuously with Scrutinizer

DeleteAllCommand::handle() A
last analyzed 2020-06-23 09:23 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
/**
 * Author: Joker
 * Date: 2020-05-08 13:57
 */

namespace JokerProject\LaravelAliyunAmqp\Command;

use Illuminate\Console\Command;
use JokerProject\LaravelAliyunAmqp\Container;
use JokerProject\LaravelAliyunAmqp\Entity\QueueEntity;
use JokerProject\LaravelAliyunAmqp\PublisherInterface;

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

yuanxing008 / laravel-aliyun-amqp

DeleteAllCommand::handle() A last analyzed 2020-06-23 09:23 UTC

Complexity

Size

Duplication

Importance

How to fix Long Method

Long Method

Duplication Side-by-Side

Filter issues like

DeleteAllCommand::handle() A
last analyzed 2020-06-23 09:23 UTC