Surfnet\StepupMiddleware\MiddlewareBundle\Console\Command\ReplaySpecificEventsCommand::__invoke()

Complexity

Conditions	7
Paths	5

Size

Total Lines	62
Code Lines	34

Duplication

Lines	0
Ratio	0 %

Importance

Changes

0

<?php
    public function __invoke(
        InputInterface $input,
        OutputInterface $output,
        #[Option(description: 'List all events available to replay', name: self::OPTION_LIST_EVENTS)]
        bool $listEvents = false,
        #[Option(description: 'List all projectors available for which events can be replayed', name: self::OPTION_LIST_PROJECTORS)]
        bool $listProjectors = false,
    ): int {
        $availableEvents = $this->collection->getEventNames();
        $availableProjectors = $this->projectorCollection->getProjectorNames();

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

            return 0;
        }

        if ($listProjectors) {
            $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;
        }

        $questionHelper = new QuestionHelper();

        $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;
    }