Cubiche\Domain\EventSourcing\Tests\Units\EventStore\EventStoreTestCase

Complexity

Total Complexity

3

Size/Duplication

Total Lines	142
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	6

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
	createStore()	0	1	?
B	testPersist()	0	32	1
A	testLoad()	0	63	1
B	testRemove()	0	28	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\Units\EventStore;

use Cubiche\Domain\EventSourcing\EventStore\EventStoreInterface;
use Cubiche\Domain\EventSourcing\EventStore\EventStream;
use Cubiche\Domain\EventSourcing\Tests\Fixtures\Event\PostTitleWasChanged;
use Cubiche\Domain\EventSourcing\Tests\Fixtures\Event\PostWasCreated;
use Cubiche\Domain\EventSourcing\Tests\Units\TestCase;
use Cubiche\Domain\Model\Tests\Fixtures\PostId;

/**
 * EventStoreTestCase class.
 *
 * Generated by TestGenerator on 2016-06-28 at 14:36:54.
 */
abstract class EventStoreTestCase extends TestCase
{
    /**
     * @return EventStoreInterface
     */
    abstract protected function createStore();

    /**
     * Test Persist method.
     */
    public function testPersist()
    {
        $this
            ->given($store = $this->createStore())
            ->and($postId = PostId::fromNative(md5(rand())))
            ->and($streamName = 'Posts-'.$postId)
            ->and(
                $postWasCreated = new PostWasCreated($postId, 'foo', 'bar'),
                $postWasCreated->setVersion(1)
            )
            ->and($eventStream = new EventStream($streamName, $postId, [$postWasCreated]))
            ->when($store->persist($eventStream))
            ->then()
                ->object($store->load($streamName)->aggregateId())
                    ->isEqualTo($eventStream->aggregateId())
        ;

        $this
            ->given($store = $this->createStore())
            ->and($postId = PostId::fromNative(md5(rand())))
            ->and($streamName = 'Posts-'.$postId)
            ->and(
                $postWasCreated = new PostWasCreated($postId, 'foo', 'bar'),
                $postWasCreated->setVersion(32)
            )
            ->and($eventStream = new EventStream($streamName, $postId, [$postWasCreated]))
            ->when($expextedVersion = $store->persist($eventStream))
            ->then()
                ->integer($expextedVersion)
                    ->isEqualTo(32)
        ;
    }

    /**
     * Test Load method.
     */
    public function testLoad()
    {
        $this
            ->given($store = $this->createStore())
            ->and($postId = PostId::fromNative(md5(rand())))
            ->and($postId1 = PostId::fromNative(md5(rand())))
            ->and($streamName = 'Posts-'.$postId)
            ->and($streamName1 = 'Posts-'.$postId1)
            ->and(
                $postWasCreated = new PostWasCreated($postId1, 'foo', 'bar'),
                $postWasCreated->setVersion(1)
            )
            ->and(
                $postTitleWasChanged = new PostTitleWasChanged($postId1, 'new title'),
                $postTitleWasChanged->setVersion(2)
            )
            ->and($streamNameFake = 'Blogs-'.$postId)
            ->and($eventStream = new EventStream($streamName, $postId, []))
            ->and($eventStream1 = new EventStream($streamName1, $postId1, [$postWasCreated, $postTitleWasChanged]))
            ->when($store->persist($eventStream))
            ->then()
                ->variable($store->load($streamName))
                    ->isNull()
                ->variable($store->load($streamNameFake))
                    ->isNull()
                ->and()
                ->when($store->persist($eventStream1))
                ->and($result = $store->load($streamName1))
                ->then()
                    ->object($result->aggregateId())
                        ->isEqualTo($eventStream1->aggregateId())
        ;

        $this
            ->given($store = $this->createStore())
            ->and($postId = PostId::fromNative(md5(rand())))
            ->and($streamName = 'Posts-'.$postId)
            ->and(
                $postWasCreated = new PostWasCreated($postId, 'foo', 'bar'),
                $postWasCreated->setVersion(1)
            )
            ->and(
                $postTitleWasChanged = new PostTitleWasChanged($postId, 'new title'),
                $postTitleWasChanged->setVersion(2)
            )
            ->and(
                $postTitleWasChangedAgain = new PostTitleWasChanged($postId, 'more title'),
                $postTitleWasChangedAgain->setVersion(3)
            )
            ->and(
                $eventStream = new EventStream(
                    $streamName,
                    $postId,
                    [$postWasCreated, $postTitleWasChanged, $postTitleWasChangedAgain]
                )
            )
            ->and($store->persist($eventStream))
            ->when($stream = $store->load($streamName, 2))
            ->then()
                ->array($stream->events())
                    ->hasSize(2)
        ;
    }

    /**
     * Test Remove method.
     */
    public function testRemove()
    {
        $this
            ->given($store = $this->createStore())
            ->and($postId = PostId::fromNative(md5(rand())))
            ->and($streamName = 'Posts-'.$postId)
            ->and($streamNameFake = 'Blogs-'.$postId)
            ->and(
                $postWasCreated = new PostWasCreated($postId, 'foo', 'bar'),
                $postWasCreated->setVersion(1)
            )
            ->and(
                $postTitleWasChanged = new PostTitleWasChanged($postId, 'new title'),
                $postTitleWasChanged->setVersion(2)
            )
            ->and($eventStream = new EventStream($streamName, $postId, [$postWasCreated, $postTitleWasChanged]))
            ->and($store->persist($eventStream))
            ->when($store->remove($streamNameFake))
            ->then()
                ->object($store->load($streamName)->aggregateId())
                    ->isEqualTo($eventStream->aggregateId())
                ->and()
                ->when($store->remove($streamName))
                ->then()
                    ->variable($store->load($streamName))
                        ->isNull()
        ;
    }
}