fix command error message missing

Author: consatan

src/Lookup/TcpLookupService.php

@@ -10,7 +10,7 @@
 
 namespace Pulsar\Lookup;
 
-
+use Protobuf\AbstractMessage;
 use Pulsar\Exception\IOException;
 use Pulsar\Exception\OptionsException;
 use Pulsar\Exception\RuntimeException;
@@ -124,7 +124,7 @@ public function lookup(string $topic): Result
 
                 //
                 default:
-                    throw new RuntimeException($subCommand->getMessage());
+                    $this->handleCommandFailed($subCommand);
             }
         }
 
@@ -152,7 +152,7 @@ public function getPartitionedTopicMetadata(string $topic): int
          */
         $subCommand = $results->subCommand;
         if ($subCommand->getResponse()->value() == CommandPartitionedTopicMetadataResponse\LookupType::Failed_VALUE) {
-            throw new RuntimeException($subCommand->getMessage());
+            $this->handleCommandFailed($subCommand);
         }
 
         return $subCommand->getPartitions();
@@ -214,4 +214,20 @@ public function close()
     {
         $this->connection->close();
     }
-}
+
+    /**
+     * @return void
+     * @throws RuntimeException
+     */
+    protected function handleCommandFailed(AbstractMessage $command)
+    {
+        $code = 0;
+        $msg = $command->getMessage();
+        if ($command->hasError()) {
+            $code = $command->getError()->value();
+            $msg = $command->getError()->name();
+        }
+
+        throw RuntimeException($msg, $code);
+    }
+}

src/Response.php

@@ -110,10 +110,7 @@ public function getSubCommand(): AbstractMessage
     protected function checkError()
     {
         if ($this->subCommand instanceof CommandError) {
-            throw new RuntimeException(
-                $this->subCommand->getMessage(),
-                $this->subCommand->getError()->value()
-            );
+            $this->handleSubCommandError();
         }
 
         $this->checkServerError();
@@ -127,10 +124,22 @@ protected function checkError()
     protected function checkServerError()
     {
         if ($this->subCommand instanceof CommandSendError) {
-            throw new RuntimeException(
-                $this->subCommand->getMessage(),
-                $this->subCommand->getError()->value()
-            );
+            $this->handleSubCommandError();
         }
     }
-}
+
+    /**
+     * @return void
+     * @throws RuntimeException
+     */
+    protected function handleSubCommandError()
+    {
+        $code = 0;
+        $msg = $this->subCommand->getMessage();
+        if ($this->subCommand->hasError()) {
+            $code = $this->subCommand->getError()->value();
+            $msg = $msg ?: $this->subCommand->getError()->name();
+        }
+        throw new RuntimeException($msg, $code);
+    }
+}