From abb1b570a4343d5e4fde34f55c1a2bf403f62981 Mon Sep 17 00:00:00 2001 From: "Emma [it/its]@Rory&" Date: Tue, 8 Apr 2025 18:55:55 +0200 Subject: Local changes --- .../Spacebar.AdminAPI.TestClient/Pages/Home.razor | 107 +++++++++++++++++++++ .../Spacebar.AdminAPI.TestClient/Pages/Login.razor | 57 +++++++++++ .../Spacebar.AdminAPI.TestClient/Pages/Users.razor | 72 ++++++++++++++ .../Pages/UsersDelete.razor | 61 ++++++++++++ 4 files changed, 297 insertions(+) create mode 100644 extra/admin-api/Utilities/Spacebar.AdminAPI.TestClient/Pages/Home.razor create mode 100644 extra/admin-api/Utilities/Spacebar.AdminAPI.TestClient/Pages/Login.razor create mode 100644 extra/admin-api/Utilities/Spacebar.AdminAPI.TestClient/Pages/Users.razor create mode 100644 extra/admin-api/Utilities/Spacebar.AdminAPI.TestClient/Pages/UsersDelete.razor (limited to 'extra/admin-api/Utilities/Spacebar.AdminAPI.TestClient/Pages') diff --git a/extra/admin-api/Utilities/Spacebar.AdminAPI.TestClient/Pages/Home.razor b/extra/admin-api/Utilities/Spacebar.AdminAPI.TestClient/Pages/Home.razor new file mode 100644 index 000000000..812a61521 --- /dev/null +++ b/extra/admin-api/Utilities/Spacebar.AdminAPI.TestClient/Pages/Home.razor @@ -0,0 +1,107 @@ +@page "/" +@using System.Net.Http.Headers +@using Spacebar.AdminAPI.TestClient.Services +@inject Config Config +@inject ILocalStorageService LocalStorage + +Home + +Spacebar API URL: + +
+ + + + + +Spacebar CDN URL: + +
+ +Spacebar Admin API URL: + +
+ +Access Token: + +New access token +
+ +@code { + + private bool IsApiUrlValid { get; set; } + + // private bool IsGatewayUrlValid { get; set; } + private bool IsCdnUrlValid { get; set; } + private bool IsAdminApiUrlValid { get; set; } + private bool IsAccessTokenValid { get; set; } + + protected override async Task OnInitializedAsync() { + await ValidateAndSaveConfig(); + } + + private async Task ValidateAndSaveConfig() { + await LocalStorage.SetItemAsync("sb_admin_tc_config", Config); + + using var hc = new HttpClient(); + HttpResponseMessage response; + try { + response = await hc.GetAsync(Config.ApiUrl + "/api/v9/policies/instance/domains"); + IsApiUrlValid = response.IsSuccessStatusCode; + } + catch { + IsApiUrlValid = false; + } + + StateHasChanged(); + + // response = await hc.GetAsync(Config.GatewayUrl + "/api/v9/policies/instance"); + // IsGatewayUrlValid = response.IsSuccessStatusCode; + // StateHasChanged(); + + try { + response = await hc.GetAsync(Config.CdnUrl + "/ping"); + IsCdnUrlValid = response.IsSuccessStatusCode; + } + catch { + IsCdnUrlValid = false; + } + + StateHasChanged(); + + try { + response = await hc.GetAsync(Config.AdminUrl + "/_spacebar/admin/ping"); + IsAdminApiUrlValid = response.IsSuccessStatusCode; + } + catch { + IsAdminApiUrlValid = false; + } + + StateHasChanged(); + + try { + var request = new HttpRequestMessage(HttpMethod.Get, Config.AdminUrl + "/_spacebar/admin/whoami"); + request.Headers.Authorization = new AuthenticationHeaderValue("Bearer", Config.AccessToken); + response = await hc.SendAsync(request); + IsAccessTokenValid = response.IsSuccessStatusCode; + } + catch { + IsAccessTokenValid = false; + } + + StateHasChanged(); + } + +} \ No newline at end of file diff --git a/extra/admin-api/Utilities/Spacebar.AdminAPI.TestClient/Pages/Login.razor b/extra/admin-api/Utilities/Spacebar.AdminAPI.TestClient/Pages/Login.razor new file mode 100644 index 000000000..ca1205ed8 --- /dev/null +++ b/extra/admin-api/Utilities/Spacebar.AdminAPI.TestClient/Pages/Login.razor @@ -0,0 +1,57 @@ +@page "/Login" +@using System.Text.Json.Nodes +@using Spacebar.AdminAPI.TestClient.Services +@inject ILocalStorageService LocalStorage +@inject Config Config +@inject NavigationManager Navigation +

Login

+ +Email: + +
+ +Password: + +
+ + +
+ +
@Error
+ + +@code { + private string Email { get; set; } + private string Password { get; set; } + private string Error { get; set; } + + private async Task DoLogin() { + HttpResponseMessage response; + using var hc = new HttpClient(); + + try { + response = await hc.PostAsJsonAsync(Config.ApiUrl + "/api/v9/auth/login", new { + login = Email, + password = Password, + login_source = "Spacebar Admin API Test Client", + undelete = false + }); + } + catch (Exception e) { + Error = e.ToString(); + return; + } + + if (!response.IsSuccessStatusCode) { + Error = await response.Content.ReadAsStringAsync(); + return; + } + + var content = await response.Content.ReadFromJsonAsync(); + var accessToken = content!["token"].ToString(); + Config.AccessToken = accessToken; + await LocalStorage.SetItemAsync("sb_admin_tc_config", Config); + Navigation.NavigateTo("/", true, true); + } + +} \ No newline at end of file diff --git a/extra/admin-api/Utilities/Spacebar.AdminAPI.TestClient/Pages/Users.razor b/extra/admin-api/Utilities/Spacebar.AdminAPI.TestClient/Pages/Users.razor new file mode 100644 index 000000000..13c346617 --- /dev/null +++ b/extra/admin-api/Utilities/Spacebar.AdminAPI.TestClient/Pages/Users.razor @@ -0,0 +1,72 @@ +@page "/Users" +@using System.Net.Http.Headers +@using System.Reflection +@using Spacebar.AdminApi.Models +@using Spacebar.AdminAPI.TestClient.Services +@using ArcaneLibs.Blazor.Components +@inject Config Config +@inject ILocalStorageService LocalStorage + +Users + +
+ Displayed columns + @foreach (var column in DisplayedColumns) { + var value = column.Value; + + + @column.Key.Name + +
+ } +
+ + + @{ + var columns = DisplayedColumns.Where(kvp => kvp.Value).Select(kvp => kvp.Key).ToList(); + } + + + @foreach (var column in columns) { + + } + + + + + @foreach (var user in UserList) { + + @foreach (var column in columns) { + + } + + + } + +
@column.NameActions
@column.GetValue(user) + Delete +
+ +@code { + + private Dictionary DisplayedColumns { get; set; } = typeof(UserModel).GetProperties() + .ToDictionary(p => p, p => p.Name == "Username" || p.Name == "Id" || p.Name == "MessageCount"); + + private List UserList { get; set; } = new(); + + protected override async Task OnInitializedAsync() { + using var hc = new HttpClient(); + hc.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", Config.AccessToken); + var response = await hc.GetAsync(Config.AdminUrl + "/_spacebar/admin/users/"); + if (!response.IsSuccessStatusCode) throw new Exception(await response.Content.ReadAsStringAsync()); + var content = response.Content.ReadFromJsonAsAsyncEnumerable(); + await foreach (var user in content) { + UserList.Add(user); + StateHasChanged(); + } + } + +} \ No newline at end of file diff --git a/extra/admin-api/Utilities/Spacebar.AdminAPI.TestClient/Pages/UsersDelete.razor b/extra/admin-api/Utilities/Spacebar.AdminAPI.TestClient/Pages/UsersDelete.razor new file mode 100644 index 000000000..084a372fe --- /dev/null +++ b/extra/admin-api/Utilities/Spacebar.AdminAPI.TestClient/Pages/UsersDelete.razor @@ -0,0 +1,61 @@ +@page "/Users/Delete/{Id}" +@using System.Net.Http.Headers +@using System.Text.Json +@using System.Text.Json.Nodes +@using ArcaneLibs.Extensions +@using Spacebar.AdminApi.Models +@using Spacebar.AdminAPI.TestClient.Services +@inject Config Config +

UsersDelete - @Id

+ +Deleted @ChannelDeleteProgress.Sum(x=>x.Value.Deleted) messages so far! +@foreach (var (channel, progress) in ChannelDeleteProgress.Where(x=>x.Value.Deleted != x.Value.Total).OrderByDescending(x=>x.Value.Progress)) { +
@channel: @progress.Total total, @progress.Deleted deleted
+ +} + +@code { + + [Parameter] + public required string Id { get; set; } + + private Dictionary ChannelDeleteProgress { get; set; } = new(); + + protected override async Task OnInitializedAsync() { + using var hc = new HttpClient(); + hc.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue("Bearer", Config.AccessToken); + var response = await hc.GetAsync(Config.AdminUrl + $"/_spacebar/admin/Users/{Id}/delete?messageDeleteChunkSize=100"); + if (!response.IsSuccessStatusCode) throw new Exception(await response.Content.ReadAsStringAsync()); + var content = response.Content.ReadFromJsonAsAsyncEnumerable(); + await foreach (var actionResult in content) { + Console.WriteLine(actionResult.ToJson(indent: false)); + switch (actionResult.MessageType) { + case "STATS": { + var data = JsonSerializer.Deserialize(actionResult.Data.ToJson()); + ChannelDeleteProgress = data!["messages_per_channel"]! + .Deserialize>()! + .ToDictionary(x=>x.Key, x=>new DeleteProgress { Total = x.Value }); + break; + } + case "BULK_DELETED": { + var data = JsonSerializer.Deserialize(actionResult.Data.ToJson()); + ChannelDeleteProgress[data!["channel_id"]!.ToString()].Deleted += data!["deleted"]!.GetValue(); + break; + } + default: { + Console.WriteLine($"Unknown message type: {actionResult.MessageType}"); + break; + } + } + + StateHasChanged(); + await Task.Delay(1); + } + } + + private class DeleteProgress { + public int Total { get; set; } + public int Deleted { get; set; } = 0; + public float Progress => (float)Deleted / Total; + } +} \ No newline at end of file -- cgit 1.5.1