Spatie\EventProjector\EloquentStoredEventRepository

Complexity

Total Complexity

11

Size/Duplication

Total Lines	73
Duplicated Lines	13.7 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	retrieveAll()	0	16	3
A	update()	0	8	1
A	getEventClass()	10	10	3
A	persist()	0	17	1
A	persistMany()	0	10	2
A	getStoredEventModel()	0	4	1

<?php

namespace Spatie\EventProjector;

use Carbon\Carbon;
use Illuminate\Support\Collection;
use Spatie\EventProjector\Models\EloquentStoredEvent;
use Spatie\EventProjector\Models\StoredEvent;
use Spatie\EventProjector\EventSerializers\EventSerializer;

class EloquentStoredEventRepository implements StoredEventRepository
{
    public static function retrieveAll(string $uuid = null, int $startingFrom = null): Collection
    {
        $query = self::getStoredEventModel()::query();

The method query cannot be called on self::getStoredEventModel() (of type string).

        if ($uuid) {

The expression $uuid of type null|string is loosely compared to true; this is ambiguous if the string can be empty. You might want to explicitly use !== null instead.

            $query->uuid($uuid);
        }

        if ($startingFrom) {

The expression $startingFrom of type null|integer is loosely compared to true; this is ambiguous if the integer can be zero. You might want to explicitly use !== null instead.

            $query->startingFrom($startingFrom);
        }

        return $query->get()->map(function (EloquentStoredEvent $storedEvent) {
            return $storedEvent->toStoredEventData();
        });
    }

    public static function persist(ShouldBeStored $event, string $uuid = null, string $model = null): StoredEvent
    {
        /** @var EloquentStoredEvent $storedEvent */
        $storedEvent = self::getStoredEventModel($model)::make();

The method make cannot be called on self::getStoredEventModel($model) (of type string).

        $storedEvent->setRawAttributes([
            'event_properties' => app(EventSerializer::class)->serialize(clone $event),
            'aggregate_uuid' => $uuid,
            'event_class' => self::getEventClass(get_class($event)),
            'meta_data' => json_encode([]),
            'created_at' => Carbon::now(),
        ]);

        $storedEvent->save();

        return $storedEvent->toStoredEventData();
    }

    public static function persistMany(array $events, string $uuid = null, string $model = null): Collection
    {
        $storedEvents = [];

        foreach ($events as $event) {
            $storedEvents[] = self::persist($event, $uuid, $model);
        }

        return collect($storedEvents);
    }

    public static function update(StoredEvent $storedEventData): StoredEvent
    {
        $storedEvent = self::getStoredEventModel()::find($storedEventData->id);

The method find cannot be called on self::getStoredEventModel() (of type string).

        $storedEvent->update($storedEventData->toArray());

        return $storedEvent->toStoredEventData();
    }

    private static function getEventClass(string $class): string

This method seems to be duplicated in your project.

    {
        $map = config('event-projector.event_class_map', []);

        if (! empty($map) && in_array($class, $map)) {
            return array_search($class, $map, true);
        }

        return $class;
    }

    private static function getStoredEventModel(string $model = null): string
    {
        return $model ?? config('event-projector.stored_event_model');
    }
}