Trace Actuator Updates

src/Management/src/Endpoint/ActuatorServiceCollectionExtensions.cs

@@ -15,6 +15,7 @@
 using Steeltoe.Management.Endpoint.Actuators.Environment;
 using Steeltoe.Management.Endpoint.Actuators.Health;
 using Steeltoe.Management.Endpoint.Actuators.HeapDump;
+using Steeltoe.Management.Endpoint.Actuators.HttpExchanges;
 using Steeltoe.Management.Endpoint.Actuators.Hypermedia;
 using Steeltoe.Management.Endpoint.Actuators.Info;
 using Steeltoe.Management.Endpoint.Actuators.Loggers;
@@ -23,7 +24,6 @@
 using Steeltoe.Management.Endpoint.Actuators.RouteMappings;
 using Steeltoe.Management.Endpoint.Actuators.Services;
 using Steeltoe.Management.Endpoint.Actuators.ThreadDump;
-using Steeltoe.Management.Endpoint.Actuators.Trace;
 using Steeltoe.Management.Endpoint.Configuration;
 using Steeltoe.Management.Endpoint.ManagementPort;
 
@@ -98,7 +98,7 @@ public static IServiceCollection AddAllActuators(this IServiceCollection service
         services.AddInfoActuator();
         services.AddHealthActuator();
         services.AddLoggersActuator();
-        services.AddTraceActuator(version);
+        services.AddHttpExchangesActuator();
         services.AddMappingsActuator();
         services.AddMetricsActuator();
         services.AddRefreshActuator();

src/Management/src/Endpoint/Actuators/HttpExchanges/ConfigureHttpExchangesEndpointOptions.cs

@@ -0,0 +1,91 @@
+// Licensed to the .NET Foundation under one or more agreements.
+// The .NET Foundation licenses this file to you under the Apache 2.0 License.
+// See the LICENSE file in the project root for more information.
+
+using Microsoft.Extensions.Configuration;
+using Microsoft.Net.Http.Headers;
+using Steeltoe.Management.Endpoint.Configuration;
+
+namespace Steeltoe.Management.Endpoint.Actuators.HttpExchanges;
+
+internal sealed class ConfigureHttpExchangesEndpointOptions(IConfiguration configuration)
+    : ConfigureEndpointOptions<HttpExchangesEndpointOptions>(configuration, ManagementInfoPrefix, "httpexchanges")
+{
+    private const string ManagementInfoPrefix = "management:endpoints:httpexchanges";
+    private const int DefaultCapacity = 100;
+
+    private static readonly string[] DefaultAllowedRequestHeaders =
+    [
+        HeaderNames.Accept,
+        HeaderNames.AcceptCharset,
+        HeaderNames.AcceptEncoding,
+        HeaderNames.AcceptLanguage,
+        HeaderNames.Allow,
+        HeaderNames.CacheControl,
+        HeaderNames.Connection,
+        HeaderNames.ContentEncoding,
+        HeaderNames.ContentLength,
+        HeaderNames.ContentType,
+        HeaderNames.Date,
+        HeaderNames.DNT,
+        HeaderNames.Expect,
+        HeaderNames.Host,
+        HeaderNames.MaxForwards,
+        HeaderNames.Range,
+        HeaderNames.SecWebSocketExtensions,
+        HeaderNames.SecWebSocketVersion,
+        HeaderNames.TE,
+        HeaderNames.Trailer,
+        HeaderNames.TransferEncoding,
+        HeaderNames.Upgrade,
+        HeaderNames.UserAgent,
+        HeaderNames.Warning,
+        HeaderNames.XRequestedWith,
+        HeaderNames.XUACompatible
+    ];
+
+    private static readonly string[] DefaultAllowedResponseHeaders =
+    [
+        HeaderNames.AcceptRanges,
+        HeaderNames.Age,
+        HeaderNames.Allow,
+        HeaderNames.AltSvc,
+        HeaderNames.Connection,
+        HeaderNames.ContentDisposition,
+        HeaderNames.ContentLanguage,
+        HeaderNames.ContentLength,
+        HeaderNames.ContentLocation,
+        HeaderNames.ContentRange,
+        HeaderNames.ContentType,
+        HeaderNames.Date,
+        HeaderNames.Expires,
+        HeaderNames.LastModified,
+        HeaderNames.Location,
+        HeaderNames.Server,
+        HeaderNames.TransferEncoding,
+        HeaderNames.Upgrade,
+        HeaderNames.XPoweredBy
+    ];
+
+    public override void Configure(HttpExchangesEndpointOptions options)
+    {
+        ArgumentNullException.ThrowIfNull(options);
+
+        base.Configure(options);
+
+        if (options.Capacity < 1)
+        {
+            options.Capacity = DefaultCapacity;
+        }
+
+        foreach (string defaultKey in DefaultAllowedRequestHeaders)
+        {
+            options.RequestHeaders.Add(defaultKey);
+        }
+
+        foreach (string defaultKey in DefaultAllowedResponseHeaders)
+        {
+            options.ResponseHeaders.Add(defaultKey);
+        }
+    }
+}

src/Management/src/Endpoint/Actuators/HttpExchanges/EndpointServiceCollectionExtensions.cs

@@ -0,0 +1,37 @@
+// Licensed to the .NET Foundation under one or more agreements.
+// The .NET Foundation licenses this file to you under the Apache 2.0 License.
+// See the LICENSE file in the project root for more information.
+
+using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.DependencyInjection.Extensions;
+using Steeltoe.Management.Diagnostics;
+
+namespace Steeltoe.Management.Endpoint.Actuators.HttpExchanges;
+
+public static class EndpointServiceCollectionExtensions
+{
+    /// <summary>
+    /// Adds the HttpExchanges actuator to the service container.
+    /// </summary>
+    /// <param name="services">
+    /// The <see cref="IServiceCollection" /> to add services to.
+    /// </param>
+    /// <returns>
+    /// The incoming <paramref name="services" /> so that additional calls can be chained.
+    /// </returns>
+    public static IServiceCollection AddHttpExchangesActuator(this IServiceCollection services)
+    {
+        ArgumentNullException.ThrowIfNull(services);
+
+        services.TryAddSingleton<IDiagnosticsManager, DiagnosticsManager>();
+        services.AddHostedService<DiagnosticsService>();
+        services.AddCommonActuatorServices();
+        services.AddHttpExchangesActuatorServices();
+        services.TryAddEnumerable(ServiceDescriptor.Singleton<IDiagnosticObserver, HttpExchangesDiagnosticObserver>());
+
+        services.TryAddSingleton<IHttpExchangesRepository>(provider =>
+            provider.GetServices<IDiagnosticObserver>().OfType<HttpExchangesDiagnosticObserver>().Single());
+
+        return services;
+    }
+}

src/Management/src/Endpoint/Actuators/HttpExchanges/HttpExchange.cs

@@ -0,0 +1,37 @@
+// Licensed to the .NET Foundation under one or more agreements.
+// The .NET Foundation licenses this file to you under the Apache 2.0 License.
+// See the LICENSE file in the project root for more information.
+
+using System.Text.Json.Serialization;
+using System.Xml;
+
+namespace Steeltoe.Management.Endpoint.Actuators.HttpExchanges;
+
+public sealed class HttpExchange
+{
+    [JsonPropertyName("TimeTaken")]
+    internal string SerializedTimeTaken => XmlConvert.ToString(TimeTaken);
+
+    public DateTime Timestamp { get; }
+    public HttpExchangePrincipal? Principal { get; }
+    public HttpExchangeSession? Session { get; }
+    public HttpExchangeRequest Request { get; }
+    public HttpExchangeResponse Response { get; }
+
+    [JsonIgnore]
+    public TimeSpan TimeTaken { get; }
+
+    public HttpExchange(HttpExchangeRequest request, HttpExchangeResponse response, DateTime timestamp, HttpExchangePrincipal? principal,
+        HttpExchangeSession? session, TimeSpan timeTaken)
+    {
+        ArgumentNullException.ThrowIfNull(request);
+        ArgumentNullException.ThrowIfNull(response);
+
+        Request = request;
+        Response = response;
+        Timestamp = timestamp;
+        Principal = principal;
+        Session = session;
+        TimeTaken = timeTaken;
+    }
+}

src/Management/src/Endpoint/Actuators/Trace/TracePrincipal.cs → src/Management/src/Endpoint/Actuators/HttpExchanges/HttpExchangePrincipal.cs

@@ -2,13 +2,13 @@
 // The .NET Foundation licenses this file to you under the Apache 2.0 License.
 // See the LICENSE file in the project root for more information.
 
-namespace Steeltoe.Management.Endpoint.Actuators.Trace;
+namespace Steeltoe.Management.Endpoint.Actuators.HttpExchanges;
 
-public sealed class TracePrincipal
+public sealed class HttpExchangePrincipal
 {
     public string Name { get; }
 
-    public TracePrincipal(string name)
+    public HttpExchangePrincipal(string name)
     {
         ArgumentException.ThrowIfNullOrEmpty(name);
 

src/Management/src/Endpoint/Actuators/Trace/TraceRequest.cs → src/Management/src/Endpoint/Actuators/HttpExchanges/HttpExchangeRequest.cs

@@ -2,19 +2,21 @@
 // The .NET Foundation licenses this file to you under the Apache 2.0 License.
 // See the LICENSE file in the project root for more information.
 
-namespace Steeltoe.Management.Endpoint.Actuators.Trace;
+using Microsoft.Extensions.Primitives;
 
-public sealed class TraceRequest
+namespace Steeltoe.Management.Endpoint.Actuators.HttpExchanges;
+
+public sealed class HttpExchangeRequest
 {
     public string Method { get; }
-    public string Uri { get; }
-    public IDictionary<string, IList<string?>> Headers { get; }
+    public Uri Uri { get; }
+    public IDictionary<string, StringValues> Headers { get; }
     public string? RemoteAddress { get; }
 
-    public TraceRequest(string method, string uri, IDictionary<string, IList<string?>> headers, string? remoteAddress)
+    public HttpExchangeRequest(string method, Uri uri, IDictionary<string, StringValues> headers, string? remoteAddress)
     {
         ArgumentException.ThrowIfNullOrWhiteSpace(method);
-        ArgumentException.ThrowIfNullOrWhiteSpace(uri);
+        ArgumentNullException.ThrowIfNull(uri);
         ArgumentNullException.ThrowIfNull(headers);
 
         Method = method;

src/Management/src/Endpoint/Actuators/Trace/TraceResponse.cs → src/Management/src/Endpoint/Actuators/HttpExchanges/HttpExchangeResponse.cs

@@ -2,14 +2,16 @@
 // The .NET Foundation licenses this file to you under the Apache 2.0 License.
 // See the LICENSE file in the project root for more information.
 
-namespace Steeltoe.Management.Endpoint.Actuators.Trace;
+using Microsoft.Extensions.Primitives;
 
-public sealed class TraceResponse
+namespace Steeltoe.Management.Endpoint.Actuators.HttpExchanges;
+
+public sealed class HttpExchangeResponse
 {
     public int Status { get; }
-    public IDictionary<string, IList<string?>> Headers { get; }
+    public IDictionary<string, StringValues> Headers { get; }
 
-    public TraceResponse(int status, IDictionary<string, IList<string?>> headers)
+    public HttpExchangeResponse(int status, IDictionary<string, StringValues> headers)
     {
         ArgumentNullException.ThrowIfNull(headers);
 

src/Management/src/Endpoint/Actuators/Trace/TraceSession.cs → src/Management/src/Endpoint/Actuators/HttpExchanges/HttpExchangeSession.cs

@@ -2,13 +2,13 @@
 // The .NET Foundation licenses this file to you under the Apache 2.0 License.
 // See the LICENSE file in the project root for more information.
 
-namespace Steeltoe.Management.Endpoint.Actuators.Trace;
+namespace Steeltoe.Management.Endpoint.Actuators.HttpExchanges;
 
-public sealed class TraceSession
+public sealed class HttpExchangeSession
 {
     public string Id { get; }
 
-    public TraceSession(string id)
+    public HttpExchangeSession(string id)
     {
         ArgumentException.ThrowIfNullOrWhiteSpace(id);