| | | 1 | | using Syki.Back.Metrics; |
| | | 2 | | using System.Collections.Concurrent; |
| | | 3 | | |
| | | 4 | | namespace Syki.Back.Middlewares; |
| | | 5 | | |
| | 2 | 6 | | public class MetricsMiddleware(RequestDelegate next) |
| | | 7 | | { |
| | | 8 | | public async Task Invoke(HttpContext context) |
| | | 9 | | { |
| | 8700 | 10 | | context.Response.OnStarting(() => |
| | 8700 | 11 | | { |
| | 8700 | 12 | | var method = context.Request.Method; |
| | 8700 | 13 | | var endpoint = context.Request.Path.ToString(); |
| | 8700 | 14 | | var status = context.Response.StatusCode.ToString(); |
| | 8700 | 15 | | |
| | 8700 | 16 | | SykiMetricsStore.Requests.AddOrUpdate( |
| | 8700 | 17 | | $"{method} {endpoint}", |
| | 8700 | 18 | | _ => |
| | 8700 | 19 | | { |
| | 1000 | 20 | | var dict = new ConcurrentDictionary<string, int>(); |
| | 1000 | 21 | | dict.TryAdd("Total", 1); |
| | 1000 | 22 | | dict.TryAdd(method, 1); |
| | 1000 | 23 | | dict.TryAdd(status, 1); |
| | 1000 | 24 | | return dict; |
| | 8700 | 25 | | }, |
| | 8700 | 26 | | (key, currentValue) => |
| | 8700 | 27 | | { |
| | 15450 | 28 | | currentValue.AddOrUpdate("Total", 1, (_, oldValue) => oldValue + 1); |
| | 15440 | 29 | | currentValue.AddOrUpdate(method, 1, (_, oldValue) => oldValue + 1); |
| | 15366 | 30 | | currentValue.AddOrUpdate(status, 1, (_, oldValue) => oldValue + 1); |
| | 7720 | 31 | | return currentValue; |
| | 8700 | 32 | | }); |
| | 8700 | 33 | | |
| | 8700 | 34 | | return Task.CompletedTask; |
| | 8700 | 35 | | }); |
| | | 36 | | |
| | 8700 | 37 | | await next(context); |
| | 8700 | 38 | | } |
| | | 39 | | } |