BinaryCube\CarrotMQ\Support\Laravel\Console\Commands\SetupCommand

Complexity

Total Complexity

5

Size/Duplication

Total Lines	95
Duplicated Lines	0 %

Importance

Changes	3
Bugs	0	Features	0

1 Method

Rating	Name	Duplication	Size	Complexity
A	handleInternal()	0	73	5

<?php

declare(strict_types=1);

namespace BinaryCube\CarrotMQ\Support\Laravel\Console\Commands;

use Illuminate\Support\Facades\Log;

The type Illuminate\Support\Facades\Log was not found. Maybe you did not declare it correctly or list all dependencies?

use function vsprintf;

/**
 * Class SetupCommand
 */
class SetupCommand extends BaseCommand
{

    /**
     * The name and signature of the console command.
     *
     * @var string
     */
    protected $signature = 'carrot-mq:setup {--force}';

    /**
     * The console command description.
     *
     * @var string
     */
    protected $description = 'Create all queues and topics';

    /**
     * @return int
     *
     * @throws \Exception
     */
    protected function handleInternal()
    {
        $force = $this->input->getOption('force');

        /*
        |--------------------------------------------------------------------------
        | Topics
        |--------------------------------------------------------------------------
        |
        */
        foreach ($this->carrot->container()->topics()->all() as $entity) {
            if ($force) {
                $entity->delete();

                $this->output->writeln(
                    vsprintf(
                        'Deleted TOPIC <info>%s</info> - <fg=yellow>%s</>',
                        [
                            $entity->id(),
                            $entity->name(),
                        ]
                    )
                );
            }

            $entity->install();

            $this->output->writeln(
                vsprintf(
                    'Created <info>TOPIC</info> <fg=yellow>%s</> - <fg=yellow>%s</>',
                    [
                        $entity->name(),
                        $entity->id(),
                    ]
                )
            );
        }//end foreach

        /*
        |--------------------------------------------------------------------------
        | Queues
        |--------------------------------------------------------------------------
        |
        */
        foreach ($this->carrot->container()->queues()->all() as $entity) {
            if ($force) {
                $entity->delete();

                $this->output->writeln(
                    vsprintf(
                        'Deleted QUEUE <info>%s</info> - <fg=yellow>%s</>',
                        [
                            $entity->id(),
                            $entity->name(),
                        ]
                    )
                );
            }

            $entity->install();

            $this->output->writeln(
                vsprintf(
                    'Created <info>QUEUE</info> <fg=yellow>%s</> - <fg=yellow>%s</>',
                    [
                        $entity->name(),
                        $entity->id(),
                    ]
                )
            );
        }//end foreach

        return 0;
    }

}