Use stub server instead of an actual cluster

Author: ali-ince

examples/src/main/java/org/neo4j/docs/driver/ConfigCustomResolverExample.java

@@ -36,9 +36,11 @@ public class ConfigCustomResolverExample implements AutoCloseable
 {
     private final Driver driver;
 
-    public ConfigCustomResolverExample( String virtualUri, String user, String password, ServerAddress[] addresses )
+    public ConfigCustomResolverExample( String virtualUri, ServerAddress... addresses )
     {
-        driver = createDriver( virtualUri, user, password, addresses );
+        driver = GraphDatabase.driver( virtualUri, AuthTokens.none(),
+                Config.build().withoutEncryption().withResolver( address -> new HashSet<>( Arrays.asList( addresses ) ) ).toConfig() );
+
     }
 
     // tag::config-custom-resolver[]
@@ -72,7 +74,7 @@ public void close() throws Exception
 
     public boolean canConnect()
     {
-        StatementResult result = driver.session().run( "RETURN 1" );
+        StatementResult result = driver.session( AccessMode.READ ).run( "RETURN 1" );
         return result.single().get( 0 ).asInt() == 1;
     }
 }

examples/src/test/java/org/neo4j/docs/driver/ExamplesClusterIT.java renamed to examples/src/test/java/org/neo4j/docs/driver/ExamplesStubIT.java

@@ -19,32 +19,31 @@
 package org.neo4j.docs.driver;
 
 import org.junit.jupiter.api.Test;
-import org.junit.jupiter.api.extension.RegisterExtension;
 
 import org.neo4j.driver.v1.net.ServerAddress;
-import org.neo4j.driver.v1.util.cc.Cluster;
-import org.neo4j.driver.v1.util.cc.ClusterExtension;
+import org.neo4j.driver.v1.util.StubServer;
 
+import static org.junit.jupiter.api.Assertions.assertEquals;
 import static org.junit.jupiter.api.Assertions.assertTrue;
-import static org.neo4j.driver.v1.util.Neo4jRunner.PASSWORD;
-import static org.neo4j.driver.v1.util.Neo4jRunner.USER;
 
-class ExamplesClusterIT
+public class ExamplesStubIT
 {
-    @RegisterExtension
-    static final ClusterExtension neo4j = new ClusterExtension();
-
     @Test
     void testShouldRunConfigCustomResolverExample() throws Exception
     {
-        Cluster cluster = neo4j.getCluster();
+        StubServer server1 = StubServer.start( "get_routing_table_only.script", 9001 );
+        StubServer server2 = StubServer.start( "return_1.script", 9002 );
 
         // Given
-        try ( ConfigCustomResolverExample example = new ConfigCustomResolverExample( "bolt+routing://x.acme.com", USER, PASSWORD,
-                cluster.cores().stream().map( c -> c.getBoltAddress() ).toArray( i -> new ServerAddress[i] ) ) )
+        try ( ConfigCustomResolverExample example = new ConfigCustomResolverExample( "bolt+routing://x.acme.com", ServerAddress.of( "localhost", 9001 ) ) )
         {
             // Then
             assertTrue( example.canConnect() );
         }
+        finally
+        {
+            assertEquals( 0, server1.exitStatus() );
+            assertEquals( 0, server2.exitStatus() );
+        }
     }
 }

examples/src/test/resources/get_routing_table_only.script

@@ -0,0 +1,11 @@
+!: AUTO INIT
+!: AUTO RESET
+!: AUTO PULL_ALL
+
+S: SUCCESS {"server": "Neo4j/3.2.2"}
+C: RUN "CALL dbms.cluster.routing.getRoutingTable({context})" {"context": {}}
+   PULL_ALL
+S: SUCCESS {"fields": ["ttl", "servers"]}
+   RECORD [9223372036854775807, [{"addresses": ["127.0.0.1:9001"],"role": "WRITE"}, {"addresses": ["127.0.0.1:9002"], "role": "READ"},{"addresses": ["127.0.0.1:9001"], "role": "ROUTE"}]]
+   SUCCESS {}
+S: <EXIT>

examples/src/test/resources/return_1.script

@@ -0,0 +1,12 @@
+!: AUTO INIT
+!: AUTO RESET
+!: AUTO PULL_ALL
+!: AUTO RUN "COMMIT" {}
+!: AUTO RUN "ROLLBACK" {}
+!: AUTO RUN "BEGIN" {}
+
+C: RUN "RETURN 1" {}
+   PULL_ALL
+S: SUCCESS {"fields": ["1"]}
+   RECORD [1]
+   SUCCESS {}