8 files changed, 415 insertions, 0 deletions
diff --git a/SystemdCtl.Client/Abstractions/StreamingHttpClient.cs b/SystemdCtl.Client/Abstractions/StreamingHttpClient.cs
new file mode 100644
index 0000000..ee39588
--- /dev/null
+++ b/SystemdCtl.Client/Abstractions/StreamingHttpClient.cs
@@ -0,0 +1,143 @@
+using System.Diagnostics;
+using System.Diagnostics.CodeAnalysis;
+using System.Net.Http.Headers;
+using System.Reflection;
+using System.Text;
+using System.Text.Json;
+using System.Text.Json.Serialization;
+using ArcaneLibs.Extensions;
+using Microsoft.AspNetCore.Components.WebAssembly.Http;
+
+namespace SystemdCtl.Client.Abstractions;
+
+public class StreamingHttpClient : HttpClient
+{
+    public Dictionary<string, string> AdditionalQueryParameters { get; set; } = new();
+    internal string? AssertedUserId { get; set; }
+
+    private JsonSerializerOptions GetJsonSerializerOptions(JsonSerializerOptions? options = null)
+    {
+        options ??= new JsonSerializerOptions();
+        options.DefaultIgnoreCondition = JsonIgnoreCondition.WhenWritingNull;
+        return options;
+    }
+
+    public async Task<HttpResponseMessage> SendAsync(HttpRequestMessage request, CancellationToken cancellationToken)
+    {
+        if (request.RequestUri is null) throw new NullReferenceException("RequestUri is null");
+        if (!request.RequestUri.IsAbsoluteUri) request.RequestUri = new Uri(BaseAddress, request.RequestUri);
+        // if (AssertedUserId is not null) request.RequestUri = request.RequestUri.AddQuery("user_id", AssertedUserId);
+        foreach (var (key, value) in AdditionalQueryParameters)
+        {
+            request.RequestUri = request.RequestUri.AddQuery(key, value);
+        }
+
+        Console.WriteLine($"Sending request to {request.RequestUri}");
+
+        try
+        {
+            var webAssemblyEnableStreamingResponseKey =
+                new HttpRequestOptionsKey<bool>("WebAssemblyEnableStreamingResponse");
+            request.Options.Set(webAssemblyEnableStreamingResponseKey, true);
+        }
+        catch (Exception e)
+        {
+            Console.WriteLine("Failed to set browser response streaming:");
+            Console.WriteLine(e);
+        }
+        
+        HttpResponseMessage responseMessage;
+        // try {
+        responseMessage = await base.SendAsync(request, HttpCompletionOption.ResponseHeadersRead, cancellationToken);
+        // }
+        // catch (Exception e) {
+        // if (requestSettings is { Retries: 0 }) throw;
+        // typeof(HttpRequestMessage).GetField("_sendStatus", BindingFlags.NonPublic | BindingFlags.Instance)
+        // ?.SetValue(request, 0);
+        // await Task.Delay(requestSettings?.RetryDelay ?? 2500, cancellationToken);
+        // if(requestSettings is not null) requestSettings.Retries--;
+        // return await SendAsync(request, cancellationToken);
+        // throw;
+        // }
+
+        if (responseMessage.IsSuccessStatusCode) return responseMessage;
+
+        //error handling
+        // var content = await responseMessage.Content.ReadAsStringAsync(cancellationToken);
+        // typeof(HttpRequestMessage).GetField("_sendStatus", BindingFlags.NonPublic | BindingFlags.Instance)
+        // ?.SetValue(request, 0);
+        // return await SendAsync(request, cancellationToken);
+        return responseMessage;
+    }
+
+    // GetAsync
+    public Task<HttpResponseMessage> GetAsync([StringSyntax("Uri")] string? requestUri, CancellationToken? cancellationToken = null)
+    {
+        return SendAsync(new HttpRequestMessage(HttpMethod.Get, requestUri), cancellationToken ?? CancellationToken.None);
+    }
+
+    // GetFromJsonAsync
+    public async Task<T> GetFromJsonAsync<T>(string requestUri, JsonSerializerOptions? options = null, CancellationToken cancellationToken = default)
+    {
+        options = GetJsonSerializerOptions(options);
+        // Console.WriteLine($"GetFromJsonAsync called for {requestUri} with json options {options?.ToJson(ignoreNull:true)} and cancellation token {cancellationToken}");
+        var request = new HttpRequestMessage(HttpMethod.Get, requestUri);
+        request.Headers.Accept.Add(new MediaTypeWithQualityHeaderValue("application/json"));
+        var response = await SendAsync(request, cancellationToken);
+        response.EnsureSuccessStatusCode();
+        await using var responseStream = await response.Content.ReadAsStreamAsync(cancellationToken);
+
+        return await JsonSerializer.DeserializeAsync<T>(responseStream, options, cancellationToken: cancellationToken) ??
+               throw new InvalidOperationException("Failed to deserialize response");
+    }
+
+    // GetStreamAsync
+    public new async Task<Stream> GetStreamAsync(string requestUri, CancellationToken cancellationToken = default)
+    {
+        var request = new HttpRequestMessage(HttpMethod.Get, requestUri);
+        request.Headers.Accept.Add(new MediaTypeWithQualityHeaderValue("application/json"));
+        var response = await SendAsync(request, cancellationToken);
+        response.EnsureSuccessStatusCode();
+        return await response.Content.ReadAsStreamAsync(cancellationToken);
+    }
+
+    public async Task<HttpResponseMessage> PutAsJsonAsync<T>([StringSyntax(StringSyntaxAttribute.Uri)] string? requestUri, T value, JsonSerializerOptions? options = null,
+        CancellationToken cancellationToken = default) where T : notnull
+    {
+        options = GetJsonSerializerOptions(options);
+        var request = new HttpRequestMessage(HttpMethod.Put, requestUri);
+        request.Headers.Accept.Add(new MediaTypeWithQualityHeaderValue("application/json"));
+        Console.WriteLine($"Sending PUT {requestUri}");
+        request.Content = new StringContent(JsonSerializer.Serialize(value, value.GetType(), options),
+            Encoding.UTF8, "application/json");
+        return await SendAsync(request, cancellationToken);
+    }
+
+    public async Task<HttpResponseMessage> PostAsJsonAsync<T>([StringSyntax(StringSyntaxAttribute.Uri)] string? requestUri, T value, JsonSerializerOptions? options = null,
+        CancellationToken cancellationToken = default) where T : notnull
+    {
+        options ??= new();
+        options.DefaultIgnoreCondition = JsonIgnoreCondition.WhenWritingNull;
+        var request = new HttpRequestMessage(HttpMethod.Post, requestUri);
+        request.Headers.Accept.Add(new MediaTypeWithQualityHeaderValue("application/json"));
+        request.Content = new StringContent(JsonSerializer.Serialize(value, value.GetType(), options),
+            Encoding.UTF8, "application/json");
+        return await SendAsync(request, cancellationToken);
+    }
+
+    public async IAsyncEnumerable<T?> GetAsyncEnumerableFromJsonAsync<T>([StringSyntax(StringSyntaxAttribute.Uri)] string? requestUri, JsonSerializerOptions? options = null)
+    {
+        options = GetJsonSerializerOptions(options);
+        var res = await GetAsync(requestUri);
+        var result = JsonSerializer.DeserializeAsyncEnumerable<T>(await res.Content.ReadAsStreamAsync(), options);
+        await foreach (var resp in result)
+        {
+            yield return resp;
+        }
+    }
+
+    public IAsyncEnumerable<TValue?> GetFromJsonAsAsyncEnumerable<TValue>(
+        [StringSyntax("Uri")] string? requestUri,
+        CancellationToken cancellationToken = default(CancellationToken)) =>
+        GetAsyncEnumerableFromJsonAsync<TValue>(requestUri);
+}
\ No newline at end of file
diff --git a/SystemdCtl.Client/Pages/ServiceManage.razor b/SystemdCtl.Client/Pages/ServiceManage.razor
new file mode 100644
index 0000000..9a32087
--- /dev/null
+++ b/SystemdCtl.Client/Pages/ServiceManage.razor
@@ -0,0 +1,66 @@
+@page "/Service/{ServiceName}/Manage"
+@using LibSystemdCli.Models
+@using LibSystemdCli
+@using System.Text.RegularExpressions
+@using SystemdCtl.Client.Abstractions
+@* @attribute [StreamRendering] *@
+@rendermode InteractiveWebAssembly
+@inject NavigationManager NavigationManager
+
+
+<PageTitle>Manage @ServiceName</PageTitle>
+
+<h1>Manage @ServiceName</h1>
+
+@* //simple log view *@
+<div class="row">
+    <div class="col-12">
+        <h3>Logs</h3>
+        <div class="card">
+            <div class="card-body">
+                <pre>
+                    @foreach (var line in LogLines) {
+                        <span>@line</span><br/>
+                    }
+                </pre>
+            </div>
+        </div>
+    </div>
+</div>
+
+@code {
+
+    [Parameter]
+    public string ServiceName { get; set; } = "";
+
+    private static bool IsClient => !Environment.CommandLine.Contains("/");
+
+    private List<string> LogLines { get; set; } = new();
+
+    protected override async Task OnInitializedAsync() {
+        Console.WriteLine("OnInitializedAsync");
+        await Run();
+    }
+
+    private async Task Run() {
+        if (!IsClient) return;
+
+        LogLines.Clear();
+        var Http = new StreamingHttpClient() { BaseAddress = new Uri(NavigationManager.BaseUri) };
+        var _items = Http.GetAsyncEnumerableFromJsonAsync<string>($"/api/unit/{ServiceName}/logs");
+        await foreach (var item in _items) {
+            LogLines.Add(item);
+            if (LogLines.Count > 100) LogLines.RemoveAt(0);
+            StateHasChanged();
+        }
+    }
+
+    private string Capitalize(string input) {
+        return input switch {
+            null => throw new ArgumentNullException(nameof(input)),
+            "" => throw new ArgumentException($"{nameof(input)} cannot be empty", nameof(input)),
+            _ => input.First().ToString().ToUpper() + input[1..]
+        };
+    }
+
+}
\ No newline at end of file
diff --git a/SystemdCtl.Client/Pages/Services.razor b/SystemdCtl.Client/Pages/Services.razor
new file mode 100644
index 0000000..d0f67a7
--- /dev/null
+++ b/SystemdCtl.Client/Pages/Services.razor
@@ -0,0 +1,154 @@
+@page "/Services"
+@using LibSystemdCli.Models
+@using System.Text.RegularExpressions
+@using SystemdCtl.Client.Abstractions
+@using ArcaneLibs.Blazor.Components
+@* @attribute [StreamRendering] *@
+@rendermode InteractiveWebAssembly
+@inject NavigationManager NavigationManager
+
+
+<PageTitle>Services</PageTitle>
+
+<h1>Services</h1>
+
+<span>
+    <label>Type: </label>
+    <InputSelect @bind-Value="TypeFilter">
+        <option value="">All</option>
+        @foreach (var i in UnitTypes) {
+            <option value="@i">@Capitalize(i)</option>
+        }
+    </InputSelect>
+</span>
+<span>
+    <InputCheckbox @bind-Value="@ShowSystem"></InputCheckbox>
+    <label>Show system services</label>
+</span>
+
+@if (filteredItems is not { Count: > 0 }) {
+    <p>
+        <em>Loading...</em>
+    </p>
+}
+else {
+    <table class="table">
+        <thead>
+            <tr>
+                <th>Service</th>
+                <th>Description</th>
+                <th>Status</th>
+                <th></th>
+            </tr>
+        </thead>
+        <tbody>
+            @foreach (var unit in filteredItems) {
+                <tr>
+                    <td>@unit.Unit</td>
+                    <td>@unit.Description</td>
+                    <td>@unit.Active</td>
+                    <td><LinkButton href="@($"/Service/{unit.Unit}/Manage")">Manage</LinkButton></td>
+                </tr>
+                @foreach (var frag in unit.FragmentPaths) {
+                    <tr>
+                        <td/>
+                        <td>@frag</td>
+                        <td/>
+                    </tr>
+                }
+            }
+        </tbody>
+    </table>
+}
+
+@code {
+
+    private static Regex[] AlwaysHidden = new Regex[] {
+        //services
+        new Regex(@"^systemd-fsck@.*\.service$"),
+        new Regex(@"^modprobe@.*\.service$"),
+        new Regex(@"^xen.*\.service$"),
+        new Regex(@"^virt.*\.service$"),
+        new Regex(@"^libvirt.*\.service$"),
+        new Regex(@"^systemd-.*\.service$"),
+        //sockets
+        new Regex(@"^virt.*\.socket$"),
+        new Regex(@"^systemd.*\.socket$"),
+        new Regex(@"^libvirt.*\.socket$"),
+        //device
+        new(@"^dev-disk-by.*\.device$"),
+        new(@"^sys-device.*\.device$"),
+        new(@".*-by\\x2d.*\.device$"),
+        //mount
+        new(@"^run-credentials.*\.mount"),
+        //target
+        new(@"^blockdev@dev-disk-by.*\.target$")
+    };
+
+    private static bool IsClient => !Environment.CommandLine.Contains("/");
+    private List<SystemdUnitListItem>? items = new();
+    private List<SystemdUnitListItem>? filteredItems = new();
+    private List<string> UnitTypes = new();
+    private string _typeFilter = "";
+    private bool _showSystem;
+
+    public string TypeFilter {
+        get => _typeFilter;
+        set {
+            _typeFilter = value;
+            FilterItems();
+        }
+    }
+
+    public bool ShowSystem {
+        get => _showSystem;
+        set {
+            _showSystem = value;
+            FilterItems();
+        }
+    }
+
+    protected override async Task OnInitializedAsync() {
+        // await Task.Delay(500);
+
+        // items = await SystemdExecutor.GetUnits();
+        Console.WriteLine("OnInitializedAsync");
+        await ReloadItems();
+    }
+
+    private async Task ReloadItems() {
+        if (!IsClient) return;
+
+        items.Clear();
+        var Http = new StreamingHttpClient() { BaseAddress = new Uri(NavigationManager.BaseUri) };
+        var _items = Http.GetAsyncEnumerableFromJsonAsync<SystemdUnitListItem>("/api/listUnits");
+        await foreach (var item in _items) {
+            items.Add(item);
+            if (items.Count % 10 == 0)
+                await FilterItems();
+        }
+
+        await FilterItems();
+    }
+
+    private async Task FilterItems() {
+        var filter = items.Where(x => true);//!AlwaysHidden.Any(y => y.IsMatch(x.Unit)));
+        if (!_showSystem)
+            filter = filter.Where(x => !x.IsSystem);
+
+        UnitTypes = filter.Select(x => x.UnitType).Distinct().ToList();
+        filter = filter.Where(x => x.Unit.EndsWith(TypeFilter)).ToList();
+
+        filteredItems = filter.ToList();
+        StateHasChanged();
+    }
+
+    private string Capitalize(string input) {
+        return input switch {
+            null => throw new ArgumentNullException(nameof(input)),
+            "" => throw new ArgumentException($"{nameof(input)} cannot be empty", nameof(input)),
+            _ => input.First().ToString().ToUpper() + input[1..]
+        };
+    }
+
+}
\ No newline at end of file
diff --git a/SystemdCtl.Client/Program.cs b/SystemdCtl.Client/Program.cs
new file mode 100644
index 0000000..524c689
--- /dev/null
+++ b/SystemdCtl.Client/Program.cs
@@ -0,0 +1,5 @@
+using Microsoft.AspNetCore.Components.WebAssembly.Hosting;
+
+var builder = WebAssemblyHostBuilder.CreateDefault(args);
+
+await builder.Build().RunAsync();
diff --git a/SystemdCtl.Client/SystemdCtl.Client.csproj b/SystemdCtl.Client/SystemdCtl.Client.csproj
new file mode 100644
index 0000000..e00a924
--- /dev/null
+++ b/SystemdCtl.Client/SystemdCtl.Client.csproj
@@ -0,0 +1,21 @@
+<Project Sdk="Microsoft.NET.Sdk.BlazorWebAssembly">
+
+  <PropertyGroup>
+    <TargetFramework>net8.0</TargetFramework>
+    <ImplicitUsings>enable</ImplicitUsings>
+    <Nullable>enable</Nullable>
+    <NoDefaultLaunchSettingsFile>true</NoDefaultLaunchSettingsFile>
+    <StaticWebAssetProjectMode>Default</StaticWebAssetProjectMode>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <PackageReference Include="ArcaneLibs" Version="1.0.0-preview7485112379.f69bb51" />
+    <PackageReference Include="ArcaneLibs.Blazor.Components" Version="1.0.0-preview7485112379.f69bb51" />
+    <PackageReference Include="Microsoft.AspNetCore.Components.WebAssembly" Version="8.0.0" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="..\LibSystemdCli.Models\LibSystemdCli.Models.csproj" />
+  </ItemGroup>
+
+</Project>
diff --git a/SystemdCtl.Client/_Imports.razor b/SystemdCtl.Client/_Imports.razor
new file mode 100644
index 0000000..3da583a
--- /dev/null
+++ b/SystemdCtl.Client/_Imports.razor
@@ -0,0 +1,10 @@
+@using System.Net.Http
+@using System.Net.Http.Json
+@using Microsoft.AspNetCore.Components.Forms
+@using Microsoft.AspNetCore.Components.Routing
+@using Microsoft.AspNetCore.Components.Web
+@using static Microsoft.AspNetCore.Components.Web.RenderMode
+@using Microsoft.AspNetCore.Components.Web.Virtualization
+@using Microsoft.JSInterop
+@using SystemdCtl.Client
+
diff --git a/SystemdCtl.Client/wwwroot/appsettings.Development.json b/SystemdCtl.Client/wwwroot/appsettings.Development.json
new file mode 100644
index 0000000..ff66ba6
--- /dev/null
+++ b/SystemdCtl.Client/wwwroot/appsettings.Development.json
@@ -0,0 +1,8 @@
+{
+  "Logging": {
+    "LogLevel": {
+      "Default": "Information",
+      "Microsoft.AspNetCore": "Warning"
+    }
+  }
+}
diff --git a/SystemdCtl.Client/wwwroot/appsettings.json b/SystemdCtl.Client/wwwroot/appsettings.json
new file mode 100644
index 0000000..ff66ba6
--- /dev/null
+++ b/SystemdCtl.Client/wwwroot/appsettings.json
@@ -0,0 +1,8 @@
+{
+  "Logging": {
+    "LogLevel": {
+      "Default": "Information",
+      "Microsoft.AspNetCore": "Warning"
+    }
+  }
+}