Borobudur\EventSourcing\Entity\AbstractEntity

Complexity

Total Complexity

7

Size/Duplication

Total Lines	60
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	8

Importance

Changes	5
Bugs	0	Features	1

4 Methods

Rating	Name	Duplication	Size	Complexity
A	registerAggregateRoot()	0	12	3
A	apply()	0	8	2
A	getAggregateRoot()	0	4	1
A	terminate()	0	4	1

<?php
/*
 * This file is part of the Borobudur-Event-Sourcing package.
 *
 * (c) Hexacodelabs <http://hexacodelabs.com>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Borobudur\EventSourcing\Entity;

use Borobudur\Bus\Message\MessageMapperTrait;
use Borobudur\Cqrs\Message\DomainEventInterface;
use Borobudur\EventSourcing\Exception\InvalidArgumentException;
use Borobudur\EventSourcing\Exception\LogicException;
use Borobudur\Serialization\Serializer\Mixin\DeserializerTrait;
use Borobudur\Serialization\Serializer\Mixin\SerializerTrait;

/**
 * @author      Iqbal Maulana <iq.bluejack@gmail.com>
 * @created     8/20/15
 */
abstract class AbstractEntity implements EntityInterface
{
    use SerializerTrait, DeserializerTrait, DomainEventDispatcherTrait, StateTrait, MessageMapperTrait;

    /**
     * @var AggregateRootInterface
     */
    protected $aggregateRoot;

    /**
     * @var bool
     */
    private $terminated = false;

    /**
     * {@inheritdoc}
     */
    public function registerAggregateRoot(AggregateRootInterface $aggregateRoot)
    {
        if (null !== $this->aggregateRoot && $this->aggregateRoot !== $aggregateRoot) {
            throw new InvalidArgumentException(sprintf(
                'Aggregate root "%s" is already registered in "%s".',
                get_class($aggregateRoot),
                get_class($this)
            ));
        }

        $this->aggregateRoot = $aggregateRoot;
    }

    /**
     * {@inheritdoc}
     */
    public function apply(DomainEventInterface $event)
    {
        if (true === $this->terminated) {
            throw new LogicException(sprintf('"%s" has been deleted.', get_called_class()));
        }

        $this->aggregateRoot->apply($event);
    }

    /**
     * Get aggregate root.
     *
     * @return AggregateRootInterface
     */
    public function getAggregateRoot()
    {
        return $this->aggregateRoot;
    }

    /**
     * {@inheritdoc}
     */
    protected function terminate()
    {
        $this->terminated = true;
    }
}