added functionality for binding transactions to client

Author: transistive

src/Basic/Client.php

@@ -77,4 +77,19 @@ public function verifyConnectivity(?string $driver = null): bool
     {
         return $this->client->verifyConnectivity($driver);
     }
+
+    public function bindTransaction(?string $alias = null, ?TransactionConfiguration $config = null): void
+    {
+        $this->client->bindTransaction($alias, $config);
+    }
+
+    public function commitBoundTransaction(?string $alias = null, int $depth = 1): void
+    {
+        $this->client->commitBoundTransaction($alias, $depth);
+    }
+
+    public function rollbackBoundTransaction(?string $alias = null, int $depth = 1): void
+    {
+        $this->client->rollbackBoundTransaction($alias, $depth);
+    }
 }

src/Client.php

@@ -33,6 +33,11 @@
  */
 final class Client implements ClientInterface
 {
+    /**
+     * @var array<string, list<UnmanagedTransactionInterface<ResultFormat>>>
+     */
+    private array $boundTransactions = [];
+
     /**
      * @psalm-mutation-free
      *
@@ -108,6 +113,42 @@ public function verifyConnectivity(?string $driver = null): bool
         return $this->driverSetups->verifyConnectivity($this->defaultSessionConfiguration, $driver);
     }
 
+    public function bindTransaction(?string $alias = null, ?TransactionConfiguration $config = null): void
+    {
+        $alias ??= $this->driverSetups->getDefaultAlias();
+
+        $this->boundTransactions[$alias] ??= [];
+        $this->boundTransactions[$alias][] = $this->beginTransaction(null, $alias, $config);
+    }
+
+    public function rollbackBoundTransaction(?string $alias = null, int $depth = 1): void
+    {
+        $this->popTransactions(static fn (UnmanagedTransactionInterface $tsx) => $tsx->rollback(), $alias, $depth);
+    }
+
+    /**
+     * @param callable(UnmanagedTransactionInterface<ResultFormat>): void $handler
+     */
+    private function popTransactions(callable $handler, ?string $alias = null, int $depth = 1): void
+    {
+        $alias ??= $this->driverSetups->getDefaultAlias();
+
+        if (!array_key_exists($alias, $this->boundTransactions)) {
+            return;
+        }
+
+        while (count($this->boundTransactions[$alias]) !== 0 && $depth !== 0) {
+            $tsx = array_pop($this->boundTransactions[$alias]);
+            $handler($tsx);
+            --$depth;
+        }
+    }
+
+    public function commitBoundTransaction(?string $alias = null, int $depth = 1): void
+    {
+        $this->popTransactions(static fn (UnmanagedTransactionInterface $tsx) => $tsx->commit(), $alias, $depth);
+    }
+
     private function getTsxConfig(?TransactionConfiguration $config): TransactionConfiguration
     {
         if ($config !== null) {

src/Common/DriverSetupManager.php

@@ -137,6 +137,11 @@ private function decideAlias(?string $alias): string
         return $alias ?? $this->default ?? array_key_first($this->driverSetups) ?? 'default';
     }
 
+    public function getDefaultAlias(): string
+    {
+        return $this->decideAlias(null);
+    }
+
     /**
      * @psalm-mutation-free
      */

src/Contracts/ClientInterface.php

@@ -109,4 +109,19 @@ public function transaction(callable $tsxHandler, ?string $alias = null, ?Transa
      * Checks to see if the driver can make a valid connection to the configured neo4j server.
      */
     public function verifyConnectivity(?string $driver = null): bool;
+
+    /**
+     * Binds a transaction to the client, so it runs all subsequent queries on the latest transaction instead of a session or the previously bound transaction.
+     */
+    public function bindTransaction(?string $alias = null, ?TransactionConfiguration $config = null): void;
+
+    /**
+     * Release a transaction from the client by committing it, so it runs all subsequent queries on a session or the previously bound transaction instead of the latest transaction. You can control the amount of transactions to be released by the depth parameter, with -1 being all transactions.
+     */
+    public function commitBoundTransaction(?string $alias = null, int $depth = 1): void;
+
+    /**
+     * Release a transaction from the client by rolling it back, so it runs all subsequent queries on a session or the previously bound transaction instead of the latest transaction. You can control the amount of transactions to be released by the depth parameter, with -1 being all transactions.
+     */
+    public function rollbackBoundTransaction(?string $alias = null, int $depth = 1): void;
 }