feat: add protocol constants, ServerInfo, ClientOptions, and NatsOptions

2026-02-22 20:00:13 -05:00
parent 270ab27ce3
commit 9e36b7c0fc
2 changed files with 100 additions and 0 deletions
--- a/src/NATS.Server/Protocol/NatsProtocol.cs
+++ b/src/NATS.Server/Protocol/NatsProtocol.cs
@@ -0,0 +1,87 @@
+using System.Text.Json.Serialization;
+
+namespace NATS.Server.Protocol;
+
+public static class NatsProtocol
+{
+    public const int MaxControlLineSize = 4096;
+    public const int MaxPayloadSize = 1024 * 1024; // 1MB
+    public const int DefaultPort = 4222;
+    public const string Version = "0.1.0";
+    public const int ProtoVersion = 1;
+
+    // Pre-encoded protocol fragments
+    public static readonly byte[] CrLf = "\r\n"u8.ToArray();
+    public static readonly byte[] PingBytes = "PING\r\n"u8.ToArray();
+    public static readonly byte[] PongBytes = "PONG\r\n"u8.ToArray();
+    public static readonly byte[] OkBytes = "+OK\r\n"u8.ToArray();
+    public static readonly byte[] InfoPrefix = "INFO "u8.ToArray();
+    public static readonly byte[] MsgPrefix = "MSG "u8.ToArray();
+    public static readonly byte[] HmsgPrefix = "HMSG "u8.ToArray();
+    public static readonly byte[] ErrPrefix = "-ERR "u8.ToArray();
+}
+
+public sealed class ServerInfo
+{
+    [JsonPropertyName("server_id")]
+    public required string ServerId { get; set; }
+
+    [JsonPropertyName("server_name")]
+    public required string ServerName { get; set; }
+
+    [JsonPropertyName("version")]
+    public required string Version { get; set; }
+
+    [JsonPropertyName("proto")]
+    public int Proto { get; set; } = NatsProtocol.ProtoVersion;
+
+    [JsonPropertyName("host")]
+    public required string Host { get; set; }
+
+    [JsonPropertyName("port")]
+    public int Port { get; set; }
+
+    [JsonPropertyName("headers")]
+    public bool Headers { get; set; } = true;
+
+    [JsonPropertyName("max_payload")]
+    public int MaxPayload { get; set; } = NatsProtocol.MaxPayloadSize;
+
+    [JsonPropertyName("client_id")]
+    [JsonIgnore(Condition = JsonIgnoreCondition.WhenWritingDefault)]
+    public ulong ClientId { get; set; }
+
+    [JsonPropertyName("client_ip")]
+    [JsonIgnore(Condition = JsonIgnoreCondition.WhenWritingNull)]
+    public string? ClientIp { get; set; }
+}
+
+public sealed class ClientOptions
+{
+    [JsonPropertyName("verbose")]
+    public bool Verbose { get; set; }
+
+    [JsonPropertyName("pedantic")]
+    public bool Pedantic { get; set; }
+
+    [JsonPropertyName("echo")]
+    public bool Echo { get; set; } = true;
+
+    [JsonPropertyName("name")]
+    public string? Name { get; set; }
+
+    [JsonPropertyName("lang")]
+    public string? Lang { get; set; }
+
+    [JsonPropertyName("version")]
+    public string? Version { get; set; }
+
+    [JsonPropertyName("protocol")]
+    public int Protocol { get; set; }
+
+    [JsonPropertyName("headers")]
+    public bool Headers { get; set; }
+
+    [JsonPropertyName("no_responders")]
+    public bool NoResponders { get; set; }
+}