diff --git a/dotnet/src/ZB.MOM.NatsNet.Server/Mqtt/MqttHandler.cs b/dotnet/src/ZB.MOM.NatsNet.Server/Mqtt/MqttHandler.cs index 9199956..aa94c9f 100644 --- a/dotnet/src/ZB.MOM.NatsNet.Server/Mqtt/MqttHandler.cs +++ b/dotnet/src/ZB.MOM.NatsNet.Server/Mqtt/MqttHandler.cs @@ -133,8 +133,10 @@ internal static class MqttServerExtensions /// Start listening for MQTT client connections. /// Mirrors Go (*Server).startMQTT(). /// - public static void StartMqtt(this NatsServer server) => - throw new NotImplementedException("TODO: session 22"); + public static void StartMqtt(this NatsServer server) + { + server.Warnf("MQTT listener not yet implemented; skipping MQTT startup"); + } /// /// Configure MQTT authentication overrides from the MQTT options block. diff --git a/dotnet/src/ZB.MOM.NatsNet.Server/NatsServer.Auth.cs b/dotnet/src/ZB.MOM.NatsNet.Server/NatsServer.Auth.cs index 3bc893a..30dec2c 100644 --- a/dotnet/src/ZB.MOM.NatsNet.Server/NatsServer.Auth.cs +++ b/dotnet/src/ZB.MOM.NatsNet.Server/NatsServer.Auth.cs @@ -362,4 +362,22 @@ public sealed partial class NatsServer /// Wraps the synchronous method. /// internal Task ShutdownAsync() => Task.Run(Shutdown); + + // ========================================================================= + // CheckAuthForWarnings (feature 3049 — Start parity) + // ========================================================================= + + /// + /// Checks for insecure auth configurations and logs warnings. + /// Mirrors Go Server.checkAuthforWarnings() in server/server.go. + /// Stub — full implementation deferred. + /// + internal void CheckAuthForWarnings() + { + // No-op stub. Go logs warnings about: + // - Password auth without TLS + // - Token auth without TLS + // - NKey auth without TLS + // These are informational warnings only. + } } diff --git a/dotnet/src/ZB.MOM.NatsNet.Server/NatsServer.JetStreamCore.cs b/dotnet/src/ZB.MOM.NatsNet.Server/NatsServer.JetStreamCore.cs index 9a5f983..eeb95db 100644 --- a/dotnet/src/ZB.MOM.NatsNet.Server/NatsServer.JetStreamCore.cs +++ b/dotnet/src/ZB.MOM.NatsNet.Server/NatsServer.JetStreamCore.cs @@ -571,4 +571,23 @@ public sealed partial class NatsServer _jetStream == null ? null : new JetStreamEngine(_jetStream); internal JetStream? GetJetStreamState() => _jetStream; + + // ========================================================================= + // Delayed API responder (feature 3049 — Start parity) + // ========================================================================= + + /// + /// Starts the delayed JetStream API response handler goroutine. + /// Started regardless of JetStream being enabled (can be enabled via config reload). + /// Mirrors Go Server.delayedAPIResponder() in server/jetstream_api.go. + /// Stub — full implementation deferred. + /// + internal void StartDelayedApiResponder() + { + StartGoRoutine(() => + { + // No-op: exits when quit is signaled. + _quitCts.Token.WaitHandle.WaitOne(); + }); + } } diff --git a/reports/current.md b/reports/current.md index 654b5bd..85d94e5 100644 --- a/reports/current.md +++ b/reports/current.md @@ -1,6 +1,6 @@ # NATS .NET Porting Status Report -Generated: 2026-03-01 19:52:36 UTC +Generated: 2026-03-01 20:01:24 UTC ## Modules (12 total)