Daikon\EventSourcing\EventStore\Commit

Complexity

Total Complexity

9

Size/Duplication

Total Lines	81
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

60%

Importance

Changes

0

9 Methods

Rating	Name	Duplication	Size	Complexity
A	getStreamId()	0	4	1
A	getMetadata()	0	4	1
A	make()	0	8	1
A	fromArray()	0	9	1
A	getStreamRevision()	0	4	1
A	getAggregateRevision()	0	4	1
A	getEventLog()	0	4	1
A	toArray()	0	10	1
A	__construct()	0	11	1

<?php
/**
 * This file is part of the daikon-cqrs/cqrs project.
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

declare(strict_types=1);

namespace Daikon\EventSourcing\EventStore;

use Daikon\EventSourcing\Aggregate\AggregateRevision;
use Daikon\EventSourcing\Aggregate\DomainEventSequence;
use Daikon\MessageBus\MessageInterface;
use Daikon\MessageBus\Metadata\Metadata;

final class Commit implements CommitInterface
{
    /** @var StreamId */
    private $streamId;

    /** @var StreamRevision */
    private $streamRevision;

    /** @var DomainEventSequence */
    private $eventLog;

    /** @var Metadata */
    private $metadata;

    public static function make(
        StreamId $streamId,
        StreamRevision $streamRevision,
        DomainEventSequence $eventLog,
        Metadata $metadata
    ): CommitInterface {
        return new self($streamId, $streamRevision, $eventLog, $metadata);
    }

    public static function fromArray(array $state): MessageInterface
    {
        return new self(
            StreamId::fromNative($state['streamId']),

\Daikon\EventSourcing\EventStore\StreamId::fromNative($state['streamId']) of type object<Daikon\Entity\ValueObject\ValueObjectInterface> is not a sub-type of object<Daikon\EventSourcing\EventStore\StreamId>. It seems like you assume a concrete implementation of the interface Daikon\Entity\ValueObject\ValueObjectInterface to be always present.

            StreamRevision::fromNative((int)$state['streamRevision']),

\Daikon\EventSourcing\EventStore\StreamRevision::fromNative((int) $state['streamRevision']) of type object<Daikon\Entity\ValueObject\ValueObjectInterface> is not a sub-type of object<Daikon\EventSourcing\EventStore\StreamRevision>. It seems like you assume a concrete implementation of the interface Daikon\Entity\ValueObject\ValueObjectInterface to be always present.

            DomainEventSequence::fromArray($state['eventLog']),
            Metadata::fromArray($state['metadata'])
        );
    }

    public function getStreamId(): StreamId
    {
        return $this->streamId;
    }

    public function getStreamRevision(): StreamRevision
    {
        return $this->streamRevision;
    }

    public function getAggregateRevision(): AggregateRevision
    {
        return $this->eventLog->getHeadRevision();
    }

    public function getEventLog(): DomainEventSequence
    {
        return $this->eventLog;
    }

    public function getMetadata(): Metadata
    {
        return $this->metadata;
    }

    public function toArray(): array
    {
        return [
            '@type' => static::class,
            'streamId' => $this->streamId->toNative(),
            'streamRevision' => $this->streamRevision->toNative(),
            'eventLog' => $this->eventLog->toNative(),
            'metadata' => $this->metadata->toArray()
        ];
    }

    private function __construct(
        StreamId $streamId,
        StreamRevision $streamRevision,
        DomainEventSequence $eventLog,
        Metadata $metadata
    ) {
        $this->streamId = $streamId;
        $this->streamRevision = $streamRevision;
        $this->eventLog = $eventLog;
        $this->metadata = $metadata;
    }
}