Add BoltKitIt for the new routing

Author: bigmontz

driver/src/test/java/org/neo4j/driver/integration/RoutingDriverBoltKitIT.java

@@ -613,6 +613,40 @@ void shouldHandleLeaderSwitchAndRetryWhenWritingInTxFunctionAsync() throws IOExc
         assertThat( writeServer.exitStatus(), equalTo( 0 ) );
     }
 
+    @Test
+    void shouldHandleLeaderSwitchAndRetryWhenWritingInTxFunctionAsyncV43() throws IOException, InterruptedException
+    {
+        // Given
+        StubServer server = stubController.startStub( "acquire_endpoints_twice_v43.script", 9001 );
+
+        // START a write server that fails on the first write attempt but then succeeds on the second
+        StubServer writeServer = stubController.startStub( "not_able_to_write_server_tx_func_retries.script", 9007 );
+        URI uri = URI.create( "neo4j://127.0.0.1:9001" );
+
+        Driver driver = GraphDatabase.driver( uri, Config.builder().withMaxTransactionRetryTime( 1, TimeUnit.MILLISECONDS ).build() );
+        AsyncSession session = driver.asyncSession( builder().withDatabase( "mydatabase" ).build() );
+        List<String> names = Futures.blockingGet( session.writeTransactionAsync(
+                tx -> tx.runAsync( "RETURN 1" )
+                        .thenComposeAsync( ignored -> {
+                            try
+                            {
+                                Thread.sleep( 100 );
+                            }
+                            catch ( InterruptedException ex )
+                            {
+                            }
+                            return tx.runAsync( "MATCH (n) RETURN n.name" );
+                        } )
+                        .thenComposeAsync( cursor -> cursor.listAsync( RoutingDriverBoltKitIT::extractNameField ) ) ) );
+
+        assertEquals( asList( "Foo", "Bar" ), names );
+
+        // Finally
+        driver.close();
+        assertThat( server.exitStatus(), equalTo( 0 ) );
+        assertThat( writeServer.exitStatus(), equalTo( 0 ) );
+    }
+
     private static String extractNameField(Record record)
     {
         return record.get( 0 ).asString();

driver/src/test/resources/acquire_endpoints_twice_v43.script

@@ -0,0 +1,13 @@
+!: BOLT 4.3
+!: AUTO RESET
+!: AUTO HELLO
+!: AUTO GOODBYE
+
+C: ROUTE { "address": "127.0.0.1:9001"} "mydatabase"
+S: SUCCESS {"rt": { "ttl": 9223372036854775807, "servers": [{"addresses": ["127.0.0.1:9007"],"role": "WRITE"}, {"addresses": ["127.0.0.1:9005","127.0.0.1:9006"], "role": "READ"},{"addresses": ["127.0.0.1:9001","127.0.0.1:9002","127.0.0.1:9003"], "role": "ROUTE"}] }}
+C: RUN "CALL dbms.routing.getRoutingTable($context, $database)" {"context": { "address": "127.0.0.1:9001"}, "database": "mydatabase"} {"mode": "r", "db": "system"}
+   PULL {"n": -1}
+S: SUCCESS {"fields": ["ttl", "servers"]}
+   RECORD [9223372036854775807, [{"addresses": ["127.0.0.1:9007"],"role": "WRITE"}, {"addresses": ["127.0.0.1:9005","127.0.0.1:9006"], "role": "READ"},{"addresses": ["127.0.0.1:9001","127.0.0.1:9002","127.0.0.1:9003"], "role": "ROUTE"}]]
+   SUCCESS {}
+   <EXIT>