TomCizek\SymfonyProoph\Tests\AsynchronousMessages\AsynchronousMessagesExampleIntegrationTest

Complexity

Total Complexity

5

Size/Duplication

Total Lines	44
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	testInvoke_WithTestConfig_BySavingNewAggregateToRepostory_ShouldPublishExpectedMessageToExpectedProducerRo()	0	12	1
A	givenTestRepository()	0	7	1
A	givenTestAggregate()	0	4	1
A	whenAggregateSaved()	0	4	1
A	getPublishedEventsFromTestBridge()	0	7	1

<?php declare(strict_types = 1);

namespace TomCizek\SymfonyProoph\Tests\AsynchronousMessages;

use TomCizek\SymfonyProoph\Tests\AsynchronousMessages\FakeImplementations\TestAsynchronousMessageProducerBridge;
use TomCizek\SymfonyProoph\Tests\EventSourcing\FakeImplementations\MemoryTestRepository;
use TomCizek\SymfonyProoph\Tests\EventSourcing\FakeImplementations\TestAggregateRoot;

class AsynchronousMessagesExampleIntegrationTest extends AbstractAsynchronousMessagesTestCase
{
	const FIXTURE_CONFIG_FILE = 'FullTestConfig.yml';
	const TEST_PRODUCER_ROUTE_KEY = 'producerRouteKey';

	public function testInvoke_WithTestConfig_BySavingNewAggregateToRepostory_ShouldPublishExpectedMessageToExpectedProducerRouteKey(
	)
	{
		$this->givenContainerWithLoadedBundlesWithGivenConfig(self::FIXTURE_CONFIG_FILE);

		$repository = $this->givenTestRepository();
		$aggregate = $this->givenTestAggregate();

		$this->whenAggregateSaved($repository, $aggregate);

		$this->thenShouldPublishExpectedMessageToExpectedProducerRouteKey(self::TEST_PRODUCER_ROUTE_KEY);
	}

	private function givenTestRepository(): MemoryTestRepository
	{
		/** @var MemoryTestRepository $repository */
		$repository = $this->container->get(MemoryTestRepository::class);

		return $repository;
	}

	private function givenTestAggregate(): TestAggregateRoot
	{
		return TestAggregateRoot::create();
	}

	private function whenAggregateSaved(MemoryTestRepository $repository, TestAggregateRoot $aggregate): void
	{
		$repository->save($aggregate);
	}

	protected function getPublishedEventsFromTestBridge(): array
	{
		/** @var TestAsynchronousMessageProducerBridge $testProducerBridge */
		$testProducerBridge = $this->container->get(TestAsynchronousMessageProducerBridge::class);

		return $testProducerBridge->getPublished();
	}
}