Add json format for metrics (#1130)

* Add json format for metrics

* Add license headers

* Fix formatting

src/Microsoft.Tye.Hosting/Model/V1/V1Metric.cs

@@ -0,0 +1,13 @@
+// Licensed to the .NET Foundation under one or more agreements.
+// The .NET Foundation licenses this file to you under the MIT license.
+// See the LICENSE file in the project root for more information.
+
+namespace Microsoft.Tye.Hosting.Model.V1
+{
+    public class V1Metric
+    {
+        public string? Name { get; set; }
+        public string? Value { get; set; }
+        public V1MetricMetadata? Metadata { get; set; }
+    }
+}

src/Microsoft.Tye.Hosting/Model/V1/V1MetricMetadata.cs

@@ -0,0 +1,11 @@
+// Licensed to the .NET Foundation under one or more agreements.
+// The .NET Foundation licenses this file to you under the MIT license.
+// See the LICENSE file in the project root for more information.
+
+namespace Microsoft.Tye.Hosting.Model.V1
+{
+    public class V1MetricMetadata
+    {
+        public string? Instance { get; set; }
+    }
+}

src/Microsoft.Tye.Hosting/Model/V1/V1ServiceMetrics.cs

@@ -0,0 +1,14 @@
+// Licensed to the .NET Foundation under one or more agreements.
+// The .NET Foundation licenses this file to you under the MIT license.
+// See the LICENSE file in the project root for more information.
+
+using System.Collections.Generic;
+
+namespace Microsoft.Tye.Hosting.Model.V1
+{
+    public class V1ServiceMetrics
+    {
+        public string? Service { get; set; }
+        public List<V1Metric>? Metrics { get; set; }
+    }
+}

src/Microsoft.Tye.Hosting/TyeDashboardApi.cs

@@ -4,6 +4,7 @@
 
 using System.Collections.Generic;
 using System.Linq;
+using System.Net.Mime;
 using System.Text;
 using System.Text.Json;
 using System.Text.Json.Serialization;
@@ -13,6 +14,7 @@ using Microsoft.AspNetCore.Http;
 using Microsoft.AspNetCore.Routing;
 using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Hosting;
+using Microsoft.Net.Http.Headers;
 using Microsoft.Tye.Hosting.Model;
 using Microsoft.Tye.Hosting.Model.V1;
 
@@ -262,6 +264,52 @@ namespace Microsoft.Tye.Hosting
         {
             var app = context.RequestServices.GetRequiredService<Application>();
 
+            var acceptHeader = context.Request.Headers[HeaderNames.Accept];
+
+            if (acceptHeader == MediaTypeNames.Application.Json)
+            {
+                context.Response.ContentType = MediaTypeNames.Application.Json;
+                var servicesMetricsCollection = CreateServicesMetricsCollectionJson(app);
+                return JsonSerializer.SerializeAsync(context.Response.Body, servicesMetricsCollection, _options);
+            }
+
+            context.Response.ContentType = MediaTypeNames.Text.Plain;
+            var response = CreateServicesMetricsCollectionText(app);
+            return context.Response.WriteAsync(response);
+        }
+
+        private Task Metrics(HttpContext context)
+        {
+            var app = context.RequestServices.GetRequiredService<Application>();
+
+            var name = (string?)context.Request.RouteValues["name"];
+
+            if (string.IsNullOrEmpty(name) || !app.Services.TryGetValue(name, out var service))
+            {
+                context.Response.StatusCode = 404;
+                return JsonSerializer.SerializeAsync(context.Response.Body, new
+                {
+                    message = $"Unknown service {name}"
+                },
+                _options);
+            }
+
+            var acceptHeader = context.Request.Headers[HeaderNames.Accept];
+
+            if (acceptHeader == MediaTypeNames.Application.Json)
+            {
+                context.Response.ContentType = MediaTypeNames.Application.Json;
+                var metricsCollectionJson = CreateMetricsCollectionJson(service);
+                return JsonSerializer.SerializeAsync(context.Response.Body, metricsCollectionJson, _options);
+            }
+
+            context.Response.ContentType = MediaTypeNames.Text.Plain;
+            var response = CreateMetricsCollectionText(service);
+            return context.Response.WriteAsync(response);
+        }
+
+        private static string CreateServicesMetricsCollectionText(Application app)
+        {
             var sb = new StringBuilder();
             foreach (var (serviceName, service) in app.Services.OrderBy(s => s.Key))
             {
@@ -283,28 +331,29 @@ namespace Microsoft.Tye.Hosting
                 sb.AppendLine();
             }
 
-            return context.Response.WriteAsync(sb.ToString());
+            return sb.ToString();
         }
 
-        private Task Metrics(HttpContext context)
+        private static List<V1ServiceMetrics> CreateServicesMetricsCollectionJson(Application app)
         {
-            var app = context.RequestServices.GetRequiredService<Application>();
+            var servicesMetrics = new List<V1ServiceMetrics>(app.Services.Count);
-
+            foreach (var (serviceName, service) in app.Services.OrderBy(s => s.Key))
-            var sb = new StringBuilder();
-
-            var name = (string?)context.Request.RouteValues["name"];
-            context.Response.ContentType = "application/json";
-
-            if (string.IsNullOrEmpty(name) || !app.Services.TryGetValue(name, out var service))
             {
-                context.Response.StatusCode = 404;
+                var serviceMetrics = new V1ServiceMetrics
-                return JsonSerializer.SerializeAsync(context.Response.Body, new
                 {
-                    message = $"Unknown service {name}"
+                    Service = serviceName,
-                },
+                    Metrics = CreateMetricsCollectionJson(service)
-                _options);
+                };
+                servicesMetrics.Add(serviceMetrics);
             }
 
+            return servicesMetrics;
+        }
+
+        private static string CreateMetricsCollectionText(Service service)
+        {
+            var sb = new StringBuilder();
+
             foreach (var (instance, replica) in service.Replicas)
             {
                 foreach (var (key, value) in replica.Metrics)
@@ -319,7 +368,27 @@ namespace Microsoft.Tye.Hosting
                 }
             }
 
-            return context.Response.WriteAsync(sb.ToString());
+            return sb.ToString();
+        }
+
+        private static List<V1Metric> CreateMetricsCollectionJson(Service service)
+        {
+            var metrics = new List<V1Metric>();
+            foreach (var (instance, replica) in service.Replicas)
+            {
+                foreach (var (key, value) in replica.Metrics)
+                {
+                    var metric = new V1Metric
+                    {
+                        Name = key,
+                        Value = value,
+                        Metadata = new V1MetricMetadata { Instance = instance }
+                    };
+                    metrics.Add(metric);
+                }
+            }
+
+            return metrics;
         }
     }
 }