Add getProperties

Author: sy-records

src/Command/PublishCommand.php

@@ -49,6 +49,7 @@ protected function configure()
                     new InputOption('will-retain', null, InputOption::VALUE_OPTIONAL, 'If given, if the client disconnects unexpectedly the message sent out will be treated as a retained message', 0),
                     new InputOption('ssl', 'S', InputOption::VALUE_OPTIONAL, 'Enable SSL encryption', false),
                     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'),
                 ])
             );
     }

src/Handler/AbstractHandler.php

@@ -149,6 +149,7 @@ public function getConnectConfig(): ClientConfig
             ->setProtocolLevel($this->getProtocolLevel())
             ->setSockType($this->getSocketType())
             ->setSwooleConfig($this->getSwooleConfig())
+            ->setProperties($this->getProperties('connect'))
             ->setMaxAttempts(0); // Disable auto reconnection
     }
 
@@ -184,6 +185,22 @@ public function getSwooleConfig(): array
         return [];
     }
 
+    public function getProperties(string $key = ''): array
+    {
+        $path = $this->input->getOption('properties-path');
+        if ($path && is_file($path)) {
+            $content = include $path;
+
+            if ($key) {
+                return $content[$key] ?? [];
+            }
+
+            return $content;
+        }
+
+        return [];
+    }
+
     protected function log($msg): void
     {
         $date = date('Y-m-d H:i:s');

src/Handler/PublishHandler.php

@@ -41,7 +41,7 @@ public function handle(InputInterface $input, OutputInterface $output): int
             if ($this->getConnectConfig()->isMQTT5()) {
                 $this->logInfo("Connect Reason Code: {$connect['code']}, Reason: " . ReasonCode::getReasonPhrase($connect['code']));
             }
-            $publish = $client->publish($topic, $message, $this->getQos(), $this->getDup(), $this->getRetain());
+            $publish = $client->publish($topic, $message, $this->getQos(), $this->getDup(), $this->getRetain(), $this->getProperties('publish'));
         } catch (\Throwable $e) {
             $this->logError('Publish error');
             goto failure;