fixed bad timeout format

Author: transistive

src/Bolt/BoltConnection.php

@@ -156,7 +156,6 @@ public function close(): void
         $this->protocol()->goodbye();
 
         $this->serverState = 'DEFUNCT';
-        $this->subscribedResults = [];
     }
 
     private function consumeResults(): void
@@ -386,7 +385,7 @@ private function buildRunExtra(?string $database, ?float $timeout): array
             $extra['db'] = $database;
         }
         if ($timeout) {
-            $extra['tx_timeout'] = $timeout * 1000;
+            $extra['tx_timeout'] = (int) ($timeout * 1000);
         }
 
         return $extra;
@@ -411,7 +410,7 @@ public function getServerState(): string
         return $this->serverState;
     }
 
-    private function subscribeResult(SummarizedResult $result): void
+    public function subscribeResult(SummarizedResult $result): void
     {
         $this->subscribedResults[] = WeakReference::create($result);
     }

src/Formatter/SummarizedResultFormatter.php

@@ -197,9 +197,13 @@ public function formatBoltResult(array $meta, BoltResult $result, BoltConnection
         /**
          * @psalm-suppress MixedArgument
          *
-         * @var SummarizedResult<CypherMap<OGMTypes>>
+         * @var SummarizedResult<CypherMap<OGMTypes>> $result
          */
-        return (new SummarizedResult($summary, $formattedResult))->withCacheLimit($result->getFetchSize());
+        $result = (new SummarizedResult($summary, $formattedResult))->withCacheLimit($result->getFetchSize());
+
+        $connection->subscribeResult($result);
+
+        return $result;
     }
 
     /**

tests/Integration/BasicDriverTest.php

@@ -1,4 +1,5 @@
 <?php
+declare(strict_types=1);
 
 /*
  * This file is part of the Laudis Neo4j package.
@@ -57,7 +58,7 @@ public function testFullWalk(string $connection): void
 
         $session = $driver->createSession();
 
-        $x = $session->run('MATCH (x) DETACH DELETE x');
+        $session->run('MATCH (x) DETACH DELETE x');
         $session->run('CREATE (x:X {id: 0})');
 
         $id = 1;

tests/Integration/BoltResultIntegrationTest.php

@@ -14,6 +14,7 @@
 use Bolt\Bolt;
 use Bolt\connection\StreamSocket;
 use Dotenv\Dotenv;
+use Laudis\Neo4j\Common\ConnectionConfiguration;
 use function explode;
 use function is_string;
 use Laudis\Neo4j\Authentication\Authenticate;
@@ -62,17 +63,16 @@ public function testIterationLong(string $connection): void
 
         $i = 0;
         $factory = new BoltFactory(new Bolt($socket), Authenticate::fromUrl($uri), '', $socket);
-        $connection = new BoltConnection(
+        $config = new ConnectionConfiguration(
             '',
             $uri,
             '',
             ConnectionProtocol::determineBoltVersion($factory->build()[0]),
             AccessMode::READ(),
-            new DatabaseInfo(''),
-            $factory,
-            null,
-            DriverConfiguration::default()
+            DriverConfiguration::default(),
+            null
         );
+        $connection = new BoltConnection($factory, null, $config);
         $connection->open();
         $connection->getImplementation()->run('UNWIND range(1, 100000) AS i RETURN i');
         $result = new BoltResult($connection, 1000, -1);