Add AddJsonOptions to KubernetesClientConfiguration and KubernetesJson

examples/prometheus/Prometheus.cs

@@ -1,7 +1,6 @@
 using k8s;
 using Prometheus;
 using System;
-using System.Net.Http;
 using System.Threading;
 
 namespace prom
@@ -12,7 +11,7 @@ private static void Main(string[] args)
         {
             var config = KubernetesClientConfiguration.BuildDefaultConfig();
             var handler = new PrometheusHandler();
-            IKubernetes client = new Kubernetes(config, new DelegatingHandler[] { handler });
+            IKubernetes client = new Kubernetes(config, handler);
 
             var server = new MetricServer(hostname: "localhost", port: 1234);
             server.Start();

src/KubernetesClient.Models/KubernetesJson.cs

@@ -66,6 +66,21 @@ static KubernetesJson()
             JsonSerializerOptions.Converters.Add(new JsonStringEnumConverter());
         }
 
+        /// <summary>
+        /// Configures <see cref="JsonSerializerOptions"/> for the <see cref="JsonSerializer"/>.
+        /// The <see cref="JsonSerializerOptions"/> can only be modified before the first serialization or deserialization takes place.
+        /// To override existing converters, add them to the top of the <see cref="JsonSerializerOptions.Converters"/> list
+        /// e.g. as follows: <code>options.Converters.Insert(index: 0, new JsonStringEnumConverter(JsonNamingPolicy.CamelCase));</code>
+        /// </summary>
+        /// <param name="configure">An <see cref="Action"/> to configure the <see cref="JsonSerializerOptions"/>.</param>
+        public static void AddJsonOptions(Action<JsonSerializerOptions> configure)
+        {
+            if (configure is not null)
+            {
+                configure(JsonSerializerOptions);
+            }
+        }
+
         public static TValue Deserialize<TValue>(string json)
         {
             return JsonSerializer.Deserialize<TValue>(json, JsonSerializerOptions);

src/KubernetesClient/Kubernetes.ConfigInit.cs

@@ -155,8 +155,6 @@ private void CreateHttpClient(DelegatingHandler[] handlers, KubernetesClientConf
             };
         }
 
-
-
         /// <summary>
         ///     Set credentials for the Client
         /// </summary>

src/KubernetesClient/KubernetesClientConfiguration.ConfigFile.cs

@@ -524,7 +524,7 @@ public static Process CreateRunnableExternalProcess(ExternalExecution config)
             process.StartInfo.RedirectStandardError = true;
             process.StartInfo.UseShellExecute = false;
             process.StartInfo.CreateNoWindow = true;
-            
+
             return process;
         }
 

src/KubernetesClient/KubernetesClientConfiguration.cs

@@ -108,5 +108,11 @@ public partial class KubernetesClientConfiguration
         /// Do not use http2 even it is available
         /// </summary>
         public bool DisableHttp2 { get; set; } = false;
+
+        /// <inheritdoc cref="KubernetesJson.AddJsonOptions(Action{JsonSerializerOptions})"/>
+        public void AddJsonOptions(Action<JsonSerializerOptions> configure)
+        {
+            KubernetesJson.AddJsonOptions(configure);
+        }
     }
 }

tests/KubernetesClient.Tests/SerializationTests.cs

@@ -0,0 +1,50 @@
+using k8s.Tests.Mock;
+using System.Text.Json;
+using System.Text.Json.Serialization;
+using System.Threading.Tasks;
+using Xunit;
+using Xunit.Abstractions;
+
+namespace k8s.Tests
+{
+    public class SerializationTests
+    {
+        private readonly ITestOutputHelper testOutput;
+
+        private enum Animals
+        {
+            Dog,
+            Cat,
+            Mouse,
+        }
+
+        public SerializationTests(ITestOutputHelper testOutput)
+        {
+            this.testOutput = testOutput;
+        }
+
+        [Fact]
+        public async Task SerializeEnumUsingCamelCase()
+        {
+            using var server = new MockKubeApiServer(testOutput);
+
+            var config = new KubernetesClientConfiguration { Host = server.Uri.ToString() };
+            config.AddJsonOptions(options =>
+            {
+                // Insert the converter at the front of the list so it overrides
+                // the default JsonStringEnumConverter without namingPolicy.
+                options.Converters.Insert(index: 0, new JsonStringEnumConverter(JsonNamingPolicy.CamelCase));
+            });
+            var client = new Kubernetes(config);
+
+            var customObject = Animals.Dog;
+
+            var result = await client.CustomObjects.CreateNamespacedCustomObjectWithHttpMessagesAsync(customObject, "TestGroup", "TestVersion", "TestNamespace", "TestPlural").ConfigureAwait(false);
+            var content = await result.Request.Content.ReadAsStringAsync();
+            Assert.Equal(@"""dog""", content);
+
+            string animal = KubernetesJson.Serialize(Animals.Cat);
+            Assert.Equal(@"""cat""", animal);
+        }
+    }
+}

tests/KubernetesClient.Tests/WatchTests.cs

@@ -445,8 +445,8 @@ public async Task TestWatchWithHandlers()
                 var handler1 = new DummyHandler();
                 var handler2 = new DummyHandler();
 
-                var client = new Kubernetes(new KubernetesClientConfiguration { Host = server.Uri.ToString() }, handler1,
-                    handler2);
+                var client = new Kubernetes(
+                    new KubernetesClientConfiguration { Host = server.Uri.ToString() }, handler1, handler2);
 
                 Assert.False(handler1.Called);
                 Assert.False(handler2.Called);
@@ -732,12 +732,13 @@ public async Task MustHttp2VersionSet()
                 return false;
             });
 
-            var h = new CheckHeaderDelegatingHandler();
-            var client = new Kubernetes(new KubernetesClientConfiguration { Host = server.Uri.ToString() }, h);
+            var handler = new CheckHeaderDelegatingHandler();
+            var client = new Kubernetes(
+                new KubernetesClientConfiguration { Host = server.Uri.ToString() }, handler);
 
-            Assert.Null(h.Version);
+            Assert.Null(handler.Version);
             await client.CoreV1.ListNamespacedPodWithHttpMessagesAsync("default", watch: true).ConfigureAwait(false);
-            Assert.Equal(HttpVersion.Version20, h.Version);
+            Assert.Equal(HttpVersion.Version20, handler.Version);
         }
     }
 }