TomCizek\SymfonyProoph\ServiceBus\ServiceBusConfigurators\AbstractBusConfigurator

Complexity

Total Complexity

2

Size/Duplication

Total Lines	44
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

100%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
	getBusClass()	0	1	?
	getBusFactoryClass()	0	1	?
A	buildDefaultConfig()	0	11	1
A	configureWithConfig()	0	19	1

<?php declare(strict_types = 1);

namespace TomCizek\SymfonyProoph\ServiceBus\ServiceBusConfigurators;

use Prooph\Common\Messaging\MessageFactory;
use Symfony\Component\DependencyInjection\Definition;
use Symfony\Component\DependencyInjection\Reference;
use TomCizek\SymfonyProoph\Common\DefaultConfigurator;

abstract class AbstractBusConfigurator extends DefaultConfigurator
{
	protected const KEY_BUS_PLUGINS = 'plugins';
	protected const KEY_BUS_ROUTER = 'router';
	protected const KEY_BUS_ROUTER_ROUTES = 'routes';
	protected const KEY_ENABLE_HANDLER_LOCATION = 'enable_handler_location';
	protected const KEY_MESSAGE_FACTORY = 'message_factory';

	abstract public function getBusClass(): string;

	abstract public function getBusFactoryClass(): string;

	public function buildDefaultConfig(): array
	{
		return [
			self::KEY_BUS_PLUGINS => [],
			self::KEY_BUS_ROUTER => [
				self::KEY_BUS_ROUTER_ROUTES => [],
			],
			self::KEY_ENABLE_HANDLER_LOCATION => true,
			self::KEY_MESSAGE_FACTORY => MessageFactory::class,
		];
	}

	public function configureWithConfig(array $config): void
	{
		$interopContainerServiceId = $this->getInteropContainerServiceId();

		$factory = $this->getBusFactoryClass();

		$serviceBusDefinition = new Definition($this->getBusClass());

		$serviceBusDefinition
			->setFactory($factory . '::' . $this->getConfigKey())
			->addArgument(
				new Reference($interopContainerServiceId)
			);

		$serviceBusDefinitionName = 'prooph.service_bus.' . $this->getConfigKey();

		$this->containerBuilder->setDefinition($serviceBusDefinitionName, $serviceBusDefinition);
		$this->containerBuilder->setAlias($this->getBusClass(), $serviceBusDefinitionName);
	}
}