Skip to content

Commit

Permalink
Fix failing tests
Browse files Browse the repository at this point in the history
  • Loading branch information
Zhen Li committed Aug 18, 2017
1 parent 6548aa0 commit b0e429a
Showing 1 changed file with 12 additions and 12 deletions.
24 changes: 12 additions & 12 deletions Neo4j.Driver/Neo4j.Driver.Tests/Routing/RoutingTableManagerTests.cs
View file
Original file line number Diff line number Diff line change
Expand Up @@ -32,9 +32,9 @@ public class RoutingTableManagerTests
{
internal static RoutingTableManager NewRoutingTableManager(
IRoutingTable routingTable,
IClusterConnectionPoolManager poolManager,
Uri seedUri)
IClusterConnectionPoolManager poolManager)
{
var seedUri = new Uri("bolt+routing://neo4j.com:6060");
return new RoutingTableManager(
routingTable,
new RoutingSettings(seedUri, new Dictionary<string, string>()),
Expand Down Expand Up @@ -102,7 +102,7 @@ public void ShouldPrependInitialRouterIfWriterIsAbsent()
poolManagerMock.Setup(x => x.AddConnectionPool(It.IsAny<IEnumerable<Uri>>()))
.Callback<IEnumerable<Uri>>(r => r.Single().Should().Be(uri));

var manager = NewRoutingTableManager(routingTableMock.Object, poolManagerMock.Object, null);
var manager = NewRoutingTableManager(routingTableMock.Object, poolManagerMock.Object);
manager.IsReadingInAbsenceOfWriter = true;
var routingTableReturnMock = new Mock<IRoutingTable>();

Expand Down Expand Up @@ -133,7 +133,7 @@ public void ShouldAddInitialUriWhenNoAvailableRouters()
poolManagerMock.Setup(x => x.AddConnectionPool(It.IsAny<IEnumerable<Uri>>()))
.Callback<IEnumerable<Uri>>(r => r.Single().Should().Be(uri));

var manager = NewRoutingTableManager(routingTableMock.Object, poolManagerMock.Object, null);
var manager = NewRoutingTableManager(routingTableMock.Object, poolManagerMock.Object);
var routingTableReturnMock = new Mock<IRoutingTable>();

// When
Expand Down Expand Up @@ -163,7 +163,7 @@ public void ShouldNotTryInitialUriIfAlreadyTried()
poolManagerMock.Setup(x => x.AddConnectionPool(It.IsAny<IEnumerable<Uri>>()))
.Callback<IEnumerable<Uri>>(r => r.Single().Should().Be(t));

var manager = NewRoutingTableManager(routingTableMock.Object, poolManagerMock.Object, null);
var manager = NewRoutingTableManager(routingTableMock.Object, poolManagerMock.Object);

IRoutingTable UpdateRoutingTableFunc(ISet<Uri> set)
{
Expand Down Expand Up @@ -204,7 +204,7 @@ public void ShouldForgetAndTryNextRouterWhenConnectionIsNull()
var poolManagerMock = new Mock<IClusterConnectionPoolManager>();
poolManagerMock.Setup(x => x.CreateClusterConnection(It.IsAny<Uri>()))
.Returns((ClusterConnection) null);
var manager = NewRoutingTableManager(routingTable, poolManagerMock.Object, null);
var manager = NewRoutingTableManager(routingTable, poolManagerMock.Object);

// When
var newRoutingTable = manager.UpdateRoutingTable(null, connection =>
Expand All @@ -229,7 +229,7 @@ public void ShouldForgetAndTryNextRouterWhenFailedWithConnectionError()
var poolManagerMock = new Mock<IClusterConnectionPoolManager>();
poolManagerMock.SetupSequence(x => x.CreateClusterConnection(It.IsAny<Uri>()))
.Returns(connA).Returns(connB);
var manager = NewRoutingTableManager(routingTable, poolManagerMock.Object, null);
var manager = NewRoutingTableManager(routingTable, poolManagerMock.Object);

// When
var newRoutingTable = manager.UpdateRoutingTable(null, connection =>
Expand Down Expand Up @@ -262,7 +262,7 @@ public void ShouldPropagateServiceUnavailable()
poolManagerMock.Setup(x => x.CreateClusterConnection(uri))
.Returns(new Mock<IConnection>().Object);

var manager = NewRoutingTableManager(routingTable, poolManagerMock.Object, null);
var manager = NewRoutingTableManager(routingTable, poolManagerMock.Object);

var exception = Record.Exception(() => manager.UpdateRoutingTable(null,
conn => throw new ServiceUnavailableException("Procedure not found")));
Expand All @@ -280,7 +280,7 @@ public void ShouldPropagateProtocolError()
var poolManagerMock = new Mock<IClusterConnectionPoolManager>();
poolManagerMock.Setup(x => x.CreateClusterConnection(uri))
.Returns(new Mock<IConnection>().Object);
var manager = NewRoutingTableManager(routingTable, poolManagerMock.Object, null);
var manager = NewRoutingTableManager(routingTable, poolManagerMock.Object);

var exception = Record.Exception(() => manager.UpdateRoutingTable(null,
conn => throw new ProtocolException("Cannot parse procedure result")));
Expand All @@ -298,7 +298,7 @@ public void ShouldPropagateAuthenticationException()
var poolManagerMock = new Mock<IClusterConnectionPoolManager>();
poolManagerMock.Setup(x => x.CreateClusterConnection(uri))
.Callback(() => throw new AuthenticationException("Failed to auth the client to the server."));
var manager = NewRoutingTableManager(routingTable, poolManagerMock.Object, null);
var manager = NewRoutingTableManager(routingTable, poolManagerMock.Object);

// When
var error = Record.Exception(() => manager.UpdateRoutingTable());
Expand Down Expand Up @@ -327,7 +327,7 @@ public void ShouldTryNextRouterIfNoReader()
var poolManagerMock = new Mock<IClusterConnectionPoolManager>();
poolManagerMock.SetupSequence(x => x.CreateClusterConnection(It.IsAny<Uri>()))
.Returns(connA).Returns(connB);
var manager = NewRoutingTableManager(routingTable, poolManagerMock.Object, null);
var manager = NewRoutingTableManager(routingTable, poolManagerMock.Object);


// When
Expand Down Expand Up @@ -361,7 +361,7 @@ public void ShouldAcceptRoutingTableIfNoWriter()
var poolManagerMock = new Mock<IClusterConnectionPoolManager>();
poolManagerMock.Setup(x => x.CreateClusterConnection(It.IsAny<Uri>()))
.Returns(connA);
var manager = NewRoutingTableManager(routingTable, poolManagerMock.Object, null);
var manager = NewRoutingTableManager(routingTable, poolManagerMock.Object);

// When
var updateRoutingTable = manager.UpdateRoutingTable(null, conn =>
Expand Down

0 comments on commit b0e429a

Please sign in to comment.