Support debugger V2 and send logs to V1

dudikeleti · dudikeleti · commit f1940c3a11a0 · 2025-09-03T11:13:15.000+02:00
diff --git a/tracer/src/Datadog.Trace/Agent/DiscoveryService/AgentConfiguration.cs b/tracer/src/Datadog.Trace/Agent/DiscoveryService/AgentConfiguration.cs
@@ -12,6 +12,7 @@ internal record AgentConfiguration
     public AgentConfiguration(
         string? configurationEndpoint,
         string? debuggerEndpoint,
+        string? debuggerV2Endpoint,
         string? symbolDbEndpoint,
         string? agentVersion,
         string? statsEndpoint,
@@ -26,6 +27,7 @@ public AgentConfiguration(
     {
         ConfigurationEndpoint = configurationEndpoint;
         DebuggerEndpoint = debuggerEndpoint;
+        DebuggerV2Endpoint = debuggerV2Endpoint;
         DiagnosticsEndpoint = diagnosticsEndpoint;
         SymbolDbEndpoint = symbolDbEndpoint;
         AgentVersion = agentVersion;
@@ -43,6 +45,8 @@ public AgentConfiguration(
 
     public string? DebuggerEndpoint { get; }
 
+    public string? DebuggerV2Endpoint { get; }
+
     public string? DiagnosticsEndpoint { get; }
 
     public string? SymbolDbEndpoint { get; }
diff --git a/tracer/src/Datadog.Trace/Agent/DiscoveryService/DiscoveryService.cs b/tracer/src/Datadog.Trace/Agent/DiscoveryService/DiscoveryService.cs
@@ -20,6 +20,7 @@ namespace Datadog.Trace.Agent.DiscoveryService
     internal class DiscoveryService : IDiscoveryService
     {
         private const string SupportedDebuggerEndpoint = "debugger/v1/input";
+        private const string SupportedDebuggerV2Endpoint = "debugger/v2/input";
         private const string SupportedDiagnosticsEndpoint = "debugger/v1/diagnostics";
         private const string SupportedSymbolDbEndpoint = "symdb/v1/input";
         private const string SupportedConfigurationEndpoint = "v0.7/config";
@@ -66,6 +67,7 @@ public DiscoveryService(
             new[]
             {
                 SupportedDebuggerEndpoint,
+                SupportedDebuggerV2Endpoint,
                 SupportedDiagnosticsEndpoint,
                 SupportedSymbolDbEndpoint,
                 SupportedConfigurationEndpoint,
@@ -223,6 +225,7 @@ private async Task ProcessDiscoveryResponse(IApiResponse response)
             var discoveredEndpoints = (jObject["endpoints"] as JArray)?.Values<string>().ToArray();
             string? configurationEndpoint = null;
             string? debuggerEndpoint = null;
+            string? debuggerV2Endpoint = null;
             string? diagnosticsEndpoint = null;
             string? symbolDbEndpoint = null;
             string? statsEndpoint = null;
@@ -246,6 +249,10 @@ private async Task ProcessDiscoveryResponse(IApiResponse response)
                     {
                         debuggerEndpoint = endpoint;
                     }
+                    else if (endpoint.Equals(SupportedDebuggerV2Endpoint, StringComparison.OrdinalIgnoreCase))
+                    {
+                        debuggerV2Endpoint = endpoint;
+                    }
                     else if (endpoint.Equals(SupportedDiagnosticsEndpoint, StringComparison.OrdinalIgnoreCase))
                     {
                         diagnosticsEndpoint = endpoint;
@@ -290,6 +297,7 @@ private async Task ProcessDiscoveryResponse(IApiResponse response)
             var newConfig = new AgentConfiguration(
                 configurationEndpoint: configurationEndpoint,
                 debuggerEndpoint: debuggerEndpoint,
+                debuggerV2Endpoint: debuggerV2Endpoint ?? diagnosticsEndpoint ?? debuggerEndpoint,
                 diagnosticsEndpoint: diagnosticsEndpoint ?? debuggerEndpoint,
                 symbolDbEndpoint: symbolDbEndpoint,
                 agentVersion: agentVersion,
diff --git a/tracer/src/Datadog.Trace/Debugger/DebuggerFactory.cs b/tracer/src/Datadog.Trace/Debugger/DebuggerFactory.cs
@@ -30,10 +30,12 @@ internal class DebuggerFactory
     internal static DynamicInstrumentation CreateDynamicInstrumentation(IDiscoveryService discoveryService, IRcmSubscriptionManager remoteConfigurationManager, TracerSettings tracerSettings, string serviceName, DebuggerSettings debuggerSettings, IGitMetadataTagsProvider gitMetadataTagsProvider)
     {
         var snapshotSlicer = SnapshotSlicer.Create(debuggerSettings);
-        var snapshotStatusSink = SnapshotSink.Create(debuggerSettings, snapshotSlicer);
+        var snapshotSink = SnapshotSink.Create(debuggerSettings, snapshotSlicer);
+        var logSink = SnapshotSink.Create(debuggerSettings, snapshotSlicer);
         var diagnosticsSink = DiagnosticsSink.Create(serviceName, debuggerSettings);
 
-        var debuggerUploader = CreateSnapshotUploader(discoveryService, debuggerSettings, gitMetadataTagsProvider, GetApiFactory(tracerSettings, true), snapshotStatusSink);
+        var snapshotUploader = CreateSnapshotUploader(discoveryService, debuggerSettings, gitMetadataTagsProvider, GetApiFactory(tracerSettings, true), snapshotSink);
+        var logUploader = CreateSnapshotUploader(discoveryService, debuggerSettings, gitMetadataTagsProvider, GetApiFactory(tracerSettings, false), logSink);
         var diagnosticsUploader = CreateDiagnosticsUploader(discoveryService, debuggerSettings, gitMetadataTagsProvider, GetApiFactory(tracerSettings, true), diagnosticsSink);
         var lineProbeResolver = LineProbeResolver.Create(debuggerSettings.ThirdPartyDetectionExcludes, debuggerSettings.ThirdPartyDetectionIncludes);
         var probeStatusPoller = ProbeStatusPoller.Create(diagnosticsSink, debuggerSettings);
@@ -46,7 +48,8 @@ internal static DynamicInstrumentation CreateDynamicInstrumentation(IDiscoverySe
             discoveryService: discoveryService,
             remoteConfigurationManager: remoteConfigurationManager,
             lineProbeResolver: lineProbeResolver,
-            snapshotUploader: debuggerUploader,
+            snapshotUploader: snapshotUploader,
+            logUploader: logUploader,
             diagnosticsUploader: diagnosticsUploader,
             probeStatusPoller: probeStatusPoller,
             configurationUpdater: configurationUpdater,
@@ -70,12 +73,22 @@ private static IDogStatsd GetDogStatsd(TracerSettings tracerSettings, string ser
         return statsd;
     }
 
-    private static SnapshotUploader CreateSnapshotUploader(IDiscoveryService discoveryService, DebuggerSettings debuggerSettings, IGitMetadataTagsProvider gitMetadataTagsProvider, IApiRequestFactory apiFactory, SnapshotSink snapshotStatusSink)
+    private static SnapshotUploader CreateSnapshotUploader(IDiscoveryService discoveryService, DebuggerSettings debuggerSettings, IGitMetadataTagsProvider gitMetadataTagsProvider, IApiRequestFactory apiFactory, SnapshotSink snapshotSink)
     {
         var snapshotBatchUploadApi = DebuggerUploadApiFactory.CreateSnapshotUploadApi(apiFactory, discoveryService, gitMetadataTagsProvider);
         var snapshotBatchUploader = BatchUploader.Create(snapshotBatchUploadApi);
 
-        var debuggerSink = SnapshotUploader.Create(snapshotStatusSink, snapshotBatchUploader, debuggerSettings);
+        var debuggerSink = SnapshotUploader.Create(snapshotSink, snapshotBatchUploader, debuggerSettings);
+
+        return debuggerSink;
+    }
+
+    private static SnapshotUploader CreateLogUploader(IDiscoveryService discoveryService, DebuggerSettings debuggerSettings, IGitMetadataTagsProvider gitMetadataTagsProvider, IApiRequestFactory apiFactory, SnapshotSink snapshotSink)
+    {
+        var logUploaderApi = DebuggerUploadApiFactory.CreateLogUploadApi(apiFactory, discoveryService, gitMetadataTagsProvider);
+        var logBatchUploader = BatchUploader.Create(logUploaderApi);
+
+        var debuggerSink = SnapshotUploader.Create(snapshotSink, logBatchUploader, debuggerSettings);
 
         return debuggerSink;
     }
diff --git a/tracer/src/Datadog.Trace/Debugger/DynamicInstrumentation.cs b/tracer/src/Datadog.Trace/Debugger/DynamicInstrumentation.cs
@@ -39,6 +39,7 @@ internal class DynamicInstrumentation : IDisposable
         private readonly IRcmSubscriptionManager _subscriptionManager;
         private readonly ISubscription _subscription;
         private readonly ISnapshotUploader _snapshotUploader;
+        private readonly ISnapshotUploader _logUploader;
         private readonly IDebuggerUploader _diagnosticsUploader;
         private readonly ILineProbeResolver _lineProbeResolver;
         private readonly List<ProbeDefinition> _unboundProbes;
@@ -57,6 +58,7 @@ internal DynamicInstrumentation(
             IRcmSubscriptionManager remoteConfigurationManager,
             ILineProbeResolver lineProbeResolver,
             ISnapshotUploader snapshotUploader,
+            ISnapshotUploader logUploader,
             IDebuggerUploader diagnosticsUploader,
             IProbeStatusPoller probeStatusPoller,
             ConfigurationUpdater configurationUpdater,
@@ -68,6 +70,7 @@ internal DynamicInstrumentation(
             _discoveryService = discoveryService;
             _lineProbeResolver = lineProbeResolver;
             _snapshotUploader = snapshotUploader;
+            _logUploader = logUploader;
             _diagnosticsUploader = diagnosticsUploader;
             _probeStatusPoller = probeStatusPoller;
             _subscriptionManager = remoteConfigurationManager;
@@ -168,6 +171,7 @@ private void StartInBackground()
             _probeStatusPoller.StartPolling();
             _ = _diagnosticsUploader.StartFlushingAsync();
             _ = _snapshotUploader.StartFlushingAsync();
+            _ = _logUploader.StartFlushingAsync();
         }
 
         internal void UpdateAddedProbeInstrumentations(IReadOnlyList<ProbeDefinition> addedProbes)
@@ -493,10 +497,27 @@ internal void AddSnapshot(ProbeInfo probe, string snapshot)
                 return;
             }
 
+            if (!probe.IsFullSnapshot)
+            {
+                AddLog(probe, snapshot);
+                return;
+            }
+
             _snapshotUploader.Add(probe.ProbeId, snapshot);
             SetProbeStatusToEmitting(probe);
         }
 
+        internal void AddLog(ProbeInfo probe, string log)
+        {
+            if (IsDisposed)
+            {
+                return;
+            }
+
+            _logUploader.Add(probe.ProbeId, log);
+            SetProbeStatusToEmitting(probe);
+        }
+
         internal void SetProbeStatusToEmitting(ProbeInfo probe)
         {
             if (IsDisposed)
diff --git a/tracer/src/Datadog.Trace/Debugger/Upload/DebuggerUploadApiBase.cs b/tracer/src/Datadog.Trace/Debugger/Upload/DebuggerUploadApiBase.cs
@@ -9,6 +9,7 @@
 using System.Threading.Tasks;
 using System.Web;
 using Datadog.Trace.Agent;
+using Datadog.Trace.Agent.Transports;
 using Datadog.Trace.Ci.Tags;
 using Datadog.Trace.Configuration;
 using Datadog.Trace.Processors;
@@ -18,6 +19,8 @@ namespace Datadog.Trace.Debugger.Upload;
 
 internal abstract class DebuggerUploadApiBase : IBatchUploadApi
 {
+    protected const string Debuggerv1Endpoint = "debugger/v1/input";
+
     private readonly IApiRequestFactory _apiRequestFactory;
     private readonly IGitMetadataTagsProvider? _gitMetadataTagsProvider;
 
@@ -54,6 +57,16 @@ protected string? Endpoint
         return builder.ToString();
     }
 
+    protected Task<IApiResponse> PostAsync(string uri, ArraySegment<byte> data)
+    {
+        var request = _apiRequestFactory.Create(new Uri(uri));
+        var isDebuggerV1 = uri.Contains(Debuggerv1Endpoint);
+
+        return isDebuggerV1
+                   ? request.PostAsync(data, MimeTypes.Json)
+                   : request.PostAsync([new("event", MimeTypes.Json, "event.json", data)]);
+    }
+
     private string GetDefaultTagsMergedWithGlobalTags()
     {
         var sb = StringBuilderCache.Acquire();
diff --git a/tracer/src/Datadog.Trace/Debugger/Upload/DebuggerUploadApiFactory.cs b/tracer/src/Datadog.Trace/Debugger/Upload/DebuggerUploadApiFactory.cs
@@ -17,6 +17,11 @@ internal static IBatchUploadApi CreateSnapshotUploadApi(IApiRequestFactory apiRe
             return SnapshotUploadApi.Create(apiRequestFactory, discoveryService, gitMetadataTagsProvider);
         }
 
+        internal static IBatchUploadApi CreateLogUploadApi(IApiRequestFactory apiRequestFactory, IDiscoveryService discoveryService, IGitMetadataTagsProvider gitMetadataTagsProvider)
+        {
+            return LogUploadApi.Create(apiRequestFactory, discoveryService, gitMetadataTagsProvider);
+        }
+
         internal static IBatchUploadApi CreateDiagnosticsUploadApi(IApiRequestFactory apiRequestFactory, IDiscoveryService discoveryService, IGitMetadataTagsProvider gitMetadataTagsProvider)
         {
             return DiagnosticsUploadApi.Create(apiRequestFactory, discoveryService, gitMetadataTagsProvider);
diff --git a/tracer/src/Datadog.Trace/Debugger/Upload/DiagnosticsUploadApi.cs b/tracer/src/Datadog.Trace/Debugger/Upload/DiagnosticsUploadApi.cs
@@ -8,26 +8,21 @@
 using System.Threading.Tasks;
 using Datadog.Trace.Agent;
 using Datadog.Trace.Agent.DiscoveryService;
-using Datadog.Trace.Agent.Transports;
 using Datadog.Trace.Configuration;
 using Datadog.Trace.Logging;
 
 namespace Datadog.Trace.Debugger.Upload
 {
     internal class DiagnosticsUploadApi : DebuggerUploadApiBase
     {
-        private const string LegacyEndpoint = "debugger/v1/input";
         private static readonly IDatadogLogger Log = DatadogLogging.GetLoggerFor<DiagnosticsUploadApi>();
 
-        private readonly IApiRequestFactory _apiRequestFactory;
-
         private DiagnosticsUploadApi(
             IApiRequestFactory apiRequestFactory,
             IDiscoveryService discoveryService,
             IGitMetadataTagsProvider gitMetadataTagsProvider)
             : base(apiRequestFactory, gitMetadataTagsProvider)
         {
-            _apiRequestFactory = apiRequestFactory;
             discoveryService.SubscribeToChanges(c => Endpoint = c.DiagnosticsEndpoint);
         }
 
@@ -42,13 +37,13 @@ public static DiagnosticsUploadApi Create(
         public override async Task<bool> SendBatchAsync(ArraySegment<byte> data)
         {
             var uri = BuildUri();
-            if (uri == null)
+            if (string.IsNullOrEmpty(uri))
             {
                 Log.Warning("Failed to upload diagnostics: debugger endpoint not yet retrieved from discovery service");
                 return false;
             }
 
-            using var response = await PostAsync(uri, data).ConfigureAwait(false);
+            using var response = await PostAsync(uri!, data).ConfigureAwait(false);
             if (response.StatusCode is >= 200 and <= 299)
             {
                 return true;
@@ -58,18 +53,5 @@ public override async Task<bool> SendBatchAsync(ArraySegment<byte> data)
             Log.Warning<int, string>("Failed to upload diagnostics with status code {StatusCode} and message: {ResponseContent}", response.StatusCode, content);
             return false;
         }
-
-        private Task<IApiResponse> PostAsync(string uri, ArraySegment<byte> data)
-        {
-            var request = _apiRequestFactory.Create(new Uri(uri));
-            var isLegacy = uri.Contains(LegacyEndpoint);
-
-            return isLegacy ?
-                request.PostAsync(data, MimeTypes.Json) :
-                request.PostAsync(new MultipartFormItem[]
-                {
-                    new("event", MimeTypes.Json, "event.json", data)
-                });
-        }
     }
 }
diff --git a/tracer/src/Datadog.Trace/Debugger/Upload/LogUploadApi.cs b/tracer/src/Datadog.Trace/Debugger/Upload/LogUploadApi.cs
@@ -0,0 +1,58 @@
+// <copyright file="LogUploadApi.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>
+
+#nullable enable
+using System;
+using System.Threading.Tasks;
+using Datadog.Trace.Agent;
+using Datadog.Trace.Agent.DiscoveryService;
+using Datadog.Trace.Configuration;
+using Datadog.Trace.Logging;
+
+namespace Datadog.Trace.Debugger.Upload
+{
+    internal class LogUploadApi : DebuggerUploadApiBase
+    {
+        private static readonly IDatadogLogger Log = DatadogLogging.GetLoggerFor<LogUploadApi>();
+
+        private LogUploadApi(
+            IApiRequestFactory apiRequestFactory,
+            IDiscoveryService discoveryService,
+            IGitMetadataTagsProvider gitMetadataTagsProvider)
+            : base(apiRequestFactory, gitMetadataTagsProvider)
+        {
+            discoveryService.SubscribeToChanges(c => Endpoint = c.DebuggerEndpoint);
+        }
+
+        public static LogUploadApi Create(
+            IApiRequestFactory apiRequestFactory,
+            IDiscoveryService discoveryService,
+            IGitMetadataTagsProvider gitMetadataTagsProvider)
+        {
+            return new LogUploadApi(apiRequestFactory, discoveryService, gitMetadataTagsProvider);
+        }
+
+        public override async Task<bool> SendBatchAsync(ArraySegment<byte> data)
+        {
+            var uri = BuildUri();
+            if (string.IsNullOrEmpty(uri))
+            {
+                Log.Warning("Failed to upload log: debugger endpoint not yet retrieved from discovery service");
+                return false;
+            }
+
+            using var response = await PostAsync(uri!, data).ConfigureAwait(false);
+
+            if (response.StatusCode is >= 200 and <= 299)
+            {
+                return true;
+            }
+
+            var content = await response.ReadAsStringAsync().ConfigureAwait(false);
+            Log.Warning<int, string>("Failed to upload log with status code {StatusCode} and message: {ResponseContent}", response.StatusCode, content);
+            return false;
+        }
+    }
+}
diff --git a/tracer/src/Datadog.Trace/Debugger/Upload/SnapshotUploadApi.cs b/tracer/src/Datadog.Trace/Debugger/Upload/SnapshotUploadApi.cs
@@ -8,7 +8,6 @@
 using System.Threading.Tasks;
 using Datadog.Trace.Agent;
 using Datadog.Trace.Agent.DiscoveryService;
-using Datadog.Trace.Agent.Transports;
 using Datadog.Trace.Configuration;
 using Datadog.Trace.Logging;
 
@@ -18,16 +17,13 @@ internal class SnapshotUploadApi : DebuggerUploadApiBase
     {
         private static readonly IDatadogLogger Log = DatadogLogging.GetLoggerFor<SnapshotUploadApi>();
 
-        private readonly IApiRequestFactory _apiRequestFactory;
-
         private SnapshotUploadApi(
             IApiRequestFactory apiRequestFactory,
             IDiscoveryService discoveryService,
             IGitMetadataTagsProvider gitMetadataTagsProvider)
             : base(apiRequestFactory, gitMetadataTagsProvider)
         {
-            _apiRequestFactory = apiRequestFactory;
-            discoveryService.SubscribeToChanges(c => Endpoint = c.DiagnosticsEndpoint);
+            discoveryService.SubscribeToChanges(c => Endpoint = c.DebuggerV2Endpoint);
         }
 
         public static SnapshotUploadApi Create(
@@ -47,9 +43,7 @@ public override async Task<bool> SendBatchAsync(ArraySegment<byte> data)
                 return false;
             }
 
-            var request = _apiRequestFactory.Create(new Uri(uri));
-
-            using var response = await request.PostAsync(data, MimeTypes.Json).ConfigureAwait(false);
+            using var response = await PostAsync(uri!, data).ConfigureAwait(false);
 
             if (response.StatusCode is >= 200 and <= 299)
             {

Original file line number	Diff line number	Diff line change
`@@ -17,6 +17,11 @@ internal static IBatchUploadApi CreateSnapshotUploadApi(IApiRequestFactory apiRe`
`17`	`17`	`return SnapshotUploadApi.Create(apiRequestFactory, discoveryService, gitMetadataTagsProvider);`
`18`	`18`	`}`
`19`	`19`
	`20`	`+ internal static IBatchUploadApi CreateLogUploadApi(IApiRequestFactory apiRequestFactory, IDiscoveryService discoveryService, IGitMetadataTagsProvider gitMetadataTagsProvider)`
	`21`	`+ {`
	`22`	`+ return LogUploadApi.Create(apiRequestFactory, discoveryService, gitMetadataTagsProvider);`
	`23`	`+ }`
	`24`	`+`
`20`	`25`	`internal static IBatchUploadApi CreateDiagnosticsUploadApi(IApiRequestFactory apiRequestFactory, IDiscoveryService discoveryService, IGitMetadataTagsProvider gitMetadataTagsProvider)`
`21`	`26`	`{`
`22`	`27`	`return DiagnosticsUploadApi.Create(apiRequestFactory, discoveryService, gitMetadataTagsProvider);`
Original file line number	Diff line number	Diff line change
`@@ -8,26 +8,21 @@`
`8`	`8`	`using System.Threading.Tasks;`
`9`	`9`	`using Datadog.Trace.Agent;`
`10`	`10`	`using Datadog.Trace.Agent.DiscoveryService;`
`11`		`-using Datadog.Trace.Agent.Transports;`
`12`	`11`	`using Datadog.Trace.Configuration;`
`13`	`12`	`using Datadog.Trace.Logging;`
`14`	`13`
`15`	`14`	`namespace Datadog.Trace.Debugger.Upload`
`16`	`15`	`{`
`17`	`16`	`internal class DiagnosticsUploadApi : DebuggerUploadApiBase`
`18`	`17`	`{`
`19`		`- private const string LegacyEndpoint = "debugger/v1/input";`
`20`	`18`	`private static readonly IDatadogLogger Log = DatadogLogging.GetLoggerFor<DiagnosticsUploadApi>();`
`21`	`19`
`22`		`- private readonly IApiRequestFactory _apiRequestFactory;`
`23`		`-`
`24`	`20`	`private DiagnosticsUploadApi(`
`25`	`21`	`IApiRequestFactory apiRequestFactory,`
`26`	`22`	`IDiscoveryService discoveryService,`
`27`	`23`	`IGitMetadataTagsProvider gitMetadataTagsProvider)`
`28`	`24`	`: base(apiRequestFactory, gitMetadataTagsProvider)`
`29`	`25`	`{`
`30`		`- _apiRequestFactory = apiRequestFactory;`
`31`	`26`	`discoveryService.SubscribeToChanges(c => Endpoint = c.DiagnosticsEndpoint);`
`32`	`27`	`}`
`33`	`28`
`@@ -42,13 +37,13 @@ public static DiagnosticsUploadApi Create(`
`42`	`37`	`public override async Task<bool> SendBatchAsync(ArraySegment<byte> data)`
`43`	`38`	`{`
`44`	`39`	`var uri = BuildUri();`
`45`		`- if (uri == null)`
	`40`	`+ if (string.IsNullOrEmpty(uri))`
`46`	`41`	`{`
`47`	`42`	`Log.Warning("Failed to upload diagnostics: debugger endpoint not yet retrieved from discovery service");`
`48`	`43`	`return false;`
`49`	`44`	`}`
`50`	`45`
`51`		`- using var response = await PostAsync(uri, data).ConfigureAwait(false);`
	`46`	`+ using var response = await PostAsync(uri!, data).ConfigureAwait(false);`
`52`	`47`	`if (response.StatusCode is >= 200 and <= 299)`
`53`	`48`	`{`
`54`	`49`	`return true;`
`@@ -58,18 +53,5 @@ public override async Task<bool> SendBatchAsync(ArraySegment<byte> data)`
`58`	`53`	`Log.Warning<int, string>("Failed to upload diagnostics with status code {StatusCode} and message: {ResponseContent}", response.StatusCode, content);`
`59`	`54`	`return false;`
`60`	`55`	`}`
`61`		`-`
`62`		`- private Task<IApiResponse> PostAsync(string uri, ArraySegment<byte> data)`
`63`		`- {`
`64`		`- var request = _apiRequestFactory.Create(new Uri(uri));`
`65`		`- var isLegacy = uri.Contains(LegacyEndpoint);`
`66`		`-`
`67`		`- return isLegacy ?`
`68`		`- request.PostAsync(data, MimeTypes.Json) :`
`69`		`- request.PostAsync(new MultipartFormItem[]`
`70`		`- {`
`71`		`- new("event", MimeTypes.Json, "event.json", data)`
`72`		`- });`
`73`		`- }`
`74`	`56`	`}`
`75`	`57`	`}`