[INTERNAL] Add interrupt to sync API (#1427)

Author: injectives

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

@@ -66,6 +66,15 @@ public boolean isOpen() {
         return tx.isOpen();
     }
 
+    /**
+     * Marks transaction as terminated and sends {@code RESET} message over allocated connection.
+     * <p>
+     * <b>THIS METHOD IS NOT PART OF PUBLIC API. This method may be changed or removed at any moment in time.</b>
+     */
+    public void interrupt() {
+        Futures.blockingGet(tx.interruptAsync());
+    }
+
     private void terminateConnectionOnThreadInterrupt(String reason) {
         tx.connection().terminateAndRelease(reason);
     }

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

@@ -24,6 +24,8 @@
 import static org.junit.Assert.assertFalse;
 import static org.junit.jupiter.api.Assertions.assertThrows;
 import static org.mockito.ArgumentMatchers.any;
+import static org.mockito.BDDMockito.given;
+import static org.mockito.BDDMockito.then;
 import static org.mockito.Mockito.mock;
 import static org.mockito.Mockito.verify;
 import static org.mockito.Mockito.when;
@@ -38,6 +40,7 @@
 import static org.neo4j.driver.testutil.TestUtil.verifyRollbackTx;
 import static org.neo4j.driver.testutil.TestUtil.verifyRunAndPull;
 
+import java.util.concurrent.CompletableFuture;
 import java.util.function.Consumer;
 import java.util.function.Function;
 import java.util.stream.Stream;
@@ -50,6 +53,7 @@
 import org.neo4j.driver.Transaction;
 import org.neo4j.driver.Value;
 import org.neo4j.driver.internal.async.ConnectionContext;
+import org.neo4j.driver.internal.async.UnmanagedTransaction;
 import org.neo4j.driver.internal.messaging.v4.BoltProtocolV4;
 import org.neo4j.driver.internal.spi.Connection;
 import org.neo4j.driver.internal.spi.ConnectionProvider;
@@ -150,6 +154,17 @@ void shouldReleaseConnectionWhenFailedToClose() {
         shouldReleaseConnectionWhenFailedToAction(Transaction::close);
     }
 
+    @Test
+    void shouldDelegateInterrupt() {
+        var unmanagedTx = mock(UnmanagedTransaction.class);
+        given(unmanagedTx.interruptAsync()).willReturn(CompletableFuture.completedFuture(null));
+        var tx = new InternalTransaction(unmanagedTx);
+
+        tx.interrupt();
+
+        then(unmanagedTx).should().interruptAsync();
+    }
+
     private void shouldReleaseConnectionWhenFailedToAction(Consumer<Transaction> txAction) {
         setupFailingRollback(connection);
         assertThrows(Exception.class, () -> txAction.accept(tx));