[CI Visibility] UDS and NamedPipes support

tracer/src/Datadog.Trace/Ci/Agent/Payloads/EventPlatformPayload.cs

@@ -4,6 +4,7 @@
 // </copyright>
 
 using System;
+using Datadog.Trace.Agent;
 using Datadog.Trace.Ci.Configuration;
 using Datadog.Trace.Telemetry.Metrics;
 using Datadog.Trace.Util;
@@ -142,7 +143,18 @@ private void EnsureUrl()
             else
             {
                 // Use Agent EVP Proxy
-                builder = new UriBuilder(_settings.TracerSettings.ExporterInternal.AgentUriInternal);
+                switch (_settings.TracerSettings.ExporterInternal.TracesTransport)
+                {
+                    case TracesTransportType.WindowsNamedPipe:
+                    case TracesTransportType.UnixDomainSocket:
+                        builder = new UriBuilder("http://localhost");
+                        break;
+                    case TracesTransportType.Default:
+                    default:
+                        builder = new UriBuilder(_settings.TracerSettings.ExporterInternal.AgentUriInternal);
+                        break;
+                }
+
                 if (CIVisibility.EventPlatformProxySupport == EventPlatformProxySupport.V4)
                 {
                     builder.Path = $"/evp_proxy/v4/{EventPlatformPath}";

tracer/src/Datadog.Trace/Ci/CIVisibility.cs

@@ -12,10 +12,12 @@
 using System.Threading.Tasks;
 using Datadog.Trace.Agent;
 using Datadog.Trace.Agent.DiscoveryService;
+using Datadog.Trace.Agent.StreamFactories;
 using Datadog.Trace.Agent.Transports;
 using Datadog.Trace.Ci.CiEnvironment;
 using Datadog.Trace.Ci.Configuration;
 using Datadog.Trace.Configuration;
+using Datadog.Trace.HttpOverStreams;
 using Datadog.Trace.Logging;
 using Datadog.Trace.Pdb;
 using Datadog.Trace.PlatformHelpers;
@@ -425,48 +427,57 @@ internal static IApiRequestFactory GetRequestFactory(ImmutableTracerSettings set
         internal static IApiRequestFactory GetRequestFactory(ImmutableTracerSettings tracerSettings, TimeSpan timeout)
         {
             IApiRequestFactory? factory = null;
-
+            var exporterSettings = tracerSettings.ExporterInternal;
+            if (exporterSettings.TracesTransport != TracesTransportType.Default)
+            {
+                factory = AgentTransportStrategy.Get(
+                    exporterSettings,
+                    productName: "CI Visibility",
+                    tcpTimeout: null,
+                    AgentHttpHeaderNames.DefaultHeaders,
+                    () => new TraceAgentHttpHeaderHelper(),
+                    uri => uri);
+            }
+            else
+            {
 #if NETCOREAPP
-            Log.Information("Using {FactoryType} for trace transport.", nameof(HttpClientRequestFactory));
-            factory = new HttpClientRequestFactory(
-                tracerSettings.ExporterInternal.AgentUriInternal,
-                AgentHttpHeaderNames.DefaultHeaders,
-                handler: new System.Net.Http.HttpClientHandler
-                {
-                    AutomaticDecompression = DecompressionMethods.GZip | DecompressionMethods.Deflate,
-                },
-                timeout: timeout);
+                Log.Information("Using {FactoryType} for trace transport.", nameof(HttpClientRequestFactory));
+                factory = new HttpClientRequestFactory(
+                    exporterSettings.AgentUriInternal,
+                    AgentHttpHeaderNames.DefaultHeaders,
+                    handler: new System.Net.Http.HttpClientHandler { AutomaticDecompression = DecompressionMethods.GZip | DecompressionMethods.Deflate, },
+                    timeout: timeout);
 #else
-            Log.Information("Using {FactoryType} for trace transport.", nameof(ApiWebRequestFactory));
-            factory = new ApiWebRequestFactory(tracerSettings.ExporterInternal.AgentUriInternal, AgentHttpHeaderNames.DefaultHeaders, timeout: timeout);
+                Log.Information("Using {FactoryType} for trace transport.", nameof(ApiWebRequestFactory));
+                factory = new ApiWebRequestFactory(tracerSettings.ExporterInternal.AgentUriInternal, AgentHttpHeaderNames.DefaultHeaders, timeout: timeout);
 #endif
+                var settings = Settings;
+                if (!string.IsNullOrWhiteSpace(settings.ProxyHttps))
+                {
+                    var proxyHttpsUriBuilder = new UriBuilder(settings.ProxyHttps);
 
-            var settings = Settings;
-            if (!string.IsNullOrWhiteSpace(settings.ProxyHttps))
-            {
-                var proxyHttpsUriBuilder = new UriBuilder(settings.ProxyHttps);
+                    var userName = proxyHttpsUriBuilder.UserName;
+                    var password = proxyHttpsUriBuilder.Password;
 
-                var userName = proxyHttpsUriBuilder.UserName;
-                var password = proxyHttpsUriBuilder.Password;
+                    proxyHttpsUriBuilder.UserName = string.Empty;
+                    proxyHttpsUriBuilder.Password = string.Empty;
 
-                proxyHttpsUriBuilder.UserName = string.Empty;
-                proxyHttpsUriBuilder.Password = string.Empty;
+                    if (proxyHttpsUriBuilder.Scheme == "https")
+                    {
+                        // HTTPS proxy is not supported by .NET BCL
+                        Log.Error("HTTPS proxy is not supported. ({ProxyHttpsUriBuilder})", proxyHttpsUriBuilder);
+                        return factory;
+                    }
 
-                if (proxyHttpsUriBuilder.Scheme == "https")
-                {
-                    // HTTPS proxy is not supported by .NET BCL
-                    Log.Error("HTTPS proxy is not supported. ({ProxyHttpsUriBuilder})", proxyHttpsUriBuilder);
-                    return factory;
-                }
+                    NetworkCredential? credential = null;
+                    if (!string.IsNullOrWhiteSpace(userName))
+                    {
+                        credential = new NetworkCredential(userName, password);
+                    }
 
-                NetworkCredential? credential = null;
-                if (!string.IsNullOrWhiteSpace(userName))
-                {
-                    credential = new NetworkCredential(userName, password);
+                    Log.Information("Setting proxy to: {ProxyHttps}", proxyHttpsUriBuilder.Uri.ToString());
+                    factory.SetProxy(new WebProxy(proxyHttpsUriBuilder.Uri, true, settings.ProxyNoProxy, credential), credential);
                 }
-
-                Log.Information("Setting proxy to: {ProxyHttps}", proxyHttpsUriBuilder.Uri.ToString());
-                factory.SetProxy(new WebProxy(proxyHttpsUriBuilder.Uri, true, settings.ProxyNoProxy, credential), credential);
             }
 
             return factory;

tracer/src/Datadog.Trace/Ci/IntelligentTestRunnerClient.cs

@@ -143,23 +143,22 @@ public IntelligentTestRunnerClient(string? workingDirectory, CIVisibilitySetting
         else
         {
             // Use Agent EVP Proxy
-            var agentUrl = _settings.TracerSettings.ExporterInternal.AgentUriInternal;
             _eventPlatformProxySupport = CIVisibility.EventPlatformProxySupport;
             switch (_eventPlatformProxySupport)
             {
                 case EventPlatformProxySupport.V2:
-                    _settingsUrl = UriHelpers.Combine(agentUrl, $"evp_proxy/v2/{settingsUrlPath}");
-                    _searchCommitsUrl = UriHelpers.Combine(agentUrl, $"evp_proxy/v2/{searchCommitsUrlPath}");
-                    _packFileUrl = UriHelpers.Combine(agentUrl, $"evp_proxy/v2/{packFileUrlPath}");
-                    _skippableTestsUrl = UriHelpers.Combine(agentUrl, $"evp_proxy/v2/{skippableTestsUrlPath}");
-                    _earlyFlakeDetectionTestsUrl = UriHelpers.Combine(agentUrl, $"evp_proxy/v2/{efdTestsUrlPath}");
+                    _settingsUrl = _apiRequestFactory.GetEndpoint($"evp_proxy/v2/{settingsUrlPath}");
+                    _searchCommitsUrl = _apiRequestFactory.GetEndpoint($"evp_proxy/v2/{searchCommitsUrlPath}");
+                    _packFileUrl = _apiRequestFactory.GetEndpoint($"evp_proxy/v2/{packFileUrlPath}");
+                    _skippableTestsUrl = _apiRequestFactory.GetEndpoint($"evp_proxy/v2/{skippableTestsUrlPath}");
+                    _earlyFlakeDetectionTestsUrl = _apiRequestFactory.GetEndpoint($"evp_proxy/v2/{efdTestsUrlPath}");
                     break;
                 case EventPlatformProxySupport.V4:
-                    _settingsUrl = UriHelpers.Combine(agentUrl, $"evp_proxy/v4/{settingsUrlPath}");
-                    _searchCommitsUrl = UriHelpers.Combine(agentUrl, $"evp_proxy/v4/{searchCommitsUrlPath}");
-                    _packFileUrl = UriHelpers.Combine(agentUrl, $"evp_proxy/v4/{packFileUrlPath}");
-                    _skippableTestsUrl = UriHelpers.Combine(agentUrl, $"evp_proxy/v4/{skippableTestsUrlPath}");
-                    _earlyFlakeDetectionTestsUrl = UriHelpers.Combine(agentUrl, $"evp_proxy/v4/{efdTestsUrlPath}");
+                    _settingsUrl = _apiRequestFactory.GetEndpoint($"evp_proxy/v4/{settingsUrlPath}");
+                    _searchCommitsUrl = _apiRequestFactory.GetEndpoint($"evp_proxy/v4/{searchCommitsUrlPath}");
+                    _packFileUrl = _apiRequestFactory.GetEndpoint($"evp_proxy/v4/{packFileUrlPath}");
+                    _skippableTestsUrl = _apiRequestFactory.GetEndpoint($"evp_proxy/v4/{skippableTestsUrlPath}");
+                    _earlyFlakeDetectionTestsUrl = _apiRequestFactory.GetEndpoint($"evp_proxy/v4/{efdTestsUrlPath}");
                     break;
                 default:
                     throw new NotSupportedException("Event platform proxy not supported by the agent.");

tracer/test/Datadog.Trace.ClrProfiler.IntegrationTests/CI/PipesXUnitEvpTests.cs

@@ -0,0 +1,77 @@
+// <copyright file="PipesXUnitEvpTests.cs" company="Datadog">
+// Unless explicitly stated otherwise all files in this repository are licensed under the Apache 2 License.
+// This product includes software developed at Datadog (https://www.datadoghq.com/). Copyright 2017 Datadog, Inc.
+// </copyright>
+#if NETCOREAPP3_1_OR_GREATER
+using System;
+using System.Threading.Tasks;
+using Datadog.Trace.Configuration;
+using Datadog.Trace.TestHelpers;
+using Xunit;
+using Xunit.Abstractions;
+
+namespace Datadog.Trace.ClrProfiler.IntegrationTests.CI;
+
+[Collection(nameof(TransportTestsCollection))]
+public class PipesXUnitEvpTests(ITestOutputHelper output) : XUnitEvpTests(output)
+{
+    [SkippableTheory]
+    [MemberData(nameof(GetData))]
+    [Trait("RunOnWindows", "True")]
+    [Trait("Category", "EndToEnd")]
+    [Trait("Category", "TestIntegrations")]
+    public override async Task SubmitTraces(string packageVersion, string evpVersionToRemove, bool expectedGzip)
+    {
+        SkipOn.Platform(SkipOn.PlatformValue.MacOs);
+        SkipOn.Platform(SkipOn.PlatformValue.Linux);
+        EnvironmentHelper.EnableWindowsNamedPipes();
+        SetEnvironmentVariable(ConfigurationKeys.DebugEnabled, "1");
+
+        // The server implementation of named pipes is flaky so have 3 attempts
+        var attemptsRemaining = 3;
+        while (true)
+        {
+            try
+            {
+                attemptsRemaining--;
+                await base.SubmitTraces(packageVersion, evpVersionToRemove, expectedGzip);
+                return;
+            }
+            catch (Exception ex) when (attemptsRemaining > 0 && ex is not SkipException)
+            {
+                await ReportRetry(Output, attemptsRemaining, ex);
+            }
+        }
+    }
+
+    [SkippableTheory]
+    [MemberData(nameof(GetDataForEarlyFlakeDetection))]
+    [Trait("RunOnWindows", "True")]
+    [Trait("Category", "EndToEnd")]
+    [Trait("Category", "TestIntegrations")]
+    [Trait("Category", "EarlyFlakeDetection")]
+    public override async Task EarlyFlakeDetection(string packageVersion, string evpVersionToRemove, bool expectedGzip, string settingsJson, string testsJson, int expectedSpans, string friendlyName)
+    {
+        SkipOn.Platform(SkipOn.PlatformValue.MacOs);
+        SkipOn.Platform(SkipOn.PlatformValue.Linux);
+        EnvironmentHelper.EnableWindowsNamedPipes();
+        SetEnvironmentVariable(ConfigurationKeys.DebugEnabled, "1");
+
+        // The server implementation of named pipes is flaky so have 3 attempts
+        var attemptsRemaining = 3;
+        while (true)
+        {
+            try
+            {
+                attemptsRemaining--;
+                await base.EarlyFlakeDetection(packageVersion, evpVersionToRemove, expectedGzip, settingsJson, testsJson, expectedSpans, friendlyName);
+                return;
+            }
+            catch (Exception ex) when (attemptsRemaining > 0 && ex is not SkipException)
+            {
+                await ReportRetry(Output, attemptsRemaining, ex);
+            }
+        }
+    }
+}
+#endif

tracer/test/Datadog.Trace.ClrProfiler.IntegrationTests/CI/PipesXUnitTests.cs

@@ -0,0 +1,49 @@
+// <copyright file="PipesXUnitTests.cs" company="Datadog">
+// Unless explicitly stated otherwise all files in this repository are licensed under the Apache 2 License.
+// This product includes software developed at Datadog (https://www.datadoghq.com/). Copyright 2017 Datadog, Inc.
+// </copyright>
+
+#if NETCOREAPP3_1_OR_GREATER
+using System;
+using System.Threading.Tasks;
+using Datadog.Trace.Configuration;
+using Datadog.Trace.TestHelpers;
+using Xunit;
+using Xunit.Abstractions;
+
+namespace Datadog.Trace.ClrProfiler.IntegrationTests.CI;
+
+[Collection(nameof(TransportTestsCollection))]
+public class PipesXUnitTests(ITestOutputHelper output) : XUnitTests(output)
+{
+    [SkippableTheory]
+    [MemberData(nameof(PackageVersions.XUnit), MemberType = typeof(PackageVersions))]
+    [Trait("RunOnWindows", "True")]
+    [Trait("Category", "EndToEnd")]
+    [Trait("Category", "TestIntegrations")]
+    public override async Task SubmitTraces(string packageVersion)
+    {
+        SkipOn.Platform(SkipOn.PlatformValue.MacOs);
+        SkipOn.Platform(SkipOn.PlatformValue.Linux);
+        EnvironmentHelper.EnableWindowsNamedPipes();
+        SetEnvironmentVariable(ConfigurationKeys.DebugEnabled, "1");
+
+        // The server implementation of named pipes is flaky so have 3 attempts
+        var attemptsRemaining = 3;
+        while (true)
+        {
+            try
+            {
+                attemptsRemaining--;
+                await base.SubmitTraces(packageVersion);
+                return;
+            }
+            catch (Exception ex) when (attemptsRemaining > 0 && ex is not SkipException)
+            {
+                await ReportRetry(Output, attemptsRemaining, ex);
+            }
+        }
+    }
+}
+
+#endif

tracer/test/Datadog.Trace.ClrProfiler.IntegrationTests/CI/TcpXUnitEvpTests.cs

@@ -0,0 +1,36 @@
+// <copyright file="TcpXUnitEvpTests.cs" company="Datadog">
+// Unless explicitly stated otherwise all files in this repository are licensed under the Apache 2 License.
+// This product includes software developed at Datadog (https://www.datadoghq.com/). Copyright 2017 Datadog, Inc.
+// </copyright>
+#if NETCOREAPP3_1_OR_GREATER
+using System.Threading.Tasks;
+using Xunit;
+using Xunit.Abstractions;
+
+namespace Datadog.Trace.ClrProfiler.IntegrationTests.CI;
+
+[Collection(nameof(TransportTestsCollection))]
+public class TcpXUnitEvpTests(ITestOutputHelper output) : XUnitEvpTests(output)
+{
+    [SkippableTheory]
+    [MemberData(nameof(GetData))]
+    [Trait("Category", "EndToEnd")]
+    [Trait("Category", "TestIntegrations")]
+    public override Task SubmitTraces(string packageVersion, string evpVersionToRemove, bool expectedGzip)
+    {
+        EnvironmentHelper.EnableDefaultTransport();
+        return base.SubmitTraces(packageVersion, evpVersionToRemove, expectedGzip);
+    }
+
+    [SkippableTheory]
+    [MemberData(nameof(GetDataForEarlyFlakeDetection))]
+    [Trait("Category", "EndToEnd")]
+    [Trait("Category", "TestIntegrations")]
+    [Trait("Category", "EarlyFlakeDetection")]
+    public override Task EarlyFlakeDetection(string packageVersion, string evpVersionToRemove, bool expectedGzip, string settingsJson, string testsJson, int expectedSpans, string friendlyName)
+    {
+        EnvironmentHelper.EnableDefaultTransport();
+        return base.EarlyFlakeDetection(packageVersion, evpVersionToRemove, expectedGzip, settingsJson, testsJson, expectedSpans, friendlyName);
+    }
+}
+#endif

tracer/test/Datadog.Trace.ClrProfiler.IntegrationTests/CI/TcpXUnitTests.cs

@@ -0,0 +1,27 @@
+// <copyright file="TcpXUnitTests.cs" company="Datadog">
+// Unless explicitly stated otherwise all files in this repository are licensed under the Apache 2 License.
+// This product includes software developed at Datadog (https://www.datadoghq.com/). Copyright 2017 Datadog, Inc.
+// </copyright>
+
+#if NETCOREAPP3_1_OR_GREATER
+using System.Threading.Tasks;
+using Xunit;
+using Xunit.Abstractions;
+
+namespace Datadog.Trace.ClrProfiler.IntegrationTests.CI;
+
+[Collection(nameof(TransportTestsCollection))]
+public class TcpXUnitTests(ITestOutputHelper output) : XUnitTests(output)
+{
+    [SkippableTheory]
+    [MemberData(nameof(PackageVersions.XUnit), MemberType = typeof(PackageVersions))]
+    [Trait("Category", "EndToEnd")]
+    [Trait("Category", "TestIntegrations")]
+    public override Task SubmitTraces(string packageVersion)
+    {
+        EnvironmentHelper.EnableDefaultTransport();
+        return base.SubmitTraces(packageVersion);
+    }
+}
+
+#endif

tracer/test/Datadog.Trace.ClrProfiler.IntegrationTests/CI/TransportTestsCollection.cs

@@ -0,0 +1,15 @@
+// <copyright file="TransportTestsCollection.cs" company="Datadog">
+// Unless explicitly stated otherwise all files in this repository are licensed under the Apache 2 License.
+// This product includes software developed at Datadog (https://www.datadoghq.com/). Copyright 2017 Datadog, Inc.
+// </copyright>
+#if NETCOREAPP3_1_OR_GREATER
+using Xunit;
+
+namespace Datadog.Trace.ClrProfiler.IntegrationTests.CI;
+
+[CollectionDefinition(nameof(TransportTestsCollection), DisableParallelization = true)]
+public class TransportTestsCollection
+{
+}
+
+#endif