Spatie\EventProjector\Models\ProjectorStatus

Complexity

Total Complexity

7

Size/Duplication

Total Lines	61
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	getForProjector()	0	7	1
A	getAllForProjector()	0	4	1
A	rememberLastProcessedEvent()	0	7	1
A	hasReceivedAllEvents()	0	8	1
A	getProjector()	0	4	1
A	markAsReceivedAllEvents()	0	8	1
A	markasAsNotReceivedAllEvents()	0	8	1

<?php

namespace Spatie\EventProjector\Models;

use Illuminate\Support\Collection;
use Illuminate\Database\Eloquent\Model;
use Spatie\EventProjector\Projectors\Projector;
use Spatie\EventProjector\Facades\EventProjectionist;

class ProjectorStatus extends Model
{
    public $guarded = [];

    public $casts = [
        'has_received_all_events' => 'boolean',
    ];

    public static function getForProjector(Projector $projector, string $stream = 'main'): ProjectorStatus
    {
        return self::firstOrCreate([
            'projector_name' => $projector->getName(),
            'stream' => $stream,
        ]);
    }

    public static function getAllForProjector(Projector $projector): Collection
    {
        return static::where('projector_name', $projector->getName())->get();
    }

    public function rememberLastProcessedEvent(StoredEvent $storedEvent): ProjectorStatus
    {
        $this->last_processed_event_id = $storedEvent->id;
        $this->save();

        return $this;
    }

    public static function hasReceivedAllEvents(Projector $projector): bool
    {
        $highestEventId = (int) self::query()
            ->where('projector_name', $projector->getName())
            ->max('last_processed_event_id') ?? 0;

        return $highestEventId === StoredEvent::getMaxId();
    }

    public function getProjector(): Projector
    {
        return EventProjectionist::getProjector($this->projector_name);
    }

    public function markAsReceivedAllEvents(): self
    {
        $this->has_received_all_events = true;

        $this->save();

        return $this;
    }

    public function markasAsNotReceivedAllEvents(): self
    {
        $this->has_received_all_events = false;

        $this->save();

        return $this;
    }
}