Spatie\EventProjector\Snapshots\Snapshot

Complexity

Total Complexity

11

Size/Duplication

Total Lines	87
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes

0

11 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	8	1
A	lastProcessedEventId()	0	4	1
A	projectorName()	0	4	1
A	getProjector()	0	6	1
A	name()	0	4	1
A	write()	0	4	1
A	read()	0	4	1
A	readStream()	0	4	1
A	delete()	0	4	1
A	createdAt()	0	6	1
A	getNameParts()	0	14	1

<?php

namespace Spatie\EventProjector\Snapshots;

use Carbon\Carbon;
use Spatie\EventProjector\EventProjectionist;
use Illuminate\Contracts\Filesystem\Filesystem;
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 function __construct(EventProjectionist $eventProjectionist, Filesystem $disk, string $fileName)
    {
        $this->eventProjectionist = $eventProjectionist;

        $this->disk = $disk;

        $this->fileName = $fileName;
    }

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

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

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

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

    public function name(): 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>.

    }

    public function delete()
    {
        $this->disk->delete($this->fileName);
    }

    public function createdAt(): Carbon
    {
        $timestamp = $this->disk->lastModified($this->fileName);

        return Carbon::createFromTimestamp($timestamp);
    }

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

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

        $projectorName =  str_replace('+', '\\', $nameParts[1]);

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

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

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