Vendor patched React MQTT Client classes

See binsoul/net-mqtt-client-react#17 and
binsoul/net-mqtt#8 for clarification.

Author: valga

.php_cs

@@ -7,6 +7,9 @@ return \PhpCsFixer\Config::create()
                 'src',
                 'tests',
             ])
+            ->exclude([
+                'React',
+            ])
     )
     ->setRules([
         '@Symfony'                            => true,

composer.json

@@ -29,7 +29,7 @@
         }
     },
     "require": {
-        "php": "^7.4",
+        "php": "^7.2",
         "ext-json": "*",
         "ext-mbstring": "*",
         "ext-zlib": "*",

src/Lite/FlowFactory.php

@@ -7,10 +7,10 @@
 use BinSoul\Net\Mqtt\ClientIdentifierGenerator;
 use BinSoul\Net\Mqtt\Connection;
 use BinSoul\Net\Mqtt\Flow;
-use BinSoul\Net\Mqtt\FlowFactory as FlowFactoryInterface;
 use BinSoul\Net\Mqtt\Message;
 use BinSoul\Net\Mqtt\PacketFactory;
 use BinSoul\Net\Mqtt\PacketIdentifierGenerator;
+use Fbns\React\FlowFactory as FlowFactoryInterface;
 
 class FlowFactory implements FlowFactoryInterface
 {
@@ -37,42 +37,42 @@ public function __construct(
         $this->packetFactory = $packetFactory;
     }
 
-    public function buildIncomingPingFlow(): Flow\IncomingPingFlow
+    public function buildIncomingPingFlow(): Flow
     {
         return new Flow\IncomingPingFlow($this->packetFactory);
     }
 
-    public function buildIncomingPublishFlow(Message $message, int $identifier = null): Flow\IncomingPublishFlow
+    public function buildIncomingPublishFlow(Message $message, int $identifier = null): Flow
     {
         return new Flow\IncomingPublishFlow($this->packetFactory, $message, $identifier);
     }
 
-    public function buildOutgoingConnectFlow(Connection $connection): OutgoingConnectFlow
+    public function buildOutgoingConnectFlow(Connection $connection): Flow
     {
         return new OutgoingConnectFlow($this->packetFactory, $connection, $this->clientIdentifierGenerator);
     }
 
-    public function buildOutgoingDisconnectFlow(Connection $connection): Flow\OutgoingDisconnectFlow
+    public function buildOutgoingDisconnectFlow(Connection $connection): Flow
     {
         return new Flow\OutgoingDisconnectFlow($this->packetFactory, $connection);
     }
 
-    public function buildOutgoingPingFlow(): Flow\OutgoingPingFlow
+    public function buildOutgoingPingFlow(): Flow
     {
         return new Flow\OutgoingPingFlow($this->packetFactory);
     }
 
-    public function buildOutgoingPublishFlow(Message $message): Flow\OutgoingPublishFlow
+    public function buildOutgoingPublishFlow(Message $message): Flow
     {
         return new Flow\OutgoingPublishFlow($this->packetFactory, $message, $this->packetIdentifierGenerator);
     }
 
-    public function buildOutgoingSubscribeFlow(array $subscriptions): Flow\OutgoingSubscribeFlow
+    public function buildOutgoingSubscribeFlow(array $subscriptions): Flow
     {
         return new Flow\OutgoingSubscribeFlow($this->packetFactory, $subscriptions, $this->packetIdentifierGenerator);
     }
 
-    public function buildOutgoingUnsubscribeFlow(array $subscriptions): Flow\OutgoingUnsubscribeFlow
+    public function buildOutgoingUnsubscribeFlow(array $subscriptions): Flow
     {
         return new Flow\OutgoingUnsubscribeFlow($this->packetFactory, $subscriptions, $this->packetIdentifierGenerator);
     }

src/Mqtt/RtiClient.php

@@ -4,7 +4,6 @@
 
 namespace Fbns\Mqtt;
 
-use BinSoul\Net\Mqtt\Client\React\ReactMqttClient;
 use BinSoul\Net\Mqtt\DefaultMessage;
 use BinSoul\Net\Mqtt\Message;
 use BinSoul\Net\Mqtt\StreamParser;
@@ -14,6 +13,7 @@
 use Fbns\Lite\ConnectResponsePacket;
 use Fbns\Lite\FlowFactory;
 use Fbns\Lite\PacketFactory;
+use Fbns\React\ReactMqttClient;
 use Psr\Log\LoggerInterface;
 use React\EventLoop\LoopInterface;
 use React\EventLoop\TimerInterface;

src/React/FlowFactory.php

@@ -0,0 +1,69 @@
+<?php
+
+declare(strict_types=1);
+
+namespace Fbns\React;
+
+use BinSoul\Net\Mqtt\Connection;
+use BinSoul\Net\Mqtt\Flow;
+use BinSoul\Net\Mqtt\Message;
+use BinSoul\Net\Mqtt\Subscription;
+
+/**
+ * Builds instances of the {@see Flow} interface.
+ */
+interface FlowFactory
+{
+    /**
+     * @return Flow
+     */
+    public function buildIncomingPingFlow(): Flow;
+
+    /**
+     * @param Message  $message
+     * @param int|null $identifier
+     *
+     * @return Flow
+     */
+    public function buildIncomingPublishFlow(Message $message, int $identifier = null): Flow;
+
+    /**
+     * @param Connection $connection
+     *
+     * @return Flow
+     */
+    public function buildOutgoingConnectFlow(Connection $connection): Flow;
+
+    /**
+     * @param Connection $connection
+     *
+     * @return Flow
+     */
+    public function buildOutgoingDisconnectFlow(Connection $connection): Flow;
+
+    /**
+     * @return Flow
+     */
+    public function buildOutgoingPingFlow(): Flow;
+
+    /**
+     * @param Message $message
+     *
+     * @return Flow
+     */
+    public function buildOutgoingPublishFlow(Message $message): Flow;
+
+    /**
+     * @param Subscription[] $subscriptions
+     *
+     * @return Flow
+     */
+    public function buildOutgoingSubscribeFlow(array $subscriptions): Flow;
+
+    /**
+     * @param Subscription[] $subscriptions
+     *
+     * @return Flow
+     */
+    public function buildOutgoingUnsubscribeFlow(array $subscriptions): Flow;
+}

src/React/LICENSE.md

@@ -0,0 +1,21 @@
+# The MIT License (MIT)
+
+Copyright (c) 2015 Sebastian Mößler <[email protected]>
+
+> Permission is hereby granted, free of charge, to any person obtaining a copy
+> of this software and associated documentation files (the "Software"), to deal
+> in the Software without restriction, including without limitation the rights
+> to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+> copies of the Software, and to permit persons to whom the Software is
+> furnished to do so, subject to the following conditions:
+>
+> The above copyright notice and this permission notice shall be included in
+> all copies or substantial portions of the Software.
+>
+> THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+> IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+> FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+> AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+> LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+> OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
+> THE SOFTWARE.