Domain\Snapshotting\FileSnapshotStore

Complexity

Total Complexity

5

Size/Duplication

Total Lines	54
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes	3
Bugs	1	Features	1

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
B	get()	0	29	2
A	save()	0	14	2

<?php

namespace Domain\Snapshotting;

use Symfony\Component\Finder\Finder;
use Domain\Identity\Identity;
use Domain\Aggregates\AggregateRoot;
use Domain\Snapshotting\Exception\IdenticalSnapshot;

/**
 * @author Sebastiaan Hilbers <bashilbers@gmail.com>
 */
class FileSnapshotStore implements SnapshotStore
{
    private $dataPath;

    public function __construct($dataPath)
    {
        $this->dataPath = $dataPath;
    }

    public function get(Identity $id, $criteria = null)
    {
        $it = Finder::create()
            ->files()
            ->name((string) $id . '-*')
            ->in($this->dataPath);

        $files = iterator_to_array($it);

        if (empty($files)) {
            throw new \Exception;
        }

        $match = end($files);

        $time = $match->getMTime();
        $creation = new \DateTime;
        $creation->setTimestamp($time);

        $aggregate = unserialize(file_get_contents($match));

        $snapshot = new Snapshot(
            $aggregate,
            $aggregate->getVersion(),
            $creation
        );

        return $snapshot;
    }

    public function save(AggregateRoot $root)
    {
        $aggregateId = (string) $root->getIdentity();
        $versionFile = $aggregateId . '-' . $root->getVersion();

        if (file_exists($this->dataPath . '/' . $versionFile)) {
            throw new IdenticalSnapshot;
        }

        $stream = fopen($this->dataPath . '/' . $versionFile, 'w');

        fwrite($stream, serialize($root));
        fclose($stream);
    }
}