Isolate\UnitOfWork\Object\InMemoryRegistry

Complexity

Total Complexity

15

Size/Duplication

Total Lines	137
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	0

Importance

Changes	1
Bugs	0	Features	0

11 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	8	1
A	isRegistered()	0	4	1
A	register()	0	5	1
A	getSnapshot()	0	4	1
A	makeNewSnapshots()	0	6	2
A	isRemoved()	0	4	1
A	remove()	0	8	2
A	cleanRemoved()	0	9	2
A	all()	0	4	1
A	reset()	0	8	2
A	getId()	0	4	1

<?php

namespace Isolate\UnitOfWork\Object;

class InMemoryRegistry implements Registry
{
    /**
     * @var SnapshotMaker
     */
    private $snapshotMaker;

    /**
     * @var PropertyCloner
     */
    private $recoveryPoint;

    /**
     * @var array
     */
    private $objects;

    /**
     * @var array
     */
    private $snapshots;

    /**
     * @var array
     */
    private $removed;

    /**
     * @param SnapshotMaker $snapshotMaker
     * @param PropertyCloner $recoveryPoint
     */
    public function __construct(SnapshotMaker $snapshotMaker, PropertyCloner $recoveryPoint)
    {
        $this->snapshotMaker = $snapshotMaker;
        $this->recoveryPoint = $recoveryPoint;
        $this->objects = [];
        $this->snapshots = [];
        $this->removed = [];
    }

    /**
     * {@inheritdoc}
     */
    public function isRegistered($object)
    {
        return array_key_exists($this->getId($object), $this->objects);
    }

    /**
     * {@inheritdoc}
     */
    public function register($object)
    {
        $this->objects[$this->getId($object)] = $object;
        $this->snapshots[$this->getId($object)] = $this->snapshotMaker->makeSnapshotOf($object);
    }

    /**
     * {@inheritdoc}
     */
    public function getSnapshot($object)
    {
        return $this->snapshots[$this->getId($object)];
    }

    /**
     * {@inheritdoc}
     */
    public function makeNewSnapshots()
    {
        foreach ($this->objects as $id => $entity) {
            $this->snapshots[$id] = $this->snapshotMaker->makeSnapshotOf($entity);
        }
    }

    /**
     * {@inheritdoc}
     */
    public function isRemoved($object)
    {
        return array_key_exists($this->getId($object), $this->removed);
    }

    /**
     * {@inheritdoc}
     */
    public function remove($object)
    {
        if (!$this->isRegistered($object)) {
            $this->register($object);
        }

        $this->removed[$this->getId($object)] = true;
    }

    /**
     * {@inheritdoc}
     */
    public function cleanRemoved()
    {
        foreach ($this->removed as $id => $object) {
            unset($this->snapshots[$id]);
            unset($this->objects[$id]);
        }

        $this->removed = [];
    }

    /**
     * {@inheritdoc}
     */
    public function all()
    {
        return array_values($this->objects);
    }

    /**
     * {@inheritdoc}
     */
    public function reset()
    {
        $this->removed = [];

        foreach ($this->snapshots as $id => $objectSnapshot) {
            $this->recoveryPoint->cloneProperties($this->objects[$id], $objectSnapshot);
        }
    }

    /**
     * @param $entity
     * @return string
     */
    private function getId($entity)
    {
        return spl_object_hash($entity);
    }
}