Spatie\EventProjector\Snapshots\Snapshot

Complexity

Total Complexity

11

Size/Duplication

Total Lines	89
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes

0

11 Methods

Rating	Name	Duplication	Size	Complexity
A	createForProjector()	0	8	1
A	createForFile()	0	4	1
A	__construct()	0	8	1
A	getLastProcessedEventId()	0	4	1
A	getProjectorName()	0	4	1
A	getProjector()	0	6	1
A	getName()	0	4	1
A	write()	0	4	1
A	read()	0	4	1
A	readStream()	0	4	1
A	getNameParts()	0	14	1

<?php

namespace Spatie\EventProjector\Snapshots;

use Illuminate\Contracts\Filesystem\Filesystem;
use Spatie\EventProjector\EventProjectionist;
use Spatie\EventProjector\Projectors\Projector;

class Snapshot
{
    /** @var \Spatie\EventProjector\EventProjectionist */
    protected $eventProjectionist;

    /** @var \Illuminate\Contracts\Filesystem\Filesystem */
    protected $disk;

    /** @var string */
    protected $fileName;

    public static function createForProjector(Projector $projector, string $name = ''): self
    {
        $lastEventId = $projector->getLastProcessedEventId();

        $name = "{$projector->getName()}---{$lastEventId}---{$name}.txt";

        return app(static::class)->setFileName($name);
    }

    public static function createForFile(Filesystem $disk, string $fileName): Snapshot
    {
        return (new static($disk,$fileName));

The call to Snapshot::__construct() misses a required argument $fileName.

$disk is of type object<Illuminate\Contracts\Filesystem\Filesystem>, but the function expects a object<Spatie\EventProjector\EventProjectionist>.

$fileName is of type string, but the function expects a object<Illuminate\Contracts\Filesystem\Filesystem>.

    }

    public function __construct(EventProjectionist $eventProjectionist, Filesystem $disk, string $fileName)
    {
        $this->eventProjectionist = $eventProjectionist;

        $this->disk = $disk;

        $this->fileName = $fileName;
    }

    public function getLastProcessedEventId(): int
    {
        return $this->getNameParts()['lastProcessedEventId'];
    }

    public function getProjectorName(): string
    {
        return $this->getNameParts()['projectorName'];
    }

    public function getProjector(): Projector
    {
        $projectorName = $this->getProjectorName();

        return $this->eventProjectionist->getProjector($projectorName);
    }

    public function getName(): string
    {
        return $this->getNameParts()['name'];
    }

    /**
     * @param string|resource $contents
     */
    public function write($contents)
    {
        $this->disk->put($this->fileName, $contents);
    }

    public function read(): ?string
    {
        return $this->disk->get($this->fileName);
    }

    public function readStream()
    {
        return $this->disk->readStream($this->fileName);

The method readStream() does not seem to exist on object<Illuminate\Contracts\Filesystem\Filesystem>.

    }

    protected function getNameParts(): array
    {
        $baseName = pathinfo($this->fileName, PATHINFO_FILENAME);

        $nameParts = explode('---', $baseName);

        $projectorName =  $nameParts[0];

        $lastProcessedEventId = (int) $nameParts[1];

        $name =  $nameParts[2] ?? '';

        return compact('projectorName', 'lastProcessedEventId', 'name');
    }
}