added begin method to connection and made timeout and database optional

Author: transistive

src/Bolt/ServerStateRepository.php renamed to src/Bolt/StateTransitionRepository.php

@@ -22,7 +22,7 @@
  *
  * @psalm-immutable
  */
-final class ServerStateRepository
+final class StateTransitionRepository
 {
     private const TRANSITIONS = [
         ['CONNECTED', 'HELLO', null, 'SUCCESS', 'READY'],

src/Common/BoltConnection.php

@@ -47,6 +47,7 @@ final class BoltConnection implements ConnectionInterface
     private DriverConfiguration $driverConfiguration;
     private int $ownerCount = 0;
     private bool $hasBeenReset = false;
+    private string $expectedState = 'READY';
 
     /**
      * @psalm-mutation-free
@@ -172,6 +173,25 @@ public function reset(): void
         }
     }
 
+    /**
+     * @param string|null $database the database to connect to
+     * @param float|null  $timeout  timeout in seconds
+     */
+    public function begin(?string $database, ?float $timeout): void
+    {
+        $params = [];
+        if ($database) {
+            $params['db'] = $database;
+        }
+        if ($timeout) {
+            $params['tx_timeout'] = $timeout * 1000;
+        }
+
+        if ($this->boltProtocol) {
+            $this->boltProtocol->begin($params);
+        }
+    }
+
     /**
      * @psalm-mutation-free
      */

src/Databags/SessionConfiguration.php

@@ -145,9 +145,9 @@ public function getAccessMode(): AccessMode
     /**
      * The database where the session is going to connect to.
      */
-    public function getDatabase(): string
+    public function getDatabase(): ?string
     {
-        return $this->database ?? self::DEFAULT_DATABASE;
+        return $this->database;
     }
 
     /**

src/Databags/TransactionConfiguration.php

@@ -62,29 +62,29 @@ public static function default(): self
     /**
      * Get the configured transaction metadata.
      *
-     * @return iterable<string, scalar|array|null>
+     * @return iterable<string, scalar|array|null>|null
      */
-    public function getMetaData(): iterable
+    public function getMetaData(): ?iterable
     {
         $tbr = $this->metaData;
         if (is_callable($tbr)) {
             $tbr = $tbr();
         }
 
-        return $tbr ?? [];
+        return $tbr;
     }
 
     /**
      * Get the configured transaction timeout in seconds.
      */
-    public function getTimeout(): float
+    public function getTimeout(): ?float
     {
         $tbr = $this->timeout;
         if (is_callable($tbr)) {
             $tbr = $tbr();
         }
 
-        return $tbr ?? self::DEFAULT_TIMEOUT;
+        return $tbr;
     }
 
     /**