Added GetCALeaf endpoint, added tests for the endpoint in AgentTest.cs, modified IAgentEndpoint.cs to have GetCALeaf

Consul.Test/AgentTest.cs

@@ -1053,6 +1053,33 @@ public async Task Agent_CARoots()
             }
         }
 
+        [Fact]
+        public async Task Agent_CALeaf()
+        {
+            var service = new AgentServiceRegistration
+            {
+                Name = "test_leaf",
+                Tags = new[]
+                {
+                    "bar",
+                    "baz"
+                },
+                Port = 8000,
+            };
+            await _client.Agent.ServiceRegister(service);
+            var leaf = await _client.Agent.GetCALeaf("test_leaf");
+            Assert.True(leaf.LastIndex > 0);
+            Assert.NotNull(leaf.Response.SerialNumber);
+            Assert.NotNull(leaf.Response.CertPEM);
+            Assert.NotNull(leaf.Response.PrivateKeyPEM);
+            Assert.Equal("test_leaf", leaf.Response.Service);
+            Assert.Contains("/svc/test_leaf", leaf.Response.ServiceURI);
+            Assert.True(leaf.Response.ModifyIndex > 0);
+            Assert.NotEqual(0, leaf.Response.CreateIndex);
+            Assert.True(leaf.Response.ValidBefore > DateTime.Now);
+            Assert.True(leaf.Response.ValidAfter < DateTime.Now);
+        }
+
         [SkippableFact]
         public async Task Agent_Reload()
         {

Consul/Agent.cs

@@ -701,6 +701,19 @@ public class Root
         public long ModifyIndex { get; set; }
     }
 
+    public class CALeaf
+    {
+        public string SerialNumber { get; set; }
+        public string CertPEM { get; set; }
+        public string PrivateKeyPEM { get; set; }
+        public string Service { get; set; }
+        public string ServiceURI { get; set; }
+        public DateTime ValidAfter { get; set; }
+        public DateTime ValidBefore { get; set; }
+        public long CreateIndex { get; set; }
+        public long ModifyIndex { get; set; }
+    }
+
     /// <summary>
     /// Agent can be used to query the Agent endpoints
     /// </summary>
@@ -1185,6 +1198,29 @@ public async Task<QueryResult<CARoots>> GetCARoots(QueryOptions q, CancellationT
             return await _client.Get<CARoots>("v1/agent/connect/ca/roots", q).Execute(ct).ConfigureAwait(false);
         }
 
+        /// <summary>
+        /// GetCALeaf, returns the leaf certificate representing a single service
+        /// </summary>
+        /// <param name="serviceId">Id of service to fetch</param>
+        /// <param name="ct">Cancellation Token</param>
+        /// <returns>Leaf certificate</returns>
+        public async Task<QueryResult<CALeaf>> GetCALeaf(string serviceId, CancellationToken ct = default)
+        {
+            return await GetCALeaf(serviceId, QueryOptions.Default, ct).ConfigureAwait(false);
+        }
+
+        /// <summary>
+        /// GetCALeaf, returns the leaf certificate representing a single service
+        /// </summary>
+        /// <param name="serviceId">Id of service to fetch</param>
+        /// <param name="q">Query Options</param>
+        /// <param name="ct">Cancellation Token</param>
+        /// <returns>Leaf certificate</returns>
+        public async Task<QueryResult<CALeaf>> GetCALeaf(string serviceId, QueryOptions q, CancellationToken ct = default)
+        {
+            return await _client.Get<CALeaf>($"v1/agent/connect/ca/leaf/{serviceId}", q).Execute(ct).ConfigureAwait(false);
+        }
+
         /// <summary>
         /// Log streamer
         /// </summary>

Consul/Interfaces/IAgentEndpoint.cs

@@ -65,6 +65,8 @@ public interface IAgentEndpoint
         Task<QueryResult<Metrics>> GetAgentMetrics(CancellationToken ct = default);
         Task<QueryResult<CARoots>> GetCARoots(CancellationToken ct = default);
         Task<QueryResult<CARoots>> GetCARoots(QueryOptions q, CancellationToken ct = default);
+        Task<QueryResult<CALeaf>> GetCALeaf(string serviceId, CancellationToken ct = default);
+        Task<QueryResult<CALeaf>> GetCALeaf(string serviceId, QueryOptions q, CancellationToken ct = default);
         Task<QueryResult<AgentVersion>> GetAgentVersion(CancellationToken ct = default);
         Task<WriteResult> Reload(CancellationToken ct = default);
         [Obsolete]