Skip to content

Commit 24a2f86

Browse files
committed
Update
1 parent 11ab7e7 commit 24a2f86

File tree

8 files changed

+14
-2
lines changed

8 files changed

+14
-2
lines changed

driver/src/test/java/org/neo4j/driver/internal/cluster/AbstractRoutingProcedureRunnerTest.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -25,6 +25,8 @@
2525

2626
import org.neo4j.driver.Record;
2727
import org.neo4j.driver.exceptions.ClientException;
28+
import org.neo4j.driver.internal.messaging.BoltProtocol;
29+
import org.neo4j.driver.internal.messaging.BoltProtocolVersion;
2830
import org.neo4j.driver.internal.spi.Connection;
2931

3032
import static org.junit.jupiter.api.Assertions.assertEquals;
@@ -101,6 +103,10 @@ static Connection connection()
101103
static Connection connection( CompletionStage<Void> releaseStage )
102104
{
103105
Connection connection = mock( Connection.class );
106+
BoltProtocol boltProtocol = mock( BoltProtocol.class );
107+
BoltProtocolVersion protocolVersion = new BoltProtocolVersion( 4, 4 );
108+
when( boltProtocol.version() ).thenReturn( protocolVersion );
109+
when( connection.protocol() ).thenReturn( boltProtocol );
104110
when( connection.release() ).thenReturn( releaseStage );
105111
return connection;
106112
}

driver/src/test/java/org/neo4j/driver/internal/handlers/HelloResponseHandlerTest.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -110,13 +110,13 @@ void shouldThrowWhenServerVersionIsNull()
110110
}
111111

112112
@Test
113-
void shouldThrowWhenServerVersionCantBeParsed()
113+
void shouldThrowWhenServerAgentIsUnrecognised()
114114
{
115115
ChannelPromise channelPromise = channel.newPromise();
116116
HelloResponseHandler handler = new HelloResponseHandler( channelPromise );
117117

118118
Map<String,Value> metadata = metadata( "WrongServerVersion", "bolt-x" );
119-
assertThrows( IllegalArgumentException.class, () -> handler.onSuccess( metadata ) );
119+
assertThrows( UntrustedServerException.class, () -> handler.onSuccess( metadata ) );
120120

121121
assertFalse( channelPromise.isSuccess() ); // initialization failed
122122
assertTrue( channel.closeFuture().isDone() ); // channel was closed

driver/src/test/java/org/neo4j/driver/internal/messaging/v3/BoltProtocolV3Test.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -149,6 +149,7 @@ void shouldInitializeChannel()
149149
assertFalse( promise.isDone() );
150150

151151
Map<String,Value> metadata = new HashMap<>();
152+
metadata.put( "server", value( "Neo4j/3.5.0" ) );
152153
metadata.put( "connection_id", value( "bolt-42" ) );
153154

154155
messageDispatcher.handleSuccessMessage( metadata );

driver/src/test/java/org/neo4j/driver/internal/messaging/v4/BoltProtocolV4Test.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -142,6 +142,7 @@ void shouldInitializeChannel()
142142
assertFalse( promise.isDone() );
143143

144144
Map<String,Value> metadata = new HashMap<>();
145+
metadata.put( "server", value( "Neo4j/4.0.0" ) );
145146
metadata.put( "connection_id", value( "bolt-42" ) );
146147

147148
messageDispatcher.handleSuccessMessage( metadata );

driver/src/test/java/org/neo4j/driver/internal/messaging/v41/BoltProtocolV41Test.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -147,6 +147,7 @@ void shouldInitializeChannel()
147147
assertFalse( promise.isDone() );
148148

149149
Map<String,Value> metadata = new HashMap<>();
150+
metadata.put( "server", value( "Neo4j/4.1.0" ) );
150151
metadata.put( "connection_id", value( "bolt-42" ) );
151152

152153
messageDispatcher.handleSuccessMessage( metadata );

driver/src/test/java/org/neo4j/driver/internal/messaging/v42/BoltProtocolV42Test.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -147,6 +147,7 @@ void shouldInitializeChannel()
147147
assertFalse( promise.isDone() );
148148

149149
Map<String,Value> metadata = new HashMap<>();
150+
metadata.put( "server", value( "Neo4j/4.2.0" ) );
150151
metadata.put( "connection_id", value( "bolt-42" ) );
151152

152153
messageDispatcher.handleSuccessMessage( metadata );

driver/src/test/java/org/neo4j/driver/internal/messaging/v43/BoltProtocolV43Test.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -146,6 +146,7 @@ void shouldInitializeChannel()
146146
assertFalse( promise.isDone() );
147147

148148
Map<String,Value> metadata = new HashMap<>();
149+
metadata.put( "server", value( "Neo4j/4.3.0" ) );
149150
metadata.put( "connection_id", value( "bolt-42" ) );
150151

151152
messageDispatcher.handleSuccessMessage( metadata );

driver/src/test/java/org/neo4j/driver/internal/messaging/v44/BoltProtocolV44Test.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -146,6 +146,7 @@ void shouldInitializeChannel()
146146
assertFalse( promise.isDone() );
147147

148148
Map<String,Value> metadata = new HashMap<>();
149+
metadata.put( "server", value( "Neo4j/4.4.0" ) );
149150
metadata.put( "connection_id", value( "bolt-42" ) );
150151

151152
messageDispatcher.handleSuccessMessage( metadata );

0 commit comments

Comments
 (0)