QA fixes

redisdb_exchange_plugin/exchange.py

@@ -121,12 +121,6 @@ def handle(self) -> None:
 
     # -----------------------------------------------------------------------------
 
-    def is_healthy(self) -> bool:
-        """Check if exchange is healthy"""
-        return self.is_alive()
-
-    # -----------------------------------------------------------------------------
-
     def register_consumer(
         self,
         consumer: IConsumer,

src/Client/AsyncClient.php

@@ -21,7 +21,6 @@
 use FastyBird\RedisDbExchangePlugin\Exceptions;
 use Nette;
 use Psr\EventDispatcher;
-use Psr\Log;
 use Ramsey\Uuid;
 use React\EventLoop;
 use React\Promise;
@@ -81,15 +80,11 @@ class AsyncClient implements IAsyncClient
 	/** @var EventLoop\LoopInterface */
 	private EventLoop\LoopInterface $eventLoop;
 
-	/** @var Log\LoggerInterface */
-	private Log\LoggerInterface $logger;
-
 	public function __construct(
 		string $channelName,
 		Connections\IConnection $connection,
 		EventLoop\LoopInterface $eventLoop,
-		?EventDispatcher\EventDispatcherInterface $dispatcher = null,
-		?Log\LoggerInterface $logger = null
+		?EventDispatcher\EventDispatcherInterface $dispatcher = null
 	) {
 		$this->channelName = $channelName;
 
@@ -104,8 +99,6 @@ public function __construct(
 
 		$this->dispatcher = $dispatcher;
 
-		$this->logger = $logger ?? new Log\NullLogger();
-
 		$this->identifier = Uuid\Uuid::uuid4()->toString();
 	}
 
@@ -349,6 +342,11 @@ private function handleMessage(RedisProtocol\Model\ModelInterface $message): voi
 	{
 		if ($message instanceof RedisProtocol\Model\MultiBulkReply) {
 			$array = $message->getValueNative();
+
+			if (!is_array($array)) {
+				return;
+			}
+
 			$type = array_shift($array);
 
 			// Pub/Sub messages are to be forwarded and should not be processed as request responses
@@ -367,7 +365,7 @@ private function handleMessage(RedisProtocol\Model\ModelInterface $message): voi
 				if (isset($array[0]) && isset($array[1]) && isset($array[2])) {
 					if ($this->dispatcher !== null) {
 						$this->dispatcher->dispatch(
-							new Events\PatternMessageReceivedEvent($array[0], $array[1], $array[2], $this)
+							new Events\PatternMessageReceivedEvent(strval($array[0]), strval($array[1]), strval($array[2]), $this)
 						);
 					}
 

src/Client/Client.php

@@ -39,9 +39,6 @@ class Client implements IClient
 	/** @var string */
 	private string $identifier;
 
-	/** @var Connections\IConnection */
-	private Connections\IConnection $connection;
-
 	/** @var Predis\Client<mixed> */
 	private Predis\Client $redis;
 
@@ -51,8 +48,6 @@ public function __construct(
 	) {
 		$this->channelName = $channelName;
 
-		$this->connection = $connection;
-
 		$options = [
 			'scheme' => 'tcp',
 			'host'   => $connection->getHost(),

src/Subscribers/AsyncClientSubscriber.php

@@ -88,7 +88,7 @@ public function handleMessage(Events\MessageReceivedEvent $event): void
 		}
 
 		try {
-			$data = Utils\ArrayHash::from(Utils\Json::decode($event->getPayload(), Utils\Json::FORCE_ARRAY));
+			$data = Utils\ArrayHash::from(Utils\Json::decode($event->getPayload(), Utils\Json::FORCE_ARRAY)); // @phpstan-ignore-line
 
 			if (
 				$data->offsetExists('origin')
@@ -98,7 +98,7 @@ public function handleMessage(Events\MessageReceivedEvent $event): void
 				$this->handle(
 					MetadataTypes\ModuleOriginType::get($data->offsetGet('origin')),
 					MetadataTypes\RoutingKeyType::get($data->offsetGet('routing_key')),
-					$data->offsetGet('data')
+					$data->offsetGet('data') // @phpstan-ignore-line
 				);
 
 			} else {
@@ -140,7 +140,7 @@ private function handle(
 		}
 
 		try {
-			$schema = $this->schemaLoader->loadByRoutingKey($routingKey->getValue());
+			$schema = $this->schemaLoader->loadByRoutingKey($routingKey->getValue()); // @phpstan-ignore-line
 
 		} catch (MetadataExceptions\InvalidArgumentException $ex) {
 			return;