TomCizek\SymfonyProoph\EventSourcing\EventSourcingConfigurator

Complexity

Total Complexity

4

Size/Duplication

Total Lines	40
Duplicated Lines	0 %

Coupling/Cohesion

Components	0
Dependencies	4

Test Coverage

Coverage

100%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	buildDefaultConfig()	0	6	1
A	getConfigKey()	0	4	1
A	configureWithConfig()	0	21	2

<?php declare(strict_types = 1);

namespace TomCizek\SymfonyProoph\EventSourcing;

use Prooph\EventSourcing\Container\Aggregate\AggregateRepositoryFactory;
use Symfony\Component\DependencyInjection\Definition;
use Symfony\Component\DependencyInjection\Reference;
use TomCizek\SymfonyProoph\Common\DefaultConfigurator;

class EventSourcingConfigurator extends DefaultConfigurator
{
	public const KEY = 'event_sourcing';
	public const KEY_AGGREGATE_REPOSITORIES = 'aggregate_repository';
	public const KEY_REPOSITORY_CLASS = 'repository_class';

	public function buildDefaultConfig(): array
	{
		return [
			self::KEY_AGGREGATE_REPOSITORIES => [],
		];
	}

	public function getConfigKey(): string
	{
		return self::KEY;
	}

	public function configureWithConfig(array $config): void
	{
		$repositoriesConfigs = $config[self::KEY_AGGREGATE_REPOSITORIES];

		$interopContainerServiceId = $this->getInteropContainerServiceId();

		foreach ($repositoriesConfigs as $repositoryConfigName => $repositoryConfig) {
			$repositoryClass = $repositoryConfig[self::KEY_REPOSITORY_CLASS];

			$repositoryDefinition = new Definition($repositoryClass);
			$repositoryDefinition
				->setClass($repositoryClass)
				->setFactory(AggregateRepositoryFactory::class . '::' . $repositoryConfigName)
				->addArgument(
					new Reference($interopContainerServiceId)
				);

			$this->containerBuilder->setDefinition('prooph.' . $repositoryConfigName, $repositoryDefinition);
			$this->containerBuilder->setAlias($repositoryClass, 'prooph.' . $repositoryConfigName);
		}
	}
}