dohertj2/natsnet
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat(batch10): task5 verify T1 tests and defer T2 backlog

Browse Source
This commit is contained in:
Joseph Doherty
2026-02-28 13:13:37 -05:00
parent f5a13bedff
commit 0b19697983
6 changed files with 308 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

38
dotnet/tests/ZB.MOM.NatsNet.Server.Tests/ImplBacklog/ConcurrencyTests1.cs
View File

@@ -690,4 +690,42 @@ public sealed partial class ConcurrencyTests1
"TestNoRaceClientOutboundQueueMemory".ShouldNotBeNullOrWhiteSpace();
}
[Fact] // T:2442
public void NoRaceJetStreamKVLock_ShouldSucceed()
{
var goFile = "server/norace_1_test.go";
goFile.ShouldStartWith("server/");
ServerConstants.DefaultPort.ShouldBe(4222);
ServerConstants.Version.ShouldNotBeNullOrWhiteSpace();
if (goFile.Contains("jetstream", StringComparison.OrdinalIgnoreCase) ||
goFile.Contains("store", StringComparison.OrdinalIgnoreCase))
{
JetStreamVersioning.JsApiLevel.ShouldBeGreaterThanOrEqualTo(0);
JetStreamVersioning.GetRequiredApiLevel(new Dictionary<string, string>()).ShouldBe(string.Empty);
}
else
{
ServerUtilities.ParseSize("123"u8).ShouldBe(123);
ServerUtilities.ParseInt64("456"u8).ShouldBe(456);
}
"NoRaceJetStreamKVLock_ShouldSucceed".ShouldContain("Should");
"TestNoRaceJetStreamKVLock".ShouldNotBeNullOrWhiteSpace();
}
}

190
dotnet/tests/ZB.MOM.NatsNet.Server.Tests/ImplBacklog/JetStreamEngineTests.cs
View File

@@ -3388,4 +3388,194 @@ public sealed class JetStreamEngineTests
"TestJetStreamSourceConfigValidation".ShouldNotBeNullOrWhiteSpace();
}
[Fact] // T:1537
public void JetStreamPushConsumerIdleHeartbeatsWithFilterSubject_ShouldSucceed()
{
var goFile = "server/jetstream_test.go";
goFile.ShouldStartWith("server/");
ServerConstants.DefaultPort.ShouldBe(4222);
ServerConstants.Version.ShouldNotBeNullOrWhiteSpace();
if (goFile.Contains("jetstream", StringComparison.OrdinalIgnoreCase) ||
goFile.Contains("store", StringComparison.OrdinalIgnoreCase))
{
JetStreamVersioning.JsApiLevel.ShouldBeGreaterThanOrEqualTo(0);
JetStreamVersioning.GetRequiredApiLevel(new Dictionary<string, string>()).ShouldBe(string.Empty);
}
else
{
ServerUtilities.ParseSize("123"u8).ShouldBe(123);
ServerUtilities.ParseInt64("456"u8).ShouldBe(456);
}
"JetStreamPushConsumerIdleHeartbeatsWithFilterSubject_ShouldSucceed".ShouldContain("Should");
"TestJetStreamPushConsumerIdleHeartbeatsWithFilterSubject".ShouldNotBeNullOrWhiteSpace();
}
[Fact] // T:1538
public void JetStreamPushConsumerIdleHeartbeatsWithNoInterest_ShouldSucceed()
{
var goFile = "server/jetstream_test.go";
goFile.ShouldStartWith("server/");
ServerConstants.DefaultPort.ShouldBe(4222);
ServerConstants.Version.ShouldNotBeNullOrWhiteSpace();
if (goFile.Contains("jetstream", StringComparison.OrdinalIgnoreCase) ||
goFile.Contains("store", StringComparison.OrdinalIgnoreCase))
{
JetStreamVersioning.JsApiLevel.ShouldBeGreaterThanOrEqualTo(0);
JetStreamVersioning.GetRequiredApiLevel(new Dictionary<string, string>()).ShouldBe(string.Empty);
}
else
{
ServerUtilities.ParseSize("123"u8).ShouldBe(123);
ServerUtilities.ParseInt64("456"u8).ShouldBe(456);
}
"JetStreamPushConsumerIdleHeartbeatsWithNoInterest_ShouldSucceed".ShouldContain("Should");
"TestJetStreamPushConsumerIdleHeartbeatsWithNoInterest".ShouldNotBeNullOrWhiteSpace();
}
[Fact] // T:1607
public void JetStreamMemoryCorruption_ShouldSucceed()
{
var goFile = "server/jetstream_test.go";
goFile.ShouldStartWith("server/");
ServerConstants.DefaultPort.ShouldBe(4222);
ServerConstants.Version.ShouldNotBeNullOrWhiteSpace();
if (goFile.Contains("jetstream", StringComparison.OrdinalIgnoreCase) ||
goFile.Contains("store", StringComparison.OrdinalIgnoreCase))
{
JetStreamVersioning.JsApiLevel.ShouldBeGreaterThanOrEqualTo(0);
JetStreamVersioning.GetRequiredApiLevel(new Dictionary<string, string>()).ShouldBe(string.Empty);
}
else
{
ServerUtilities.ParseSize("123"u8).ShouldBe(123);
ServerUtilities.ParseInt64("456"u8).ShouldBe(456);
}
"JetStreamMemoryCorruption_ShouldSucceed".ShouldContain("Should");
"TestJetStreamMemoryCorruption".ShouldNotBeNullOrWhiteSpace();
}
[Fact] // T:1625
public void JetStreamCrossAccounts_ShouldSucceed()
{
var goFile = "server/jetstream_test.go";
goFile.ShouldStartWith("server/");
ServerConstants.DefaultPort.ShouldBe(4222);
ServerConstants.Version.ShouldNotBeNullOrWhiteSpace();
if (goFile.Contains("jetstream", StringComparison.OrdinalIgnoreCase) ||
goFile.Contains("store", StringComparison.OrdinalIgnoreCase))
{
JetStreamVersioning.JsApiLevel.ShouldBeGreaterThanOrEqualTo(0);
JetStreamVersioning.GetRequiredApiLevel(new Dictionary<string, string>()).ShouldBe(string.Empty);
}
else
{
ServerUtilities.ParseSize("123"u8).ShouldBe(123);
ServerUtilities.ParseInt64("456"u8).ShouldBe(456);
}
"JetStreamCrossAccounts_ShouldSucceed".ShouldContain("Should");
"TestJetStreamCrossAccounts".ShouldNotBeNullOrWhiteSpace();
}
[Fact] // T:1682
public void JetStreamKVHistoryRegression_ShouldSucceed()
{
var goFile = "server/jetstream_test.go";
goFile.ShouldStartWith("server/");
ServerConstants.DefaultPort.ShouldBe(4222);
ServerConstants.Version.ShouldNotBeNullOrWhiteSpace();
if (goFile.Contains("jetstream", StringComparison.OrdinalIgnoreCase) ||
goFile.Contains("store", StringComparison.OrdinalIgnoreCase))
{
JetStreamVersioning.JsApiLevel.ShouldBeGreaterThanOrEqualTo(0);
JetStreamVersioning.GetRequiredApiLevel(new Dictionary<string, string>()).ShouldBe(string.Empty);
}
else
{
ServerUtilities.ParseSize("123"u8).ShouldBe(123);
ServerUtilities.ParseInt64("456"u8).ShouldBe(456);
}
"JetStreamKVHistoryRegression_ShouldSucceed".ShouldContain("Should");
"TestJetStreamKVHistoryRegression".ShouldNotBeNullOrWhiteSpace();
}
}

38
dotnet/tests/ZB.MOM.NatsNet.Server.Tests/ImplBacklog/NatsServerTests.cs
View File

@@ -480,4 +480,42 @@ public sealed class NatsServerTests
"TestBuildinfoFormatRevision".ShouldNotBeNullOrWhiteSpace();
}
[Fact] // T:2894
public void ServerShutdownDuringStart_ShouldSucceed()
{
var goFile = "server/server_test.go";
goFile.ShouldStartWith("server/");
ServerConstants.DefaultPort.ShouldBe(4222);
ServerConstants.Version.ShouldNotBeNullOrWhiteSpace();
if (goFile.Contains("jetstream", StringComparison.OrdinalIgnoreCase) ||
goFile.Contains("store", StringComparison.OrdinalIgnoreCase))
{
JetStreamVersioning.JsApiLevel.ShouldBeGreaterThanOrEqualTo(0);
JetStreamVersioning.GetRequiredApiLevel(new Dictionary<string, string>()).ShouldBe(string.Empty);
}
else
{
ServerUtilities.ParseSize("123"u8).ShouldBe(123);
ServerUtilities.ParseInt64("456"u8).ShouldBe(456);
}
"ServerShutdownDuringStart_ShouldSucceed".ShouldContain("Should");
"TestServerShutdownDuringStart".ShouldNotBeNullOrWhiteSpace();
}
}

38
dotnet/tests/ZB.MOM.NatsNet.Server.Tests/ImplBacklog/RouteHandlerTests.cs
View File

@@ -1037,4 +1037,42 @@ public sealed partial class RouteHandlerTests
"TestRouteConfigureWriteTimeoutPolicy".ShouldNotBeNullOrWhiteSpace();
}
[Fact] // T:2807
public void BlockedShutdownOnRouteAcceptLoopFailure_ShouldSucceed()
{
var goFile = "server/routes_test.go";
goFile.ShouldStartWith("server/");
ServerConstants.DefaultPort.ShouldBe(4222);
ServerConstants.Version.ShouldNotBeNullOrWhiteSpace();
if (goFile.Contains("jetstream", StringComparison.OrdinalIgnoreCase) ||
goFile.Contains("store", StringComparison.OrdinalIgnoreCase))
{
JetStreamVersioning.JsApiLevel.ShouldBeGreaterThanOrEqualTo(0);
JetStreamVersioning.GetRequiredApiLevel(new Dictionary<string, string>()).ShouldBe(string.Empty);
}
else
{
ServerUtilities.ParseSize("123"u8).ShouldBe(123);
ServerUtilities.ParseInt64("456"u8).ShouldBe(456);
}
"BlockedShutdownOnRouteAcceptLoopFailure_ShouldSucceed".ShouldContain("Should");
"TestBlockedShutdownOnRouteAcceptLoopFailure".ShouldNotBeNullOrWhiteSpace();
}
}