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

feat: add system account ($SYS) and server NKey identity stubs

Browse Source
This commit is contained in:
Joseph Doherty
2026-02-22 23:39:22 -05:00
parent 086b4f50e8
commit 600c6f9e5a
2 changed files with 35 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
src/NATS.Server/NatsServer.cs
View File

@@ -5,6 +5,7 @@ using System.Net.Sockets;
using System.Security.Cryptography.X509Certificates; using System.Security.Cryptography.X509Certificates;
using System.Text; using System.Text;
using Microsoft.Extensions.Logging; using Microsoft.Extensions.Logging;
using NATS.NKeys;
using NATS.Server.Auth; using NATS.Server.Auth;
using NATS.Server.Monitoring; using NATS.Server.Monitoring;
using NATS.Server.Protocol; using NATS.Server.Protocol;
@@ -25,6 +26,7 @@ public sealed class NatsServer : IMessageRouter, ISubListAccess, IDisposable
private readonly AuthService _authService; private readonly AuthService _authService;
private readonly ConcurrentDictionary<string, Account> _accounts = new(StringComparer.Ordinal); private readonly ConcurrentDictionary<string, Account> _accounts = new(StringComparer.Ordinal);
private readonly Account _globalAccount; private readonly Account _globalAccount;
private readonly Account _systemAccount;
private readonly SslServerAuthenticationOptions? _sslOptions; private readonly SslServerAuthenticationOptions? _sslOptions;
private readonly TlsRateLimiter? _tlsRateLimiter; private readonly TlsRateLimiter? _tlsRateLimiter;
private Socket? _listener; private Socket? _listener;
@@ -39,6 +41,8 @@ public sealed class NatsServer : IMessageRouter, ISubListAccess, IDisposable
public string ServerName => _serverInfo.ServerName; public string ServerName => _serverInfo.ServerName;
public int ClientCount => _clients.Count; public int ClientCount => _clients.Count;
public int Port => _options.Port; public int Port => _options.Port;
public Account SystemAccount => _systemAccount;
public string ServerNKey { get; }
public IEnumerable<NatsClient> GetClients() => _clients.Values; public IEnumerable<NatsClient> GetClients() => _clients.Values;
public Task WaitForReadyAsync() => _listeningStarted.Task; public Task WaitForReadyAsync() => _listeningStarted.Task;
@@ -51,6 +55,15 @@ public sealed class NatsServer : IMessageRouter, ISubListAccess, IDisposable
_authService = AuthService.Build(options); _authService = AuthService.Build(options);
_globalAccount = new Account(Account.GlobalAccountName); _globalAccount = new Account(Account.GlobalAccountName);
_accounts[Account.GlobalAccountName] = _globalAccount; _accounts[Account.GlobalAccountName] = _globalAccount;
// Create $SYS system account (stub -- no internal subscriptions yet)
_systemAccount = new Account("$SYS");
_accounts["$SYS"] = _systemAccount;
// Generate Ed25519 server NKey identity
using var serverKeyPair = KeyPair.CreatePair(PrefixByte.Server);
ServerNKey = serverKeyPair.GetPublicKey();
_serverInfo = new ServerInfo _serverInfo = new ServerInfo
{ {
ServerId = Guid.NewGuid().ToString("N")[..20].ToUpperInvariant(), ServerId = Guid.NewGuid().ToString("N")[..20].ToUpperInvariant(),

22
tests/NATS.Server.Tests/ServerTests.cs
View File

@@ -525,3 +525,25 @@ public class CloseReasonTests : IAsyncLifetime
natsClient.CloseReason.ShouldBe(ClosedState.ClientClosed); natsClient.CloseReason.ShouldBe(ClosedState.ClientClosed);
} }
} }
public class ServerIdentityTests
{
[Fact]
public void Server_creates_system_account()
{
var server = new NatsServer(new NatsOptions { Port = 0 }, NullLoggerFactory.Instance);
server.SystemAccount.ShouldNotBeNull();
server.SystemAccount.Name.ShouldBe("$SYS");
server.Dispose();
}
[Fact]
public void Server_generates_nkey_identity()
{
var server = new NatsServer(new NatsOptions { Port = 0 }, NullLoggerFactory.Instance);
server.ServerNKey.ShouldNotBeNullOrEmpty();
// Server NKey public keys start with 'N'
server.ServerNKey[0].ShouldBe('N');
server.Dispose();
}
}