Spatie\EventProjector\Console\ReplayEventsCommand

Complexity

Total Complexity

8

Size/Duplication

Total Lines	67
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	6

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	6	1
B	handle()	0	24	2
A	getProjectors()	0	15	2
A	guardAgainstNonExistingProjectors()	0	8	3

<?php

namespace Spatie\EventProjector\Console;

use Illuminate\Console\Command;
use Illuminate\Support\Collection;
use Spatie\EventProjector\StoredEvent;
use Spatie\EventProjector\EventProjectionist;
use Spatie\EventProjector\Exceptions\InvalidEventHandler;

class ReplayEventsCommand extends Command
{
    protected $signature = 'event-projector:replay-events 
                            {--projector=*} : The projector that should receive the event';

    protected $description = 'Replay stored events';

    /** @var \Spatie\EventProjector\EventProjectionist */
    protected $eventSorcerer;

    public function __construct(EventProjectionist $eventSorcerer)
    {
        parent::__construct();

        $this->eventSorcerer = $eventSorcerer;
    }

    public function handle()
    {
        $projectors = $this->getProjectors();

        if ($projectors->isEmpty()) {
            $this->warn('No projectors found to replay events to...');

            return;
        }

        $this->comment('Replaying events...');

        $bar = $this->output->createProgressBar(StoredEvent::count());

        StoredEvent::chunk(1000, function (StoredEvent $storedEvent) use ($projectors, $bar) {
            $this->eventSorcerer->callEventHandlers($projectors, $storedEvent);

            $bar->advance();
        });

        $bar->finish();

        $this->comment('All done!');
    }

    protected function getProjectors(): Collection
    {
        $onlyCallProjectors = $this->option('projector');

        $this->guardAgainstNonExistingProjectors($onlyCallProjectors);

It seems like $onlyCallProjectors defined by $this->option('projector') on line 55 can also be of type string; however, Spatie\EventProjector\Console\ReplayEventsCommand::guardAgainstNonExistingProjectors() does only seem to accept array, maybe add an additional type check?

        return $this->eventSorcerer->projectors
            ->filter(function (string $projector) use ($onlyCallProjectors) {
                if (! count($onlyCallProjectors)) {
                    return true;
                }

                return in_array($projector, $onlyCallProjectors);
            });
    }

    protected function guardAgainstNonExistingProjectors(array $onlyCallProjectors)
    {
        foreach ($onlyCallProjectors as $projector) {
            if (! class_exists($projector)) {
                throw InvalidEventHandler::doesNotExist($projector);
            }
        }
    }
}