Add handleVerbose (#65)

simps · Nov 6, 2021 · 2170b88 · 2170b88
1 parent 25910df
commit 2170b88
Show file tree

Hide file tree

Showing 2 changed files with 41 additions and 0 deletions.
diff --git a/src/Client.php b/src/Client.php
@@ -17,6 +17,7 @@
 use Simps\MQTT\Exception\ConnectException;
 use Simps\MQTT\Exception\ProtocolException;
 use Simps\MQTT\Hex\ReasonCode;
+use Simps\MQTT\Tools\Common;
 use Swoole\Coroutine;
 
 class Client
@@ -224,6 +225,8 @@ public function recv()
         } elseif ($response === false && $this->client->errCode !== SOCKET_ETIMEDOUT) {
             $this->handleException();
         } elseif (is_string($response) && strlen($response) > 0) {
+            $this->handleVerbose($response);
+
             if ($this->getConfig()->isMQTT5()) {
                 return Protocol\V5::unpack($response);
             }
@@ -312,4 +315,28 @@ public function getClient()
     {
         return $this->client;
     }
+
+    protected function handleVerbose(string $data)
+    {
+        switch ($this->getConfig()->getVerbose()) {
+            case MQTT_VERBOSE_HEXDUMP:
+                echo Common::hexDump($data), PHP_EOL;
+                break;
+            case MQTT_VERBOSE_HEXDUMP_ASCII:
+                echo Common::hexDumpAscii($data), PHP_EOL;
+                break;
+            case MQTT_VERBOSE_ASCII:
+                echo Common::ascii($data), PHP_EOL;
+                break;
+            case MQTT_VERBOSE_TEXT:
+                echo Common::printableText($data), PHP_EOL;
+                break;
+            case MQTT_VERBOSE_HEX_STREAM:
+                echo Common::hexStream($data), PHP_EOL;
+                break;
+            case MQTT_VERBOSE_NONE:
+            default:
+                break;
+        }
+    }
 }
diff --git a/src/Config/ClientConfig.php b/src/Config/ClientConfig.php
@@ -41,6 +41,8 @@ class ClientConfig extends AbstractConfig
 
     protected $sockType = SWOOLE_SOCK_TCP;
 
+    protected $verbose = MQTT_VERBOSE_NONE;
+
     public function getClientId(): string
     {
         return $this->clientId;
@@ -181,4 +183,16 @@ public function isMQTT5(): bool
     {
         return $this->getProtocolLevel() === ProtocolInterface::MQTT_PROTOCOL_LEVEL_5_0;
     }
+
+    public function getVerbose(): int
+    {
+        return $this->verbose;
+    }
+
+    public function setVerbose(int $verbose)
+    {
+        $this->verbose = $verbose;
+
+        return $this;
+    }
 }