Spatie\EventProjector\Console\Concerns\ReplaysEvents

Complexity

Total Complexity

9

Size/Duplication

Total Lines	75
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	7

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	determineAfterEventId()	0	31	3
A	emptyLine()	0	6	2
A	replay()	0	33	4

<?php

namespace Spatie\EventProjector\Console\Concerns;

use Illuminate\Support\Collection;
use Illuminate\Support\Facades\DB;
use Spatie\EventProjector\Models\StoredEvent;
use Spatie\EventProjector\Projectors\Projector;
use Spatie\EventProjector\Models\ProjectorStatus;

trait ReplaysEvents
{
    public function replay(Collection $projectors)
    {
        $afterEventId = $this->determineAfterEventId($projectors);

        if ($afterEventId === StoredEvent::getMaxId()) {
            $this->warn('There are no events to replay.');

It seems like warn() must be provided by classes using this trait. How about adding it as abstract method to this trait?

        }

        $replayCount = StoredEvent::after($afterEventId)->count();

        if ($replayCount === 0) {
            $this->warn('There are no events to replay');

It seems like warn() must be provided by classes using this trait. How about adding it as abstract method to this trait?

            return;
        }

        $afterEventId === 0
            ? $this->comment('Replaying all events...')

It seems like comment() must be provided by classes using this trait. How about adding it as abstract method to this trait?

            : $this->comment("Replaying events after stored event id {$afterEventId}...");

It seems like comment() must be provided by classes using this trait. How about adding it as abstract method to this trait?

        $this->emptyLine();

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

The property output does not exist. Did you maybe forget to declare it?

        $onEventReplayed = function () use ($bar) {
            $bar->advance();
        };

        $this->Projectionist->replay($projectors, $afterEventId, $onEventReplayed);

The property Projectionist does not exist. Did you maybe forget to declare it?

        $bar->finish();

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

It seems like comment() must be provided by classes using this trait. How about adding it as abstract method to this trait?

    }

    protected function determineAfterEventId(Collection $projectors): int
    {
        $projectorsWithoutStatus = collect($projectors)
            ->filter(function (Projector $projector) {
                return ! ProjectorStatus::query()

The method exists() does not exist on Illuminate\Database\Eloquent\Builder. Did you maybe mean canUseExistsForExistenceCheck()?

                        ->where('projector_name', $projector->getName())
                        ->exists();
            });

        if ($projectorsWithoutStatus->isNotEmpty()) {
            return 0;
        }

        $allProjectorStatusesCount = DB::table('projector_statuses')
            ->whereIn('projector_name', $projectors->map->getName()->toArray())
            ->count();

        $allUpToDateProjectorStatusesCount = DB::table('projector_statuses')
            ->whereIn('projector_name', $projectors->map->getName()->toArray())
            ->where('has_received_all_events', true)
            ->count();

        if ($allProjectorStatusesCount === $allUpToDateProjectorStatusesCount) {
            return StoredEvent::getMaxId();
        }

        return DB::table('projector_statuses')
                ->whereIn('projector_name', $projectors->map->getName()->toArray())
                ->where('has_received_all_events', false)
                ->min('last_processed_event_id') ?? 0;
    }

    protected function emptyLine(int $amount = 1)
    {
        foreach (range(1, $amount) as $i) {
            $this->line('');

It seems like line() must be provided by classes using this trait. How about adding it as abstract method to this trait?

        }
    }
}