[INTERNAL] Add tx type support to sync API (#1429)

Author: injectives

driver/src/main/java/org/neo4j/driver/internal/InternalSession.java

@@ -90,8 +90,12 @@ public Transaction beginTransaction() {
 
     @Override
     public Transaction beginTransaction(TransactionConfig config) {
-        UnmanagedTransaction tx = Futures.blockingGet(
-                session.beginTransactionAsync(config),
+        return beginTransaction(config, null);
+    }
+
+    public Transaction beginTransaction(TransactionConfig config, String txType) {
+        var tx = Futures.blockingGet(
+                session.beginTransactionAsync(config, txType),
                 () -> terminateConnectionOnThreadInterrupt("Thread interrupted while starting a transaction"));
         return new InternalTransaction(tx);
     }

driver/src/test/java/org/neo4j/driver/internal/InternalSessionTest.java

@@ -18,6 +18,7 @@
  */
 package org.neo4j.driver.internal;
 
+import static java.util.concurrent.CompletableFuture.completedFuture;
 import static org.junit.jupiter.api.Assertions.assertEquals;
 import static org.mockito.ArgumentMatchers.any;
 import static org.mockito.BDDMockito.given;
@@ -28,13 +29,15 @@
 import java.util.List;
 import java.util.function.Consumer;
 import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
 import org.junit.jupiter.params.ParameterizedTest;
 import org.junit.jupiter.params.provider.MethodSource;
 import org.neo4j.driver.Session;
 import org.neo4j.driver.TransactionCallback;
 import org.neo4j.driver.TransactionConfig;
 import org.neo4j.driver.TransactionContext;
 import org.neo4j.driver.internal.async.NetworkSession;
+import org.neo4j.driver.internal.async.UnmanagedTransaction;
 import org.neo4j.driver.internal.retry.RetryLogic;
 
 public class InternalSessionTest {
@@ -84,6 +87,19 @@ void shouldDelegateExecuteReadToRetryLogic(ExecuteVariation executeVariation) {
         then(logic).should().retry(any());
     }
 
+    @Test
+    void shouldDelegateBeginWithType() {
+        var internalSession = (InternalSession) session;
+        var config = TransactionConfig.empty();
+        var type = "TYPE";
+        given(networkSession.beginTransactionAsync(config, type))
+                .willReturn(completedFuture(mock(UnmanagedTransaction.class)));
+
+        internalSession.beginTransaction(config, type);
+
+        then(networkSession).should().beginTransactionAsync(config, type);
+    }
+
     static List<ExecuteVariation> executeVariations() {
         return Arrays.asList(
                 new ExecuteVariation(false, false, false),