passed bookmarks to bolt protocol

Author: transistive

src/Bolt/BoltConnection.php

@@ -21,6 +21,7 @@
 use Laudis\Neo4j\BoltFactory;
 use Laudis\Neo4j\Common\ConnectionConfiguration;
 use Laudis\Neo4j\Contracts\ConnectionInterface;
+use Laudis\Neo4j\Databags\BookmarkHolder;
 use Laudis\Neo4j\Databags\DatabaseInfo;
 use Laudis\Neo4j\Databags\DriverConfiguration;
 use Laudis\Neo4j\Enum\AccessMode;
@@ -270,14 +271,14 @@ public function discard(?int $qid): void
      *
      * @return BoltMeta
      */
-    public function run(string $text, array $parameters, ?string $database, ?float $timeout): array
+    public function run(string $text, array $parameters, ?string $database, ?float $timeout, BookmarkHolder $holder): array
     {
         if (!str_starts_with($this->serverState, 'TX_') || str_starts_with($this->getServerVersion(), '3')) {
             $this->consumeResults();
         }
 
         try {
-            $extra = $this->buildRunExtra($database, $timeout);
+            $extra = $this->buildRunExtra($database, $timeout, $holder);
 
             $tbr = $this->protocol()->run($text, $parameters, $extra);
 
@@ -398,7 +399,7 @@ public function __destruct()
         }
     }
 
-    private function buildRunExtra(?string $database, ?float $timeout): array
+    private function buildRunExtra(?string $database, ?float $timeout, BookmarkHolder $holder): array
     {
         $extra = [];
         if ($database) {
@@ -408,6 +409,10 @@ private function buildRunExtra(?string $database, ?float $timeout): array
             $extra['tx_timeout'] = (int) ($timeout * 1000);
         }
 
+        if (!$holder->getBookmark()->isEmpty()) {
+            $extra['bookmarks'] = $holder->getBookmark()->values();
+        }
+
         return $extra;
     }
 

src/Bolt/BoltUnmanagedTransaction.php

@@ -132,7 +132,8 @@ public function runStatement(Statement $statement)
                 $statement->getText(),
                 $parameters->toArray(),
                 $this->database,
-                $this->tsxConfig->getTimeout()
+                $this->tsxConfig->getTimeout(),
+                $this->bookmarkHolder
             );
             $run = microtime(true);
         } catch (MessageException $e) {