Merge branch 'null-error-messages-7x' of https://github.com/mlambley/elasticsearch-php into mlambley-null-error-messages-7x

Author: ezimuel

src/Elasticsearch/Connections/Connection.php

@@ -612,7 +612,6 @@ private function buildCurlCommand(string $method, string $uri, ?string $body): s
     private function process4xxError(array $request, array $response, array $ignore): ?ElasticsearchException
     {
         $statusCode = $response['status'];
-        $responseBody = $response['body'];
 
         /**
  * @var \Exception $exception
@@ -622,12 +621,8 @@ private function process4xxError(array $request, array $response, array $ignore)
         if (array_search($response['status'], $ignore) !== false) {
             return null;
         }
-
-        // if responseBody is not string, we convert it so it can be used as Exception message
-        if (!is_string($responseBody)) {
-            $responseBody = json_encode($responseBody);
-        }
-
+        
+        $responseBody = $this->convertBodyToString($response['body'], $statusCode, $exception);
         if ($statusCode === 403) {
             $exception = new Forbidden403Exception($responseBody, $statusCode);
         } elseif ($statusCode === 404) {
@@ -672,14 +667,33 @@ private function process5xxError(array $request, array $response, array $ignore)
         } elseif ($statusCode === 500 && strpos($responseBody, 'NoShardAvailableActionException') !== false) {
             $exception = new NoShardAvailableException($exception->getMessage(), $statusCode, $exception);
         } else {
-            $exception = new ServerErrorResponseException($responseBody, $statusCode);
+            $exception = new ServerErrorResponseException(
+                $this->convertBodyToString($responseBody, $statusCode, $exception),
+                $statusCode
+            );
         }
 
         $this->logRequestFail($request, $response, $exception);
 
         throw $exception;
     }
 
+    private function convertBodyToString($body, int $statusCode, ElasticsearchException $exception) : string
+    {
+        if (empty($body)) {
+            return sprintf(
+                "Unknown %d error from Elasticsearch %s",
+                $statusCode,
+                $exception->getMessage()
+            );
+        }
+        // if body is not string, we convert it so it can be used as Exception message
+        if (!is_string($body)) {
+            return json_encode($body);
+        }
+        return $body;
+    }
+
     private function tryDeserialize400Error(array $response): ElasticsearchException
     {
         return $this->tryDeserializeError($response, BadRequest400Exception::class);