Spatie\EventProjector\Projectors\ProjectsEvents

Complexity

Total Complexity

10

Size/Duplication

Total Lines	54
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	4

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	getName()	0	8	2
A	rememberReceivedEvent()	0	4	1
A	hasReceivedAllPriorEvents()	0	4	1
A	hasReceivedAllEvents()	0	4	1
A	getLastProcessedEventId()	0	4	1
A	lastEventProcessedAt()	0	4	1
A	reset()	0	10	2
A	getStatus()	0	4	1

<?php

namespace Spatie\EventProjector\Projectors;

use Carbon\Carbon;
use Illuminate\Database\Eloquent\Concerns\HasEvents;
use Spatie\EventProjector\EventHandlers\HandlesEvents;
use Spatie\EventProjector\Exceptions\CouldNotResetProjector;
use Spatie\EventProjector\Models\StoredEvent;
use Spatie\EventProjector\Models\ProjectorStatus;

trait ProjectsEvents
{
    use HandlesEvents;

    public function getName(): string
    {
        if (isset($this->name)) {
            return $this->name;

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

        }

        return get_class($this);
    }

    public function rememberReceivedEvent(StoredEvent $storedEvent)
    {
        $this->getStatus()->rememberLastProcessedEvent($storedEvent);
    }

    public function hasReceivedAllPriorEvents(StoredEvent $storedEvent): bool
    {
        return $storedEvent->id === $this->getStatus()->last_processed_event_id + 1;
    }

    public function hasReceivedAllEvents(): bool
    {
        return (int) $this->getStatus()->last_processed_event_id === StoredEvent::getMaxId();
    }

    public function getLastProcessedEventId(): int
    {
        return $this->getStatus()->last_processed_event_id ?? 0;
    }

    public function lastEventProcessedAt(): Carbon
    {
        return $this->getStatus()->updated_at;
    }

    public function reset()
    {
        if (! method_exists($this, 'resetState')) {
            throw CouldNotResetProjector::doesNotHaveResetStateMethod($this);
        }

        $this->resetState();

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

        $this->getStatus()->delete();
    }

    protected function getStatus(): ProjectorStatus
    {
        return ProjectorStatus::getForProjector($this);
    }
}