Migrate to High Performance Logging for Enhanced Observability and Performance

examples/WebRTCExamples/WebRTCAspire/Directory.Build.props

@@ -0,0 +1,8 @@
+<Project>
+  <!-- See https://aka.ms/dotnet/msbuild/customize for more details on customizing your build -->
+  <PropertyGroup>
+
+      <LangVersion>latest</LangVersion>
+
+  </PropertyGroup>
+</Project>

examples/WebRTCExamples/WebRTCAspire/WebRTCAspire.AppHost/Program.cs

@@ -0,0 +1,7 @@
+var builder = DistributedApplication.CreateBuilder(args);
+
+builder.AddProject<Projects.WebRTCAspire_Web>("webfrontend")
+    //.WithEnvironment("Logging__LogLevel__Default", "Trace")
+    .WithExternalHttpEndpoints();
+
+builder.Build().Run();

examples/WebRTCExamples/WebRTCAspire/WebRTCAspire.AppHost/Properties/launchSettings.json

@@ -0,0 +1,30 @@
+{
+  "$schema": "https://json.schemastore.org/launchsettings.json",
+  "profiles": {
+    "https": {
+      "commandName": "Project",
+      "dotnetRunMessages": true,
+      "launchBrowser": true,
+      "applicationUrl": "https://localhost:17217;http://localhost:15014",
+      "environmentVariables": {
+        "ASPNETCORE_ENVIRONMENT": "Development",
+        "DOTNET_ENVIRONMENT": "Development",
+        "DOTNET_DASHBOARD_OTLP_ENDPOINT_URL": "https://localhost:21105",
+        "DOTNET_RESOURCE_SERVICE_ENDPOINT_URL": "https://localhost:22267"
+      }
+    },
+    "http": {
+      "commandName": "Project",
+      "dotnetRunMessages": true,
+      "launchBrowser": true,
+      "applicationUrl": "http://localhost:15014",
+      "environmentVariables": {
+        "ASPNETCORE_ENVIRONMENT": "Development",
+        "DOTNET_ENVIRONMENT": "Development",
+        "ASPIRE_ALLOW_UNSECURED_TRANSPORT": "true",
+        "DOTNET_DASHBOARD_OTLP_ENDPOINT_URL": "http://localhost:19196",
+        "DOTNET_RESOURCE_SERVICE_ENDPOINT_URL": "http://localhost:20216"
+      }
+    }
+  }
+}

examples/WebRTCExamples/WebRTCAspire/WebRTCAspire.AppHost/WebRTCAspire.AppHost.csproj

@@ -0,0 +1,22 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <Sdk Name="Aspire.AppHost.Sdk" Version="9.1.0" />
+
+  <PropertyGroup>
+    <OutputType>Exe</OutputType>
+    <TargetFramework>net8.0</TargetFramework>
+    <ImplicitUsings>enable</ImplicitUsings>
+    <Nullable>enable</Nullable>
+    <IsAspireHost>true</IsAspireHost>
+    <UserSecretsId>df4d7e22-716b-43ca-a898-c5d18441f114</UserSecretsId>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="..\WebRTCAspire.Web\WebRTCAspire.Web.csproj" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <PackageReference Include="Aspire.Hosting.AppHost" Version="9.1.0" />
+  </ItemGroup>
+
+</Project>

examples/WebRTCExamples/WebRTCAspire/WebRTCAspire.AppHost/appsettings.Development.json

@@ -0,0 +1,8 @@
+{
+  "Logging": {
+    "LogLevel": {
+      "Default": "Information",
+      "Microsoft.AspNetCore": "Warning"
+    }
+  }
+}

examples/WebRTCExamples/WebRTCAspire/WebRTCAspire.AppHost/appsettings.json

@@ -0,0 +1,9 @@
+{
+  "Logging": {
+    "LogLevel": {
+      "Default": "Information",
+      "Microsoft.AspNetCore": "Warning",
+      "Aspire.Hosting.Dcp": "Warning"
+    }
+  }
+}

examples/WebRTCExamples/WebRTCAspire/WebRTCAspire.ServiceDefaults/Extensions.cs

@@ -0,0 +1,111 @@
+using Microsoft.AspNetCore.Builder;
+using Microsoft.AspNetCore.Diagnostics.HealthChecks;
+using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.Diagnostics.HealthChecks;
+using Microsoft.Extensions.Logging;
+using OpenTelemetry;
+using OpenTelemetry.Metrics;
+using OpenTelemetry.Trace;
+
+namespace Microsoft.Extensions.Hosting;
+
+// Adds common .NET Aspire services: service discovery, resilience, health checks, and OpenTelemetry.
+// This project should be referenced by each service project in your solution.
+// To learn more about using this project, see https://aka.ms/dotnet/aspire/service-defaults
+public static class Extensions
+{
+    public static IHostApplicationBuilder AddServiceDefaults(this IHostApplicationBuilder builder)
+    {
+        builder.ConfigureOpenTelemetry();
+
+        builder.AddDefaultHealthChecks();
+
+        builder.Services.AddServiceDiscovery();
+
+        builder.Services.ConfigureHttpClientDefaults(http =>
+        {
+            // Turn on resilience by default
+            http.AddStandardResilienceHandler();
+
+            // Turn on service discovery by default
+            http.AddServiceDiscovery();
+        });
+
+        return builder;
+    }
+
+    public static IHostApplicationBuilder ConfigureOpenTelemetry(this IHostApplicationBuilder builder)
+    {
+        builder.Logging.AddOpenTelemetry(logging =>
+        {
+            logging.IncludeFormattedMessage = true;
+            logging.IncludeScopes = true;
+        });
+
+        builder.Services.AddOpenTelemetry()
+            .WithMetrics(metrics =>
+            {
+                metrics.AddAspNetCoreInstrumentation()
+                    .AddHttpClientInstrumentation()
+                    .AddRuntimeInstrumentation();
+            })
+            .WithTracing(tracing =>
+            {
+                tracing.AddAspNetCoreInstrumentation()
+                    // Uncomment the following line to enable gRPC instrumentation (requires the OpenTelemetry.Instrumentation.GrpcNetClient package)
+                    //.AddGrpcClientInstrumentation()
+                    .AddHttpClientInstrumentation();
+            });
+
+        builder.AddOpenTelemetryExporters();
+
+        return builder;
+    }
+
+    private static IHostApplicationBuilder AddOpenTelemetryExporters(this IHostApplicationBuilder builder)
+    {
+        var useOtlpExporter = !string.IsNullOrWhiteSpace(builder.Configuration["OTEL_EXPORTER_OTLP_ENDPOINT"]);
+
+        if (useOtlpExporter)
+        {
+            builder.Services.AddOpenTelemetry().UseOtlpExporter();
+        }
+
+        // Uncomment the following lines to enable the Azure Monitor exporter (requires the Azure.Monitor.OpenTelemetry.AspNetCore package)
+        //if (!string.IsNullOrEmpty(builder.Configuration["APPLICATIONINSIGHTS_CONNECTION_STRING"]))
+        //{
+        //    builder.Services.AddOpenTelemetry()
+        //       .UseAzureMonitor();
+        //}
+
+        return builder;
+    }
+
+    public static IHostApplicationBuilder AddDefaultHealthChecks(this IHostApplicationBuilder builder)
+    {
+        builder.Services.AddHealthChecks()
+            // Add a default liveness check to ensure app is responsive
+            .AddCheck("self", () => HealthCheckResult.Healthy(), ["live"]);
+
+        return builder;
+    }
+
+    public static WebApplication MapDefaultEndpoints(this WebApplication app)
+    {
+        // Adding health checks endpoints to applications in non-development environments has security implications.
+        // See https://aka.ms/dotnet/aspire/healthchecks for details before enabling these endpoints in non-development environments.
+        if (app.Environment.IsDevelopment())
+        {
+            // All health checks must pass for app to be considered ready to accept traffic after starting
+            app.MapHealthChecks("/health");
+
+            // Only health checks tagged with the "live" tag must pass for app to be considered alive
+            app.MapHealthChecks("/alive", new HealthCheckOptions
+            {
+                Predicate = r => r.Tags.Contains("live")
+            });
+        }
+
+        return app;
+    }
+}

examples/WebRTCExamples/WebRTCAspire/WebRTCAspire.ServiceDefaults/WebRTCAspire.ServiceDefaults.csproj

@@ -0,0 +1,22 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <TargetFramework>net8.0</TargetFramework>
+    <ImplicitUsings>enable</ImplicitUsings>
+    <Nullable>enable</Nullable>
+    <IsAspireSharedProject>true</IsAspireSharedProject>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <FrameworkReference Include="Microsoft.AspNetCore.App" />
+
+    <PackageReference Include="Microsoft.Extensions.Http.Resilience" Version="9.2.0" />
+    <PackageReference Include="Microsoft.Extensions.ServiceDiscovery" Version="9.1.0" />
+    <PackageReference Include="OpenTelemetry.Exporter.OpenTelemetryProtocol" Version="1.11.1" />
+    <PackageReference Include="OpenTelemetry.Extensions.Hosting" Version="1.11.1" />
+    <PackageReference Include="OpenTelemetry.Instrumentation.AspNetCore" Version="1.11.0" />
+    <PackageReference Include="OpenTelemetry.Instrumentation.Http" Version="1.11.0" />
+    <PackageReference Include="OpenTelemetry.Instrumentation.Runtime" Version="1.11.0" />
+  </ItemGroup>
+
+</Project>

examples/WebRTCExamples/WebRTCAspire/WebRTCAspire.Web/Pages/Error.cshtml

@@ -0,0 +1,26 @@
+@page
+@model ErrorModel
+@{
+    ViewData["Title"] = "Error";
+}
+
+<h1 class="text-danger">Error.</h1>
+<h2 class="text-danger">An error occurred while processing your request.</h2>
+
+@if (Model.ShowRequestId)
+{
+    <p>
+        <strong>Request ID:</strong> <code>@Model.RequestId</code>
+    </p>
+}
+
+<h3>Development Mode</h3>
+<p>
+    Swapping to the <strong>Development</strong> environment displays detailed information about the error that occurred.
+</p>
+<p>
+    <strong>The Development environment shouldn't be enabled for deployed applications.</strong>
+    It can result in displaying sensitive information from exceptions to end users.
+    For local debugging, enable the <strong>Development</strong> environment by setting the <strong>ASPNETCORE_ENVIRONMENT</strong> environment variable to <strong>Development</strong>
+    and restarting the app.
+</p>

examples/WebRTCExamples/WebRTCAspire/WebRTCAspire.Web/Pages/Error.cshtml.cs

@@ -0,0 +1,27 @@
+using System.Diagnostics;
+using Microsoft.AspNetCore.Mvc;
+using Microsoft.AspNetCore.Mvc.RazorPages;
+
+namespace WebRTCAspire.Web.Pages;
+
+[ResponseCache(Duration = 0, Location = ResponseCacheLocation.None, NoStore = true)]
+[IgnoreAntiforgeryToken]
+public class ErrorModel : PageModel
+{
+    public string? RequestId { get; set; }
+
+    public bool ShowRequestId => !string.IsNullOrEmpty(RequestId);
+
+    private readonly ILogger<ErrorModel> _logger;
+
+    public ErrorModel(ILogger<ErrorModel> logger)
+    {
+        _logger = logger;
+    }
+
+    public void OnGet()
+    {
+        RequestId = Activity.Current?.Id ?? HttpContext.TraceIdentifier;
+    }
+}
+

examples/WebRTCExamples/WebRTCAspire/WebRTCAspire.Web/Pages/Index.cshtml

@@ -0,0 +1,98 @@
+@page
+@model IndexModel
+@{
+    ViewData["Title"] = "Home Page";
+}
+
+<script type="text/javascript">
+
+    const id = '@Guid.NewGuid().ToString()';
+    const baseUrl = "api/webrtc/";
+    const getOfferUrl = `${baseUrl}getoffer?id=${id}`;
+    const setAnswerUrl = `${baseUrl}setanswer?id=${id}`;
+    const setIceCandidateUrl = `${baseUrl}addicecandidate?id=${id}`
+
+    var pc
+
+    async function start() {
+
+        closePeer();
+
+        let videoControl = document.querySelector('#audioCtl');
+
+        const localStream = await navigator.mediaDevices.getUserMedia({ video: false, audio: true });
+        videoControl.srcObject = localStream;
+
+        pc = new RTCPeerConnection(null);
+
+        localStream.getTracks().forEach(track => {
+            console.log('add local track ' + track.kind + ' to peer connection.');
+            console.log(track);
+            pc.addTrack(track, localStream);
+        });
+
+        pc.onicegatheringstatechange = function () {
+            console.log("onicegatheringstatechange: " + pc.iceGatheringState);
+        }
+
+        pc.oniceconnectionstatechange = function () {
+            console.log("oniceconnectionstatechange: " + pc.iceConnectionState);
+        }
+
+        pc.onsignalingstatechange = function () {
+            console.log("onsignalingstatechange: " + pc.signalingState);
+        }
+
+        pc.onicecandidate = async function (event) {
+            if (event.candidate) {
+                console.log('new-ice-candidate:');
+                console.log(event.candidate.candidate);
+                console.log(event.candidate);
+                await fetch(setIceCandidateUrl, {
+                    method: 'POST',
+                    body: JSON.stringify(event.candidate),
+                    headers: { 'Content-Type': 'application/json' }
+                });
+            }
+        };
+
+        let offerResponse = await fetch(getOfferUrl);
+        let offer = await offerResponse.json();
+        console.log("got offer: " + offer.type + " " + offer.sdp + ".");
+        await pc.setRemoteDescription(offer);
+
+        pc.createAnswer().then(function (answer) {
+            return pc.setLocalDescription(answer);
+        }).then(async function () {
+            console.log("Sending answer SDP.");
+            console.log("SDP: " + pc.localDescription.sdp);
+            await fetch(setAnswerUrl, {
+                method: 'POST',
+                body: JSON.stringify(pc.localDescription),
+                headers: { 'Content-Type': 'application/json' }
+            });
+        });
+
+    };
+
+    function closePeer() {
+        if (pc != null) {
+            console.log("close peer");
+            pc.close();
+        }
+    };
+
+</script>
+
+<div class="text-center">
+    <h1 class="display-4">Welcome</h1>
+    <p>WebRTC ASP.Net Example with the <a target="_blank" href="https://github.com/sipsorcery/sipsorcery">SIPSorcery WebRTC Library</a>.</p>
+</div>
+
+
+<audio controls autoplay="autoplay" id="audioCtl"></audio>
+
+<div>
+    <button type="button" class="btn btn-success" onclick="start();">Start</button>
+    <button type="button" class="btn btn-success" onclick="closePeer();">Close</button>
+</div>

examples/WebRTCExamples/WebRTCAspire/WebRTCAspire.Web/Pages/Index.cshtml.cs

@@ -0,0 +1,19 @@
+using Microsoft.AspNetCore.Mvc;
+using Microsoft.AspNetCore.Mvc.RazorPages;
+
+namespace WebRTCAspire.Web.Pages;
+
+public class IndexModel : PageModel
+{
+    private readonly ILogger<IndexModel> _logger;
+
+    public IndexModel(ILogger<IndexModel> logger)
+    {
+        _logger = logger;
+    }
+
+    public void OnGet()
+    {
+
+    }
+}