Add Subscribe event

Author: sy-records

src/Command/SubscribeCommand.php

@@ -48,6 +48,7 @@ protected function configure()
                     new InputOption('config-path', null, InputOption::VALUE_OPTIONAL, 'Setting the Swoole config file path'),
                     new InputOption('properties-path', null, InputOption::VALUE_OPTIONAL, 'Setting the Properties config file path'),
                     new InputOption('unsubscribe', 'U', InputOption::VALUE_OPTIONAL | InputOption::VALUE_IS_ARRAY, 'Topics that need to be unsubscribed'),
+                    new InputOption('event', 'e', InputOption::VALUE_OPTIONAL, 'Subscribed EventDispatcher', ''),
                 ])
             );
     }

src/Event/AbstractEvent.php

@@ -0,0 +1,41 @@
+<?php
+/**
+ * This file is part of Simps
+ *
+ * @link     https://github.com/simps/mqtt
+ * @contact  Lu Fei <[email protected]>
+ *
+ * For the full copyright and license information,
+ * please view the LICENSE file that was distributed with this source code
+ */
+
+declare(strict_types=1);
+
+namespace Simps\MQTTCLI\Event;
+
+use Simps\MQTT\Client;
+use Symfony\Component\Console\Input\InputInterface;
+use Symfony\Component\Console\Output\OutputInterface;
+use Symfony\Contracts\EventDispatcher\Event;
+
+abstract class AbstractEvent extends Event
+{
+    /** @var Client */
+    protected $client;
+
+    /** @var InputInterface */
+    protected $input;
+
+    /** @var OutputInterface */
+    protected $output;
+
+    public function __construct(Client $client, InputInterface $input, OutputInterface $output)
+    {
+        $this->client = $client;
+        $this->input = $input;
+        $this->output = $output;
+        $this->handle();
+    }
+
+    abstract public function handle();
+}

src/Handler/AbstractHandler.php

@@ -230,6 +230,11 @@ public function getUnsubscribe(): array
         return $this->input->getOption('unsubscribe');
     }
 
+    public function getEvent(): string
+    {
+        return $this->input->getOption('event');
+    }
+
     protected function log($msg): void
     {
         $date = date('Y-m-d H:i:s');

src/Handler/SubscribeHandler.php

@@ -19,6 +19,7 @@
 use Symfony\Component\Console\Command\Command;
 use Symfony\Component\Console\Input\InputInterface;
 use Symfony\Component\Console\Output\OutputInterface;
+use Symfony\Component\EventDispatcher\EventDispatcher;
 
 class SubscribeHandler extends AbstractHandler
 {
@@ -102,8 +103,11 @@ public function handle(InputInterface $input, OutputInterface $output): int
                 $buffer = $client->recv();
                 if ($buffer && $buffer !== true) {
                     $this->log(json_encode($buffer));
-                    // TODO: need event
-                    // $client $this->input $this->output
+                    $event = $this->getEvent();
+                    if (!empty($event) && class_exists($event)) {
+                        echo 'sas';
+                        (new EventDispatcher())->dispatch(new $event($client, $input, $output));
+                    }
                 }
                 if ($timeSincePing <= (time() - $client->getConfig()->getKeepAlive())) {
                     $buffer = $client->ping();