Cubiche\Domain\EventSourcing\Tests\Fixtures\Projector\PublishedPostProjector

Complexity

Total Complexity

9

Size/Duplication

Total Lines	66
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	5

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	projectPostWasCreated()	0	7	1
A	projectPostTitleWasChanged()	0	4	1
A	shouldBeProjected()	0	11	3
A	shouldBeRemoved()	0	11	3
A	writeModelClass()	0	4	1

<?php

/**
 * This file is part of the Cubiche package.
 *
 * Copyright (c) Cubiche
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Cubiche\Domain\EventSourcing\Tests\Fixtures\Projector;

use Cubiche\Domain\EventSourcing\EventStore\EventStream;
use Cubiche\Domain\EventSourcing\Projector\Projector;
use Cubiche\Domain\EventSourcing\Tests\Fixtures\Event\PostTitleWasChanged;
use Cubiche\Domain\EventSourcing\Tests\Fixtures\Event\PostWasCreated;
use Cubiche\Domain\EventSourcing\Tests\Fixtures\Event\PostWasPublished;
use Cubiche\Domain\EventSourcing\Tests\Fixtures\Event\PostWasUnPublished;
use Cubiche\Domain\EventSourcing\Tests\Fixtures\PostEventSourced;
use Cubiche\Domain\EventSourcing\Tests\Fixtures\ReadModel\PublishedPost;

/**
 * PublishedPostProjector class.
 *
 * @author Ivannis Suárez Jerez <ivannis.suarez@gmail.com>
 */
class PublishedPostProjector extends Projector
{
    /**
     * @param PostWasCreated $event
     *
     * @return PublishedPost
     */
    public function projectPostWasCreated(PostWasCreated $event)
    {
        return new PublishedPost(
            $event->aggregateId(),

$event->aggregateId() of type object<Cubiche\Domain\Model\IdInterface> is not a sub-type of object<Cubiche\Domain\Model\Tests\Fixtures\PostId>. It seems like you assume a concrete implementation of the interface Cubiche\Domain\Model\IdInterface to be always present.

            $event->title()
        );
    }

    /**
     * @param PostTitleWasChanged $event
     * @param PublishedPost       $readModel
     */
    public function projectPostTitleWasChanged(PostTitleWasChanged $event, PublishedPost $readModel)
    {
        $readModel->setTitle($event->title());
    }

    /**
     * @param EventStream $eventStream
     *
     * @return bool
     */
    protected function shouldBeProjected(EventStream $eventStream)
    {
        $events = $eventStream->events();
        foreach ($events as $event) {
            if ($event instanceof PostWasPublished) {
                return true;
            }
        }

        return false;
    }

    /**
     * @param EventStream $eventStream
     *
     * @return bool
     */
    protected function shouldBeRemoved(EventStream $eventStream)
    {
        $events = $eventStream->events();
        foreach ($events as $event) {
            if ($event instanceof PostWasUnPublished) {
                return true;
            }
        }

        return false;
    }

    /**
     * @return string
     */
    protected function writeModelClass()
    {
        return PostEventSourced::class;
    }
}