fixed summary handling

Author: transistive

src/Formatter/SummarizedResultFormatter.php

@@ -72,7 +72,13 @@ public function __construct(OGMFormatter $formatter)
      */
     public function formatHttpStats(stdClass $response, ConnectionInterface $connection, Statement $statement, float $resultAvailableAfter, float $resultConsumedAfter, CypherList $results): SummarizedResult
     {
-        if (!isset($response->stats)) {
+        if ($response->summary instanceof stdClass) {
+            /** @var stdClass $stats */
+            $stats = $response->summary->stats;
+        } elseif (!isset($response->stats)) {
+            /** @var stdClass $stats */
+            $stats = $response->stats;
+        } else {
             throw new UnexpectedValueException('No stats found in the response set');
         }
 
@@ -81,20 +87,20 @@ public function formatHttpStats(stdClass $response, ConnectionInterface $connect
          * @psalm-suppress MixedArgument
          */
         $counters = new SummaryCounters(
-            $response->stats->nodes_created ?? 0,
-            $response->stats->nodes_deleted ?? 0,
-            $response->stats->relationships_created ?? 0,
-            $response->stats->relationships_deleted ?? 0,
-            $response->stats->properties_set ?? 0,
-            $response->stats->labels_added ?? 0,
-            $response->stats->labels_removed ?? 0,
-            $response->stats->indexes_added ?? 0,
-            $response->stats->indexes_removed ?? 0,
-            $response->stats->constraints_added ?? 0,
-            $response->stats->constraints_removed ?? 0,
-            $response->stats->contains_updates ?? false,
-            $response->stats->contains_system_updates ?? false,
-            $response->stats->system_updates ?? 0,
+            $stats->nodes_created ?? 0,
+            $stats->nodes_deleted ?? 0,
+            $stats->relationships_created ?? 0,
+            $stats->relationships_deleted ?? 0,
+            $stats->properties_set ?? 0,
+            $stats->labels_added ?? 0,
+            $stats->labels_removed ?? 0,
+            $stats->indexes_added ?? 0,
+            $stats->indexes_removed ?? 0,
+            $stats->constraints_added ?? 0,
+            $stats->constraints_removed ?? 0,
+            $stats->contains_updates ?? false,
+            $stats->contains_system_updates ?? false,
+            $stats->system_updates ?? 0,
         );
 
         $summary = new ResultSummary(

src/Http/HttpSession.php

@@ -13,6 +13,7 @@
 
 namespace Laudis\Neo4j\Http;
 
+use function is_object;
 use JsonException;
 use Laudis\Neo4j\Common\Resolvable;
 use Laudis\Neo4j\Common\TransactionHelper;
@@ -26,14 +27,13 @@
 use Laudis\Neo4j\Databags\TransactionConfiguration;
 use Laudis\Neo4j\Enum\AccessMode;
 use Laudis\Neo4j\Types\CypherList;
+use function microtime;
+use function parse_url;
+use const PHP_URL_PATH;
 use Psr\Http\Client\ClientInterface;
 use Psr\Http\Message\RequestInterface;
 use Psr\Http\Message\StreamFactoryInterface;
 use stdClass;
-use function is_object;
-use function microtime;
-use function parse_url;
-use const PHP_URL_PATH;
 
 /**
  * @template T
@@ -78,22 +78,21 @@ final class HttpSession implements SessionInterface
     /**
      * @psalm-mutation-free
      *
-     * @param FormatterInterface<T> $formatter
+     * @param FormatterInterface<T>              $formatter
      * @param Resolvable<StreamFactoryInterface> $factory
-     * @param Resolvable<string> $uri
-     * @param Resolvable<RequestFactory> $requestFactory
+     * @param Resolvable<string>                 $uri
+     * @param Resolvable<RequestFactory>         $requestFactory
      */
     public function __construct(
-        Resolvable            $factory,
-        HttpConnectionPool    $manager,
-        SessionConfiguration  $config,
-        FormatterInterface    $formatter,
-        Resolvable            $requestFactory,
-        Resolvable            $uri,
+        Resolvable $factory,
+        HttpConnectionPool $manager,
+        SessionConfiguration $config,
+        FormatterInterface $formatter,
+        Resolvable $requestFactory,
+        Resolvable $uri,
         AuthenticateInterface $auth,
-        string                $userAgent
-    )
-    {
+        string $userAgent
+    ) {
         $this->streamFactory = $factory;
         $this->config = $config;
         $this->pool = $manager;
@@ -134,7 +133,7 @@ public function openTransaction(iterable $statements = null, ?TransactionConfigu
 
     public function writeTransaction(callable $tsxHandler, ?TransactionConfiguration $config = null)
     {
-        return TransactionHelper::retry(fn() => $this->openTransaction(), $tsxHandler);
+        return TransactionHelper::retry(fn () => $this->openTransaction(), $tsxHandler);
     }
 
     public function readTransaction(callable $tsxHandler, ?TransactionConfiguration $config = null)
@@ -213,7 +212,7 @@ private function makeTransaction(ConnectionInterface $connection, RequestInterfa
 
     private function instantCommitRequest(RequestInterface $request): RequestInterface
     {
-        $path = $request->getUri()->getPath() . '/commit';
+        $path = $request->getUri()->getPath().'/commit';
         $uri = $request->getUri()->withPath($path);
 
         return $request->withUri($uri);