Add Metadata to KV Bucket (#741)

* Add Metadata to KV Bucket

* Add test

* Fix test

Author: mtmk

src/NATS.Client.KeyValueStore/NatsKVConfig.cs

@@ -77,6 +77,11 @@ public record NatsKVConfig
     /// Sources defines the configuration for sources of a KeyValue store.
     /// </summary>
     public ICollection<StreamSource>? Sources { get; set; }
+
+    /// <summary>
+    /// Additional metadata for the Bucket
+    /// </summary>
+    public IDictionary<string, string>? Metadata { get; set; }
 }
 
 /// <summary>

src/NATS.Client.KeyValueStore/NatsKVContext.cs

@@ -246,6 +246,7 @@ private static StreamConfig CreateStreamConfig(NatsKVConfig config)
             MirrorDirect = mirrorDirect,
             Sources = sources,
             Retention = StreamConfigRetention.Limits, // from ADR-8
+            Metadata = config.Metadata,
         };
 
         return streamConfig;

tests/NATS.Client.KeyValueStore.Tests/KeyValueStoreTest.cs

@@ -515,7 +515,13 @@ public async Task Status()
         var js = new NatsJSContext(nats);
         var kv = new NatsKVContext(js);
 
-        var store = await kv.CreateStoreAsync(new NatsKVConfig("kv1") { History = 10 }, cancellationToken: cancellationToken);
+        var store = await kv.CreateStoreAsync(
+            new NatsKVConfig("kv1")
+            {
+                History = 10,
+                Metadata = new Dictionary<string, string> { { "meta1", "value1" } },
+            },
+            cancellationToken: cancellationToken);
 
         Assert.Equal("kv1", store.Bucket);
 
@@ -524,6 +530,16 @@ public async Task Status()
         Assert.Equal("kv1", status.Bucket);
         Assert.Equal("KV_kv1", status.Info.Config.Name);
         Assert.Equal(10, status.Info.Config.MaxMsgsPerSubject);
+
+        if (!nats.ServerInfo!.Version.StartsWith("2.9."))
+        {
+            _output.WriteLine("Check metadata");
+            Assert.Equal("value1", status.Info.Config.Metadata?["meta1"]);
+        }
+        else
+        {
+            _output.WriteLine("Metadata is not supported in server versions < 2.10");
+        }
     }
 
     [SkipIfNatsServer(versionEarlierThan: "2.10")]