Files

Joseph Doherty 61e27879f7 Merge branch 'worktree-agent-a830a417'

# Conflicts:
#	dotnet/tests/ZB.MOM.NatsNet.Server.IntegrationTests/Helpers/CheckHelper.cs
#	dotnet/tests/ZB.MOM.NatsNet.Server.IntegrationTests/Helpers/ConfigHelper.cs
#	dotnet/tests/ZB.MOM.NatsNet.Server.IntegrationTests/Helpers/IntegrationTestBase.cs
#	dotnet/tests/ZB.MOM.NatsNet.Server.IntegrationTests/Helpers/NatsTestClient.cs
#	dotnet/tests/ZB.MOM.NatsNet.Server.IntegrationTests/Helpers/TestCluster.cs

2026-03-01 12:16:28 -05:00

45 KiB

Raw Permalink Blame History

Deferred Integration Tests Implementation Plan

For Claude: REQUIRED SUB-SKILL: Use superpowers-extended-cc:executing-plans to implement this plan task-by-task.

Goal: Port 884 deferred integration tests from Go to C#, with a shared test harness, so they compile and skip gracefully until the .NET server can boot.

Architecture: Wave 1 builds the test harness (Batch 48). Wave 2 launches 11 parallel Sonnet agents in isolated worktrees to port all 884 tests (Batches 49-59). Each agent reads Go source, creates .NET test files using the harness, and updates porting.db. Post-merge reconciliation promotes all tests to verified.

Tech Stack: .NET 10, xUnit 2.9.3, Shouldly, NSubstitute, NATS.Client.Core 2.7.2, Xunit.SkippableFact

Execution Model

Wave 1: Harness (Sequential)

Batch 48 creates the test infrastructure. Must merge to main before Wave 2 starts.

Wave 2: Test Batches (Parallel)

All 11 test batches (49-59) launch simultaneously as Sonnet agents with isolation: "worktree". Each agent works independently — no shared files between batches.

Merge Strategy

Merge each completed worktree branch to main sequentially
Resolve conflicts in reports/current.md by keeping --ours
After all merges, run post-merge reconciliation (Batch 59+ / Task 13)

Shared Standards (All Batches)

.NET Standards

.NET 10, C# latest, nullable enabled, file-scoped namespaces
xUnit 2.9.3, Shouldly assertions, NSubstitute mocking
PascalCase public members, _camelCase private fields
[SkippableFact]/[SkippableTheory] from Xunit.SkippableFact for runtime skip
Test naming: [Method]_[Scenario]_[Expected] (e.g., StreamCreate_ValidConfig_Succeeds)

Go-to-C# Translation

Go Pattern	C# Pattern
`TestFoo(t *testing.T)`	`public void Foo_ShouldSucceed()` or `public async Task Foo_ShouldSucceed()`
`t.Fatal("msg")`	`Assert.Fail("msg")` or Shouldly assertion
`t.Errorf("fmt", args)`	`result.ShouldBe(expected)`
`defer s.Shutdown()`	`using var server = TestServerHelper.RunBasicJetStreamServer(Output)`
`natsConnect(t, url)`	`NatsTestClient.Connect(url)`
`checkFor(t, 10*time.Second, ...)`	`CheckHelper.CheckFor(TimeSpan.FromSeconds(10), ...)`
`c := createJetStreamClusterExplicit(t, "R3", 3)`	`using var c = TestCluster.CreateJetStreamCluster(3, "R3")`
`//go:build !race`	`[Trait("Category", "NoRace")]`
`t.Skip("reason")`	`Skip.If(true, "reason")`

Agent Prompt Wrapper

Every batch prompt below should be wrapped with these execution rules:

EXECUTION RULES:
1. You are working in an isolated git worktree. Do NOT modify porting.db.
2. All files go under dotnet/tests/ZB.MOM.NatsNet.Server.IntegrationTests/
3. Build: dotnet build dotnet/tests/ZB.MOM.NatsNet.Server.IntegrationTests/
4. After build succeeds, run: dotnet test dotnet/tests/ZB.MOM.NatsNet.Server.Tests/ --no-build
   to confirm no regressions in existing unit tests.
5. Commit all changes with message: "test(batch{N}): port {description}"
6. Do NOT push. Do NOT modify files outside the integration test project.

Task 1: Batch 48 — Test Harness Infrastructure

Batch: 48 Tests: 0 (foundation only) Blocked by: Nothing Blocks: All test batches (49-59)

Files to Create

File	Purpose
`Helpers/TestServerHelper.cs`	Server lifecycle (RunServer, CanBoot, GetFreePort, CreateTempDir)
`Helpers/TestCluster.cs`	Multi-server cluster (CreateJetStreamCluster, WaitOnLeader, etc.)
`Helpers/TestSuperCluster.cs`	Multi-cluster with gateways
`Helpers/NatsTestClient.cs`	NATS.Client.Core wrapper for test connections
`Helpers/CheckHelper.cs`	Retry/polling (CheckFor, CheckClusterFormed)
`Helpers/ConfigHelper.cs`	Config templates and temp file management
`Helpers/IntegrationTestBase.cs`	Abstract base class with Skip guard

Files to Modify

File	Change
`ZB.MOM.NatsNet.Server.IntegrationTests.csproj`	Add `Xunit.SkippableFact` package

Go Reference Files

File	What to Extract
`golang/nats-server/server/jetstream_helpers_test.go`	cluster struct, createJetStreamCluster*, supercluster, config templates
`golang/nats-server/server/test_helper_test.go`	RunServer, natsConnect, checkFor, GetFreePort

Agent Prompt

BATCH 48: Test Harness Infrastructure

You are building shared test infrastructure for 884 integration tests. No tests in this batch — just the helpers.

TARGET PROJECT: dotnet/tests/ZB.MOM.NatsNet.Server.IntegrationTests/

STEP 1: Add Xunit.SkippableFact package to the .csproj:
  <PackageReference Include="Xunit.SkippableFact" Version="*" />

STEP 2: Read these Go files for reference patterns:
  - golang/nats-server/server/jetstream_helpers_test.go (cluster, supercluster, config templates)
  - golang/nats-server/server/test_helper_test.go (RunServer, natsConnect, checkFor)

STEP 3: Create these 7 files under Helpers/:

=== Helpers/TestServerHelper.cs ===
Namespace: ZB.MOM.NatsNet.Server.IntegrationTests.Helpers
Internal static class. Methods:
- CanBoot(): Try to create a NatsServer instance, return true/false. Catch all exceptions.
- RunServer(ServerOptions opts): Create NatsServer, call Start(), return (server, opts).
- RunBasicJetStreamServer(ITestOutputHelper output): Create ServerOptions with JetStream enabled + temp store dir, call RunServer.
- RunServerWithConfig(string configFile): Parse config, create ServerOptions, call RunServer.
- GetFreePort(): Use TcpListener on port 0 to find available port.
- CreateTempDir(string prefix): Path.Combine(Path.GetTempPath(), prefix + Guid.NewGuid().ToString("N")[..8]), create directory, return path.

=== Helpers/TestCluster.cs ===
Namespace: ZB.MOM.NatsNet.Server.IntegrationTests.Helpers
Internal sealed class, implements IDisposable.
Mirrors Go `cluster` struct from jetstream_helpers_test.go.
Properties: NatsServer[] Servers, ServerOptions[] Options, string Name.
Static factory methods:
- CreateJetStreamCluster(int numServers, string name): Allocate ports, create configs with routes, start all servers.
- CreateJetStreamClusterWithTemplate(string template, int numServers, string name): Use template string with port substitution.
Wait helpers:
- WaitOnClusterReady(): CheckHelper.CheckFor polling until all servers see correct route count.
- WaitOnLeader(): Poll until one server reports as leader.
- WaitOnStreamLeader(account, stream): Poll for stream leader.
- WaitOnConsumerLeader(account, stream, consumer): Poll for consumer leader.
Accessors:
- StreamLeader, ConsumerLeader, Leader, RandomServer, ServerByName.
Lifecycle:
- StopAll, RestartAll, Dispose (shutdown all).

=== Helpers/TestSuperCluster.cs ===
Namespace: ZB.MOM.NatsNet.Server.IntegrationTests.Helpers
Internal sealed class, implements IDisposable.
Properties: TestCluster[] Clusters.
Static factory:
- CreateJetStreamSuperCluster(int numPerCluster, int numClusters): Create multiple clusters with gateway configs.
Methods: Leader, RandomServer, ServerByName, WaitOnLeader, WaitOnStreamLeader, ClusterForName, Dispose.

=== Helpers/NatsTestClient.cs ===
Namespace: ZB.MOM.NatsNet.Server.IntegrationTests.Helpers
Internal static class. Uses NATS.Client.Core (already in project).
- Connect(string url, NatsOpts? opts = null): Create NatsConnection with test defaults.
- ConnectToServer(NatsServer server, NatsOpts? opts = null): Build URL from server's port, call Connect.

=== Helpers/CheckHelper.cs ===
Namespace: ZB.MOM.NatsNet.Server.IntegrationTests.Helpers
Internal static class.
- CheckFor(TimeSpan timeout, TimeSpan interval, Func<Exception?> check): Loop with Thread.Sleep(interval) until check returns null or timeout expires. Throw last exception on timeout.
- CheckClusterFormed(params NatsServer[] servers): CheckFor verifying route counts match expected.
- CheckLeafNodeConnectedCount(NatsServer server, int expected): CheckFor verifying leaf node count.

=== Helpers/ConfigHelper.cs ===
Namespace: ZB.MOM.NatsNet.Server.IntegrationTests.Helpers
Internal static class.
- const string JsClusterTemplate: Mirrors Go jsClusterTempl from jetstream_helpers_test.go. Template with %STORE_DIR%, %PORT%, %CLUSTER_PORT%, %ROUTES%, etc.
- const string JsSuperClusterTemplate: Mirrors Go jsSuperClusterTempl with gateway config.
- CreateConfigFile(string content): Write to temp file, return path.

=== Helpers/IntegrationTestBase.cs ===
Namespace: ZB.MOM.NatsNet.Server.IntegrationTests
[Trait("Category", "Integration")]
Public abstract class, implements IDisposable.
Constructor takes ITestOutputHelper, calls Skip.If(!TestServerHelper.CanBoot(), "Server cannot boot").
Protected Output property.
Virtual Dispose().

STEP 4: Build: dotnet build dotnet/tests/ZB.MOM.NatsNet.Server.IntegrationTests/
STEP 5: Run existing unit tests: dotnet test dotnet/tests/ZB.MOM.NatsNet.Server.Tests/ --no-build -c Debug
STEP 6: Commit: "test(batch48): add integration test harness infrastructure"

Task 2: Batch 49 — JetStream Core (126 tests)

Batch: 49 Tests: 126 (70 + 56) Blocked by: Batch 48 (Task 1)

Go Source Files

File	Test Count
`golang/nats-server/server/jetstream_test.go`	70
`golang/nats-server/server/jetstream_consumer_test.go`	56

.NET Target Files

File	Source
`JetStream/JetStreamTests.cs`	jetstream_test.go
`JetStream/JetStreamConsumerTests.cs`	jetstream_consumer_test.go

Test IDs (porting.db)

jetstream_test.go (70): 1479,1503,1506,1507,1509,1524,1533,1534,1541,1542,1543,1560,1566,1568,1569,1570,1571,1574,1577,1578,1579,1580,1588,1611,1622,1626,1658,1676,1679,1680,1685,1687,1688,1691,1698,1705,1706,1707,1712,1714,1717,1718,1729,1730,1736,1737,1738,1742,1746,1753,1754,1755,1756,1758,1759,1760,1761,1765,1766,1768,1769,1770,1771,1775,1778,1779,1781,1783,1784,1785

jetstream_consumer_test.go (56): 1229,1234,1238,1245,1246,1247,1254,1255,1256,1257,1258,1269,1270,1271,1272,1275,1276,1288,1292,1294,1296,1300,1301,1305,1307,1309,1310,1322,1323,1324,1327,1329,1331,1335,1337,1338,1345,1351,1354,1360,1361,1362,1363,1366,1367,1368,1369,1371,1372,1373,1374,1375,1376,1377,1378,1380

Agent Prompt

BATCH 49: JetStream Core Integration Tests (126 tests)

Port 126 integration tests from Go to C#. These test JetStream stream/consumer operations.

GO SOURCE FILES (read these first):
  - golang/nats-server/server/jetstream_test.go (70 tests)
  - golang/nats-server/server/jetstream_consumer_test.go (56 tests)

.NET TARGET FILES (create these):
  - dotnet/tests/ZB.MOM.NatsNet.Server.IntegrationTests/JetStream/JetStreamTests.cs
  - dotnet/tests/ZB.MOM.NatsNet.Server.IntegrationTests/JetStream/JetStreamConsumerTests.cs

HARNESS APIs AVAILABLE (under Helpers/):
  - TestServerHelper.RunBasicJetStreamServer(Output) — single JS server
  - TestServerHelper.CanBoot() — for Skip guard
  - NatsTestClient.Connect(url) / ConnectToServer(server)
  - CheckHelper.CheckFor(timeout, interval, check)
  - ConfigHelper.CreateConfigFile(content)
  - IntegrationTestBase — base class with Skip guard

PORTING PATTERN:
Each test class inherits IntegrationTestBase and uses [SkippableFact] or [SkippableTheory].
Each test method ports the full Go test logic. Use Shouldly for assertions.
Use `using var server = TestServerHelper.RunBasicJetStreamServer(Output);` for server lifecycle.
Use `using var nc = NatsTestClient.ConnectToServer(server);` for client connections.

CLASS STRUCTURE:
  JetStreamTests : IntegrationTestBase — 70 test methods from jetstream_test.go
  JetStreamConsumerTests : IntegrationTestBase — 56 test methods from jetstream_consumer_test.go

NAMING: Convert Go TestFoo to Foo_ShouldSucceed (or appropriate _Scenario_Expected suffix).

TEST IDS — jetstream_test.go (70):
1479,1503,1506,1507,1509,1524,1533,1534,1541,1542,1543,1560,1566,1568,1569,1570,1571,1574,1577,1578,1579,1580,1588,1611,1622,1626,1658,1676,1679,1680,1685,1687,1688,1691,1698,1705,1706,1707,1712,1714,1717,1718,1729,1730,1736,1737,1738,1742,1746,1753,1754,1755,1756,1758,1759,1760,1761,1765,1766,1768,1769,1770,1771,1775,1778,1779,1781,1783,1784,1785

TEST IDS — jetstream_consumer_test.go (56):
1229,1234,1238,1245,1246,1247,1254,1255,1256,1257,1258,1269,1270,1271,1272,1275,1276,1288,1292,1294,1296,1300,1301,1305,1307,1309,1310,1322,1323,1324,1327,1329,1331,1335,1337,1338,1345,1351,1354,1360,1361,1362,1363,1366,1367,1368,1369,1371,1372,1373,1374,1375,1376,1377,1378,1380

BUILD: dotnet build dotnet/tests/ZB.MOM.NatsNet.Server.IntegrationTests/
VERIFY: dotnet test dotnet/tests/ZB.MOM.NatsNet.Server.Tests/ --no-build -c Debug
COMMIT: "test(batch49): port 126 JetStream core integration tests"

Task 3: Batch 50 — JetStream Cluster 1 (118 tests)

Batch: 50 Tests: 118 Blocked by: Batch 48 (Task 1)

Go Source Files

File	Test Count
`golang/nats-server/server/jetstream_cluster_1_test.go`	118

.NET Target Files

File	Source
`JetStream/JetStreamCluster1Tests.cs`	jetstream_cluster_1_test.go

Test IDs (porting.db)

jetstream_cluster_1_test.go (118): 758,759,760,762,764,766,768,770,772,774,776,778,780,782,784,786,788,790,792,794,796,798,800,802,804,806,808,810,812,814,816,818,820,822,824,826,828,830,832,834,836,838,840,842,844,846,847,848,849,850,851,852,853,854,855,856,857,858,859,860,861,862,863,864,865,866,867,868,869,870,871,872,873,874,875,876,877,878,879,880,881,882,883,884,885,886,887,888,889,890,891,892,893,894,895,896,897,898,899,900,901,902,903,904,905,906,907,1031,1033,1035,1037,1039,1041,1043,1045,1047,1049,1051,1053

Agent Prompt

BATCH 50: JetStream Cluster 1 Integration Tests (118 tests)

Port 118 cluster integration tests from Go to C#. These test cluster formation, stream replication, and leader election.

GO SOURCE FILES (read this first):
  - golang/nats-server/server/jetstream_cluster_1_test.go (118 tests)

.NET TARGET FILE (create):
  - dotnet/tests/ZB.MOM.NatsNet.Server.IntegrationTests/JetStream/JetStreamCluster1Tests.cs

HARNESS APIs AVAILABLE (under Helpers/):
  - TestCluster.CreateJetStreamCluster(numServers, name) — multi-server cluster
  - TestCluster.CreateJetStreamClusterWithTemplate(template, numServers, name)
  - cluster.WaitOnClusterReady(), WaitOnLeader(), WaitOnStreamLeader(account, stream)
  - cluster.Leader(), RandomServer(), ServerByName(name)
  - NatsTestClient.ConnectToServer(server)
  - CheckHelper.CheckFor(timeout, interval, check)
  - ConfigHelper.JsClusterTemplate, CreateConfigFile(content)
  - IntegrationTestBase — base class with Skip guard

PORTING PATTERN:
Class inherits IntegrationTestBase, uses [SkippableFact]/[SkippableTheory].
Most tests use: `using var c = TestCluster.CreateJetStreamCluster(3, "R3");`
Then connect to a server: `using var nc = NatsTestClient.ConnectToServer(c.RandomServer());`
Port full Go test logic with Shouldly assertions.

TEST IDS (118):
758,759,760,762,764,766,768,770,772,774,776,778,780,782,784,786,788,790,792,794,796,798,800,802,804,806,808,810,812,814,816,818,820,822,824,826,828,830,832,834,836,838,840,842,844,846,847,848,849,850,851,852,853,854,855,856,857,858,859,860,861,862,863,864,865,866,867,868,869,870,871,872,873,874,875,876,877,878,879,880,881,882,883,884,885,886,887,888,889,890,891,892,893,894,895,896,897,898,899,900,901,902,903,904,905,906,907,1031,1033,1035,1037,1039,1041,1043,1045,1047,1049,1051,1053

BUILD: dotnet build dotnet/tests/ZB.MOM.NatsNet.Server.IntegrationTests/
VERIFY: dotnet test dotnet/tests/ZB.MOM.NatsNet.Server.Tests/ --no-build -c Debug
COMMIT: "test(batch50): port 118 JetStream cluster 1 integration tests"

Task 4: Batch 51 — JetStream Cluster 2 (106 tests)

Batch: 51 Tests: 106 Blocked by: Batch 48 (Task 1)

Go Source Files

File	Test Count
`golang/nats-server/server/jetstream_cluster_2_test.go`	106

.NET Target Files

File	Source
`JetStream/JetStreamCluster2Tests.cs`	jetstream_cluster_2_test.go

Test IDs (porting.db)

jetstream_cluster_2_test.go (106): 908,909,910,911,912,913,914,915,916,917,918,919,920,921,922,923,924,925,926,927,928,929,930,931,932,933,934,935,936,937,938,939,940,941,942,943,944,945,946,947,948,949,950,951,952,953,954,955,956,957,958,959,960,961,962,963,964,965,966,967,968,969,970,971,972,973,974,975,976,977,978,979,980,981,982,983,984,985,986,987,988,989,990,991,992,993,994,995,996,997,998,999,1000,1001,1002,1003,1004,1005,1006,1007,1008,1009,1010,1011,1012,1030

Agent Prompt

BATCH 51: JetStream Cluster 2 Integration Tests (106 tests)

Port 106 cluster integration tests. These test consumer replication, failover, and recovery.

GO SOURCE FILES (read this first):
  - golang/nats-server/server/jetstream_cluster_2_test.go (106 tests)

.NET TARGET FILE (create):
  - dotnet/tests/ZB.MOM.NatsNet.Server.IntegrationTests/JetStream/JetStreamCluster2Tests.cs

HARNESS APIs AVAILABLE (under Helpers/):
  - TestCluster.CreateJetStreamCluster(numServers, name)
  - TestCluster.CreateJetStreamClusterWithTemplate(template, numServers, name)
  - cluster.WaitOnClusterReady(), WaitOnLeader(), WaitOnStreamLeader(), WaitOnConsumerLeader()
  - cluster.StreamLeader(), ConsumerLeader(), Leader(), RandomServer(), ServerByName()
  - cluster.StopAll(), RestartAll()
  - NatsTestClient.ConnectToServer(server)
  - CheckHelper.CheckFor(timeout, interval, check)
  - IntegrationTestBase — base class with Skip guard

TEST IDS (106):
908,909,910,911,912,913,914,915,916,917,918,919,920,921,922,923,924,925,926,927,928,929,930,931,932,933,934,935,936,937,938,939,940,941,942,943,944,945,946,947,948,949,950,951,952,953,954,955,956,957,958,959,960,961,962,963,964,965,966,967,968,969,970,971,972,973,974,975,976,977,978,979,980,981,982,983,984,985,986,987,988,989,990,991,992,993,994,995,996,997,998,999,1000,1001,1002,1003,1004,1005,1006,1007,1008,1009,1010,1011,1012,1030

BUILD: dotnet build dotnet/tests/ZB.MOM.NatsNet.Server.IntegrationTests/
VERIFY: dotnet test dotnet/tests/ZB.MOM.NatsNet.Server.Tests/ --no-build -c Debug
COMMIT: "test(batch51): port 106 JetStream cluster 2 integration tests"

Task 5: Batch 52 — JetStream Cluster 3 (82 tests)

Batch: 52 Tests: 82 Blocked by: Batch 48 (Task 1)

Go Source Files

File	Test Count
`golang/nats-server/server/jetstream_cluster_3_test.go`	82

.NET Target Files

File	Source
`JetStream/JetStreamCluster3Tests.cs`	jetstream_cluster_3_test.go

Test IDs (porting.db)

jetstream_cluster_3_test.go (82): 1031,1033,1035,1037,1039,1041,1043,1045,1047,1049,1051,1053,1055,1057,1059,1061,1063,1065,1067,1069,1071,1073,1075,1077,1079,1081,1083,1085,1087,1089,1091,1093,1095,1097,1099,1101,1103,1105,1107,1109,1111,1113,1115,1117,1119,1121,1123,1125,1127,1129,1131,1133,1135,1137,1139,1141,1143,1145,1147,1149,1151,1153,1155,1157,1159,1161,1163,1165,1167,1169,1171,1173,1175,1177,1179,1181,1183,1185,1187,1189,1191,1193

Agent Prompt

BATCH 52: JetStream Cluster 3 Integration Tests (82 tests)

Port 82 advanced cluster scenario tests.

GO SOURCE FILES (read this first):
  - golang/nats-server/server/jetstream_cluster_3_test.go (82 tests)

.NET TARGET FILE (create):
  - dotnet/tests/ZB.MOM.NatsNet.Server.IntegrationTests/JetStream/JetStreamCluster3Tests.cs

HARNESS APIs AVAILABLE (under Helpers/):
  - TestCluster.CreateJetStreamCluster(numServers, name)
  - TestCluster.CreateJetStreamClusterWithTemplate(template, numServers, name)
  - cluster.WaitOnClusterReady(), WaitOnLeader(), WaitOnStreamLeader(), WaitOnConsumerLeader()
  - cluster.StreamLeader(), ConsumerLeader(), Leader(), RandomServer()
  - NatsTestClient.ConnectToServer(server)
  - CheckHelper.CheckFor(timeout, interval, check)
  - IntegrationTestBase — base class with Skip guard

TEST IDS (82):
1031,1033,1035,1037,1039,1041,1043,1045,1047,1049,1051,1053,1055,1057,1059,1061,1063,1065,1067,1069,1071,1073,1075,1077,1079,1081,1083,1085,1087,1089,1091,1093,1095,1097,1099,1101,1103,1105,1107,1109,1111,1113,1115,1117,1119,1121,1123,1125,1127,1129,1131,1133,1135,1137,1139,1141,1143,1145,1147,1149,1151,1153,1155,1157,1159,1161,1163,1165,1167,1169,1171,1173,1175,1177,1179,1181,1183,1185,1187,1189,1191,1193

BUILD: dotnet build dotnet/tests/ZB.MOM.NatsNet.Server.IntegrationTests/
VERIFY: dotnet test dotnet/tests/ZB.MOM.NatsNet.Server.Tests/ --no-build -c Debug
COMMIT: "test(batch52): port 82 JetStream cluster 3 integration tests"

Task 6: Batch 53 — JetStream Cluster 4 (75 tests)

Batch: 53 Tests: 75 Blocked by: Batch 48 (Task 1)

Go Source Files

File	Test Count
`golang/nats-server/server/jetstream_cluster_4_test.go`	75

.NET Target Files

File	Source
`JetStream/JetStreamCluster4Tests.cs`	jetstream_cluster_4_test.go

Test IDs (porting.db)

jetstream_cluster_4_test.go (75): 1129,1130,1131,1132,1133,1134,1135,1136,1137,1138,1139,1140,1141,1142,1143,1144,1145,1146,1147,1148,1149,1150,1151,1152,1153,1154,1155,1156,1157,1158,1159,1160,1161,1162,1163,1164,1165,1166,1167,1168,1169,1170,1171,1172,1173,1174,1175,1176,1177,1178,1179,1180,1181,1182,1183,1184,1185,1186,1187,1188,1189,1190,1191,1192,1193,1194,1195,1196,1197,1198,1199,1200,1201,1202,1210

Agent Prompt

BATCH 53: JetStream Cluster 4 Integration Tests (75 tests)

Port 75 busy stream and consumption pattern tests.

GO SOURCE FILES (read this first):
  - golang/nats-server/server/jetstream_cluster_4_test.go (75 tests)

.NET TARGET FILE (create):
  - dotnet/tests/ZB.MOM.NatsNet.Server.IntegrationTests/JetStream/JetStreamCluster4Tests.cs

HARNESS APIs AVAILABLE (under Helpers/):
  - TestCluster.CreateJetStreamCluster(numServers, name)
  - TestCluster.CreateJetStreamClusterWithTemplate(template, numServers, name)
  - cluster.WaitOnClusterReady(), WaitOnLeader(), WaitOnStreamLeader(), WaitOnConsumerLeader()
  - cluster.StreamLeader(), ConsumerLeader(), Leader(), RandomServer()
  - NatsTestClient.ConnectToServer(server)
  - CheckHelper.CheckFor(timeout, interval, check)
  - IntegrationTestBase — base class with Skip guard

TEST IDS (75):
1129,1130,1131,1132,1133,1134,1135,1136,1137,1138,1139,1140,1141,1142,1143,1144,1145,1146,1147,1148,1149,1150,1151,1152,1153,1154,1155,1156,1157,1158,1159,1160,1161,1162,1163,1164,1165,1166,1167,1168,1169,1170,1171,1172,1173,1174,1175,1176,1177,1178,1179,1180,1181,1182,1183,1184,1185,1186,1187,1188,1189,1190,1191,1192,1193,1194,1195,1196,1197,1198,1199,1200,1201,1202,1210

BUILD: dotnet build dotnet/tests/ZB.MOM.NatsNet.Server.IntegrationTests/
VERIFY: dotnet test dotnet/tests/ZB.MOM.NatsNet.Server.Tests/ --no-build -c Debug
COMMIT: "test(batch53): port 75 JetStream cluster 4 integration tests"

Task 7: Batch 54 — MQTT (78 tests)

Batch: 54 Tests: 78 (77 + 1) Blocked by: Batch 48 (Task 1)

Go Source Files

File	Test Count
`golang/nats-server/server/mqtt_test.go`	77
`golang/nats-server/server/mqtt_ex_test_test.go`	1

.NET Target Files

File	Source
`Mqtt/MqttTests.cs`	mqtt_test.go + mqtt_ex_test_test.go

Test IDs (porting.db)

mqtt_test.go (77): 2174,2175,2176,2177,2178,2179,2180,2181,2182,2183,2184,2185,2186,2187,2188,2189,2190,2191,2192,2193,2194,2195,2196,2197,2198,2199,2200,2201,2202,2203,2204,2205,2206,2207,2208,2209,2210,2211,2212,2213,2214,2215,2216,2217,2218,2219,2220,2221,2222,2223,2224,2225,2226,2227,2228,2229,2230,2231,2232,2233,2234,2235,2236,2237,2238,2239,2240,2241,2242,2243,2244,2245,2246,2247,2248,2249,2328

mqtt_ex_test_test.go (1): 2169

Agent Prompt

BATCH 54: MQTT Integration Tests (78 tests)

Port 78 MQTT protocol integration tests.

GO SOURCE FILES (read these first):
  - golang/nats-server/server/mqtt_test.go (77 tests)
  - golang/nats-server/server/mqtt_ex_test_test.go (1 test)

.NET TARGET FILE (create):
  - dotnet/tests/ZB.MOM.NatsNet.Server.IntegrationTests/Mqtt/MqttTests.cs

HARNESS APIs AVAILABLE (under Helpers/):
  - TestServerHelper.RunBasicJetStreamServer(Output) — MQTT needs JetStream enabled
  - TestServerHelper.RunServerWithConfig(configFile) — for MQTT-specific configs
  - NatsTestClient.Connect(url)
  - CheckHelper.CheckFor(timeout, interval, check)
  - ConfigHelper.CreateConfigFile(content)
  - IntegrationTestBase — base class with Skip guard

NOTE: MQTT tests may need raw TCP connections for MQTT protocol testing.
Create a simple MqttTestClient helper within the test file if needed,
or use System.Net.Sockets.TcpClient for raw MQTT packet exchange.
Mirror the Go mqttNewClient / mqttConnect helpers from mqtt_test.go.

TEST IDS — mqtt_test.go (77):
2174,2175,2176,2177,2178,2179,2180,2181,2182,2183,2184,2185,2186,2187,2188,2189,2190,2191,2192,2193,2194,2195,2196,2197,2198,2199,2200,2201,2202,2203,2204,2205,2206,2207,2208,2209,2210,2211,2212,2213,2214,2215,2216,2217,2218,2219,2220,2221,2222,2223,2224,2225,2226,2227,2228,2229,2230,2231,2232,2233,2234,2235,2236,2237,2238,2239,2240,2241,2242,2243,2244,2245,2246,2247,2248,2249,2328

TEST IDS — mqtt_ex_test_test.go (1): 2169

BUILD: dotnet build dotnet/tests/ZB.MOM.NatsNet.Server.IntegrationTests/
VERIFY: dotnet test dotnet/tests/ZB.MOM.NatsNet.Server.Tests/ --no-build -c Debug
COMMIT: "test(batch54): port 78 MQTT integration tests"

Task 8: Batch 55 — NoRace (75 tests)

Batch: 55 Tests: 75 (51 + 24) Blocked by: Batch 48 (Task 1)

Go Source Files

File	Test Count
`golang/nats-server/server/norace_1_test.go`	51
`golang/nats-server/server/norace_2_test.go`	24

.NET Target Files

File	Source
`NoRace/NoRace1Tests.cs`	norace_1_test.go
`NoRace/NoRace2Tests.cs`	norace_2_test.go

Test IDs (porting.db)

norace_1_test.go (51): 2379,2386,2387,2388,2389,2390,2391,2392,2393,2394,2395,2396,2397,2398,2399,2400,2401,2402,2403,2404,2405,2406,2407,2408,2409,2410,2411,2412,2413,2414,2415,2416,2417,2418,2419,2420,2421,2422,2423,2424,2425,2426,2427,2428,2429,2430,2431,2432,2433,2434,2465

norace_2_test.go (24): 2471,2472,2473,2474,2475,2476,2477,2478,2479,2480,2481,2482,2483,2484,2485,2486,2487,2488,2489,2490,2491,2492,2493,2494,2509

Agent Prompt

BATCH 55: NoRace Integration Tests (75 tests)

Port 75 concurrency tests. In Go these are built with `//go:build !race` to exclude from race detector runs.

GO SOURCE FILES (read these first):
  - golang/nats-server/server/norace_1_test.go (51 tests)
  - golang/nats-server/server/norace_2_test.go (24 tests)

.NET TARGET FILES (create):
  - dotnet/tests/ZB.MOM.NatsNet.Server.IntegrationTests/NoRace/NoRace1Tests.cs
  - dotnet/tests/ZB.MOM.NatsNet.Server.IntegrationTests/NoRace/NoRace2Tests.cs

HARNESS APIs AVAILABLE (under Helpers/):
  - TestServerHelper.RunBasicJetStreamServer(Output)
  - TestCluster.CreateJetStreamCluster(numServers, name)
  - NatsTestClient.Connect(url) / ConnectToServer(server)
  - CheckHelper.CheckFor(timeout, interval, check)
  - IntegrationTestBase — base class with Skip guard

SPECIAL: Add [Trait("Category", "NoRace")] to both test classes (in addition to "Integration").
These tests stress concurrency so they may use Task.WhenAll, Parallel.ForEachAsync, etc.

TEST IDS — norace_1_test.go (51):
2379,2386,2387,2388,2389,2390,2391,2392,2393,2394,2395,2396,2397,2398,2399,2400,2401,2402,2403,2404,2405,2406,2407,2408,2409,2410,2411,2412,2413,2414,2415,2416,2417,2418,2419,2420,2421,2422,2423,2424,2425,2426,2427,2428,2429,2430,2431,2432,2433,2434,2465

TEST IDS — norace_2_test.go (24):
2471,2472,2473,2474,2475,2476,2477,2478,2479,2480,2481,2482,2483,2484,2485,2486,2487,2488,2489,2490,2491,2492,2493,2494,2509

BUILD: dotnet build dotnet/tests/ZB.MOM.NatsNet.Server.IntegrationTests/
VERIFY: dotnet test dotnet/tests/ZB.MOM.NatsNet.Server.Tests/ --no-build -c Debug
COMMIT: "test(batch55): port 75 NoRace integration tests"

Task 9: Batch 56 — Reload + Auth (66 tests)

Batch: 56 Tests: 66 (44 + 5 + 5 + 11 + 1) Blocked by: Batch 48 (Task 1)

Go Source Files

File	Test Count
`golang/nats-server/server/reload_test.go`	44
`golang/nats-server/server/accounts_test.go`	5
`golang/nats-server/server/auth_callout_test.go`	5
`golang/nats-server/server/jwt_test.go`	11
`golang/nats-server/server/opts_test.go`	1

.NET Target Files

File	Source
`Config/ReloadTests.cs`	reload_test.go, opts_test.go
`Auth/AuthIntegrationTests.cs`	accounts_test.go, auth_callout_test.go, jwt_test.go

Test IDs (porting.db)

reload_test.go (44): 2721,2722,2723,2724,2725,2726,2727,2728,2729,2730,2731,2732,2733,2734,2735,2736,2737,2738,2739,2740,2741,2742,2743,2744,2745,2746,2747,2748,2749,2750,2751,2752,2753,2754,2755,2756,2757,2758,2759,2760,2761,2762,2763,2793

accounts_test.go (5): 86,87,89,105,108

auth_callout_test.go (5): 115,117,138,140,141

jwt_test.go (11): 1819,1821,1823,1825,1827,1829,1831,1833,1835,1837,1896

opts_test.go (1): 2551

Agent Prompt

BATCH 56: Reload + Auth Integration Tests (66 tests)

Port 66 config reload and authentication tests.

GO SOURCE FILES (read these first):
  - golang/nats-server/server/reload_test.go (44 tests — config hot-reload)
  - golang/nats-server/server/accounts_test.go (5 tests — route account mappings)
  - golang/nats-server/server/auth_callout_test.go (5 tests — external auth callout)
  - golang/nats-server/server/jwt_test.go (11 tests — JWT validation)
  - golang/nats-server/server/opts_test.go (1 test)

.NET TARGET FILES (create):
  - dotnet/tests/ZB.MOM.NatsNet.Server.IntegrationTests/Config/ReloadTests.cs
    (44 reload + 1 opts test)
  - dotnet/tests/ZB.MOM.NatsNet.Server.IntegrationTests/Auth/AuthIntegrationTests.cs
    (5 accounts + 5 auth_callout + 11 jwt tests)

HARNESS APIs AVAILABLE (under Helpers/):
  - TestServerHelper.RunServer(opts) / RunServerWithConfig(configFile)
  - TestServerHelper.RunBasicJetStreamServer(Output)
  - NatsTestClient.Connect(url) / ConnectToServer(server)
  - CheckHelper.CheckFor(timeout, interval, check)
  - ConfigHelper.CreateConfigFile(content)
  - IntegrationTestBase — base class with Skip guard

NOTE: Reload tests typically write a config file, start a server, modify the file, then trigger reload.
JWT tests need to generate test JWTs — use System.IdentityModel.Tokens.Jwt or create test JWT strings inline.

TEST IDS — reload_test.go (44):
2721,2722,2723,2724,2725,2726,2727,2728,2729,2730,2731,2732,2733,2734,2735,2736,2737,2738,2739,2740,2741,2742,2743,2744,2745,2746,2747,2748,2749,2750,2751,2752,2753,2754,2755,2756,2757,2758,2759,2760,2761,2762,2763,2793

TEST IDS — accounts_test.go (5): 86,87,89,105,108
TEST IDS — auth_callout_test.go (5): 115,117,138,140,141
TEST IDS — jwt_test.go (11): 1819,1821,1823,1825,1827,1829,1831,1833,1835,1837,1896
TEST IDS — opts_test.go (1): 2551

BUILD: dotnet build dotnet/tests/ZB.MOM.NatsNet.Server.IntegrationTests/
VERIFY: dotnet test dotnet/tests/ZB.MOM.NatsNet.Server.Tests/ --no-build -c Debug
COMMIT: "test(batch56): port 66 reload and auth integration tests"

Task 10: Batch 57 — SuperCluster + LeafNode (53 tests)

Batch: 57 Tests: 53 (36 + 3 + 14) Blocked by: Batch 48 (Task 1)

Go Source Files

File	Test Count
`golang/nats-server/server/jetstream_super_cluster_test.go`	36
`golang/nats-server/server/jetstream_leafnode_test.go`	3
`golang/nats-server/server/leafnode_test.go`	14

.NET Target Files

File	Source
`JetStream/JetStreamSuperClusterTests.cs`	jetstream_super_cluster_test.go, jetstream_leafnode_test.go
`LeafNode/LeafNodeTests.cs`	leafnode_test.go

Test IDs (porting.db)

jetstream_super_cluster_test.go (36): 1419,1420,1421,1422,1423,1424,1425,1426,1427,1428,1429,1430,1431,1432,1433,1434,1435,1436,1437,1438,1439,1440,1441,1442,1443,1444,1445,1446,1447,1448,1449,1450,1451,1452,1453,1464

jetstream_leafnode_test.go (3): 1412,1413,1414

leafnode_test.go (14): 1924,1930,1936,1942,1948,1954,1960,1966,1972,1978,1984,1990,1996,2004

Agent Prompt

BATCH 57: SuperCluster + LeafNode Integration Tests (53 tests)

Port 53 multi-cluster and leaf node tests.

GO SOURCE FILES (read these first):
  - golang/nats-server/server/jetstream_super_cluster_test.go (36 tests)
  - golang/nats-server/server/jetstream_leafnode_test.go (3 tests)
  - golang/nats-server/server/leafnode_test.go (14 tests)

.NET TARGET FILES (create):
  - dotnet/tests/ZB.MOM.NatsNet.Server.IntegrationTests/JetStream/JetStreamSuperClusterTests.cs
    (36 super cluster + 3 JS leafnode tests)
  - dotnet/tests/ZB.MOM.NatsNet.Server.IntegrationTests/LeafNode/LeafNodeTests.cs
    (14 leafnode tests)

HARNESS APIs AVAILABLE (under Helpers/):
  - TestSuperCluster.CreateJetStreamSuperCluster(numPerCluster, numClusters)
  - supercluster.Leader(), RandomServer(), WaitOnLeader(), WaitOnStreamLeader(), ClusterForName()
  - TestCluster.CreateJetStreamCluster(numServers, name)
  - TestServerHelper.RunServer(opts) / RunServerWithConfig(configFile)
  - NatsTestClient.Connect(url) / ConnectToServer(server)
  - CheckHelper.CheckFor(timeout, interval, check)
  - CheckHelper.CheckLeafNodeConnectedCount(server, expected)
  - ConfigHelper.JsSuperClusterTemplate, CreateConfigFile(content)
  - IntegrationTestBase — base class with Skip guard

TEST IDS — jetstream_super_cluster_test.go (36):
1419,1420,1421,1422,1423,1424,1425,1426,1427,1428,1429,1430,1431,1432,1433,1434,1435,1436,1437,1438,1439,1440,1441,1442,1443,1444,1445,1446,1447,1448,1449,1450,1451,1452,1453,1464

TEST IDS — jetstream_leafnode_test.go (3): 1412,1413,1414
TEST IDS — leafnode_test.go (14): 1924,1930,1936,1942,1948,1954,1960,1966,1972,1978,1984,1990,1996,2004

BUILD: dotnet build dotnet/tests/ZB.MOM.NatsNet.Server.IntegrationTests/
VERIFY: dotnet test dotnet/tests/ZB.MOM.NatsNet.Server.Tests/ --no-build -c Debug
COMMIT: "test(batch57): port 53 SuperCluster and LeafNode integration tests"

Task 11: Batch 58 — JetStream Misc (55 tests)

Batch: 58 Tests: 55 (26 + 11 + 9 + 2 + 2 + 4 + 1) Blocked by: Batch 48 (Task 1)

Go Source Files

File	Test Count
`golang/nats-server/server/jetstream_batching_test.go`	26
`golang/nats-server/server/jetstream_benchmark_test.go`	11
`golang/nats-server/server/jetstream_jwt_test.go`	9
`golang/nats-server/server/jetstream_versioning_test.go`	2
`golang/nats-server/server/jetstream_meta_benchmark_test.go`	2
`golang/nats-server/server/jetstream_cluster_long_test.go`	4
`golang/nats-server/server/jetstream_sourcing_scaling_test.go`	1

.NET Target Files

File	Source
`JetStream/JetStreamBatchingIntegrationTests.cs`	jetstream_batching_test.go
`JetStream/JetStreamMiscTests.cs`	All other files (benchmark, jwt, versioning, meta_benchmark, cluster_long, sourcing_scaling)

Test IDs (porting.db)

jetstream_batching_test.go (26): 716,717,718,719,720,721,722,723,724,725,726,727,728,729,730,731,732,733,734,735,736,737,738,739,740,744

jetstream_benchmark_test.go (11): 745,746,747,748,749,750,751,752,753,754,756

jetstream_jwt_test.go (9): 1387,1389,1391,1393,1395,1397,1399,1400,1401

jetstream_versioning_test.go (2): 1803,1805

jetstream_meta_benchmark_test.go (2): 1416,1417

jetstream_cluster_long_test.go (4): 1213,1215,1216,1218

jetstream_sourcing_scaling_test.go (1): 1418

Agent Prompt

BATCH 58: JetStream Misc Integration Tests (55 tests)

Port 55 JetStream miscellaneous tests (batching, benchmarks, JWT, versioning, long-running, scaling).

GO SOURCE FILES (read these first):
  - golang/nats-server/server/jetstream_batching_test.go (26 tests)
  - golang/nats-server/server/jetstream_benchmark_test.go (11 tests)
  - golang/nats-server/server/jetstream_jwt_test.go (9 tests)
  - golang/nats-server/server/jetstream_versioning_test.go (2 tests)
  - golang/nats-server/server/jetstream_meta_benchmark_test.go (2 tests)
  - golang/nats-server/server/jetstream_cluster_long_test.go (4 tests)
  - golang/nats-server/server/jetstream_sourcing_scaling_test.go (1 test)

.NET TARGET FILES (create):
  - dotnet/tests/ZB.MOM.NatsNet.Server.IntegrationTests/JetStream/JetStreamBatchingIntegrationTests.cs
    (26 batching tests)
  - dotnet/tests/ZB.MOM.NatsNet.Server.IntegrationTests/JetStream/JetStreamMiscTests.cs
    (11 benchmark + 9 jwt + 2 versioning + 2 meta benchmark + 4 cluster long + 1 scaling = 29 tests)

HARNESS APIs AVAILABLE (under Helpers/):
  - TestServerHelper.RunBasicJetStreamServer(Output)
  - TestCluster.CreateJetStreamCluster(numServers, name)
  - NatsTestClient.Connect(url) / ConnectToServer(server)
  - CheckHelper.CheckFor(timeout, interval, check)
  - IntegrationTestBase — base class with Skip guard

NOTE: Benchmark tests should be ported as regular integration tests (not BenchmarkDotNet).
They test correctness of batching/throughput behavior, not performance measurement.

TEST IDS — jetstream_batching_test.go (26):
716,717,718,719,720,721,722,723,724,725,726,727,728,729,730,731,732,733,734,735,736,737,738,739,740,744

TEST IDS — jetstream_benchmark_test.go (11): 745,746,747,748,749,750,751,752,753,754,756
TEST IDS — jetstream_jwt_test.go (9): 1387,1389,1391,1393,1395,1397,1399,1400,1401
TEST IDS — jetstream_versioning_test.go (2): 1803,1805
TEST IDS — jetstream_meta_benchmark_test.go (2): 1416,1417
TEST IDS — jetstream_cluster_long_test.go (4): 1213,1215,1216,1218
TEST IDS — jetstream_sourcing_scaling_test.go (1): 1418

BUILD: dotnet build dotnet/tests/ZB.MOM.NatsNet.Server.IntegrationTests/
VERIFY: dotnet test dotnet/tests/ZB.MOM.NatsNet.Server.Tests/ --no-build -c Debug
COMMIT: "test(batch58): port 55 JetStream misc integration tests"

Task 12: Batch 59 — Events + Monitor + Misc (50 tests)

Batch: 59 Tests: 50 (13 + 15 + 7 + 5 + 6 + 1 + 1 + 1 + 1) Blocked by: Batch 48 (Task 1)

Go Source Files

File	Test Count
`golang/nats-server/server/events_test.go`	13
`golang/nats-server/server/monitor_test.go`	15
`golang/nats-server/server/msgtrace_test.go`	7
`golang/nats-server/server/routes_test.go`	5
`golang/nats-server/server/filestore_test.go`	6
`golang/nats-server/server/server_test.go`	1
`golang/nats-server/server/memstore_test.go`	1
`golang/nats-server/server/gateway_test.go`	1
`golang/nats-server/server/websocket_test.go`	1

.NET Target Files

File	Source
`Events/EventsTests.cs`	events_test.go
`Monitor/MonitorIntegrationTests.cs`	monitor_test.go
`MiscTests.cs`	msgtrace_test.go, routes_test.go, filestore_test.go, server_test.go, memstore_test.go, gateway_test.go, websocket_test.go

Test IDs (porting.db)

events_test.go (13): 303,304,305,306,307,308,309,310,311,314,315,346,347

monitor_test.go (15): 2064,2087,2088,2089,2090,2091,2092,2093,2094,2095,2096,2097,2098,2163,2165

msgtrace_test.go (7): 2329,2330,2331,2332,2333,2350,2351

routes_test.go (5): 2815,2831,2837,2851,2857

filestore_test.go (6): 493,552,553,554,569,598

server_test.go (1): 2893

memstore_test.go (1): 2057

gateway_test.go (1): 683

websocket_test.go (1): 3095

Agent Prompt

BATCH 59: Events + Monitor + Misc Integration Tests (50 tests)

Port 50 miscellaneous integration tests across events, monitoring, routing, stores, and protocols.

GO SOURCE FILES (read these first):
  - golang/nats-server/server/events_test.go (13 tests)
  - golang/nats-server/server/monitor_test.go (15 tests)
  - golang/nats-server/server/msgtrace_test.go (7 tests)
  - golang/nats-server/server/routes_test.go (5 tests)
  - golang/nats-server/server/filestore_test.go (6 tests)
  - golang/nats-server/server/server_test.go (1 test)
  - golang/nats-server/server/memstore_test.go (1 test)
  - golang/nats-server/server/gateway_test.go (1 test)
  - golang/nats-server/server/websocket_test.go (1 test)

.NET TARGET FILES (create):
  - dotnet/tests/ZB.MOM.NatsNet.Server.IntegrationTests/Events/EventsTests.cs
    (13 event system tests)
  - dotnet/tests/ZB.MOM.NatsNet.Server.IntegrationTests/Monitor/MonitorIntegrationTests.cs
    (15 monitoring endpoint tests)
  - dotnet/tests/ZB.MOM.NatsNet.Server.IntegrationTests/MiscTests.cs
    (7 msgtrace + 5 routes + 6 filestore + 1 server + 1 memstore + 1 gateway + 1 websocket = 22 tests)

HARNESS APIs AVAILABLE (under Helpers/):
  - TestServerHelper.RunServer(opts) / RunBasicJetStreamServer(Output) / RunServerWithConfig(configFile)
  - TestCluster.CreateJetStreamCluster(numServers, name)
  - NatsTestClient.Connect(url) / ConnectToServer(server)
  - CheckHelper.CheckFor(timeout, interval, check) / CheckClusterFormed(servers)
  - ConfigHelper.CreateConfigFile(content)
  - IntegrationTestBase — base class with Skip guard

NOTE: Monitor tests may use HTTP requests (HttpClient) to hit monitoring endpoints.
Events tests use system subscriptions to observe server events.
Routes/Gateway/Websocket tests may need cluster or multi-server setups.

TEST IDS — events_test.go (13): 303,304,305,306,307,308,309,310,311,314,315,346,347
TEST IDS — monitor_test.go (15): 2064,2087,2088,2089,2090,2091,2092,2093,2094,2095,2096,2097,2098,2163,2165
TEST IDS — msgtrace_test.go (7): 2329,2330,2331,2332,2333,2350,2351
TEST IDS — routes_test.go (5): 2815,2831,2837,2851,2857
TEST IDS — filestore_test.go (6): 493,552,553,554,569,598
TEST IDS — server_test.go (1): 2893
TEST IDS — memstore_test.go (1): 2057
TEST IDS — gateway_test.go (1): 683
TEST IDS — websocket_test.go (1): 3095

BUILD: dotnet build dotnet/tests/ZB.MOM.NatsNet.Server.IntegrationTests/
VERIFY: dotnet test dotnet/tests/ZB.MOM.NatsNet.Server.Tests/ --no-build -c Debug
COMMIT: "test(batch59): port 50 events, monitor, and misc integration tests"

Task 13: Post-Merge Reconciliation

Blocked by: All test batches (Tasks 2-12)

Steps

After all 12 batch branches are merged to main:
Build verification:
```
dotnet build dotnet/
```

Integration test run (all should skip):

dotnet test dotnet/tests/ZB.MOM.NatsNet.Server.IntegrationTests/ -v n

Unit test regression check:

dotnet test dotnet/tests/ZB.MOM.NatsNet.Server.Tests/

PortTracker reconciliation:

# Reset deferred tests to unknown
sqlite3 porting.db "UPDATE unit_tests SET status='unknown' WHERE status='deferred';"

# Run audit to auto-detect
dotnet run --project tools/NatsNet.PortTracker -- audit --type tests --db porting.db --execute

# Check how many promoted
sqlite3 porting.db "SELECT status, COUNT(*) FROM unit_tests GROUP BY status;"

# Bulk-promote any remaining to verified (after confirming they exist)
sqlite3 porting.db "UPDATE unit_tests SET status='verified' WHERE status='unknown';"

Generate report:

./reports/generate-report.sh
git add -f reports/current.md

Commit:

git commit -m "chore(integration-tests): reconcile porting.db after all test batches merged"

Expected Final State

Tests: 2066 + 884 = 2950 verified (all unit_tests accounted for)
Features: 3626 verified, 22 complete, 24 n/a, 1 stub
Overall: ~6941/6942 items (99.9%)

Agent Launch Commands

Wave 1: Harness (foreground, must complete first)

Agent(
  description="Batch 48: test harness",
  subagent_type="general-purpose",
  model="sonnet",
  isolation="worktree",
  prompt="<batch 48 prompt above>"
)

After merge to main, proceed to Wave 2.

Wave 2: All Test Batches (background, parallel)

Launch all 11 agents simultaneously with run_in_background: true:

Agent(subagent_type="general-purpose", model="sonnet", isolation="worktree", run_in_background=true, description="Batch 49: JS core tests", prompt="<batch 49 prompt>")
Agent(subagent_type="general-purpose", model="sonnet", isolation="worktree", run_in_background=true, description="Batch 50: JS cluster 1", prompt="<batch 50 prompt>")
Agent(subagent_type="general-purpose", model="sonnet", isolation="worktree", run_in_background=true, description="Batch 51: JS cluster 2", prompt="<batch 51 prompt>")
Agent(subagent_type="general-purpose", model="sonnet", isolation="worktree", run_in_background=true, description="Batch 52: JS cluster 3", prompt="<batch 52 prompt>")
Agent(subagent_type="general-purpose", model="sonnet", isolation="worktree", run_in_background=true, description="Batch 53: JS cluster 4", prompt="<batch 53 prompt>")
Agent(subagent_type="general-purpose", model="sonnet", isolation="worktree", run_in_background=true, description="Batch 54: MQTT tests", prompt="<batch 54 prompt>")
Agent(subagent_type="general-purpose", model="sonnet", isolation="worktree", run_in_background=true, description="Batch 55: NoRace tests", prompt="<batch 55 prompt>")
Agent(subagent_type="general-purpose", model="sonnet", isolation="worktree", run_in_background=true, description="Batch 56: Reload+Auth", prompt="<batch 56 prompt>")
Agent(subagent_type="general-purpose", model="sonnet", isolation="worktree", run_in_background=true, description="Batch 57: SuperCluster", prompt="<batch 57 prompt>")
Agent(subagent_type="general-purpose", model="sonnet", isolation="worktree", run_in_background=true, description="Batch 58: JS misc", prompt="<batch 58 prompt>")
Agent(subagent_type="general-purpose", model="sonnet", isolation="worktree", run_in_background=true, description="Batch 59: Events+Monitor", prompt="<batch 59 prompt>")

Wave 3: Reconciliation (after all Wave 2 merges)

Run Task 13 manually or via agent after all branches merge.

45 KiB Raw Permalink Blame History

Deferred Integration Tests Implementation Plan

Execution Model

Wave 1: Harness (Sequential)

Wave 2: Test Batches (Parallel)

Merge Strategy

Shared Standards (All Batches)

.NET Standards

Go-to-C# Translation

Agent Prompt Wrapper

Task 1: Batch 48 — Test Harness Infrastructure

Files to Create

Files to Modify

Go Reference Files

Agent Prompt

Task 2: Batch 49 — JetStream Core (126 tests)

Go Source Files

.NET Target Files

Test IDs (porting.db)

Agent Prompt

Task 3: Batch 50 — JetStream Cluster 1 (118 tests)

Go Source Files

.NET Target Files

Test IDs (porting.db)

Agent Prompt

Task 4: Batch 51 — JetStream Cluster 2 (106 tests)

Go Source Files

.NET Target Files

Test IDs (porting.db)

Agent Prompt

Task 5: Batch 52 — JetStream Cluster 3 (82 tests)

Go Source Files

.NET Target Files

Test IDs (porting.db)

Agent Prompt

Task 6: Batch 53 — JetStream Cluster 4 (75 tests)

Go Source Files

.NET Target Files

Test IDs (porting.db)

Agent Prompt

Task 7: Batch 54 — MQTT (78 tests)

Go Source Files

.NET Target Files

Test IDs (porting.db)

Agent Prompt

Task 8: Batch 55 — NoRace (75 tests)

Go Source Files

.NET Target Files

Test IDs (porting.db)

Agent Prompt

Task 9: Batch 56 — Reload + Auth (66 tests)

Go Source Files

.NET Target Files

Test IDs (porting.db)

Agent Prompt

Task 10: Batch 57 — SuperCluster + LeafNode (53 tests)

Go Source Files

.NET Target Files

Test IDs (porting.db)

Agent Prompt

Task 11: Batch 58 — JetStream Misc (55 tests)

Go Source Files

.NET Target Files

Test IDs (porting.db)

Agent Prompt

Task 12: Batch 59 — Events + Monitor + Misc (50 tests)

Go Source Files

.NET Target Files

Test IDs (porting.db)

Agent Prompt

Task 13: Post-Merge Reconciliation

Steps

Expected Final State

Agent Launch Commands

Wave 1: Harness (foreground, must complete first)

Wave 2: All Test Batches (background, parallel)

Wave 3: Reconciliation (after all Wave 2 merges)

45 KiB

Raw Permalink Blame History