[exchange] Implementing exchange factory (#86)

config/example.neon

@@ -6,7 +6,7 @@
 # @author       Adam Kadlec <adam.kadlec@fastybird.com>
 # @package      FastyBird:DevicesModule!
 # @subpackage   config
-# @since        0.1.0
+# @since        1.0.0
 #
 # @date         25.11.20
 

src/Commands/Connector.php

@@ -8,7 +8,7 @@
  * @author         Adam Kadlec <adam.kadlec@fastybird.com>
  * @package        FastyBird:DevicesModule!
  * @subpackage     Commands
- * @since          0.60.0
+ * @since          1.0.0
  *
  * @date           31.05.22
  */
@@ -17,6 +17,7 @@
 
 use BadMethodCallException;
 use FastyBird\DateTimeFactory;
+use FastyBird\Library\Exchange\Exchange as ExchangeExchange;
 use FastyBird\Library\Metadata\Exceptions as MetadataExceptions;
 use FastyBird\Library\Metadata\Types as MetadataTypes;
 use FastyBird\Module\Devices\Connectors;
@@ -62,6 +63,9 @@ class Connector extends Console\Command\Command
 
 	private Log\LoggerInterface $logger;
 
+	/**
+	 * @param array<ExchangeExchange\Factory> $exchangeFactories
+	 */
 	public function __construct(
 		private readonly Models\Connectors\ConnectorsRepository $connectorsRepository,
 		private readonly Models\Devices\DevicesRepository $devicesRepository,
@@ -71,6 +75,7 @@ public function __construct(
 		private readonly Utilities\ChannelPropertiesStates $channelPropertiesStateManager,
 		private readonly DateTimeFactory\Factory $dateTimeFactory,
 		private readonly EventLoop\LoopInterface $eventLoop,
+		private readonly array $exchangeFactories = [],
 		private readonly PsrEventDispatcher\EventDispatcherInterface|null $dispatcher = null,
 		Log\LoggerInterface|null $logger = null,
 		string|null $name = null,
@@ -319,6 +324,10 @@ private function executeConnector(Style\SymfonyStyle $io, Input\InputInterface $
 			}
 
 			$this->dispatcher?->dispatch(new Events\AfterConnectorStart($connector));
+
+			foreach ($this->exchangeFactories as $exchangeFactory) {
+				$exchangeFactory->create();
+			}
 		});
 
 		$this->eventLoop->addSignal(SIGINT, function () use ($connector, $service): void {

src/Commands/Exchange.php

@@ -0,0 +1,138 @@
+<?php declare(strict_types = 1);
+
+/**
+ * Exchange.php
+ *
+ * @license        More in LICENSE.md
+ * @copyright      https://www.fastybird.com
+ * @author         Adam Kadlec <adam.kadlec@fastybird.com>
+ * @package        FastyBird:DevicesModule!
+ * @subpackage     Commands
+ * @since          1.0.0
+ *
+ * @date           31.05.22
+ */
+
+namespace FastyBird\Module\Devices\Commands;
+
+use FastyBird\Library\Exchange\Consumers as ExchangeConsumers;
+use FastyBird\Library\Exchange\Exchange as ExchangeExchange;
+use FastyBird\Library\Metadata\Types as MetadataTypes;
+use FastyBird\Module\Devices\Consumers;
+use FastyBird\Module\Devices\Events;
+use Nette;
+use Psr\EventDispatcher;
+use Psr\Log;
+use React\EventLoop;
+use Symfony\Component\Console;
+use Symfony\Component\Console\Input;
+use Symfony\Component\Console\Output;
+use Symfony\Component\Console\Style;
+use Throwable;
+
+/**
+ * Module exchange command
+ *
+ * @package        FastyBird:RabbitMqPlugin!
+ * @subpackage     Commands
+ *
+ * @author         Adam Kadlec <adam.kadlec@fastybird.com>
+ */
+final class Exchange extends Console\Command\Command
+{
+
+	use Nette\SmartObject;
+
+	public const NAME = 'fb:devices-module:exchange';
+
+	private Log\LoggerInterface $logger;
+
+	/**
+	 * @param array<ExchangeExchange\Factory> $exchangeFactories
+	 */
+	public function __construct(
+		private readonly EventLoop\LoopInterface $eventLoop,
+		private readonly ExchangeConsumers\Container $consumer,
+		private readonly array $exchangeFactories = [],
+		private readonly EventDispatcher\EventDispatcherInterface|null $dispatcher = null,
+		Log\LoggerInterface|null $logger = null,
+		string|null $name = null,
+	)
+	{
+		parent::__construct($name);
+
+		$this->logger = $logger ?? new Log\NullLogger();
+	}
+
+	/**
+	 * @throws Console\Exception\InvalidArgumentException
+	 */
+	protected function configure(): void
+	{
+		$this
+			->setName(self::NAME)
+			->setDescription('Devices module exchange');
+	}
+
+	/**
+	 * @throws Console\Exception\InvalidArgumentException
+	 */
+	protected function execute(
+		Input\InputInterface $input,
+		Output\OutputInterface $output,
+	): int
+	{
+		$io = new Style\SymfonyStyle($input, $output);
+
+		if ($input->getOption('quiet') === false) {
+			$io->title('Devices module - exchange');
+
+			$io->note('This action will run module exchange service');
+		}
+
+		if ($input->getOption('no-interaction') === false) {
+			$question = new Console\Question\ConfirmationQuestion(
+				'Would you like to continue?',
+				false,
+			);
+
+			$continue = (bool) $io->askQuestion($question);
+
+			if (!$continue) {
+				return Console\Command\Command::SUCCESS;
+			}
+		}
+
+		try {
+			$this->dispatcher?->dispatch(new Events\ExchangeStartup());
+
+			foreach ($this->exchangeFactories as $exchangeFactory) {
+				$exchangeFactory->create();
+			}
+
+			$this->consumer->enable(Consumers\State::class);
+
+			$this->eventLoop->run();
+
+		} catch (Throwable $ex) {
+			// Log caught exception
+			$this->logger->error('An unhandled error occurred', [
+				'source' => MetadataTypes\ModuleSource::SOURCE_MODULE_DEVICES,
+				'type' => 'command',
+				'exception' => [
+					'message' => $ex->getMessage(),
+					'code' => $ex->getCode(),
+				],
+			]);
+
+			if ($input->getOption('quiet') === false) {
+				$io->error('Something went wrong, service could not be finished. Error was logged.');
+			}
+
+			return Console\Command\Command::FAILURE;
+		}
+
+		return self::SUCCESS;
+	}
+
+}

src/Commands/Initialize.php

@@ -8,7 +8,7 @@
  * @author         Adam Kadlec <adam.kadlec@fastybird.com>
  * @package        FastyBird:DevicesModule!
  * @subpackage     Commands
- * @since          0.1.0
+ * @since          1.0.0
  *
  * @date           08.08.20
  */

src/Connectors/Connector.php

@@ -8,7 +8,7 @@
  * @author         Adam Kadlec <adam.kadlec@fastybird.com>
  * @package        FastyBird:DevicesModule!
  * @subpackage     Connectors
- * @since          0.60.0
+ * @since          1.0.0
  *
  * @date           31.05.22
  */

src/Connectors/ConnectorFactory.php

@@ -8,7 +8,7 @@
  * @author         Adam Kadlec <adam.kadlec@fastybird.com>
  * @package        FastyBird:DevicesModule!
  * @subpackage     Connectors
- * @since          0.67.0
+ * @since          1.0.0
  *
  * @date           03.07.22
  */

src/Constants.php

@@ -8,7 +8,7 @@
  * @author         Adam Kadlec <adam.kadlec@fastybird.com>
  * @package        FastyBird:DevicesModule!
  * @subpackage     common
- * @since          0.1.0
+ * @since          1.0.0
  *
  * @date           18.03.20
  */

src/Consumers/State.php

@@ -8,7 +8,7 @@
  * @author         Adam Kadlec <adam.kadlec@fastybird.com>
  * @package        FastyBird:DevicesModule!
  * @subpackage     Consumers
- * @since          0.1.0
+ * @since          1.0.0
  *
  * @date           22.10.22
  */

src/Controllers/BaseV1.php

@@ -8,7 +8,7 @@
  * @author         Adam Kadlec <adam.kadlec@fastybird.com>
  * @package        FastyBird:DevicesModule!
  * @subpackage     Controllers
- * @since          0.1.0
+ * @since          1.0.0
  *
  * @date           13.04.19
  */

src/Controllers/ChannelControlsV1.php

@@ -8,7 +8,7 @@
  * @author         Adam Kadlec <adam.kadlec@fastybird.com>
  * @package        FastyBird:DevicesModule!
  * @subpackage     Controllers
- * @since          0.1.0
+ * @since          1.0.0
  *
  * @date           04.06.19
  */

src/Controllers/ChannelPropertiesV1.php

@@ -8,7 +8,7 @@
  * @author         Adam Kadlec <adam.kadlec@fastybird.com>
  * @package        FastyBird:DevicesModule!
  * @subpackage     Controllers
- * @since          0.1.0
+ * @since          1.0.0
  *
  * @date           04.06.19
  */

src/Controllers/ChannelPropertyChildrenV1.php

@@ -8,7 +8,7 @@
  * @author         Adam Kadlec <adam.kadlec@fastybird.com>
  * @package        FastyBird:DevicesModule!
  * @subpackage     Controllers
- * @since          0.33.0
+ * @since          1.0.0
  *
  * @date           09.02.22
  */

src/Controllers/ChannelsV1.php

@@ -8,7 +8,7 @@
  * @author         Adam Kadlec <adam.kadlec@fastybird.com>
  * @package        FastyBird:DevicesModule!
  * @subpackage     Controllers
- * @since          0.1.0
+ * @since          1.0.0
  *
  * @date           13.04.19
  */

src/Controllers/ConnectorControlsV1.php

@@ -8,7 +8,7 @@
  * @author         Adam Kadlec <adam.kadlec@fastybird.com>
  * @package        FastyBird:DevicesModule!
  * @subpackage     Controllers
- * @since          0.4.0
+ * @since          1.0.0
  *
  * @date           29.09.21
  */

src/Controllers/ConnectorPropertiesV1.php

@@ -8,7 +8,7 @@
  * @author         Adam Kadlec <adam.kadlec@fastybird.com>
  * @package        FastyBird:DevicesModule!
  * @subpackage     Controllers
- * @since          0.31.0
+ * @since          1.0.0
  *
  * @date           08.02.22
  */

src/Controllers/ConnectorsV1.php

@@ -8,7 +8,7 @@
  * @author         Adam Kadlec <adam.kadlec@fastybird.com>
  * @package        FastyBird:DevicesModule!
  * @subpackage     Controllers
- * @since          0.1.0
+ * @since          1.0.0
  *
  * @date           17.01.21
  */

src/Controllers/DeviceChildrenV1.php

@@ -8,7 +8,7 @@
  * @author         Adam Kadlec <adam.kadlec@fastybird.com>
  * @package        FastyBird:DevicesModule!
  * @subpackage     Controllers
- * @since          0.1.0
+ * @since          1.0.0
  *
  * @date           04.06.19
  */

src/Controllers/DeviceControlsV1.php

@@ -8,7 +8,7 @@
  * @author         Adam Kadlec <adam.kadlec@fastybird.com>
  * @package        FastyBird:DevicesModule!
  * @subpackage     Controllers
- * @since          0.4.0
+ * @since          1.0.0
  *
  * @date           29.09.21
  */

src/Controllers/DeviceParentsV1.php

@@ -8,7 +8,7 @@
  * @author         Adam Kadlec <adam.kadlec@fastybird.com>
  * @package        FastyBird:DevicesModule!
  * @subpackage     Controllers
- * @since          0.42.0
+ * @since          1.0.0
  *
  * @date           25.03.22
  */

src/Controllers/DevicePropertiesV1.php

@@ -8,7 +8,7 @@
  * @author         Adam Kadlec <adam.kadlec@fastybird.com>
  * @package        FastyBird:DevicesModule!
  * @subpackage     Controllers
- * @since          0.1.0
+ * @since          1.0.0
  *
  * @date           04.06.19
  */

src/Controllers/DevicePropertyChildrenV1.php

@@ -8,7 +8,7 @@
  * @author         Adam Kadlec <adam.kadlec@fastybird.com>
  * @package        FastyBird:DevicesModule!
  * @subpackage     Controllers
- * @since          0.33.0
+ * @since          1.0.0
  *
  * @date           09.02.22
  */

src/Controllers/DevicesV1.php

@@ -8,7 +8,7 @@
  * @author         Adam Kadlec <adam.kadlec@fastybird.com>
  * @package        FastyBird:DevicesModule!
  * @subpackage     Controllers
- * @since          0.1.0
+ * @since          1.0.0
  *
  * @date           13.04.19
  */

src/Controllers/Finders/TChannel.php

@@ -8,7 +8,7 @@
  * @author         Adam Kadlec <adam.kadlec@fastybird.com>
  * @package        FastyBird:DevicesModule!
  * @subpackage     Controllers
- * @since          0.1.0
+ * @since          1.0.0
  *
  * @date           13.04.19
  */

src/Controllers/Finders/TChannelProperty.php

@@ -8,7 +8,7 @@
  * @author         Adam Kadlec <adam.kadlec@fastybird.com>
  * @package        FastyBird:DevicesModule!
  * @subpackage     Controllers
- * @since          0.33.0
+ * @since          1.0.0
  *
  * @date           09.02.22
  */

src/Controllers/Finders/TConnector.php

@@ -8,7 +8,7 @@
  * @author         Adam Kadlec <adam.kadlec@fastybird.com>
  * @package        FastyBird:DevicesModule!
  * @subpackage     Controllers
- * @since          0.4.0
+ * @since          1.0.0
  *
  * @date           29.09.21
  */