DDDominio\EventSourcing\Versioning\EventUpgrader

Complexity

Total Complexity

17

Size/Duplication

Total Lines	86
Duplicated Lines	33.72 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

100%

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	registerUpgrade()	0	4	1
A	migrate()	0	12	3
A	upgrade()	14	15	6
A	downgrade()	15	16	6

<?php

namespace DDDominio\EventSourcing\Versioning;

use DDDominio\EventSourcing\EventStore\StoredEvent;

class EventUpgrader implements EventUpgraderInterface
{
    /**
     * @var array
     */
    private $upgrades;

    /**
     * @var EventAdapter
     */
    private $eventAdapter;

    /**
     * @param EventAdapter $eventAdapter
     */
    public function __construct(EventAdapter $eventAdapter)
    {
        $this->eventAdapter = $eventAdapter;
    }

    /**
     * @param UpgradeInterface $upgrade
     */
    public function registerUpgrade(UpgradeInterface $upgrade)
    {
        $this->upgrades[$upgrade->eventClass()][] = $upgrade;
    }

    /**
     * @param StoredEvent $storedEvent
     * @param Version $version
     */
    public function migrate(StoredEvent $storedEvent, $version = null)
    {
        if (is_null($version)) {
            $this->upgrade($storedEvent);
        } else {
            if ($storedEvent->version()->greaterThan($version)) {
                $this->downgrade($storedEvent, $version);
            } else {
                $this->upgrade($storedEvent, $version);
            }
        }
    }

    /**
     * @param StoredEvent $storedEvent
     * @param Version $version
     */
    public function upgrade(StoredEvent $storedEvent, $version = null)

This method seems to be duplicated in your project.

    {
        if (isset($this->upgrades[$storedEvent->type()])) {
            /** @var UpgradeInterface $upgrade */
            foreach ($this->upgrades[$storedEvent->type()] as $upgrade) {
                if ($storedEvent->version()->equalTo($upgrade->from())) {
                    $upgrade->upgrade($storedEvent);
                    $storedEvent->setVersion($upgrade->to());
                    if (!is_null($version) && $upgrade->to()->equalTo($version)) {
                        return;
                    }
                }
            }
        }
    }

    /**
     * @param StoredEvent $storedEvent
     * @param Version $version
     */
    public function downgrade(StoredEvent $storedEvent, $version = null)

This method seems to be duplicated in your project.

    {
        if (isset($this->upgrades[$storedEvent->type()])) {
            $upgrades = array_reverse($this->upgrades[$storedEvent->type()]);
            /** @var UpgradeInterface $upgrade */
            foreach ($upgrades as $upgrade) {
                if ($storedEvent->version()->equalTo($upgrade->to())) {
                    $upgrade->downgrade($storedEvent);
                    $storedEvent->setVersion($upgrade->from());
                    if (!is_null($version) && $upgrade->to()->equalTo($version)) {
                        return;
                    }
                }
            }
        }
    }
}