IPub\WebSockets\DI\WebSocketsZMQExtension

Complexity

Total Complexity

2

Size/Duplication

Total Lines	53
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
B	loadConfiguration()	0	24	1
A	register()	0	6	1

<?php
/**
 * WebSocketsZMQExtension.php
 *
 * @copyright      More in license.md
 * @license        http://www.ipublikuj.eu
 * @author         Adam Kadlec http://www.ipublikuj.eu
 * @package        iPublikuj:WebSocketZMQ!
 * @subpackage     DI
 * @since          1.0.0
 *
 * @date           01.03.17
 */

declare(strict_types = 1);

namespace IPub\WebSocketsZMQ\DI;

use Nette;
use Nette\DI;

use IPub;
use IPub\WebSocketsZMQ;
use IPub\WebSocketsZMQ\Consumer;
use IPub\WebSocketsZMQ\Pusher;

/**
 * WebSockets ZeroMQ extension container
 *
 * @package        iPublikuj:WebSocket!
 * @subpackage     DI
 *
 * @author         Adam Kadlec <adam.kadlec@ipublikuj.eu>
 *
 * @method DI\ContainerBuilder getContainerBuilder()
 * @method array getConfig(array $defaults)
 * @method string prefix(string $name)
 */
final class WebSocketsZMQExtension extends DI\CompilerExtension
{
	/**
	 * @var array
	 */
	private $defaults = [
		'host'       => '127.0.0.1',
		'port'       => 5555,
		'persistent' => TRUE,
		'protocol'   => 'tcp',
	];

	/**
	 * {@inheritdoc}
	 */
	public function loadConfiguration()
	{
		parent::loadConfiguration();

		/** @var DI\ContainerBuilder $builder */
		$builder = $this->getContainerBuilder();
		/** @var array $configuration */
		$configuration = $this->getConfig($this->defaults);

		$configuration = new WebSocketsZMQ\Configuration(
			$configuration['host'],
			$configuration['port'],
			$configuration['persistent'],
			$configuration['protocol']
		);

		$builder->addDefinition($this->prefix('consumer'))
			->setClass(Consumer\Consumer::class)
			->setArguments(['configuration' => $configuration]);

		$builder->addDefinition($this->prefix('pusher'))
			->setClass(Pusher\Pusher::class)
			->setArguments(['configuration' => $configuration]);
	}

	/**
	 * @param Nette\Configurator $config
	 * @param string $extensionName
	 *
	 * @return void
	 */
	public static function register(Nette\Configurator $config, string $extensionName = 'webSocketsZMQ')
	{
		$config->onCompile[] = function (Nette\Configurator $config, DI\Compiler $compiler) use ($extensionName) {
			$compiler->addExtension($extensionName, new WebSocketsZMQExtension());
		};
	}
}