Aggrego\Domain\ProgressiveBoard\Board

Complexity

Total Complexity

15

Size/Duplication

Total Lines	108
Duplicated Lines	0 %

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	9	1
A	factory()	0	19	2
A	setStep()	0	5	2
A	isStepReadyForNextTransformation()	0	6	2
A	getProfile()	0	3	1
A	updateShard()	0	10	3
A	transformStep()	0	22	4

<?php

declare(strict_types = 1);

namespace Aggrego\Domain\ProgressiveBoard;

use Aggrego\Domain\Api\Application\Event\Aggregate;
use Aggrego\Domain\Profile\BoardConstruction\Builder;
use Aggrego\Domain\Profile\BoardTransformation\Transformation;
use Aggrego\Domain\Profile\Profile;
use Aggrego\Domain\ProgressiveBoard\Events\BoardCreatedEvent;
use Aggrego\Domain\ProgressiveBoard\Events\BoardDeletedEvent;
use Aggrego\Domain\ProgressiveBoard\Events\BoardTransformedEvent;
use Aggrego\Domain\ProgressiveBoard\Events\FinalBoardTransformedEvent;
use Aggrego\Domain\ProgressiveBoard\Events\ShardAddedEvent;
use Aggrego\Domain\ProgressiveBoard\Events\ShardUpdatedEvent;
use Aggrego\Domain\ProgressiveBoard\Events\UpdatedLastStepsShardEvent;
use Aggrego\Domain\ProgressiveBoard\Exception\UnfinishedStepPassedForTransformationException;
use Aggrego\Domain\ProgressiveBoard\Exception\UnprocessableBoardException;
use Aggrego\Domain\ProgressiveBoard\Shard\Collection;
use Aggrego\Domain\ProgressiveBoard\Shard\FinalItem;
use Aggrego\Domain\ProgressiveBoard\Shard\InitialItem;
use Aggrego\Domain\ProgressiveBoard\Step\State;
use Aggrego\Domain\ProgressiveBoard\Step\Step;
use Aggrego\Domain\ProgressiveBoard\Step\Steps\FinalStep;
use Aggrego\Domain\ProgressiveBoard\Step\Steps\ProgressStep;
use Aggrego\Domain\Shared\Event\Model\TraitAggregate;
use Aggrego\Domain\Shared\ValueObject\Data;
use Aggrego\Domain\Shared\ValueObject\Key;
use Aggrego\Domain\Shared\ValueObject\Uuid;

class Board implements Aggregate
{
    use TraitAggregate;

    /** @var Uuid */
    private $uuid;

    /** @var Key */
    private $key;

    /** @var Profile */
    private $profile;

    /** @var Step */
    private $step;

    /** @var bool */
    private $isDeleted;

    private function __construct(Uuid $uuid, Key $key, Profile $profile, ProgressStep $step)
    {
        $this->uuid = $uuid;
        $this->key = $key;
        $this->profile = $profile;
        $this->step = $step;

        $this->pushEvent(new BoardCreatedEvent($uuid, $key, $profile));
        $this->setStep($step);
    }

    public static function factory(Key $key, Builder $factory): self
    {
        $initialBoard = $factory->build($key);

        $shardsList = [];
        /** @var InitialItem $item */
        foreach ($initialBoard->getShards() as $item) {
            $shardsList[] = new InitialItem(
                $item->getUuid(),
                $item->getProfile(),
                $item->getKey()
            );
        }

        return new self(
            $initialBoard->getUuid(),
            $initialBoard->getKey(),
            $initialBoard->getProfile(),
            new ProgressStep(State::createInitial(), new Collection($shardsList))
        );
    }

    public function getProfile(): Profile
    {
        return $this->profile;
    }

    public function updateShard(Uuid $shardUuid, Profile $profile, Data $data): void
    {
        if ($this->isDeleted) {
            throw new UnprocessableBoardException();
        }
        $shard = new FinalItem($shardUuid, $profile, $data);
        $this->step->replace($shard);

The method replace() does not exist on Aggrego\Domain\ProgressiveBoard\Step\Step. It seems like you code against a sub-type of Aggrego\Domain\ProgressiveBoard\Step\Step such as Aggrego\Domain\ProgressiveBoard\Step\Steps\ProgressStep.

        $this->pushEvent(new ShardUpdatedEvent($this->uuid, $shard));
        if ($this->isStepReadyForNextTransformation()) {
            $this->pushEvent(new UpdatedLastStepsShardEvent($this->uuid));
        }
    }

    public function isStepReadyForNextTransformation(): bool
    {
        if ($this->isDeleted) {
            return false;
        }
        return $this->step->isReadyForTransformation();

The method isReadyForTransformation() does not exist on Aggrego\Domain\ProgressiveBoard\Step\Step. It seems like you code against a sub-type of Aggrego\Domain\ProgressiveBoard\Step\Step such as Aggrego\Domain\ProgressiveBoard\Step\Steps\ProgressStep.

    }

    public function transformStep(Transformation $transformation): void
    {
        if ($this->isDeleted) {
            throw new UnprocessableBoardException();
        }

        if (!$this->isStepReadyForNextTransformation()) {
            throw new UnfinishedStepPassedForTransformationException();
        }

        $step = $transformation->process($this->step);

        if ($step->getState()->isFinal()) {
            /** @var FinalStep $step */
            $this->pushEvent(new FinalBoardTransformedEvent($this->uuid, $step));

            $this->isDeleted = true;
            $this->pushEvent(new BoardDeletedEvent($this->uuid));
        } else {
            /** @var ProgressStep $step */
            $this->pushEvent(new BoardTransformedEvent($this->uuid, $step));
            $this->setStep($step);
        }
    }

    private function setStep(ProgressStep $step): void
    {
        $this->step = $step;
        foreach ($step->getShards() as $shard) {
            $this->pushEvent(new ShardAddedEvent($this->uuid, $shard));
        }
    }
}