ReplaySpecificEventsCommand::execute() - Code Metrics - OpenConext/Stepup-Middleware - Measure and Improve Code Quality continuously with Scrutinizer

ReplaySpecificEventsCommand::execute() B
last analyzed 2025-06-25 07:56 UTC

↳ Parent: ReplaySpecificEventsCommand

Complexity

Conditions	7
Paths	5

Size

Total Lines	57
Code Lines	34

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
cc	7
eloc	34
nc	5
nop	2
dl	0
loc	57
rs	8.4426
c	0
b	0
f	0

How to fix Long Method

<?php

/**
 * Copyright 2017 SURFnet B.V.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */


namespace Surfnet\StepupMiddleware\MiddlewareBundle\Console\Command;

use Surfnet\StepupMiddleware\MiddlewareBundle\EventSourcing\EventCollection;
use Surfnet\StepupMiddleware\MiddlewareBundle\EventSourcing\ProjectorCollection;
use Surfnet\StepupMiddleware\MiddlewareBundle\Service\PastEventsService;
filter:
    dependency_paths: ["lib/*"]
use Surfnet\StepupMiddleware\MiddlewareBundle\Service\TransactionAwareEventDispatcher;
filter:
    dependency_paths: ["lib/*"]
use Symfony\Component\Console\Attribute\AsCommand;
use Symfony\Component\Console\Command\Command;
use Symfony\Component\Console\Helper\QuestionHelper;
use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Input\InputOption;
use Symfony\Component\Console\Output\OutputInterface;
use Symfony\Component\Console\Question\ChoiceQuestion;

#[AsCommand(
    name: 'stepup:event:replay',
    description: 'replay specified events for specified projectors'
)]
class ReplaySpecificEventsCommand extends Command

{
    public const OPTION_LIST_EVENTS = 'list-events';
    public const OPTION_LIST_PROJECTORS = 'list-projectors';

    protected function configure(): void
    {
        $this
            ->addOption(
                self::OPTION_LIST_EVENTS,
                null,
                InputOption::VALUE_NONE,
                'List all events available to replay',
            )
            ->addOption(
                self::OPTION_LIST_PROJECTORS,
                null,
                InputOption::VALUE_NONE,
                'List all projectors available for which events can be replayed',
            );
    }

    public function __construct(
        private readonly EventCollection $collection,
        private readonly ProjectorCollection $projectorCollection,
        private readonly PastEventsService $pastEventsService,
        private readonly TransactionAwareEventDispatcher $eventDispatcher,
    ) {
        parent::__construct();
    }

    protected function execute(InputInterface $input, OutputInterface $output): int
    {
        $availableEvents = $this->collection->getEventNames();
        $availableProjectors = $this->projectorCollection->getProjectorNames();

        if ($input->getOption(self::OPTION_LIST_EVENTS)) {
            $output->writeln('<info>The following events can be replayed:</info>');
            $output->writeln($availableEvents === [] ? 'None.' : $availableEvents);

            return 0;
        }

        if ($input->getOption(self::OPTION_LIST_PROJECTORS)) {
            $output->writeln('<info>Events can be replayed for the following projectors:</info>');
            $output->writeln($availableProjectors === [] ? 'None.' : $availableProjectors);

            return 0;
        }

        if ($availableProjectors === []) {
            $output->writeln('<error>There are no projectors configured to replay events for</error>');

            return 1;
        }

        /** @var QuestionHelper $questionHelper */

        $questionHelper = $this->getHelper('question');

        $selectEventsQuestion = new ChoiceQuestion(
            'Which events would you like to replay? Please supply a comma-separated list of numbers.',
            $availableEvents,
        );
        $selectEventsQuestion->setMultiselect(true);

        $chosenEvents = $questionHelper->ask($input, $output, $selectEventsQuestion);
        $eventSelection = $this->collection->select($chosenEvents);

        $selectProjectorsQuestion = new ChoiceQuestion(
            'For which projectors would you like to replay the selected events? '
            . 'Please supply a comma-separated list of numbers.',
            $availableProjectors,
        );
        $selectProjectorsQuestion->setMultiselect(true);

        $chosenProjectors = $questionHelper->ask($input, $output, $selectProjectorsQuestion);
        $projectorSelection = $this->projectorCollection->selectByNames($chosenProjectors);

        $events = $this->pastEventsService->findEventsBy($eventSelection);

        $output->writeln('<info>Registering projectors</info>');
        foreach ($projectorSelection as $projector) {
            $this->eventDispatcher->registerProjector($projector);
        }

        $output->writeln('<info>Dispatching events</info>');
        $this->eventDispatcher->dispatch($events);
        return 0;
    }
}


1			<?php
2
3			/**
4			* Copyright 2017 SURFnet B.V.
5			*
6			* Licensed under the Apache License, Version 2.0 (the "License");
7			* you may not use this file except in compliance with the License.
8			* You may obtain a copy of the License at
9			*
10			* http://www.apache.org/licenses/LICENSE-2.0
11			*
12			* Unless required by applicable law or agreed to in writing, software
13			* distributed under the License is distributed on an "AS IS" BASIS,
14			* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
15			* See the License for the specific language governing permissions and
16			* limitations under the License.
17			*/
			0 ignored issues – show Coding Style introduced 2023-09-07 09:35 UTC by Report Bug Copy Issue Report Missing @link tag in file comment Loading history...
18
19			namespace Surfnet\StepupMiddleware\MiddlewareBundle\Console\Command;
20
21			use Surfnet\StepupMiddleware\MiddlewareBundle\EventSourcing\EventCollection;
22			use Surfnet\StepupMiddleware\MiddlewareBundle\EventSourcing\ProjectorCollection;
23			use Surfnet\StepupMiddleware\MiddlewareBundle\Service\PastEventsService;
			0 ignored issues – show Bug introduced 2025-01-06 14:59 UTC by Report Bug Copy Issue Report The type `Surfnet\StepupMiddleware...rvice\PastEventsService` was not found. Maybe you did not declare it correctly or list all dependencies? The issue could also be caused by a filter entry in the build configuration. If the path has been excluded in your configuration, e.g. `excluded_paths: ["lib/"]`, you can move it to the dependency path list as follows: filter: dependency_paths: ["lib/"] For further information see https://scrutinizer-ci.com/docs/tools/php/php-scrutinizer/#list-dependency-paths Loading history...
24			use Surfnet\StepupMiddleware\MiddlewareBundle\Service\TransactionAwareEventDispatcher;
			0 ignored issues – show Bug introduced 2025-01-06 14:59 UTC by Report Bug Copy Issue Report The type `Surfnet\StepupMiddleware...ionAwareEventDispatcher` was not found. Maybe you did not declare it correctly or list all dependencies? The issue could also be caused by a filter entry in the build configuration. If the path has been excluded in your configuration, e.g. `excluded_paths: ["lib/"]`, you can move it to the dependency path list as follows: filter: dependency_paths: ["lib/"] For further information see https://scrutinizer-ci.com/docs/tools/php/php-scrutinizer/#list-dependency-paths Loading history...
25			use Symfony\Component\Console\Attribute\AsCommand;
26			use Symfony\Component\Console\Command\Command;
27			use Symfony\Component\Console\Helper\QuestionHelper;
28			use Symfony\Component\Console\Input\InputInterface;
29			use Symfony\Component\Console\Input\InputOption;
30			use Symfony\Component\Console\Output\OutputInterface;
31			use Symfony\Component\Console\Question\ChoiceQuestion;
32
33			#[AsCommand(
34			name: 'stepup:event:replay',
35			description: 'replay specified events for specified projectors'
36			)]
37			class ReplaySpecificEventsCommand extends Command
			0 ignored issues – show Coding Style introduced 2023-09-07 09:35 UTC by Report Bug Copy Issue Report Missing doc comment for class ReplaySpecificEventsCommand Loading history...
38			{
39			public const OPTION_LIST_EVENTS = 'list-events';
40			public const OPTION_LIST_PROJECTORS = 'list-projectors';
41
42			protected function configure(): void
43			{
44			$this
45			->addOption(
46			self::OPTION_LIST_EVENTS,
47			null,
48			InputOption::VALUE_NONE,
49			'List all events available to replay',
50			)
51			->addOption(
52			self::OPTION_LIST_PROJECTORS,
53			null,
54			InputOption::VALUE_NONE,
55			'List all projectors available for which events can be replayed',
56			);
57			}
58
59			public function __construct(
60			private readonly EventCollection $collection,
61			private readonly ProjectorCollection $projectorCollection,
62			private readonly PastEventsService $pastEventsService,
63			private readonly TransactionAwareEventDispatcher $eventDispatcher,
64			) {
65			parent::__construct();
66			}
67
68			protected function execute(InputInterface $input, OutputInterface $output): int
69			{
70			$availableEvents = $this->collection->getEventNames();
71			$availableProjectors = $this->projectorCollection->getProjectorNames();
72
73			if ($input->getOption(self::OPTION_LIST_EVENTS)) {
74			$output->writeln('<info>The following events can be replayed:</info>');
75			$output->writeln($availableEvents === [] ? 'None.' : $availableEvents);
76
77			return 0;
78			}
79
80			if ($input->getOption(self::OPTION_LIST_PROJECTORS)) {
81			$output->writeln('<info>Events can be replayed for the following projectors:</info>');
82			$output->writeln($availableProjectors === [] ? 'None.' : $availableProjectors);
83
84			return 0;
85			}
86
87			if ($availableProjectors === []) {
88			$output->writeln('<error>There are no projectors configured to replay events for</error>');
89
90			return 1;
91			}
92
93			/** @var QuestionHelper $questionHelper */
			0 ignored issues – show Coding Style introduced 2023-09-07 09:35 UTC by Report Bug Copy Issue Report The open comment tag must be the only content on the line Loading history... Coding Style introduced 2023-09-07 09:35 UTC by Report Bug Copy Issue Report The close comment tag must be the only content on the line Loading history...
94			$questionHelper = $this->getHelper('question');
95
96			$selectEventsQuestion = new ChoiceQuestion(
97			'Which events would you like to replay? Please supply a comma-separated list of numbers.',
98			$availableEvents,
99			);
100			$selectEventsQuestion->setMultiselect(true);
101
102			$chosenEvents = $questionHelper->ask($input, $output, $selectEventsQuestion);
103			$eventSelection = $this->collection->select($chosenEvents);
104
105			$selectProjectorsQuestion = new ChoiceQuestion(
106			'For which projectors would you like to replay the selected events? '
107			. 'Please supply a comma-separated list of numbers.',
108			$availableProjectors,
109			);
110			$selectProjectorsQuestion->setMultiselect(true);
111
112			$chosenProjectors = $questionHelper->ask($input, $output, $selectProjectorsQuestion);
113			$projectorSelection = $this->projectorCollection->selectByNames($chosenProjectors);
114
115			$events = $this->pastEventsService->findEventsBy($eventSelection);
116
117			$output->writeln('<info>Registering projectors</info>');
118			foreach ($projectorSelection as $projector) {
119			$this->eventDispatcher->registerProjector($projector);
120			}
121
122			$output->writeln('<info>Dispatching events</info>');
123			$this->eventDispatcher->dispatch($events);
124			return 0;
125			}
126			}
127

OpenConext / Stepup-Middleware

ReplaySpecificEventsCommand::execute() B last analyzed 2025-06-25 07:56 UTC

Complexity

Size

Duplication

Importance

How to fix Long Method

Long Method

Duplication Side-by-Side

Filter issues like

ReplaySpecificEventsCommand::execute() B
last analyzed 2025-06-25 07:56 UTC