1 files changed, 40 insertions, 10 deletions
diff --git a/SystemdCtl.Client/Pages/ServiceManage.razor b/SystemdCtl.Client/Pages/ServiceManage.razor
index 851f1b6..39be89e 100644
--- a/SystemdCtl.Client/Pages/ServiceManage.razor
+++ b/SystemdCtl.Client/Pages/ServiceManage.razor
@@ -6,6 +6,8 @@
 @using SystemdCtl.Client.Abstractions
 @using System.Diagnostics.Metrics
 @using System.Text.Json
+@using ArcaneLibs
+@using SystemdCtl.Client.Pages.Graphs
 @* @attribute [StreamRendering] *@
 @rendermode InteractiveWebAssembly
 @inject NavigationManager NavigationManager
@@ -33,6 +35,19 @@
     </div>
 </div>
 
+<div class="row">
+    <div class="col-12">
+        <h3>Statistics</h3>
+        <div class="card">
+            <div class="card-body">
+                <p>CPU usage: @ServiceInfo?.CpuUsagePercent.ToString("P2")</p>
+                <TimelineGraph Data="@CpuUsageHistory" Height="50" Width="500" MinValue="0" ValueFormatter="@(value => value.ToString("P2"))"/>
+                <p>Memory usage: @Util.SI_BytesToString(ServiceInfo?.MemoryCurrent ?? 0) (peak: @Util.SI_BytesToString(ServiceInfo?.MemoryPeak ?? 0))</p>
+                <TimelineGraph Data="@MemoryUsageHistory" Height="50" Width="500" ValueFormatter="@(value => Util.SI_BytesToString((long)value))"/>
+            </div>
+        </div>
+    </div>
+</div>
 
 @* //simple log view *@
 <div class="row">
@@ -72,17 +87,22 @@
 
     private async Task Run() {
         if (!IsClient) return;
-        int history = 100;
-        LogLines.Clear();
         GetServiceDataTask();
+        GetLogs();
+    }
+
+    private JsonSerializerOptions jso = new() {
+        DefaultBufferSize = 1,
+        AllowTrailingCommas = true
+    };
+
+    private async Task GetLogs() {
+        int history = 100;
         var Http = new StreamingHttpClient() { BaseAddress = new Uri(NavigationManager.BaseUri) };
-        var jso = new JsonSerializerOptions() {
-            DefaultBufferSize = 1,
-            AllowTrailingCommas = true
-        };
+
+        LogLines.Clear();
         var _items = Http.GetAsyncEnumerableFromJsonAsync<SystemdJournalLogItem>($"/api/unit/{ServiceName}/logs?contextLines={history}", jso);
         await foreach (var item in _items) {
-            // LogLines.RemoveAll(x=>x.SystemdInvocationId != item.SystemdInvocationId);
             LogLines.Add(item);
             if (LogLines.Count > history) {
                 LogLines.RemoveAt(0);
@@ -95,10 +115,17 @@
     private async Task GetServiceDataTask() {
         if (!IsClient) return;
         var Http = new StreamingHttpClient() { BaseAddress = new Uri(NavigationManager.BaseUri) };
-        while (true) {
-            ServiceInfo = await Http.GetFromJsonAsync<SystemdServiceData>($"/api/unit/{ServiceName}/data");
+
+        var stream = Http.GetAsyncEnumerableFromJsonAsync<SystemdServiceData>($"/api/unit/{ServiceName}/dataStream", jso);
+        await foreach (var item in stream) {
+            ServiceInfo = item;
+            CpuUsageHistory.Add(ServiceInfo.Timestamp, ServiceInfo.CpuUsagePercent);
+            MemoryUsageHistory.Add(ServiceInfo.Timestamp, ServiceInfo.MemoryCurrent);
+            CpuUsageHistory = CpuUsageHistory.Where((x, y) => x.Key > DateTime.Now.AddMinutes(-1))
+                .OrderBy(x => x.Key).ToDictionary();
+            MemoryUsageHistory = MemoryUsageHistory.Where((x, y) => x.Key > DateTime.Now.AddMinutes(-1)).OrderBy(x => x.Key).ToDictionary();
+
             StateHasChanged();
-            await Task.Delay(TimeSpan.FromSeconds(5));
         }
     }
 
@@ -130,4 +157,7 @@
         await Http.GetAsync($"/api/unit/{ServiceName}/kill", null);
     }
 
+    public Dictionary<DateTime, double> CpuUsageHistory { get; set; } = [];
+    public Dictionary<DateTime, double> MemoryUsageHistory { get; set; } = [];
+
 }
\ No newline at end of file