[AzureMonitorExporter] Refactor RestClient and DebugWritter (Azure#32172)

* refactor rest client and debugwritter

* changelog

Author: Timothy Mothra

sdk/monitor/Azure.Monitor.OpenTelemetry.Exporter/CHANGELOG.md

@@ -15,6 +15,7 @@
 
 * Update OpenTelemetry dependencies ([#32047](https://github.com/Azure/azure-sdk-for-net/pull/32047))
   - OpenTelemetry v1.4.0-beta.2
+* Debugging Output now includes Telemetry sent from storage. ([#32172](https://github.com/Azure/azure-sdk-for-net/pull/32172))
 
 ## 1.0.0-beta.4 (2022-10-07)
 

sdk/monitor/Azure.Monitor.OpenTelemetry.Exporter/src/Customizations/ApplicationInsightsRestClient.cs

@@ -3,6 +3,7 @@
 
 using System;
 using System.Collections.Generic;
+using System.Runtime.CompilerServices;
 using System.Threading;
 using System.Threading.Tasks;
 
@@ -14,6 +15,8 @@ namespace Azure.Monitor.OpenTelemetry.Exporter
 {
     internal partial class ApplicationInsightsRestClient
     {
+        private RawRequestUriBuilder _rawRequestUriBuilder;
+
         /// <summary>
         /// This operation sends a sequence of telemetry events that will be monitored by Azure Monitor.
         /// </summary>
@@ -75,42 +78,42 @@ internal async Task<HttpMessage> InternalTrackAsync(ReadOnlyMemory<byte> body, C
 
         internal HttpMessage CreateTrackRequest(IEnumerable<TelemetryItem> body)
         {
-            var message = _pipeline.CreateMessage();
-            var request = message.Request;
-            request.Method = RequestMethod.Post;
-            var uri = new RawRequestUriBuilder();
-            uri.AppendRaw(_host, false);
-            uri.AppendRaw("/v2", false);
-            uri.AppendPath("/track", false);
-            request.Uri = uri;
-            request.Headers.Add("Content-Type", "application/json");
-            request.Headers.Add("Accept", "application/json");
             using var content = new NDJsonWriter();
             foreach (var item in body)
             {
                 content.JsonWriter.WriteObjectValue(item);
                 content.WriteNewLine();
             }
-            request.Content = RequestContent.Create(content.ToBytes());
+
             TelemetryDebugWriter.WriteTelemetry(content);
-            return message;
+
+            return CreateRequest(RequestContent.Create(content.ToBytes()));
         }
 
         internal HttpMessage CreateTrackRequest(ReadOnlyMemory<byte> body)
+        {
+            TelemetryDebugWriter.WriteTelemetryFromStorage(body);
+
+            return CreateRequest(RequestContent.Create(body));
+        }
+
+        [MethodImpl(MethodImplOptions.AggressiveInlining)]
+        private HttpMessage CreateRequest(RequestContent requestContent)
         {
             var message = _pipeline.CreateMessage();
             var request = message.Request;
             request.Method = RequestMethod.Post;
-            var uri = new RawRequestUriBuilder();
-            uri.AppendRaw(_host, false);
-            uri.AppendRaw("/v2", false);
-            uri.AppendPath("/track", false);
-            request.Uri = uri;
+            request.Uri = LazyInitializer.EnsureInitialized(ref _rawRequestUriBuilder, () =>
+            {
+                var uri = new RawRequestUriBuilder();
+                uri.AppendRaw(_host, false);
+                uri.AppendRaw("/v2/track", false);
+                return uri;
+            });
             request.Headers.Add("Content-Type", "application/json");
             request.Headers.Add("Accept", "application/json");
-            using var content = new NDJsonWriter();
-            request.Content = RequestContent.Create(body);
-            TelemetryDebugWriter.WriteTelemetry(content);
+            request.Content = requestContent;
+
             return message;
         }
     }

sdk/monitor/Azure.Monitor.OpenTelemetry.Exporter/src/Internals/TelemetryDebugWriter.cs

@@ -1,7 +1,9 @@
 // Copyright (c) Microsoft Corporation. All rights reserved.
 // Licensed under the MIT License.
 
+using System;
 using System.Diagnostics;
+using System.Text;
 
 namespace Azure.Monitor.OpenTelemetry.Exporter.Internals
 {
@@ -16,7 +18,7 @@ public static void WriteMessage(string message)
 
             if (Debugger.IsAttached && Debugger.IsLogging())
             {
-                Debugger.Log(0, null, message);
+                Debugger.Log(0, null, message + "\n");
             }
         }
 
@@ -32,5 +34,13 @@ public static void WriteTelemetry(NDJsonWriter content)
                 Debugger.Log(0, null, content.ToString());
             }
         }
+
+        public static void WriteTelemetryFromStorage(ReadOnlyMemory<byte> content)
+        {
+            if (Debugger.IsAttached && Debugger.IsLogging())
+            {
+                Debugger.Log(0, null, "(TRANSMITTING TELEMETRY FROM STORAGE)\n" + Encoding.UTF8.GetString(content.ToArray()));
+            }
+        }
     }
 }