TomCizek\SymfonyProoph\Tests\AsynchronousMessages\AbstractAsynchronousMessagesTestCase

Complexity

Total Complexity

1

Size/Duplication

Total Lines	16
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	1

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	thenShouldPublishExpectedMessageToExpectedProducerRouteKey()	0	11	1
	getPublishedEventsFromTestBridge()	0	1	?

<?php declare(strict_types = 1);

namespace TomCizek\SymfonyProoph\Tests\AsynchronousMessages;

use TomCizek\SymfonyProoph\Tests\AsynchronousMessages\FakeImplementations\TestAsynchronousMessageProducerBridge;
use TomCizek\SymfonyProoph\Tests\Configurators\ProophTestCase;
use TomCizek\SymfonyProoph\Tests\EventSourcing\FakeImplementations\TestAggregateCreated;

abstract class AbstractAsynchronousMessagesTestCase extends ProophTestCase
{
	protected function thenShouldPublishExpectedMessageToExpectedProducerRouteKey($expectedProducerRouteKey): void
	{
		$publishedMessagesDump = $this->getPublishedEventsFromTestBridge();

		self::assertCount(1, $publishedMessagesDump);
		$publishedProducerRouteKey = $publishedMessagesDump[0][TestAsynchronousMessageProducerBridge::KEY_ROUTING_KEY];
		$publishedMessageData = $publishedMessagesDump[0][TestAsynchronousMessageProducerBridge::KEY_DATA];
		self::assertEquals($publishedProducerRouteKey, $expectedProducerRouteKey);
		self::assertEquals($publishedMessageData['message_name'], TestAggregateCreated::class);
		self::assertEquals($publishedMessageData['payload'], TestAggregateCreated::TEST_PAYLOAD);
	}

	abstract protected function getPublishedEventsFromTestBridge(): array;
}