displaying issue tree

Author: alshabalin

src/Issue.php

@@ -0,0 +1,72 @@
+<?php
+
+namespace YandexCloud\Ydb;
+
+use Ydb\Issue\IssueMessage;
+
+class Issue
+{
+    /**
+     * @var \Ydb\Issue\IssueMessage
+     */
+    protected $issue;
+
+    public function __construct(IssueMessage $issue)
+    {
+        $this->issue = $issue;
+    }
+
+    /**
+     * @return string
+     */
+    public function toString()
+    {
+        $msgs = [];
+        $msg = trim($this->issue->getMessage());
+        if (count($this->issue->getIssues()))
+        {
+            $msgs = [$msg . ':'];
+            foreach ($this->issue->getIssues() as $issue)
+            {
+                $issues = static::getSubIssues($issue);
+                if ($issues)
+                {
+                    array_push($msgs, ...$issues);
+                }
+            }
+        }
+        else
+        {
+            $msgs = [$msg];
+        }
+        return implode("\n", $msgs);
+    }
+
+    /**
+     * @param \Ydb\Issue\IssueMessage $issue
+     * @param int $level
+     * @return array
+     */
+    protected static function getSubIssues(IssueMessage $issue, $level = 0)
+    {
+        $msgs = [];
+        foreach ($issue->getIssues() as $sub_issue)
+        {
+            $msg = str_repeat('  ', $level) . '- ' . trim($sub_issue->getMessage());
+            if (count($sub_issue->getIssues()))
+            {
+                $msgs[] = $msg;
+                $issues = static::getSubIssues($sub_issue, $level + 1);
+                if ($issues)
+                {
+                    array_push($msgs, ...$issues);
+                }
+            }
+            else
+            {
+                $msgs[] = $msg;
+            }
+        }
+        return $msgs;
+    }
+}

src/Traits/RequestTrait.php

@@ -3,6 +3,8 @@
 namespace YandexCloud\Ydb\Traits;
 
 use Ydb\StatusIds\StatusCode;
+
+use YandexCloud\Ydb\Issue;
 use YandexCloud\Ydb\Exception;
 use YandexCloud\Ydb\QueryResult;
 
@@ -252,7 +254,14 @@ protected function processResponse($service, $method, $response, $resultClass)
             // case StatusCode::TRANSPORT_UNAVAILABLE:
             case StatusCode::TIMEOUT: // ?
                 $statusName = StatusCode::name($statusCode);
-                $message = $response->getIssues()->getIterator()->current()->getMessage();
+
+                $issues = [];
+                foreach ($response->getIssues() as $issue)
+                {
+                    $issues[] = (new Issue($issue))->toString();
+                }
+
+                $message = implode("\n", $issues);
 
                 $this->logger()->warning('YDB: Service [' . $service . '] method [' . $method . '] Failed to receive a valid response.', [
                     'status' => $statusCode . ' (' . $statusName . ')',
@@ -270,7 +279,14 @@ protected function processResponse($service, $method, $response, $resultClass)
 
             default:
                 $statusName = StatusCode::name($statusCode);
-                $message = $response->getIssues()->getIterator()->current()->getMessage();
+
+                $issues = [];
+                foreach ($response->getIssues() as $issue)
+                {
+                    $issues[] = (new Issue($issue))->toString();
+                }
+
+                $message = implode("\n", $issues);
 
                 $this->logger()->error(
                     'YDB: Service [' . $service . '] method [' . $method . '] Failed to receive a valid response.',