Skip to content

Commit

Permalink
Separated tests to individual states
Browse files Browse the repository at this point in the history
  • Loading branch information
@budgetpreneur
budgetpreneur committed Aug 1, 2023
1 parent 780cf4d commit 39c21e4
Show file tree
Hide file tree
Showing 11 changed files with 1,024 additions and 912 deletions.
91 changes: 91 additions & 0 deletions src/UnitTests/PubnubApi.Tests/EventEngine/HandshakeFailedStateTransition.cs
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,91 @@
using NUnit.Framework;
using PubnubApi.EventEngine.Core;
using PubnubApi.EventEngine.Subscribe.Common;
using PubnubApi.EventEngine.Subscribe.Context;
using PubnubApi.EventEngine.Subscribe.Events;
using PubnubApi.EventEngine.Subscribe.States;
using System.Linq;

namespace PubnubApi.Tests.EventEngine
{
internal class HandshakeFailedStateTransition
{
[Test]
public void TestHandshakeFailedStateTransitionWithSubscriptionChangedEvent()
{
//Arrange
State handshakeFailedState = new HandshakeFailedState() { Channels = new string[] { "ch1", "ch2" }, ChannelGroups = new string[] { "cg1", "cg2" } };
State handshakingState = new HandshakingState();
//Act
TransitionResult result = handshakeFailedState.Transition(new SubscriptionChangedEvent()
{
Channels = new string[] { "ch1", "ch2", "ch3" },
ChannelGroups = new string[] { "cg1", "cg2", "cg3" }
} );
//Assert
Assert.IsTrue(result.State.GetType().Equals(handshakingState.GetType()));
Assert.AreEqual("ch1", ((HandshakingState)(result.State)).Channels.ElementAt(0));
Assert.AreEqual("ch2", ((HandshakingState)(result.State)).Channels.ElementAt(1));
Assert.AreEqual("ch3", ((HandshakingState)(result.State)).Channels.ElementAt(2));
Assert.AreEqual("cg1", ((HandshakingState)(result.State)).ChannelGroups.ElementAt(0));
Assert.AreEqual("cg2", ((HandshakingState)(result.State)).ChannelGroups.ElementAt(1));
Assert.AreEqual("cg3", ((HandshakingState)(result.State)).ChannelGroups.ElementAt(2));
}

[Test]
public void TestHandshakeFailedStateTransitionWithSubscriptionRestoredEvent()
{
//Arrange
State handshakeFailedState = new HandshakeFailedState() { Channels = new string[] { "ch1", "ch2" }, ChannelGroups = new string[] { "cg1", "cg2" } };
State handshakingState = new HandshakingState();
//Act
TransitionResult result = handshakeFailedState.Transition(new SubscriptionRestoredEvent()
{
Channels = new string[] { "ch1", "ch2" },
ChannelGroups = new string[] { "cg1", "cg2" }
} );
//Assert
Assert.IsTrue(result.State.GetType().Equals(handshakingState.GetType()));
Assert.AreEqual("ch1", ((HandshakingState)(result.State)).Channels.ElementAt(0));
Assert.AreEqual("ch2", ((HandshakingState)(result.State)).Channels.ElementAt(1));
Assert.AreEqual("cg1", ((HandshakingState)(result.State)).ChannelGroups.ElementAt(0));
Assert.AreEqual("cg2", ((HandshakingState)(result.State)).ChannelGroups.ElementAt(1));
}

[Test]
public void TestHandshakeFailedStateTransitionWithReconnectEvent()
{
//Arrange
State handshakeFailedState = new HandshakeFailedState() { Channels = new string[] { "ch1", "ch2" }, ChannelGroups = new string[] { "cg1", "cg2" } };
State handshakingState = new HandshakingState();
//Act
TransitionResult result = handshakeFailedState.Transition(new ReconnectEvent()
{
Channels = new string[] { "ch1", "ch2" },
ChannelGroups = new string[] { "cg1", "cg2" },
Cursor = new SubscriptionCursor() { Region = 1, Timetoken = 1234567890 }
} );
//Assert
Assert.IsTrue(result.State.GetType().Equals(handshakingState.GetType()));
Assert.AreEqual("ch1", ((HandshakingState)(result.State)).Channels.ElementAt(0));
Assert.AreEqual("ch2", ((HandshakingState)(result.State)).Channels.ElementAt(1));
Assert.AreEqual("cg1", ((HandshakingState)(result.State)).ChannelGroups.ElementAt(0));
Assert.AreEqual("cg2", ((HandshakingState)(result.State)).ChannelGroups.ElementAt(1));
Assert.AreEqual(1, ((HandshakingState)(result.State)).Cursor.Region);
Assert.AreEqual(1234567890, ((HandshakingState)(result.State)).Cursor.Timetoken);
}

[Test]
public void TestHandshakeFailedStateTransitionWithUnsubscribeEvent()
{
//Arrange
State handshakeFailedState = new HandshakeFailedState() { Channels = new string[] { "ch1", "ch2" }, ChannelGroups = new string[] { "cg1", "cg2" } };
State unsubscribedState = new UnsubscribedState();
//Act
TransitionResult result = handshakeFailedState.Transition(new UnsubscribeAllEvent() { });
//Assert
Assert.IsTrue(result.State.GetType().Equals(unsubscribedState.GetType()));
}

}
}
140 changes: 140 additions & 0 deletions src/UnitTests/PubnubApi.Tests/EventEngine/HandshakeReconnectingStateTransition.cs
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,140 @@
using NUnit.Framework;
using PubnubApi.EventEngine.Core;
using PubnubApi.EventEngine.Subscribe.Common;
using PubnubApi.EventEngine.Subscribe.Context;
using PubnubApi.EventEngine.Subscribe.Events;
using PubnubApi.EventEngine.Subscribe.States;
using System.Linq;

namespace PubnubApi.Tests.EventEngine
{
internal class HandshakeReconnectingStateTransition
{
[Test]
public void TestHandshakeReconnectingStateTransitionWithSubscriptionChangedEvent()
{
//Arrange
State handshakeReconnectingState = new HandshakeReconnectingState() { Channels = new string[] { "ch1", "ch2" }, ChannelGroups = new string[] { "cg1", "cg2" } };
State handshakingState = new HandshakingState();
//Act
TransitionResult result = handshakeReconnectingState.Transition(new SubscriptionChangedEvent()
{
Channels = new string[] { "ch1", "ch2", "ch3" },
ChannelGroups = new string[] { "cg1", "cg2", "cg3" }
});
//Assert
Assert.IsTrue(result.State.GetType().Equals(handshakingState.GetType()));
Assert.AreEqual("ch1", ((HandshakingState)(result.State)).Channels.ElementAt(0));
Assert.AreEqual("ch2", ((HandshakingState)(result.State)).Channels.ElementAt(1));
Assert.AreEqual("ch3", ((HandshakingState)(result.State)).Channels.ElementAt(2));
Assert.AreEqual("cg1", ((HandshakingState)(result.State)).ChannelGroups.ElementAt(0));
Assert.AreEqual("cg2", ((HandshakingState)(result.State)).ChannelGroups.ElementAt(1));
Assert.AreEqual("cg3", ((HandshakingState)(result.State)).ChannelGroups.ElementAt(2));
}

[Test]
public void TestHandshakeReconnectingStateTransitionWithSubscriptionRestoredEvent()
{
//Arrange
State handshakeReconnectingState = new HandshakeReconnectingState() { Channels = new string[] { "ch1", "ch2" }, ChannelGroups = new string[] { "cg1", "cg2" } };
State handshakingState = new HandshakingState();
//Act
TransitionResult result = handshakeReconnectingState.Transition(new SubscriptionRestoredEvent()
{
Channels = new string[] { "ch1", "ch2" },
ChannelGroups = new string[] { "cg1", "cg2" }
});
//Assert
Assert.IsTrue(result.State.GetType().Equals(handshakingState.GetType()));
Assert.AreEqual("ch1", ((HandshakingState)(result.State)).Channels.ElementAt(0));
Assert.AreEqual("ch2", ((HandshakingState)(result.State)).Channels.ElementAt(1));
Assert.AreEqual("cg1", ((HandshakingState)(result.State)).ChannelGroups.ElementAt(0));
Assert.AreEqual("cg2", ((HandshakingState)(result.State)).ChannelGroups.ElementAt(1));
}

[Test]
public void TestHandshakeReconnectingStateTransitionWithHandshakeReconnectFailureEvent()
{
//Arrange
State handshakeReconnectingState = new HandshakeReconnectingState() { Channels = new string[] { "ch1", "ch2" }, ChannelGroups = new string[] { "cg1", "cg2" } };
State handshakeReconnectingState2 = new HandshakeReconnectingState();
//Act
TransitionResult result = handshakeReconnectingState.Transition(new HandshakeReconnectFailureEvent() { });
//Assert
Assert.IsTrue(result.State.GetType().Equals(handshakeReconnectingState2.GetType()));
Assert.AreEqual("ch1", ((HandshakeReconnectingState)(result.State)).Channels.ElementAt(0));
Assert.AreEqual("ch2", ((HandshakeReconnectingState)(result.State)).Channels.ElementAt(1));
Assert.AreEqual("cg1", ((HandshakeReconnectingState)(result.State)).ChannelGroups.ElementAt(0));
Assert.AreEqual("cg2", ((HandshakeReconnectingState)(result.State)).ChannelGroups.ElementAt(1));
}

[Test]
public void TestHandshakeReconnectingStateTransitionWithDisconnectEvent()
{
//Arrange
State handshakeReconnectingState = new HandshakeReconnectingState() { Channels = new string[] { "ch1", "ch2" }, ChannelGroups = new string[] { "cg1", "cg2" } };
State handshakeStoppedState = new HandshakeStoppedState();
//Act
TransitionResult result = handshakeReconnectingState.Transition(new DisconnectEvent()
{ Channels = new string[] { "ch1", "ch2" }, ChannelGroups = new string[] { "cg1", "cg2" } } );
//Assert
Assert.IsTrue(result.State.GetType().Equals(handshakeStoppedState.GetType()));
Assert.AreEqual("ch1", ((HandshakeStoppedState)(result.State)).Channels.ElementAt(0));
Assert.AreEqual("ch2", ((HandshakeStoppedState)(result.State)).Channels.ElementAt(1));
Assert.AreEqual("cg1", ((HandshakeStoppedState)(result.State)).ChannelGroups.ElementAt(0));
Assert.AreEqual("cg2", ((HandshakeStoppedState)(result.State)).ChannelGroups.ElementAt(1));
}

[Test]
public void TestHandshakeReconnectingStateTransitionWithHandshakeReconnectGiveupEvent()
{
//Arrange
State handshakeReconnectingState = new HandshakeReconnectingState() { Channels = new string[] { "ch1", "ch2" }, ChannelGroups = new string[] { "cg1", "cg2" } };
State handshakeFailedState = new HandshakeFailedState();
//Act
TransitionResult result = handshakeReconnectingState.Transition(new HandshakeReconnectGiveUpEvent() { } );
//Assert
Assert.IsTrue(result.State.GetType().Equals(handshakeFailedState.GetType()));
Assert.AreEqual("ch1", ((HandshakeFailedState)(result.State)).Channels.ElementAt(0));
Assert.AreEqual("ch2", ((HandshakeFailedState)(result.State)).Channels.ElementAt(1));
Assert.AreEqual("cg1", ((HandshakeFailedState)(result.State)).ChannelGroups.ElementAt(0));
Assert.AreEqual("cg2", ((HandshakeFailedState)(result.State)).ChannelGroups.ElementAt(1));
}

[Test]
public void TestHandshakeReconnectingStateTransitionWithHandshakeReconnectSuccessEvent()
{
//Arrange
State handshakeReconnectingState = new HandshakeReconnectingState() { Channels = new string[] { "ch1", "ch2" }, ChannelGroups = new string[] { "cg1", "cg2" }, ReconnectionConfiguration = new ReconnectionConfiguration(PNReconnectionPolicy.LINEAR, 50) };
State receivingState = new ReceivingState();
//Act
TransitionResult result = handshakeReconnectingState.Transition(new HandshakeReconnectSuccessEvent()
{
Cursor = new SubscriptionCursor() { Region = 1, Timetoken = 1234567890 },
} );
//Assert
Assert.IsTrue(result.State.GetType().Equals(receivingState.GetType()));
Assert.AreEqual("ch1", ((ReceivingState)(result.State)).Channels.ElementAt(0));
Assert.AreEqual("ch2", ((ReceivingState)(result.State)).Channels.ElementAt(1));
Assert.AreEqual("cg1", ((ReceivingState)(result.State)).ChannelGroups.ElementAt(0));
Assert.AreEqual("cg2", ((ReceivingState)(result.State)).ChannelGroups.ElementAt(1));
Assert.AreEqual(1, ((ReceivingState)(result.State)).Cursor.Region);
Assert.AreEqual(1234567890, ((ReceivingState)(result.State)).Cursor.Timetoken);
Assert.AreEqual(PNReconnectionPolicy.LINEAR, ((ReceivingState)(result.State)).ReconnectionConfiguration.ReconnectionPolicy);
Assert.AreEqual(50, ((ReceivingState)(result.State)).ReconnectionConfiguration.MaximumReconnectionRetries);
}

[Test]
public void TestHandshakeReconnectingStateTransitionWithUnsubscribeEvent()
{
//Arrange
State handshakeReconnectingState = new HandshakeReconnectingState() { Channels = new string[] { "ch1", "ch2" }, ChannelGroups = new string[] { "cg1", "cg2" }, ReconnectionConfiguration = new ReconnectionConfiguration(PNReconnectionPolicy.LINEAR, 50) };
State unsubscribedState = new UnsubscribedState();
//Act
TransitionResult result = handshakeReconnectingState.Transition(new UnsubscribeAllEvent() { });
//Assert
Assert.IsTrue(result.State.GetType().Equals(unsubscribedState.GetType()));
}

}
}
90 changes: 90 additions & 0 deletions src/UnitTests/PubnubApi.Tests/EventEngine/HandshakeStoppedStateTransition.cs
View file
Original file line number Diff line number Diff line change
@@ -0,0 +1,90 @@
using NUnit.Framework;
using PubnubApi.EventEngine.Core;
using PubnubApi.EventEngine.Subscribe.Common;
using PubnubApi.EventEngine.Subscribe.Events;
using PubnubApi.EventEngine.Subscribe.States;
using System.Linq;

namespace PubnubApi.Tests.EventEngine
{
internal class HandshakeStoppedStateTransition
{
[Test]
public void TestHandshakeStoppedStateTransitionWithSubscriptionChangedEvent()
{
//Arrange
State handshakeStoppedState = new HandshakeStoppedState() { Channels = new string[] { "ch1", "ch2" }, ChannelGroups = new string[] { "cg1", "cg2" } };
State handshakingState = new HandshakingState();
//Act
TransitionResult result = handshakeStoppedState.Transition(new SubscriptionChangedEvent()
{
Channels = new string[] { "ch1", "ch2", "ch3" },
ChannelGroups = new string[] { "cg1", "cg2", "cg3" }
} );
//Assert
Assert.IsTrue(result.State.GetType().Equals(handshakingState.GetType()));
Assert.AreEqual("ch1", ((HandshakingState)(result.State)).Channels.ElementAt(0));
Assert.AreEqual("ch2", ((HandshakingState)(result.State)).Channels.ElementAt(1));
Assert.AreEqual("ch3", ((HandshakingState)(result.State)).Channels.ElementAt(2));
Assert.AreEqual("cg1", ((HandshakingState)(result.State)).ChannelGroups.ElementAt(0));
Assert.AreEqual("cg2", ((HandshakingState)(result.State)).ChannelGroups.ElementAt(1));
Assert.AreEqual("cg3", ((HandshakingState)(result.State)).ChannelGroups.ElementAt(2));
}

[Test]
public void TestHandshakeStoppedStateTransitionWithSubscriptionRestoredEvent()
{
//Arrange
State handshakeStoppedState = new HandshakeStoppedState() { Channels = new string[] { "ch1", "ch2" }, ChannelGroups = new string[] { "cg1", "cg2" } };
State handshakingState = new HandshakingState();
//Act
TransitionResult result = handshakeStoppedState.Transition(new SubscriptionRestoredEvent()
{
Channels = new string[] { "ch1", "ch2" },
ChannelGroups = new string[] { "cg1", "cg2" }
} );
//Assert
Assert.IsTrue(result.State.GetType().Equals(handshakingState.GetType()));
Assert.AreEqual("ch1", ((HandshakingState)(result.State)).Channels.ElementAt(0));
Assert.AreEqual("ch2", ((HandshakingState)(result.State)).Channels.ElementAt(1));
Assert.AreEqual("cg1", ((HandshakingState)(result.State)).ChannelGroups.ElementAt(0));
Assert.AreEqual("cg2", ((HandshakingState)(result.State)).ChannelGroups.ElementAt(1));
}

[Test]
public void TestHandshakeStoppedStateTransitionWithReconnectEvent()
{
//Arrange
State handshakeStoppedState = new HandshakeStoppedState() { Channels = new string[] { "ch1", "ch2" }, ChannelGroups = new string[] { "cg1", "cg2" } };
State handshakingState = new HandshakingState();
//Act
TransitionResult result = handshakeStoppedState.Transition(new ReconnectEvent()
{
Channels = new string[] { "ch1", "ch2" },
ChannelGroups = new string[] { "cg1", "cg2" },
Cursor = new SubscriptionCursor() { Region = 1, Timetoken = 1234567890 }
} );
//Assert
Assert.IsTrue(result.State.GetType().Equals(handshakingState.GetType()));
Assert.AreEqual("ch1", ((HandshakingState)(result.State)).Channels.ElementAt(0));
Assert.AreEqual("ch2", ((HandshakingState)(result.State)).Channels.ElementAt(1));
Assert.AreEqual("cg1", ((HandshakingState)(result.State)).ChannelGroups.ElementAt(0));
Assert.AreEqual("cg2", ((HandshakingState)(result.State)).ChannelGroups.ElementAt(1));
Assert.AreEqual(1, ((HandshakingState)(result.State)).Cursor.Region);
Assert.AreEqual(1234567890, ((HandshakingState)(result.State)).Cursor.Timetoken);
}

[Test]
public void TestHandshakeStoppedStateWithUnsubscribeEvent()
{
//Arrange
State handshakeStoppedState = new HandshakeStoppedState() { Channels = new string[] { "ch1", "ch2" }, ChannelGroups = new string[] { "cg1", "cg2" } };
State unsubscribedState = new UnsubscribedState();
//Act
TransitionResult result = handshakeStoppedState.Transition(new UnsubscribeAllEvent() { });
//Assert
Assert.IsTrue(result.State.GetType().Equals(unsubscribedState.GetType()));
}

}
}
Loading

0 comments on commit 39c21e4

Please sign in to comment.