added test for bookmark updates

Author: transistive

src/Bolt/BoltConnection.php

@@ -210,11 +210,11 @@ public function reset(): void
      *
      * Any of the preconditioned states are: 'READY', 'INTERRUPTED'.
      */
-    public function begin(?string $database, ?float $timeout): void
+    public function begin(?string $database, ?float $timeout, BookmarkHolder $holder): void
     {
         $this->consumeResults();
 
-        $extra = $this->buildRunExtra($database, $timeout);
+        $extra = $this->buildRunExtra($database, $timeout, $holder);
         try {
             $this->protocol()->begin($extra);
         } catch (IgnoredException $e) {

src/Bolt/Session.php

@@ -180,7 +180,7 @@ private function startTransaction(TransactionConfiguration $config, SessionConfi
         try {
             $connection = $this->acquireConnection($config, $sessionConfig);
 
-            $connection->begin($this->config->getDatabase(), $config->getTimeout());
+            $connection->begin($this->config->getDatabase(), $config->getTimeout(), $this->bookmarkHolder);
         } catch (MessageException $e) {
             if (isset($connection) && $connection->getServerState() === 'FAILED') {
                 $connection->reset();

tests/Integration/BoltDriverIntegrationTest.php

@@ -18,6 +18,8 @@
 use Exception;
 use Laudis\Neo4j\Bolt\BoltDriver;
 use Laudis\Neo4j\Common\Uri;
+use Laudis\Neo4j\Contracts\TransactionInterface;
+use Laudis\Neo4j\Databags\SummarizedResult;
 use PHPUnit\Framework\TestCase;
 use Psr\Http\Message\UriInterface;
 
@@ -103,4 +105,34 @@ public function testInvalidSocket(): void
         $this->expectException(ConnectException::class);
         $driver->createSession()->run('RETURN 1');
     }
+
+    public function testBookmarkUpdates(): void
+    {
+        if ($this->uri === null) {
+            self::markTestSkipped('No bolt uri provided');
+        }
+
+        $session = BoltDriver::create($this->uri->__toString())->createSession();
+        $bookmark = $session->getLastBookmark();
+        $this->assertEquals([], $bookmark->values());
+        $this->assertTrue($bookmark->isEmpty());
+        $previousBookmark = $bookmark;
+
+        /** @var SummarizedResult $result */
+        $result = $session->run('MATCH (x) RETURN x');
+        $result->preload();
+
+        $bookmark = $session->getLastBookmark();
+        $this->assertFalse($bookmark->isEmpty());
+        $this->assertNotEquals($previousBookmark->values(), $bookmark->values());
+        $previousBookmark = $bookmark;
+
+        /** @var SummarizedResult $result */
+        $result = $session->run('CREATE (x:Node)');
+        $result->preload();
+
+        $bookmark = $session->getLastBookmark();
+        $this->assertFalse($bookmark->isEmpty());
+        $this->assertNotEquals($previousBookmark->values(), $bookmark->values());
+    }
 }