IPub\MQTTClient\Commands\ClientCommand

Complexity

Total Complexity

7

Size/Duplication

Total Lines	89
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

Test Coverage

Coverage

4.17%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	10	2
A	setLogger()	0	8	2
A	configure()	0	6	1
A	execute()	0	26	2

<?php
/**
 * ClientCommand.php
 *
 * @copyright      More in license.md
 * @license        http://www.ipublikuj.eu
 * @author         Adam Kadlec http://www.ipublikuj.eu
 * @package        iPublikuj:MQTTClient!
 * @subpackage     Commands
 * @since          1.0.0
 *
 * @date           12.03.17
 */

declare(strict_types = 1);

namespace IPub\MQTTClient\Commands;

use Symfony\Component\Console;
use Symfony\Component\Console\Input;
use Symfony\Component\Console\Style;
use Symfony\Component\Console\Output;

use Psr\Log;

use BinSoul\Net\Mqtt;

use IPub\MQTTClient\Client;
use IPub\MQTTClient\Exceptions;
use IPub\MQTTClient\Logger;

/**
 * MQTT client command
 *
 * @package        iPublikuj:MQTTClient!
 * @subpackage     Commands
 *
 * @author         Adam Kadlec <adam.kadlec@ipublikuj.eu>
 */
class ClientCommand extends Console\Command\Command
{
	/**
	 * @var Client\IClient
	 */
	private $client;

	/**
	 * @var Log\LoggerInterface|Log\NullLogger|NULL
	 */
	private $logger;

	/**
	 * @var bool
	 */
	private $isRunning = FALSE;

	/**
	 * @param Client\IClient $client
	 * @param Log\LoggerInterface|NULL $logger
	 * @param string|NULL $name
	 */
	public function __construct(
		Client\IClient $client,
		Log\LoggerInterface $logger = NULL,
		string $name = NULL
	) {
		parent::__construct($name);

		$this->client = $client;
		$this->logger = $logger === NULL ? new Log\NullLogger : $logger;
	}

	/**
	 * @param Log\LoggerInterface $logger
	 *
	 * @return void
	 *
	 * @throws Exceptions\InvalidStateException
	 */
	public function setLogger(Log\LoggerInterface $logger) : void
	{
		if ($this->isRunning) {
			throw new Exceptions\InvalidStateException('Client is connected, logger could not be set.');
		}

		$this->logger = $logger;
	}

	/**
	 * @return void
	 */
	protected function configure()
	{
		$this
			->setName('ipub:mqttclient:start')
			->setDescription('Start MQTT client.');
	}

	/**
	 * {@inheritdoc}
	 */
	protected function execute(Input\InputInterface $input, Output\OutputInterface $output)
	{
		$io = new Style\SymfonyStyle($input, $output);

		$io->text([
			'',
			'+-------------+',
			'| MQTT client |',
			'+-------------+',
			'',
		]);

		if ($this->logger instanceof Logger\Console) {
			$this->logger->setFormatter(new Logger\Formatter\Symfony($io));
		}

		$this->client->onOpen[] = (function (Mqtt\Connection $connection, Client\Client $client) {

Accessing onOpen on the interface IPub\MQTTClient\Client\IClient suggest that you code against a concrete implementation. How about adding an instanceof check?

			$this->logger->debug(sprintf('Connection to %s opened', $client->getUri()));
		});

		$this->client->connect();

		$this->isRunning = TRUE;

		$this->client->getLoop()->run();
	}
}