FileSnapshotStore::get() - Code Metrics - bashilbers/domain - Measure and Improve Code Quality continuously with Scrutinizer

FileSnapshotStore::get() B
last analyzed 2015-11-26 21:16 UTC

↳ Parent: FileSnapshotStore

Complexity

Conditions	2
Paths	2

Size

Total Lines	29
Code Lines	18

Duplication

Lines	0
Ratio	0 %

Importance

Changes	2
Bugs	0	Features	1

Metric	Value
c	2
b	0
f	1
dl	0
loc	29
rs	8.8571
cc	2
eloc	18
nc	2
nop	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 <[email protected]>
 */
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);
    }
}


1			<?php
2
3			namespace Domain\Snapshotting;
4
5			use Symfony\Component\Finder\Finder;
6			use Domain\Identity\Identity;
7			use Domain\Aggregates\AggregateRoot;
8			use Domain\Snapshotting\Exception\IdenticalSnapshot;
9
10			/**
11			* @author Sebastiaan Hilbers <[email protected]>
12			*/
13			class FileSnapshotStore implements SnapshotStore
14			{
15			private $dataPath;
16
17			public function __construct($dataPath)
18			{
19			$this->dataPath = $dataPath;
20			}
21
22			public function get(Identity $id, $criteria = null)
23			{
24			$it = Finder::create()
25			->files()
26			->name((string) $id . '-*')
27			->in($this->dataPath);
28
29			$files = iterator_to_array($it);
30
31			if (empty($files)) {
32			throw new \Exception;
33			}
34
35			$match = end($files);
36
37			$time = $match->getMTime();
38			$creation = new \DateTime;
39			$creation->setTimestamp($time);
40
41			$aggregate = unserialize(file_get_contents($match));
42
43			$snapshot = new Snapshot(
44			$aggregate,
45			$aggregate->getVersion(),
46			$creation
47			);
48
49			return $snapshot;
50			}
51
52			public function save(AggregateRoot $root)
53			{
54			$aggregateId = (string) $root->getIdentity();
55			$versionFile = $aggregateId . '-' . $root->getVersion();
56
57			if (file_exists($this->dataPath . '/' . $versionFile)) {
58			throw new IdenticalSnapshot;
59			}
60
61			$stream = fopen($this->dataPath . '/' . $versionFile, 'w');
62
63			fwrite($stream, serialize($root));
64			fclose($stream);
65			}
66			}
67

bashilbers / domain

FileSnapshotStore::get() B last analyzed 2015-11-26 21:16 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

FileSnapshotStore::get() B
last analyzed 2015-11-26 21:16 UTC