Spatie\EventProjector\Models\StoredEvent

Complexity

Total Complexity

8

Size/Duplication

Total Lines	70
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes	1
Bugs	0	Features	0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	createForEvent()	0	12	1
A	getMaxId()	0	4	1
A	last()	0	4	1
A	getEventAttribute()	0	7	1
A	scopeAfter()	0	4	1
A	scopePrevious()	0	7	1
A	previousInStream()	0	9	1
A	groupProjectorStatusBy()	0	4	1

<?php

namespace Spatie\EventProjector\Models;

use Illuminate\Support\Facades\DB;
use Illuminate\Database\Eloquent\Model;
use Illuminate\Database\Eloquent\Builder;
use Spatie\EventProjector\ShouldBeStored;
use Spatie\SchemalessAttributes\SchemalessAttributes;
use Spatie\EventProjector\EventSerializers\EventSerializer;

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

    public $timestamps = false;

    public $casts = [
        'event_properties' => 'array',
        'meta_data' => 'array',
    ];

    public static function createForEvent(ShouldBeStored $event): self
    {
        $storedEvent = new static();
        $storedEvent->event_class = get_class($event);
        $storedEvent->attributes['event_properties'] = app(EventSerializer::class)->serialize(clone $event);
        $storedEvent->meta_data = [];
        $storedEvent->created_at = now();

        $storedEvent->save();

        return $storedEvent;
    }

    public static function getMaxId(): int
    {
        return DB::table((new static())->getTable())->max('id') ?? 0;
    }

    public static function last(): ?self
    {
        return static::find(self::getMaxId());
    }

    public function getEventAttribute(): ShouldBeStored
    {
        return app(EventSerializer::class)->deserialize(
           $this->event_class,
           $this->getOriginal('event_properties')
       );
    }

    public function scopeAfter(Builder $query, int $storedEventId)
    {
        $query->where('id', '>', $storedEventId);
    }

    public function scopePrevious(Builder $query, self $storedEvent): ?self
    {
        static::query()
            ->where('event_class', $storedEvent->event_class)
            ->latest()
            ->first();
    }

    public function previousInStream(): ?self
    {
        return static::query()

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

            ->where('stream_name', $this->stream_name)
            ->where('stream_id', $this->stream_id)
            ->where('id', '<', $this->id)
            ->orderBy('id', 'desc')
            ->first();
    }

    public function groupProjectorStatusBy(): array
    {
        return [];
    }
}