From 03313562d21d5db9bf6a14ebbeab80e06c883d3a Mon Sep 17 00:00:00 2001 From: Rory& Date: Wed, 24 Jan 2024 02:31:56 +0100 Subject: MRU->RMU, fixes, cleanup --- MatrixRoomUtils.Web/Pages/About.razor | 12 - MatrixRoomUtils.Web/Pages/Dev/DevOptions.razor | 71 ----- MatrixRoomUtils.Web/Pages/Dev/DevUtilities.razor | 81 ----- MatrixRoomUtils.Web/Pages/Dev/ModalTest.razor | 88 ------ MatrixRoomUtils.Web/Pages/HSAdmin/HSAdmin.razor | 34 --- MatrixRoomUtils.Web/Pages/HSAdmin/RoomQuery.razor | 200 ------------ .../Pages/HSAdmin/RoomQuery.razor.css | 0 MatrixRoomUtils.Web/Pages/Index.razor | 191 ------------ MatrixRoomUtils.Web/Pages/Index.razor.css | 25 -- MatrixRoomUtils.Web/Pages/InvalidSession.razor | 100 ------ MatrixRoomUtils.Web/Pages/LoginPage.razor | 160 ---------- .../ModerationUtilities/UserRoomHistory.razor | 115 ------- MatrixRoomUtils.Web/Pages/Rooms/Create.razor | 338 --------------------- MatrixRoomUtils.Web/Pages/Rooms/Index.razor | 250 --------------- MatrixRoomUtils.Web/Pages/Rooms/PolicyList.razor | 267 ---------------- MatrixRoomUtils.Web/Pages/Rooms/Space.razor | 100 ------ MatrixRoomUtils.Web/Pages/Rooms/StateEditor.razor | 144 --------- MatrixRoomUtils.Web/Pages/Rooms/StateViewer.razor | 127 -------- MatrixRoomUtils.Web/Pages/Rooms/Timeline.razor | 60 ---- MatrixRoomUtils.Web/Pages/ServerInfo.razor | 235 -------------- .../Pages/Tools/CopyPowerlevel.razor | 84 ----- .../Pages/Tools/KnownHomeserverList.razor | 54 ---- MatrixRoomUtils.Web/Pages/Tools/MassJoinRoom.razor | 110 ------- MatrixRoomUtils.Web/Pages/Tools/MediaLocator.razor | 111 ------- MatrixRoomUtils.Web/Pages/Tools/SpaceDebug.razor | 113 ------- MatrixRoomUtils.Web/Pages/User/DMManager.razor | 62 ---- MatrixRoomUtils.Web/Pages/User/DMSpace.razor | 86 ------ .../Pages/User/DMSpaceStages/DMSpaceStage0.razor | 11 - .../Pages/User/DMSpaceStages/DMSpaceStage1.razor | 128 -------- .../Pages/User/DMSpaceStages/DMSpaceStage2.razor | 242 --------------- .../Pages/User/DMSpaceStages/DMSpaceStage3.razor | 191 ------------ MatrixRoomUtils.Web/Pages/User/Profile.razor | 134 -------- 32 files changed, 3924 deletions(-) delete mode 100644 MatrixRoomUtils.Web/Pages/About.razor delete mode 100644 MatrixRoomUtils.Web/Pages/Dev/DevOptions.razor delete mode 100644 MatrixRoomUtils.Web/Pages/Dev/DevUtilities.razor delete mode 100644 MatrixRoomUtils.Web/Pages/Dev/ModalTest.razor delete mode 100644 MatrixRoomUtils.Web/Pages/HSAdmin/HSAdmin.razor delete mode 100644 MatrixRoomUtils.Web/Pages/HSAdmin/RoomQuery.razor delete mode 100644 MatrixRoomUtils.Web/Pages/HSAdmin/RoomQuery.razor.css delete mode 100644 MatrixRoomUtils.Web/Pages/Index.razor delete mode 100644 MatrixRoomUtils.Web/Pages/Index.razor.css delete mode 100644 MatrixRoomUtils.Web/Pages/InvalidSession.razor delete mode 100644 MatrixRoomUtils.Web/Pages/LoginPage.razor delete mode 100644 MatrixRoomUtils.Web/Pages/ModerationUtilities/UserRoomHistory.razor delete mode 100644 MatrixRoomUtils.Web/Pages/Rooms/Create.razor delete mode 100644 MatrixRoomUtils.Web/Pages/Rooms/Index.razor delete mode 100644 MatrixRoomUtils.Web/Pages/Rooms/PolicyList.razor delete mode 100644 MatrixRoomUtils.Web/Pages/Rooms/Space.razor delete mode 100644 MatrixRoomUtils.Web/Pages/Rooms/StateEditor.razor delete mode 100644 MatrixRoomUtils.Web/Pages/Rooms/StateViewer.razor delete mode 100644 MatrixRoomUtils.Web/Pages/Rooms/Timeline.razor delete mode 100644 MatrixRoomUtils.Web/Pages/ServerInfo.razor delete mode 100644 MatrixRoomUtils.Web/Pages/Tools/CopyPowerlevel.razor delete mode 100644 MatrixRoomUtils.Web/Pages/Tools/KnownHomeserverList.razor delete mode 100644 MatrixRoomUtils.Web/Pages/Tools/MassJoinRoom.razor delete mode 100644 MatrixRoomUtils.Web/Pages/Tools/MediaLocator.razor delete mode 100644 MatrixRoomUtils.Web/Pages/Tools/SpaceDebug.razor delete mode 100644 MatrixRoomUtils.Web/Pages/User/DMManager.razor delete mode 100644 MatrixRoomUtils.Web/Pages/User/DMSpace.razor delete mode 100644 MatrixRoomUtils.Web/Pages/User/DMSpaceStages/DMSpaceStage0.razor delete mode 100644 MatrixRoomUtils.Web/Pages/User/DMSpaceStages/DMSpaceStage1.razor delete mode 100644 MatrixRoomUtils.Web/Pages/User/DMSpaceStages/DMSpaceStage2.razor delete mode 100644 MatrixRoomUtils.Web/Pages/User/DMSpaceStages/DMSpaceStage3.razor delete mode 100644 MatrixRoomUtils.Web/Pages/User/Profile.razor (limited to 'MatrixRoomUtils.Web/Pages') diff --git a/MatrixRoomUtils.Web/Pages/About.razor b/MatrixRoomUtils.Web/Pages/About.razor deleted file mode 100644 index 18d7c3f..0000000 --- a/MatrixRoomUtils.Web/Pages/About.razor +++ /dev/null @@ -1,12 +0,0 @@ -@page "/About" - -About - -

Rory&::MatrixUtils - About

-
-

Rory&::MatrixUtils is a "small" collection of tools to do not-so-everyday things.

-

These range from joining rooms on dead homeservers, to managing your accounts and rooms, and creating rooms based on templates.

- -

-

You can find the source code on cgit.rory.gay.

-

You can also join the Matrix room for this project.

diff --git a/MatrixRoomUtils.Web/Pages/Dev/DevOptions.razor b/MatrixRoomUtils.Web/Pages/Dev/DevOptions.razor deleted file mode 100644 index a1e928f..0000000 --- a/MatrixRoomUtils.Web/Pages/Dev/DevOptions.razor +++ /dev/null @@ -1,71 +0,0 @@ -@page "/Dev/Options" -@using ArcaneLibs.Extensions -@using System.Text.Unicode -@using System.Text -@using System.Text.Json -@inject NavigationManager NavigationManager -@inject ILocalStorageService LocalStorage - -Developer options - -

Rory&::MatrixUtils - Developer options

-
- -

- Import local storage: - -

-

- Export local storage: - -

- -@if (userSettings is not null) { - - -
- - -
- - -
-} -
- -@code { - - private MRUStorageWrapper.Settings? userSettings { get; set; } - protected override async Task OnInitializedAsync() { - // userSettings = await TieredStorage.DataStorageProvider.LoadObjectAsync("mru.settings"); - - await base.OnInitializedAsync(); - } - - private async Task LogStuff() { - await Task.Delay(100); - Console.WriteLine($"Settings: {userSettings.ToJson()}"); - await TieredStorage.DataStorageProvider.SaveObjectAsync("mru.settings", userSettings); - } - - private async Task ExportLocalStorage() { - var keys = await TieredStorage.DataStorageProvider.GetAllKeysAsync(); - var data = new Dictionary(); - foreach (var key in keys) { - data.Add(key, await TieredStorage.DataStorageProvider.LoadObjectAsync(key)); - } - var dataUri = "data:application/json;base64,"; - dataUri += Convert.ToBase64String(Encoding.UTF8.GetBytes(JsonSerializer.Serialize(data))); - await JSRuntime.InvokeVoidAsync("window.open", dataUri, "_blank"); - } - - private async Task ImportLocalStorage(InputFileChangeEventArgs obj) { - if (obj.FileCount != 1) return; - var data = await JsonSerializer.DeserializeAsync>(obj.File.OpenReadStream()); - foreach (var (key, value) in data) { - await TieredStorage.DataStorageProvider.SaveObjectAsync(key, value); - } - NavigationManager.NavigateTo(NavigationManager.Uri, true, true); - } - -} diff --git a/MatrixRoomUtils.Web/Pages/Dev/DevUtilities.razor b/MatrixRoomUtils.Web/Pages/Dev/DevUtilities.razor deleted file mode 100644 index 27fe35e..0000000 --- a/MatrixRoomUtils.Web/Pages/Dev/DevUtilities.razor +++ /dev/null @@ -1,81 +0,0 @@ -@page "/Dev/Utilities" -@using System.Reflection -@using ArcaneLibs.Extensions -@using LibMatrix.Extensions -@using LibMatrix.Homeservers -@using MatrixRoomUtils.Abstractions -@inject ILocalStorageService LocalStorage -@inject NavigationManager NavigationManager -

Debug Tools

-
-@if (Rooms.Count == 0) { -

You are not in any rooms!

- @*

Loading progress: @checkedRoomCount/@totalRoomCount

*@ -} -else { -
- Room List - @foreach (var room in Rooms) { - - - - } -
-} - -
- Send GET request to URL -
- - -
-
- 
@get_request_result
-
- -
- - -@code { - public List Rooms { get; set; } = new(); - public AuthenticatedHomeserverGeneric? hs { get; set; } - - protected override async Task OnInitializedAsync() { - await base.OnInitializedAsync(); - hs = await MRUStorage.GetCurrentSessionOrNavigate(); - if (hs == null) return; - Rooms = (await hs.GetJoinedRooms()).Select(x => x.RoomId).ToList(); - Console.WriteLine("Fetched joined rooms!"); - } - - //send req - string get_request_url { get; set; } = ""; - string get_request_result { get; set; } = ""; - - private async Task SendGetRequest() { - var field = typeof(RemoteHomeserver).GetRuntimeFields().First(x => x.ToString().Contains("<_httpClient>k__BackingField")); - var hs = await MRUStorage.GetCurrentSessionOrNavigate(); - if (hs == null) return; - var httpClient = field.GetValue(hs) as MatrixHttpClient; - try { - var res = await httpClient.GetAsync(get_request_url); - if (res.IsSuccessStatusCode) { - if (res.Content.Headers.ContentType.MediaType == "application/json") - get_request_result = (await res.Content.ReadFromJsonAsync()).ToJson(); - else - get_request_result = await res.Content.ReadAsStringAsync(); - StateHasChanged(); - return; - } - if (res.Content.Headers.ContentType.MediaType == "application/json") - get_request_result = $"Error: {res.StatusCode}\n" + (await res.Content.ReadFromJsonAsync()).ToJson(); - else - get_request_result = $"Error: {res.StatusCode}\n" + await res.Content.ReadAsStringAsync(); - } - catch (Exception e) { - get_request_result = $"Error: {e}"; - } - StateHasChanged(); - } - -} \ No newline at end of file diff --git a/MatrixRoomUtils.Web/Pages/Dev/ModalTest.razor b/MatrixRoomUtils.Web/Pages/Dev/ModalTest.razor deleted file mode 100644 index 4a0487f..0000000 --- a/MatrixRoomUtils.Web/Pages/Dev/ModalTest.razor +++ /dev/null @@ -1,88 +0,0 @@ -@page "/Dev/ModalTest" -@inject IJSRuntime JsRuntime -

ModalTest

- -@foreach (var (key, value) in _windowInfos) { - @* @value.Content *@ -} -@for (var i = 0; i < 5; i++) { - var i1 = i; - - @for (var j = 0; j < i1; j++) { -

@j

- } - -} - -@code { - - private Dictionary _windowInfos = new(); - - private class WindowInfo { - public double X; - public double Y; - public string Title; - public RenderFragment Content; - } - - protected override async Task OnInitializedAsync() { - double _x = 2; - double _xv = 20; - double _y = 0; - double multiplier = 1; - - for (var i = 0; i < 200; i++) { - var i1 = i; - _windowInfos.Add(_windowInfos.Count, new WindowInfo { - X = _x, - Y = _y, - Title = "Win" + i1, - Content = builder => { - builder.OpenComponent(0); - builder.AddAttribute(1, "X", _x); - builder.AddAttribute(2, "Y", _y); - builder.AddAttribute(3, "Title", "Win" + i1); - builder.AddAttribute(4, "ChildContent", (RenderFragment)(builder2 => { - builder2.OpenElement(0, "h1"); - builder2.AddContent(1, "Hello " + i1); - builder2.CloseElement(); - })); - builder.CloseComponent(); - } - }); - //_x += _xv /= 1000/System.Math.Sqrt((double)_windowInfos.Count)*_windowInfos.Count.ToString().Length*multiplier; - _y += 20; - _x += 20; - var dimension = await JsRuntime.InvokeAsync("getWindowDimensions"); - if (_x > dimension.Width - 100) _x %= dimension.Width - 100; - if (_y > dimension.Height - 50) { - _y %= dimension.Height - 50; - _xv = 20; - } - if ( - (_windowInfos.Count < 10 && _windowInfos.Count % 2 == 0) || - (_windowInfos.Count < 100 && _windowInfos.Count % 10 == 0) || - (_windowInfos.Count < 1000 && _windowInfos.Count % 50 == 0) || - (_windowInfos.Count < 10000 && _windowInfos.Count % 100 == 0) - ) { - StateHasChanged(); - await Task.Delay(25); - } - if(_windowInfos.Count > 750) multiplier = 2; - if(_windowInfos.Count > 1500) multiplier = 3; - - } - - await base.OnInitializedAsync(); - } - - private void OnCloseClicked(int i1) { - Console.WriteLine("Close clicked on " + i1); - } - - public class WindowDimension { - public int Width { get; set; } - public int Height { get; set; } - } - -} diff --git a/MatrixRoomUtils.Web/Pages/HSAdmin/HSAdmin.razor b/MatrixRoomUtils.Web/Pages/HSAdmin/HSAdmin.razor deleted file mode 100644 index d1a2df5..0000000 --- a/MatrixRoomUtils.Web/Pages/HSAdmin/HSAdmin.razor +++ /dev/null @@ -1,34 +0,0 @@ -@page "/HSAdmin" -@using LibMatrix.Homeservers -@using ArcaneLibs.Extensions -

Homeserver Admininistration

-
- -@if (Homeserver is null) { -

Homeserver is null...

-} -else { - @if (Homeserver is AuthenticatedHomeserverSynapse) { -

Synapse tools

-
- Query rooms - } - else { -

Homeserver type @Homeserver.GetType().Name does not have any administration tools in MRU.

-

Server info:

- 
@ServerVersionResponse?.ToJson(ignoreNull: true)
- } -} - -@code { - public AuthenticatedHomeserverGeneric? Homeserver { get; set; } - public ServerVersionResponse? ServerVersionResponse { get; set; } - - protected override async Task OnInitializedAsync() { - Homeserver = await MRUStorage.GetCurrentSessionOrNavigate(); - if (Homeserver is null) return; - ServerVersionResponse = await (Homeserver.FederationClient?.GetServerVersionAsync() ?? Task.FromResult(null)); - await base.OnInitializedAsync(); - } - -} \ No newline at end of file diff --git a/MatrixRoomUtils.Web/Pages/HSAdmin/RoomQuery.razor b/MatrixRoomUtils.Web/Pages/HSAdmin/RoomQuery.razor deleted file mode 100644 index 7e4058b..0000000 --- a/MatrixRoomUtils.Web/Pages/HSAdmin/RoomQuery.razor +++ /dev/null @@ -1,200 +0,0 @@ -@page "/HSAdmin/RoomQuery" -@using LibMatrix.Responses.Admin -@using LibMatrix.Filters -@using LibMatrix.Homeservers -@using ArcaneLibs.Extensions - -

Homeserver Administration - Room Query

- - -
- -
- -
-
- - Local filtering (slow) - - -
- String contains - Room ID: - Room name: - Canonical alias: - Creator: - Room version: - Encryption algorithm: - Join rules: - Guest access: - History visibility: - - Optional checks - - Is federated: - @if (Filter.CheckFederation) { - - } - - - Is public: - @if (Filter.CheckPublic) { - - } - - - Ranges - - state events - - - members - - - local members - -
-
- -
- -@if (Results.Count > 0) { -

Found @Results.Count rooms

-
- TSV data (copy/paste) - 
-            
-                @foreach (var res in Results) {
-                    
-                        
-                        
-                        
-                        
-                    
-                }
-            
@res.RoomId@("\t")@res.CanonicalAlias@("\t")@res.Creator@("\t")@res.Name

-
-
-} - -@foreach (var res in Results) { -
- -

- @if (!string.IsNullOrWhiteSpace(res.CanonicalAlias)) { - @res.CanonicalAlias (@res.RoomId) -
- } - else { - @res.RoomId -
- } - @if (!string.IsNullOrWhiteSpace(res.Creator)) { - Created by -
- } -

- @res.StateEvents state events
- @res.JoinedMembers members, of which @res.JoinedLocalMembers are on this server -
- Full result data - 
@res.ToJson(ignoreNull: true)
-
-
-} - - - -@code { - - [Parameter] - [SupplyParameterFromQuery(Name = "order_by")] - public string? OrderBy { get; set; } - - [Parameter] - [SupplyParameterFromQuery(Name = "name_search")] - public string SearchTerm { get; set; } - - [Parameter] - [SupplyParameterFromQuery(Name = "ascending")] - public bool Ascending { get; set; } - - public List Results { get; set; } = new(); - - private string Status { get; set; } - - public LocalRoomQueryFilter Filter { get; set; } = new(); - - protected override Task OnParametersSetAsync() { - if (Ascending == null) - Ascending = true; - OrderBy ??= "name"; - return Task.CompletedTask; - } - - private async Task Search() { - Results.Clear(); - var hs = await MRUStorage.GetCurrentSessionOrNavigate(); - if (hs is AuthenticatedHomeserverSynapse synapse) { - var searchRooms = synapse.Admin.SearchRoomsAsync(orderBy: OrderBy!, dir: Ascending ? "f" : "b", searchTerm: SearchTerm, localFilter: Filter).GetAsyncEnumerator(); - while (await searchRooms.MoveNextAsync()) { - var room = searchRooms.Current; - Console.WriteLine("Hit: " + room.ToJson(false)); - Results.Add(room); - if (Results.Count % 10 == 0) - StateHasChanged(); - } - } - - } - - private readonly Dictionary validOrderBy = new() { - { "name", "Room name" }, - { "canonical_alias", "Main alias address" }, - { "joined_members", "Number of members (reversed)" }, - { "joined_local_members", "Number of local members (reversed)" }, - { "version", "Room version" }, - { "creator", "Creator of the room" }, - { "encryption", "End-to-end encryption algorithm" }, - { "federatable", "Is room federated" }, - { "public", "Visibility in room list" }, - { "join_rules", "Join rules" }, - { "guest_access", "Guest access" }, - { "history_visibility", "Visibility of history" }, - { "state_events", "Number of state events" } - }; - -} diff --git a/MatrixRoomUtils.Web/Pages/HSAdmin/RoomQuery.razor.css b/MatrixRoomUtils.Web/Pages/HSAdmin/RoomQuery.razor.css deleted file mode 100644 index e69de29..0000000 diff --git a/MatrixRoomUtils.Web/Pages/Index.razor b/MatrixRoomUtils.Web/Pages/Index.razor deleted file mode 100644 index 250dc2d..0000000 --- a/MatrixRoomUtils.Web/Pages/Index.razor +++ /dev/null @@ -1,191 +0,0 @@ -@page "/" -@inject ILogger logger -@using LibMatrix.Responses -@using LibMatrix -@using LibMatrix.Homeservers -@using ArcaneLibs.Extensions -@using MatrixRoomUtils.Web.Pages.Dev - -Index - -

Rory&::MatrixUtils

-Small collection of tools to do not-so-everyday things. - -

-
Signed in accounts - Add new account
-
-
- - @foreach (var session in _sessions.OrderByDescending(x => x.UserInfo.RoomCount)) { - var _auth = session.UserAuth; - - - - - - } -
- - -

- Manage - Remove - Log out -

-
-
- -@if (_offlineSessions.Count > 0) { -
-
-
Sessions on unreachable servers
-
-
- - @foreach (var session in _offlineSessions) { - - - - - } -
-

- @{ - string[] parts = session.UserId.Split(':'); - } - @parts[0][1..] on @parts[1] - @if (!string.IsNullOrWhiteSpace(session.Proxy)) { - (proxied via @session.Proxy) - } -

- 		- Remove -
-
-} - -@code -{ -#if DEBUG - private const bool _debug = true; -#else - private const bool _debug = false; -#endif - - private class AuthInfo { - public UserAuth UserAuth { get; set; } - public UserInfo UserInfo { get; set; } - public ServerVersionResponse ServerVersion { get; set; } - public AuthenticatedHomeserverGeneric Homeserver { get; set; } - } - - // private Dictionary _users = new(); - private readonly List _sessions = []; - private readonly List _offlineSessions = []; - private LoginResponse? _currentSession; - - protected override async Task OnInitializedAsync() { - Console.WriteLine("Index.OnInitializedAsync"); - _currentSession = await MRUStorage.GetCurrentToken(); - _sessions.Clear(); - _offlineSessions.Clear(); - var tokens = await MRUStorage.GetAllTokens(); - var profileTasks = tokens.Select(async token => { - UserInfo userInfo = new(); - AuthenticatedHomeserverGeneric hs; - Console.WriteLine($"Getting hs for {token.ToJson()}"); - try { - hs = await hsProvider.GetAuthenticatedWithToken(token.Homeserver, token.AccessToken, token.Proxy); - } - catch (MatrixException e) { - if (e.ErrorCode != "M_UNKNOWN_TOKEN") throw; - NavigationManager.NavigateTo("/InvalidSession?ctx=" + token.AccessToken); - return; - - } - catch (Exception e) { - logger.LogError(e, $"Failed to instantiate AuthenticatedHomeserver for {token.ToJson()}, homeserver may be offline?", token.UserId); - _offlineSessions.Add(token); - return; - } - - Console.WriteLine($"Got hs for {token.ToJson()}"); - - var roomCountTask = hs.GetJoinedRooms(); - var profile = await hs.GetProfileAsync(hs.WhoAmI.UserId); - userInfo.DisplayName = profile.DisplayName ?? hs.WhoAmI.UserId; - Console.WriteLine(profile.ToJson()); - _sessions.Add(new() { - UserInfo = new() { - AvatarUrl = string.IsNullOrWhiteSpace(profile.AvatarUrl) ? "https://api.dicebear.com/6.x/identicon/svg?seed=" + hs.WhoAmI.UserId : hs.ResolveMediaUri(profile.AvatarUrl), - RoomCount = (await roomCountTask).Count, - DisplayName = profile.DisplayName ?? hs.WhoAmI.UserId - }, - UserAuth = token, - ServerVersion = await (hs.FederationClient?.GetServerVersionAsync() ?? Task.FromResult(null)), - Homeserver = hs - }); - }); - Console.WriteLine("Waiting for profile tasks"); - await Task.WhenAll(profileTasks); - Console.WriteLine("Done waiting for profile tasks"); - await base.OnInitializedAsync(); - } - - private class UserInfo { - internal string AvatarUrl { get; set; } - internal string DisplayName { get; set; } - internal int RoomCount { get; set; } - } - - private async Task RemoveUser(UserAuth auth, bool logout = false) { - try { - if (logout) { - await (await hsProvider.GetAuthenticatedWithToken(auth.Homeserver, auth.AccessToken, auth.Proxy)).Logout(); - } - } - catch (Exception e) { - if (e is MatrixException { ErrorCode: "M_UNKNOWN_TOKEN" }) { - //todo: handle this - return; - } - - Console.WriteLine(e); - } - - await MRUStorage.RemoveToken(auth); - if ((await MRUStorage.GetCurrentToken())?.AccessToken == auth.AccessToken) - await MRUStorage.SetCurrentToken((await MRUStorage.GetAllTokens() ?? throw new InvalidOperationException()).FirstOrDefault()); - await OnInitializedAsync(); - } - - - private async Task SwitchSession(UserAuth auth) { - Console.WriteLine($"Switching to {auth.Homeserver} {auth.UserId} via {auth.Proxy}"); - await MRUStorage.SetCurrentToken(auth); - await OnInitializedAsync(); - } - - private async Task ManageUser(UserAuth auth) { - await SwitchSession(auth); - NavigationManager.NavigateTo("/User/Profile"); - } -} \ No newline at end of file diff --git a/MatrixRoomUtils.Web/Pages/Index.razor.css b/MatrixRoomUtils.Web/Pages/Index.razor.css deleted file mode 100644 index c6b7bd7..0000000 --- a/MatrixRoomUtils.Web/Pages/Index.razor.css +++ /dev/null @@ -1,25 +0,0 @@ -.user-entry { - margin-bottom: 1em; -} - -.avatar { - width: 4em; - height: 4em; - border-radius: 50%; - margin-right: 0.5em; - vertical-align: middle; -} - -.user-entry > td { - margin-right: 0.5em; - vertical-align: middle; -} - -.user-info { - margin-bottom: 0.5em; - display: inline-block; - vertical-align: middle; -} -.user-info > p { - margin: 0; -} diff --git a/MatrixRoomUtils.Web/Pages/InvalidSession.razor b/MatrixRoomUtils.Web/Pages/InvalidSession.razor deleted file mode 100644 index 7d4769c..0000000 --- a/MatrixRoomUtils.Web/Pages/InvalidSession.razor +++ /dev/null @@ -1,100 +0,0 @@ -@page "/InvalidSession" -@using LibMatrix - -Invalid session - -

Rory&::MatrixUtils - Invalid session encountered

-

A session was encountered that is no longer valid. This can happen if you have logged out of the account on another device, or if the access token has expired.

- -@if (_login is not null) { -

It appears that the affected user is @_login.UserId (@_login.DeviceId) on @_login.Homeserver!

- Refresh token - Remove - - @if (_showRefreshDialog) { - -
- Log in - @if (_loginException is not null) { - 
@_loginException.RawContent
- } - - } -} -else { - Something has gone wrong and the login was not passed along! -} - -@code -{ - [Parameter] - [SupplyParameterFromQuery(Name = "ctx")] - public string Context { get; set; } - - private UserAuth? _login { get; set; } - - private bool _showRefreshDialog { get; set; } - - private string _password { get; set; } = ""; - - private MatrixException? _loginException { get; set; } - - protected override async Task OnInitializedAsync() { - var tokens = await MRUStorage.GetAllTokens(); - if (tokens is null || tokens.Count == 0) { - NavigationManager.NavigateTo("/Login"); - return; - } - - _login = tokens.FirstOrDefault(x => x.AccessToken == Context); - - if (_login is null) { - Console.WriteLine($"Could not find {_login} in stored tokens!"); - } - - await base.OnInitializedAsync(); - } - - private async Task RemoveUser() { - await MRUStorage.RemoveToken(_login!); - if ((await MRUStorage.GetCurrentToken())!.AccessToken == _login!.AccessToken) - await MRUStorage.SetCurrentToken((await MRUStorage.GetAllTokens())?.FirstOrDefault()); - await OnInitializedAsync(); - } - - private async Task OpenRefreshDialog() { - _showRefreshDialog = true; - StateHasChanged(); - await Task.CompletedTask; - } - - private async Task SwitchSession(UserAuth auth) { - Console.WriteLine($"Switching to {auth.Homeserver} {auth.AccessToken} {auth.UserId}"); - await MRUStorage.SetCurrentToken(auth); - await OnInitializedAsync(); - } - - private async Task TryLogin() { - if(_login is null) throw new NullReferenceException("Login is null!"); - try { - var result = new UserAuth(await hsProvider.Login(_login.Homeserver, _login.UserId, _password)); - if (result is null) { - Console.WriteLine($"Failed to login to {_login.Homeserver} as {_login.UserId}!"); - return; - } - Console.WriteLine($"Obtained access token for {result.UserId}!"); - - await RemoveUser(); - await MRUStorage.AddToken(result); - if (result.UserId == (await MRUStorage.GetCurrentToken())?.UserId) - await MRUStorage.SetCurrentToken(result); - NavigationManager.NavigateTo("/"); - } - catch (MatrixException e) { - Console.WriteLine($"Failed to login to {_login.Homeserver} as {_login.UserId}!"); - Console.WriteLine(e); - _loginException = e; - StateHasChanged(); - } - } -} diff --git a/MatrixRoomUtils.Web/Pages/LoginPage.razor b/MatrixRoomUtils.Web/Pages/LoginPage.razor deleted file mode 100644 index b6f244d..0000000 --- a/MatrixRoomUtils.Web/Pages/LoginPage.razor +++ /dev/null @@ -1,160 +0,0 @@ -@page "/Login" -@using System.Text.Json -@using System.Text.Json.Serialization -@using LibMatrix -@inject ILocalStorageService LocalStorage -@inject IJSRuntime JsRuntime -

Login

-
- - - - @@: - - - - - - - - - -
-Add account to queue -Log in -
-
- -

Import from TSV

-
-Import credentials from a TSV (Tab Separated Values) file
-Columns: username, homeserver, password, proxy
-Keep in mind there is no column header!
-
- -
-
- - - - - - - - - - @foreach (var record in records) { - var r = record; - - - - - - - - @if (r.Exception is MatrixException me) { - - - - - - } - else if (r.Exception is { } e) { - - - - - } - } -
UsernameHomeserverPasswordProxyActions
- - - - - - - - - Remove -
Exception:@me.ErrorCode@me.Error
Exception:@e.Message
-
-Log in - - -@code { - readonly List records = new(); - private LoginStruct newRecordInput = new(); - - List? LoggedInSessions { get; set; } = new(); - - async Task LoginAll() { - var loginTasks = records.Select(Login); - await Task.WhenAll(loginTasks); - } - - async Task Login(LoginStruct record) { - if (!records.Contains(record)) - records.Add(record); - if (LoggedInSessions.Any(x => x.UserId == $"@{record.Username}:{record.Homeserver}" && x.Proxy == record.Proxy)) return; - StateHasChanged(); - try { - var result = new UserAuth(await hsProvider.Login(record.Homeserver, record.Username, record.Password, record.Proxy)) { - Proxy = record.Proxy - }; - if (result == null) { - Console.WriteLine($"Failed to login to {record.Homeserver} as {record.Username}!"); - return; - } - - Console.WriteLine($"Obtained access token for {result.UserId}!"); - - await MRUStorage.AddToken(result); - LoggedInSessions = await MRUStorage.GetAllTokens(); - } - catch (Exception e) { - Console.WriteLine($"Failed to login to {record.Homeserver} as {record.Username}!"); - Console.WriteLine(e); - record.Exception = e; - } - - StateHasChanged(); - } - - private async Task FileChanged(InputFileChangeEventArgs obj) { - LoggedInSessions = await MRUStorage.GetAllTokens(); - Console.WriteLine(JsonSerializer.Serialize(obj, new JsonSerializerOptions { - WriteIndented = true - })); - await using var rs = obj.File.OpenReadStream(); - using var sr = new StreamReader(rs); - var tsvData = await sr.ReadToEndAsync(); - records.Clear(); - foreach (var line in tsvData.Split('\n')) { - string?[] parts = line.Split('\t'); - if (parts.Length < 3) - continue; - string? via = parts.Length > 3 ? parts[3] : null; - records.Add(new() { Homeserver = parts[0], Username = parts[1], Password = parts[2], Proxy = via }); - } - } - - private async Task AddRecord() { - LoggedInSessions = await MRUStorage.GetAllTokens(); - records.Add(newRecordInput); - newRecordInput = new(); - } - - private class LoginStruct { - public string? Homeserver { get; set; } = ""; - public string? Username { get; set; } = ""; - public string? Password { get; set; } = ""; - public string? Proxy { get; set; } - - [JsonIgnore] - internal Exception? Exception { get; set; } - } - -} \ No newline at end of file diff --git a/MatrixRoomUtils.Web/Pages/ModerationUtilities/UserRoomHistory.razor b/MatrixRoomUtils.Web/Pages/ModerationUtilities/UserRoomHistory.razor deleted file mode 100644 index 506a8a1..0000000 --- a/MatrixRoomUtils.Web/Pages/ModerationUtilities/UserRoomHistory.razor +++ /dev/null @@ -1,115 +0,0 @@ -@page "/UserRoomHistory/{UserId}" -@using LibMatrix.Homeservers -@using LibMatrix -@using LibMatrix.EventTypes.Spec.State -@using LibMatrix.RoomTypes -@using ArcaneLibs.Extensions -@using MatrixRoomUtils.Abstractions -

UserRoomHistory

- -Enter mxid: - - -@if (string.IsNullOrWhiteSpace(UserId)) { -

UserId is null!

-} -else { -

Checked @checkedRooms.Count so far...

- @if (currentHs is not null) { -

Checking rooms from @currentHs.UserId's perspective

- } - else if (checkedRooms.Count > 1) { -

Done!

- } - @foreach (var (state, rooms) in matchingStates) { - @state -
- @foreach (var roomInfo in rooms) { - - } - } -} - -@code { - private string? _userId; - - [Parameter] - public string? UserId { - get => _userId; - set { - _userId = value; - FindMember(value); - } - } - - private List hss = new(); - private AuthenticatedHomeserverGeneric? currentHs { get; set; } - - protected override async Task OnInitializedAsync() { - var hs = await MRUStorage.GetCurrentSessionOrNavigate(); - if (hs is null) return; - var sessions = await MRUStorage.GetAllTokens(); - foreach (var userAuth in sessions) { - var session = await MRUStorage.GetSession(userAuth); - if (session is not null) { - hss.Add(session); - StateHasChanged(); - } - } - - StateHasChanged(); - Console.WriteLine("Rerendered!"); - await base.OnInitializedAsync(); - if (!string.IsNullOrWhiteSpace(UserId)) FindMember(UserId); - } - - public Dictionary> matchingStates = new(); - public List checkedRooms = new(); - private SemaphoreSlim _semaphoreSlim = new(1, 1); - - public async Task FindMember(string mxid) { - await _semaphoreSlim.WaitAsync(); - if (mxid != UserId) { - _semaphoreSlim.Release(); - return; //abort if changed - } - matchingStates.Clear(); - foreach (var homeserver in hss) { - currentHs = homeserver; - var rooms = await homeserver.GetJoinedRooms(); - rooms.RemoveAll(x => checkedRooms.Contains(x.RoomId)); - checkedRooms.AddRange(rooms.Select(x => x.RoomId)); - var tasks = rooms.Select(x => GetMembershipAsync(x, mxid)).ToAsyncEnumerable(); - await foreach (var (room, state) in tasks) { - if (state is null) continue; - if (!matchingStates.ContainsKey(state.Membership)) - matchingStates.Add(state.Membership, new()); - var roomInfo = new RoomInfo() { - Room = room - }; - matchingStates[state.Membership].Add(roomInfo); - roomInfo.StateEvents.Add(new() { - Type = RoomNameEventContent.EventId, - TypedContent = new RoomNameEventContent() { - Name = await room.GetNameOrFallbackAsync(4) - }, - RoomId = null, Sender = null, EventId = null //TODO implement - }); - StateHasChanged(); - if (mxid != UserId) { - _semaphoreSlim.Release(); - return; //abort if changed - } - } - StateHasChanged(); - } - currentHs = null; - StateHasChanged(); - _semaphoreSlim.Release(); - } - - public async Task<(GenericRoom roomId, RoomMemberEventContent? content)> GetMembershipAsync(GenericRoom room, string mxid) { - return (room, await room.GetStateOrNullAsync(RoomMemberEventContent.EventId, mxid)); - } - -} \ No newline at end of file diff --git a/MatrixRoomUtils.Web/Pages/Rooms/Create.razor b/MatrixRoomUtils.Web/Pages/Rooms/Create.razor deleted file mode 100644 index e477f4c..0000000 --- a/MatrixRoomUtils.Web/Pages/Rooms/Create.razor +++ /dev/null @@ -1,338 +0,0 @@ -@page "/Rooms/Create" -@using System.Text.Json -@using System.Reflection -@using ArcaneLibs.Extensions -@using LibMatrix -@using LibMatrix.EventTypes.Spec.State -@using LibMatrix.EventTypes.Spec.State.RoomInfo -@using LibMatrix.Homeservers -@using LibMatrix.Responses -@using MatrixRoomUtils.Web.Classes.RoomCreationTemplates -@* @* ReSharper disable once RedundantUsingDirective - Must not remove this, Rider marks this as "unused" when it's not */ *@ - -

Room Manager - Create Room

- -@* 
@JsonString
*@ - - - - - - - @if (creationEvent is not null) { - - - - - - - - - - - - - - - - - - - - - - - -
- @creationEvent.PowerLevelContentOverride.Users.Count members - @foreach (var user in creationEvent.PowerLevelContentOverride.Events.Keys) { - var _event = user; -
- - - - } - @foreach (var user in creationEvent.PowerLevelContentOverride.Users.Keys) { - var _user = user; - - - - - } - - - - - - - - - - - - @* Initial states, should remain at bottom *@ - - - - - } -
Preset: - @if (Presets is null) { -

Presets is null!

- } - else { - - @foreach (var createRoomRequest in Presets) { - - } - - } -
Room name: - @if (creationEvent.Name is null) { -

creationEvent.Name is null!

- } - else { - -

(#:@Homeserver.WhoAmI.UserId.Split(':').Last())

- } -
Room type: - @if (creationEvent.CreationContentBaseType is null) { -

creationEvent._creationContentBaseType is null!

- } - else { - - - - - - } -
History visibility: - - - - - - -
Guest access: - - @(guestAccessEvent.IsGuestAccessEnabled ? "Guests can join" : "Guests cannot join") (@guestAccessEvent.GuestAccess) - - - - - -
Room icon: - -
-
- -
-
Permissions:
- - : - - -
: - -
Server ACLs: - @if (serverAcl?.Allow is null) { -

No allow rules exist!

- - } - else { -
- @((creationEvent["m.room.server_acls"].TypedContent as RoomServerACLEventContent).Allow.Count) allow rules - @* *@ -
- } - @if (serverAcl?.Deny is null) { -

No deny rules exist!

- - } - else { -
- @((creationEvent["m.room.server_acls"].TypedContent as RoomServerACLEventContent).Deny.Count) deny rules - @* *@ -
- } -
Invited members: -
- @creationEvent.InitialState.Count(x => x.Type == "m.room.member") members - @* *@ - @foreach (var member in creationEvent.InitialState.Where(x => x.Type == "m.room.member" && x.StateKey != Homeserver.UserId)) { - - } -
-
Initial states: -
- - @code - { - private static readonly string[] ImplementedStates = { "m.room.avatar", "m.room.history_visibility", "m.room.guest_access", "m.room.server_acl" }; - } - - @creationEvent.InitialState.Count(x => !ImplementedStates.Contains(x.Type)) custom states - - @foreach (var initialState in creationEvent.InitialState.Where(x => !ImplementedStates.Contains(x.Type))) { - - - - - } -
- @(initialState.Type): - @if (!string.IsNullOrEmpty(initialState.StateKey)) { -
- (@initialState.StateKey) - } - - 		- 
@JsonSerializer.Serialize(initialState.RawContent, new JsonSerializerOptions { WriteIndented = true })
-
-
-
- @creationEvent.InitialState.Count initial states - - @foreach (var initialState in creationEvent.InitialState) { - var _state = initialState; - - - - - - } -
- @(_state.Type):
- - 		- 
@JsonSerializer.Serialize(_state.RawContent, new JsonSerializerOptions { WriteIndented = true })
-
-
-
- -
- - 
-        @creationEvent.ToJson(ignoreNull: true)
-
- - - 
-        @creationEvent.ToJson()
-
- - -@if (_matrixException is not null) { - - 
-            @_matrixException.Message
-
- -} - -@code { - - private string RoomPreset { - get => Presets.ContainsValue(creationEvent) ? Presets.First(x => x.Value == creationEvent).Key : "Not a preset"; - set { - creationEvent = Presets[value]; - JsonChanged(); - StateHasChanged(); - } - } - - private CreateRoomRequest? creationEvent { get; set; } - - private Dictionary? Presets { get; set; } = new(); - private AuthenticatedHomeserverGeneric? Homeserver { get; set; } - - private MatrixException? _matrixException { get; set; } - - private RoomHistoryVisibilityEventContent? historyVisibility => creationEvent?["m.room.history_visibility"].TypedContent as RoomHistoryVisibilityEventContent; - private RoomGuestAccessEventContent? guestAccessEvent => creationEvent?["m.room.guest_access"].TypedContent as RoomGuestAccessEventContent; - private RoomServerACLEventContent? serverAcl => creationEvent?["m.room.server_acls"].TypedContent as RoomServerACLEventContent; - private RoomAvatarEventContent? roomAvatarEvent => creationEvent?["m.room.avatar"].TypedContent as RoomAvatarEventContent; - - protected override async Task OnInitializedAsync() { - Homeserver = await MRUStorage.GetCurrentSessionOrNavigate(); - if (Homeserver is null) return; - - foreach (var x in Assembly.GetExecutingAssembly().GetTypes().Where(x => x.IsClass && !x.IsAbstract && x.GetInterfaces().Contains(typeof(IRoomCreationTemplate))).ToList()) { - Console.WriteLine($"Found room creation template in class: {x.FullName}"); - var instance = (IRoomCreationTemplate)Activator.CreateInstance(x); - Presets[instance.Name] = instance.CreateRoomRequest; - } - Presets = Presets.OrderBy(x => x.Key).ToDictionary(x => x.Key, x => x.Value); - - if (!Presets.ContainsKey("Default")) { - Console.WriteLine($"No default room found in {Presets.Count} presets: {string.Join(", ", Presets.Keys)}"); - } - else RoomPreset = "Default"; - - await base.OnInitializedAsync(); - } - - private void JsonChanged() => Console.WriteLine(creationEvent.ToJson()); - - private async Task RoomIconFilePicked(InputFileChangeEventArgs obj) { - var res = await Homeserver.UploadFile(obj.File.Name, obj.File.OpenReadStream(), obj.File.ContentType); - Console.WriteLine(res); - (creationEvent["m.room.avatar"].TypedContent as RoomAvatarEventContent).Url = res; - StateHasChanged(); - } - - private async Task CreateRoom() { - Console.WriteLine("Create room"); - Console.WriteLine(creationEvent.ToJson()); - creationEvent.CreationContent.Add("rory.gay.created_using", "Rory&::MatrixRoomUtils (https://mru.rory.gay)"); - try { - var id = await Homeserver.CreateRoom(creationEvent); - } - catch (MatrixException e) { - _matrixException = e; - } - } - - private void InviteMember(string mxid) { - if (!creationEvent.InitialState.Any(x => x.Type == "m.room.member" && x.StateKey == mxid) && Homeserver.UserId != mxid) - creationEvent.InitialState.Add(new StateEvent { - Type = "m.room.member", - StateKey = mxid, - TypedContent = new RoomMemberEventContent { - Membership = "invite", - Reason = "Automatically invited at room creation time." - } - }); - } - - private string GetStateFriendlyName(string key) => key switch { - "m.room.history_visibility" => "History visibility", - "m.room.guest_access" => "Guest access", - "m.room.join_rules" => "Join rules", - "m.room.server_acl" => "Server ACL", - "m.room.avatar" => "Avatar", - _ => key - }; - - private string GetPermissionFriendlyName(string key) => key switch { - "m.reaction" => "Send reaction", - "m.room.avatar" => "Change room icon", - "m.room.canonical_alias" => "Change room alias", - "m.room.encryption" => "Enable encryption", - "m.room.history_visibility" => "Change history visibility", - "m.room.name" => "Change room name", - "m.room.power_levels" => "Change power levels", - "m.room.tombstone" => "Upgrade room", - "m.room.topic" => "Change room topic", - "m.room.pinned_events" => "Pin events", - "m.room.server_acl" => "Change server ACLs", - _ => key - }; - -} diff --git a/MatrixRoomUtils.Web/Pages/Rooms/Index.razor b/MatrixRoomUtils.Web/Pages/Rooms/Index.razor deleted file mode 100644 index 6cabe82..0000000 --- a/MatrixRoomUtils.Web/Pages/Rooms/Index.razor +++ /dev/null @@ -1,250 +0,0 @@ -@page "/Rooms" -@using LibMatrix.Filters -@using LibMatrix.Helpers -@using LibMatrix.Extensions -@using LibMatrix.Responses -@using System.Collections.ObjectModel -@using System.Diagnostics -@using ArcaneLibs.Extensions -@using MatrixRoomUtils.Abstractions -@inject ILogger logger -

Room list

- -

@Status

-

@Status2

- -Create new room - - - -@code { - private ObservableCollection Rooms { get; } = new(); - private UserProfileResponse GlobalProfile { get; set; } - - private AuthenticatedHomeserverGeneric? Homeserver { get; set; } - - private static SyncFilter filter = new() { - AccountData = new SyncFilter.EventFilter { - NotTypes = new List { "*" }, - Limit = 1 - }, - Presence = new SyncFilter.EventFilter { - NotTypes = new List { "*" }, - Limit = 1 - }, - Room = new SyncFilter.RoomFilter { - AccountData = new SyncFilter.RoomFilter.StateFilter { - NotTypes = new List { "*" }, - Limit = 1 - }, - Ephemeral = new SyncFilter.RoomFilter.StateFilter { - NotTypes = new List { "*" }, - Limit = 1 - }, - State = new SyncFilter.RoomFilter.StateFilter { - Types = new List { - "m.room.create", - "m.room.name", - "m.room.avatar", - "org.matrix.mjolnir.shortcode", - "m.room.power_levels", - } - }, - Timeline = new SyncFilter.RoomFilter.StateFilter { - NotTypes = new List { "*" }, - Limit = 1 - } - } - }; - - // private static SyncFilter profileUpdateFilter = new() { - // AccountData = new SyncFilter.EventFilter { - // NotTypes = new List { "*" }, - // Limit = 1 - // }, - // Presence = new SyncFilter.EventFilter { - // NotTypes = new List { "*" }, - // Limit = 1 - // }, - // Room = new SyncFilter.RoomFilter { - // AccountData = new SyncFilter.RoomFilter.StateFilter { - // NotTypes = new List { "*" }, - // Limit = 1 - // }, - // Ephemeral = new SyncFilter.RoomFilter.StateFilter { - // NotTypes = new List { "*" }, - // Limit = 1 - // }, - // State = new SyncFilter.RoomFilter.StateFilter { - // Types = new List { - // "m.room.member" - // }, - // Senders = new() - // }, - // Timeline = new SyncFilter.RoomFilter.StateFilter { - // NotTypes = new List { "*" }, - // Limit = 1 - // } - // } - // }; - - private SyncHelper syncHelper; - - // SyncHelper profileSyncHelper; - - protected override async Task OnInitializedAsync() { - Homeserver = await MRUStorage.GetCurrentSessionOrNavigate(); - if (Homeserver is null) return; - var rooms = await Homeserver.GetJoinedRooms(); - // SemaphoreSlim _semaphore = new(160, 160); - - var roomTasks = rooms.Select(async room => { - RoomInfo ri; - // await _semaphore.WaitAsync(); - ri = new() { Room = room }; - await Task.WhenAll((filter.Room?.State?.Types ?? []).Select(x => ri.GetStateEvent(x))); - return ri; - }).ToAsyncEnumerable(); - - await foreach (var room in roomTasks) { - Rooms.Add(room); - StateHasChanged(); - // await Task.Delay(50); - // _semaphore.Release(); - } - - if (rooms.Count >= 150) RenderContents = true; - - GlobalProfile = await Homeserver.GetProfileAsync(Homeserver.WhoAmI.UserId); - syncHelper = new SyncHelper(Homeserver, logger) { - Timeout = 30000, - Filter = filter, - MinimumDelay = TimeSpan.FromMilliseconds(5000) - }; - // profileSyncHelper = new SyncHelper(Homeserver, logger) { - // Timeout = 10000, - // Filter = profileUpdateFilter, - // MinimumDelay = TimeSpan.FromMilliseconds(5000) - // }; - // profileUpdateFilter.Room.State.Senders.Add(Homeserver.WhoAmI.UserId); - - RunSyncLoop(syncHelper); - // RunSyncLoop(profileSyncHelper); - RunQueueProcessor(); - - await base.OnInitializedAsync(); - } - - private async Task RunQueueProcessor() { - var renderTimeSw = Stopwatch.StartNew(); - var isInitialSync = true; - while (true) { - try { - while (queue.Count == 0) { - Console.WriteLine("Queue is empty, waiting..."); - await Task.Delay(isInitialSync ? 100 : 2500); - } - - Console.WriteLine($"Queue no longer empty after {renderTimeSw.Elapsed}!"); - - int maxUpdates = 10; - isInitialSync = false; - while (maxUpdates-- > 0 && queue.TryDequeue(out var queueEntry)) { - var (roomId, roomData) = queueEntry; - Console.WriteLine($"Dequeued room {roomId}"); - RoomInfo room; - - if (Rooms.Any(x => x.Room.RoomId == roomId)) { - room = Rooms.First(x => x.Room.RoomId == roomId); - Console.WriteLine($"QueueWorker: {roomId} already known with {room.StateEvents?.Count ?? 0} state events"); - } - else { - Console.WriteLine($"QueueWorker: encountered new room {roomId}!"); - room = new RoomInfo() { - Room = Homeserver.GetRoom(roomId) - }; - Rooms.Add(room); - } - - if (room.StateEvents is null) { - Console.WriteLine($"QueueWorker: {roomId} does not have state events on record?"); - throw new InvalidDataException("Somehow this is null???"); - } - - if (roomData.State?.Events is { Count: > 0 }) - room.StateEvents.MergeStateEventLists(roomData.State.Events); - else { - Console.WriteLine($"QueueWorker: could not merge state for {room.Room.RoomId} as new data contains no state events!"); - } - } - Console.WriteLine($"QueueWorker: {queue.Count} entries left in queue, {maxUpdates} maxUpdates left, RenderContents: {RenderContents}"); - Status = $"Got {Rooms.Count} rooms so far! {queue.Count} entries in processing queue..."; - - RenderContents |= queue.Count == 0; - await Task.Delay(Rooms.Count); - } - catch (Exception e) { - Console.WriteLine("QueueWorker exception: " + e); - } - } - } - - private bool RenderContents { get; set; } = false; - - private string _status; - - public string Status { - get => _status; - set { - _status = value; - StateHasChanged(); - } - } - - private string _status2; - - public string Status2 { - get => _status2; - set { - _status2 = value; - StateHasChanged(); - } - } - - private Queue> queue = new(); - - private async Task RunSyncLoop(SyncHelper syncHelper) { - Status = "Initial syncing..."; - Console.WriteLine("starting sync"); - - var syncs = syncHelper.EnumerateSyncAsync(); - await foreach (var sync in syncs) { - Console.WriteLine("trying sync"); - if (sync is null) continue; - - Status = $"Got sync with {sync.Rooms?.Join?.Count ?? 0} room updates, next batch: {sync.NextBatch}!"; - if (sync?.Rooms?.Join != null) - foreach (var joinedRoom in sync.Rooms.Join) - if ( /*joinedRoom.Value.AccountData?.Events?.Count > 0 ||*/ joinedRoom.Value.State?.Events?.Count > 0) { - joinedRoom.Value.State.Events.RemoveAll(x => x.Type == "m.room.member" && x.StateKey != Homeserver.WhoAmI?.UserId); - // We can't trust servers to give us what we ask for, and this ruins performance - // Thanks, Conduit. - joinedRoom.Value.State.Events.RemoveAll(x => filter.Room?.State?.Types?.Contains(x.Type) == false); - if (filter.Room?.State?.NotSenders?.Any() ?? false) - joinedRoom.Value.State.Events.RemoveAll(x => filter.Room?.State?.NotSenders?.Contains(x.Sender) ?? false); - - queue.Enqueue(joinedRoom); - } - if (sync.Rooms.Leave is {Count: > 0}) - foreach (var leftRoom in sync.Rooms.Leave) - if (Rooms.Any(x => x.Room.RoomId == leftRoom.Key)) - Rooms.Remove(Rooms.First(x => x.Room.RoomId == leftRoom.Key)); - - Status = $"Got {Rooms.Count} rooms so far! {queue.Count} entries in processing queue... " + - $"{sync?.Rooms?.Join?.Count ?? 0} new updates!"; - - Status2 = $"Next batch: {sync.NextBatch}"; - } - } - -} \ No newline at end of file diff --git a/MatrixRoomUtils.Web/Pages/Rooms/PolicyList.razor b/MatrixRoomUtils.Web/Pages/Rooms/PolicyList.razor deleted file mode 100644 index b89d59c..0000000 --- a/MatrixRoomUtils.Web/Pages/Rooms/PolicyList.razor +++ /dev/null @@ -1,267 +0,0 @@ -@page "/Rooms/{RoomId}/Policies" -@using LibMatrix -@using ArcaneLibs.Extensions -@using LibMatrix.EventTypes.Spec.State -@using LibMatrix.EventTypes.Spec.State.Policy -@using System.Diagnostics -@using LibMatrix.RoomTypes -@using System.Collections.Frozen -@using System.Reflection -@using ArcaneLibs.Attributes -@using LibMatrix.EventTypes - -@using MatrixRoomUtils.Web.Shared.PolicyEditorComponents - -

Policy list editor - Editing @RoomId

-
-@* *@ -Create new policy - -@if (Loading) { -

Loading...

-} -else if (PolicyEventsByType is not { Count: > 0 }) { -

No policies yet

-} -else { - @foreach (var (type, value) in PolicyEventsByType) { -

- @(GetValidPolicyEventsByType(type).Count) active, - @(GetInvalidPolicyEventsByType(type).Count) invalid - (@value.Count total) - @(GetPolicyTypeName(type).ToLower()) -

- } - - @foreach (var type in KnownPolicyTypes.OrderByDescending(t => GetPolicyEventsByType(t).Count)) { -
- - - @($"{GetPolicyTypeName(type)}: {GetPolicyEventsByType(type).Count} policies") - -
- - - @{ - var policies = GetValidPolicyEventsByType(type); - var invalidPolicies = GetInvalidPolicyEventsByType(type); - // enumerate all properties with friendly name - var props = type.GetProperties(BindingFlags.Public | BindingFlags.Instance) - .Where(x => (x.GetFriendlyNameOrNull() ?? x.GetJsonPropertyNameOrNull()) is not null) - .Where(x => x.GetCustomAttribute() is null) - .ToFrozenSet(); - var propNames = props.Select(x => x.GetFriendlyNameOrNull() ?? x.GetJsonPropertyName()!).ToFrozenSet(); - } - - - @foreach (var name in propNames) { - - } - - - - - @foreach (var policy in policies.OrderBy(x => x.RawContent?["entity"]?.GetValue())) { - - @{ - var typedContent = policy.TypedContent!; - var proxySafeProps = typedContent.GetType().GetProperties(BindingFlags.Public | BindingFlags.Instance) - .Where(x => props.Any(y => y.Name == x.Name)) - .ToFrozenSet(); - Console.WriteLine($"{proxySafeProps?.Count} proxy safe props found in {policies.FirstOrDefault()?.TypedContent?.GetType()}"); - } - @foreach (var prop in proxySafeProps ?? Enumerable.Empty()) { - - } - - - } - -
@nameActions
@prop.GetGetMethod()?.Invoke(typedContent, null) -
- @if (PowerLevels.UserHasStatePermission(Homeserver.WhoAmI.UserId, policy.Type)) { - Edit - Remove - @if (policy.IsLegacyType) { - Update policy type - } - } -
-
-
- - - @("Invalid " + GetPolicyTypeName(type).ToLower()) - - - - - - - - - - - @foreach (var policy in invalidPolicies) { - - - - - } - -
State keyJson contents
@policy.StateKey - 
@policy.RawContent.ToJson(true, false)
-
-
-
- } -} - -@if (CurrentlyEditingEvent is not null) { - -} - -@code { - -#if DEBUG - private const bool Debug = true; -#else - private const bool Debug = false; -#endif - - private bool Loading { get; set; } = true; - //get room list - // - sync withroom list filter - // Type = support.feline.msc3784 - //support.feline.policy.lists.msc.v1 - - [Parameter] - public string RoomId { get; set; } = null!; - - private bool _enableAvatars; - private StateEventResponse? _currentlyEditingEvent; - - // static readonly Dictionary Avatars = new(); - // static readonly Dictionary Servers = new(); - - // private static List PolicyEvents { get; set; } = new(); - private Dictionary> PolicyEventsByType { get; set; } = new(); - - private StateEventResponse? CurrentlyEditingEvent { - get => _currentlyEditingEvent; - set { - _currentlyEditingEvent = value; - StateHasChanged(); - } - } - - // public bool EnableAvatars { - // get => _enableAvatars; - // set { - // _enableAvatars = value; - // if (value) GetAllAvatars(); - // } - // } - - private AuthenticatedHomeserverGeneric Homeserver { get; set; } - private GenericRoom Room { get; set; } - private RoomPowerLevelEventContent PowerLevels { get; set; } - - protected override async Task OnInitializedAsync() { - var sw = Stopwatch.StartNew(); - await base.OnInitializedAsync(); - Homeserver = (await MRUStorage.GetCurrentSessionOrNavigate())!; - if (Homeserver is null) return; - Room = Homeserver.GetRoom(RoomId!); - PowerLevels = (await Room.GetPowerLevelsAsync())!; - await LoadStatesAsync(); - Console.WriteLine($"Policy list editor initialized in {sw.Elapsed}!"); - } - - private async Task LoadStatesAsync() { - Loading = true; - var states = Room.GetFullStateAsync(); - PolicyEventsByType.Clear(); - await foreach (var state in states) { - if (state is null) continue; - if (!state.MappedType.IsAssignableTo(typeof(PolicyRuleEventContent))) continue; - if (!PolicyEventsByType.ContainsKey(state.MappedType)) PolicyEventsByType.Add(state.MappedType, new()); - PolicyEventsByType[state.MappedType].Add(state); - } - - Loading = false; - StateHasChanged(); - } - - // private async Task GetAllAvatars() { - // // if (!_enableAvatars) return; - // Console.WriteLine("Getting avatars..."); - // var users = GetValidPolicyEventsByType(typeof(UserPolicyRuleEventContent)).Select(x => x.RawContent!["entity"]!.GetValue()).Where(x => x.Contains(':') && !x.Contains("*")).ToList(); - // Console.WriteLine($"Got {users.Count} users!"); - // var usersByHomeServer = users.GroupBy(x => x!.Split(':')[1]).ToDictionary(x => x.Key!, x => x.ToList()); - // Console.WriteLine($"Got {usersByHomeServer.Count} homeservers!"); - // var homeserverTasks = usersByHomeServer.Keys.Select(x => RemoteHomeserver.TryCreate(x)).ToAsyncEnumerable(); - // await foreach (var server in homeserverTasks) { - // if (server is null) continue; - // var profileTasks = usersByHomeServer[server.BaseUrl].Select(x => TryGetProfile(server, x)).ToList(); - // await Task.WhenAll(profileTasks); - // profileTasks.RemoveAll(x => x.Result is not { Value: { AvatarUrl: not null } }); - // foreach (var profile in profileTasks.Select(x => x.Result!.Value)) { - // // if (profile is null) continue; - // if (!string.IsNullOrWhiteSpace(profile.Value.AvatarUrl)) { - // var url = await hsResolver.ResolveMediaUri(server.BaseUrl, profile.Value.AvatarUrl); - // Avatars.TryAdd(profile.Key, url); - // } - // else Avatars.TryAdd(profile.Key, null); - // } - // - // StateHasChanged(); - // } - // } - // - // private async Task?> TryGetProfile(RemoteHomeserver server, string mxid) { - // try { - // return new KeyValuePair(mxid, await server.GetProfileAsync(mxid)); - // } - // catch { - // return null; - // } - // } - - private List GetPolicyEventsByType(Type type) => PolicyEventsByType.ContainsKey(type) ? PolicyEventsByType[type] : []; - - private List GetValidPolicyEventsByType(Type type) => GetPolicyEventsByType(type) - .Where(x => !string.IsNullOrWhiteSpace(x.RawContent?["entity"]?.GetValue())).ToList(); - - private List GetInvalidPolicyEventsByType(Type type) => GetPolicyEventsByType(type) - .Where(x => string.IsNullOrWhiteSpace(x.RawContent?["entity"]?.GetValue())).ToList(); - - private string? GetPolicyTypeNameOrNull(Type type) => type.GetFriendlyNamePluralOrNull() - ?? type.GetCustomAttributes() - .FirstOrDefault(x => !string.IsNullOrWhiteSpace(x.EventName))?.EventName; - - private string GetPolicyTypeName(Type type) => GetPolicyTypeNameOrNull(type) ?? type.Name; - - private async Task RemovePolicyAsync(StateEventResponse policyEvent) { - await Room.SendStateEventAsync(policyEvent.Type, policyEvent.StateKey, new { }); - PolicyEventsByType[policyEvent.MappedType].Remove(policyEvent); - await LoadStatesAsync(); - } - - private async Task UpdatePolicyAsync(StateEventResponse policyEvent) { - await Room.SendStateEventAsync(policyEvent.Type, policyEvent.StateKey, policyEvent.RawContent); - await LoadStatesAsync(); - } - - private async Task UpgradePolicyAsync(StateEventResponse policyEvent) { - policyEvent.RawContent["upgraded_from_type"] = policyEvent.Type; - await LoadStatesAsync(); - } - - private static FrozenSet KnownPolicyTypes = StateEvent.KnownStateEventTypes.Where(x => x.IsAssignableTo(typeof(PolicyRuleEventContent))).ToFrozenSet(); - - // event types, unnamed - private static Dictionary PolicyTypes = KnownPolicyTypes - .ToDictionary(x => x.GetCustomAttributes().First(y => !string.IsNullOrWhiteSpace(y.EventName)).EventName, x => x); - -} \ No newline at end of file diff --git a/MatrixRoomUtils.Web/Pages/Rooms/Space.razor b/MatrixRoomUtils.Web/Pages/Rooms/Space.razor deleted file mode 100644 index ce94d01..0000000 --- a/MatrixRoomUtils.Web/Pages/Rooms/Space.razor +++ /dev/null @@ -1,100 +0,0 @@ -@page "/Rooms/{RoomId}/Space" -@using LibMatrix.RoomTypes -@using ArcaneLibs.Extensions -@using LibMatrix -

Room manager - Viewing Space

- - -@foreach (var room in Rooms) { - -} - - -
-
- State list - @foreach (var stateEvent in States.OrderBy(x => x.StateKey).ThenBy(x => x.Type)) { -

@stateEvent.StateKey/@stateEvent.Type:

- 
@stateEvent.RawContent.ToJson()
- } -
- -@code { - - [Parameter] - public string RoomId { get; set; } = "invalid!!!!!!"; - - private GenericRoom? Room { get; set; } - - private StateEventResponse[] States { get; set; } = Array.Empty(); - private List Rooms { get; } = new(); - private List ServersInSpace { get; } = new(); - - protected override async Task OnInitializedAsync() { - var hs = await MRUStorage.GetCurrentSessionOrNavigate(); - if (hs is null) return; - - Room = hs.GetRoom(RoomId.Replace('~', '.')); - - var state = Room.GetFullStateAsync(); - await foreach (var stateEvent in state) { - switch (stateEvent.Type) { - case "m.space.child": { - var roomId = stateEvent.StateKey; - var room = hs.GetRoom(roomId); - if (room is not null) { - Rooms.Add(room); - } - break; - } - case "m.room.member": { - var serverName = stateEvent.StateKey.Split(':').Last(); - if (!ServersInSpace.Contains(serverName)) { - ServersInSpace.Add(serverName); - } - break; - } - } - } - await base.OnInitializedAsync(); - - // var state = await Room.GetStateAsync(""); - // if (state is not null) { - // // Console.WriteLine(state.Value.ToJson()); - // States = state.Value.Deserialize()!; - // - // foreach (var stateEvent in States) { - // if (stateEvent.Type == "m.space.child") { - // // if (stateEvent.Content.ToJson().Length < 5) return; - // var roomId = stateEvent.StateKey; - // var room = hs.GetRoom(roomId); - // if (room is not null) { - // Rooms.Add(room); - // } - // } - // else if (stateEvent.Type == "m.room.member") { - // var serverName = stateEvent.StateKey.Split(':').Last(); - // if (!ServersInSpace.Contains(serverName)) { - // ServersInSpace.Add(serverName); - // } - // } - // } - - // if(state.Value.TryGetProperty("Type", out var Type)) - // { - // } - // else - // { - // //this is fine, apprently... - // //Console.WriteLine($"Room {room.RoomId} has no Content.Type in m.room.create!"); - // } - - // await base.OnInitializedAsync(); - } - - private async Task JoinAllRooms() { - List> tasks = Rooms.Select(room => room.JoinAsync(ServersInSpace.ToArray())).ToList(); - await Task.WhenAll(tasks); - } - -} diff --git a/MatrixRoomUtils.Web/Pages/Rooms/StateEditor.razor b/MatrixRoomUtils.Web/Pages/Rooms/StateEditor.razor deleted file mode 100644 index 0e9d4f6..0000000 --- a/MatrixRoomUtils.Web/Pages/Rooms/StateEditor.razor +++ /dev/null @@ -1,144 +0,0 @@ -@page "/Rooms/{RoomId}/State/Edit" -@using ArcaneLibs.Extensions -@using LibMatrix -@inject ILocalStorageService LocalStorage -@inject NavigationManager NavigationManager -

Room state editor - Editing @RoomId

-
- -

@status

- - Show member events -
- - - @foreach (var stateEvent in FilteredEvents.Where(x => x.StateKey != "").Select(x => x.StateKey).Distinct().OrderBy(x => x)) { - - Console.WriteLine(stateEvent); - } - -
- - - @foreach (var stateEvent in FilteredEvents.Where(x => x.StateKey != shownStateKey).Select(x => x.Type).Distinct().OrderBy(x => x)) { - - } - -
- - - - - -@code { - //get room list - // - sync withroom list filter - // Type = support.feline.msc3784 - //support.feline.policy.lists.msc.v1 - - [Parameter] - public string? RoomId { get; set; } - - public List FilteredEvents { get; set; } = new(); - public List Events { get; set; } = new(); - public string status = ""; - - protected override async Task OnInitializedAsync() { - await base.OnInitializedAsync(); - var hs = await MRUStorage.GetCurrentSessionOrNavigate(); - if (hs is null) return; - RoomId = RoomId.Replace('~', '.'); - await LoadStatesAsync(); - Console.WriteLine("Policy list editor initialized!"); - } - - private DateTime _lastUpdate = DateTime.Now; - - private async Task LoadStatesAsync() { - var hs = await MRUStorage.GetCurrentSessionOrNavigate(); - - var StateLoaded = 0; - var response = (hs.GetRoom(RoomId)).GetFullStateAsync(); - await foreach (var _ev in response) { - // var e = new StateEventResponse { - // Type = _ev.Type, - // StateKey = _ev.StateKey, - // OriginServerTs = _ev.OriginServerTs, - // Content = _ev.Content - // }; - Events.Add(_ev); - if (string.IsNullOrEmpty(_ev.StateKey)) { - FilteredEvents.Add(_ev); - } - StateLoaded++; - - if (!((DateTime.Now - _lastUpdate).TotalMilliseconds > 100)) continue; - _lastUpdate = DateTime.Now; - status = $"Loaded {StateLoaded} state events"; - StateHasChanged(); - await Task.Delay(0); - } - - StateHasChanged(); - } - - private async Task RebuildFilteredData() { - status = "Rebuilding filtered data..."; - StateHasChanged(); - await Task.Delay(1); - var _FilteredEvents = Events; - if (!ShowMembershipEvents) - _FilteredEvents = _FilteredEvents.Where(x => x.Type != "m.room.member").ToList(); - - status = "Done, rerendering!"; - StateHasChanged(); - await Task.Delay(1); - FilteredEvents = _FilteredEvents; - - if (_shownType is not null) - shownEventJson = _FilteredEvents.First(x => x.Type == _shownType).RawContent.ToJson(indent: true, ignoreNull: true); - - StateHasChanged(); - } - - public struct PreRenderedStateEvent { - public string content { get; set; } - public long origin_server_ts { get; set; } - public string state_key { get; set; } - public string type { get; set; } - // public string Sender { get; set; } - // public string EventId { get; set; } - // public string UserId { get; set; } - // public string ReplacesState { get; set; } - } - - public bool ShowMembershipEvents { - get => _showMembershipEvents; - set { - _showMembershipEvents = value; - RebuildFilteredData(); - } - } - - private bool _showMembershipEvents; - private string _shownStateKey; - private string _shownType; - - private string shownStateKey { - get => _shownStateKey; - set { - _shownStateKey = value; - RebuildFilteredData(); - } - } - - private string shownType { - get => _shownType; - set { - _shownType = value; - RebuildFilteredData(); - } - } - - private string shownEventJson { get; set; } -} diff --git a/MatrixRoomUtils.Web/Pages/Rooms/StateViewer.razor b/MatrixRoomUtils.Web/Pages/Rooms/StateViewer.razor deleted file mode 100644 index 2d0e0b0..0000000 --- a/MatrixRoomUtils.Web/Pages/Rooms/StateViewer.razor +++ /dev/null @@ -1,127 +0,0 @@ -@page "/Rooms/{RoomId}/State/View" -@using ArcaneLibs.Extensions -@using LibMatrix -@inject ILocalStorageService LocalStorage -@inject NavigationManager NavigationManager -

Room state viewer - Viewing @RoomId

-
- -

@status

- - Show member events - - - - - - - - - - @foreach (var stateEvent in FilteredEvents.Where(x => x.StateKey == "").OrderBy(x => x.OriginServerTs)) { - - - - - } - -
TypeContent
@stateEvent.Type - 
@stateEvent.RawContent.ToJson()
-
- -@foreach (var group in FilteredEvents.GroupBy(x => x.StateKey).OrderBy(x => x.Key).Where(x => x.Key != "")) { -
- @group.Key - - - - - - - - - @foreach (var stateEvent in group.OrderBy(x => x.OriginServerTs)) { - - - - - } - -
TypeContent
@stateEvent.Type - 
@stateEvent.RawContent.ToJson()
-
-
-} - - - -@code { - //get room list - // - sync withroom list filter - // Type = support.feline.msc3784 - //support.feline.policy.lists.msc.v1 - - [Parameter] - public string? RoomId { get; set; } - - public List FilteredEvents { get; set; } = new(); - public List Events { get; set; } = new(); - public string status = ""; - - protected override async Task OnInitializedAsync() { - await base.OnInitializedAsync(); - var hs = await MRUStorage.GetCurrentSessionOrNavigate(); - if (hs is null) return; - await LoadStatesAsync(); - Console.WriteLine("Policy list editor initialized!"); - } - - private DateTime _lastUpdate = DateTime.Now; - - private async Task LoadStatesAsync() { - var StateLoaded = 0; - var hs = await MRUStorage.GetCurrentSessionOrNavigate(); - if (hs is null) return; - var response = (hs.GetRoom(RoomId)).GetFullStateAsync(); - await foreach (var _ev in response) { - Events.Add(_ev); - if (string.IsNullOrEmpty(_ev.StateKey)) { - FilteredEvents.Add(_ev); - } - StateLoaded++; - - if (!((DateTime.Now - _lastUpdate).TotalMilliseconds > 100)) continue; - _lastUpdate = DateTime.Now; - status = $"Loaded {StateLoaded} state events"; - StateHasChanged(); - await Task.Delay(0); - } - - StateHasChanged(); - } - - private async Task RebuildFilteredData() { - status = "Rebuilding filtered data..."; - StateHasChanged(); - await Task.Delay(1); - var _FilteredEvents = Events; - if (!ShowMembershipEvents) - _FilteredEvents = _FilteredEvents.Where(x => x.Type != "m.room.member").ToList(); - - status = "Done, rerendering!"; - StateHasChanged(); - await Task.Delay(1); - FilteredEvents = _FilteredEvents; - StateHasChanged(); - } - - public bool ShowMembershipEvents { - get => _showMembershipEvents; - set { - _showMembershipEvents = value; - RebuildFilteredData(); - } - } - - private bool _showMembershipEvents; -} diff --git a/MatrixRoomUtils.Web/Pages/Rooms/Timeline.razor b/MatrixRoomUtils.Web/Pages/Rooms/Timeline.razor deleted file mode 100644 index 01bf555..0000000 --- a/MatrixRoomUtils.Web/Pages/Rooms/Timeline.razor +++ /dev/null @@ -1,60 +0,0 @@ -@page "/Rooms/{RoomId}/Timeline" -@using MatrixRoomUtils.Web.Shared.TimelineComponents -@using LibMatrix -@using LibMatrix.EventTypes.Spec -@using LibMatrix.EventTypes.Spec.State -@using LibMatrix.Homeservers -

RoomManagerTimeline

-
-

Loaded @Events.Count events...

- -@foreach (var evt in Events) { -
- - -
-} - -@code { - - [Parameter] - public string RoomId { get; set; } - - private List Messages { get; } = new(); - private List Events { get; } = new(); - - private AuthenticatedHomeserverGeneric? Homeserver { get; set; } - - protected override async Task OnInitializedAsync() { - Console.WriteLine("RoomId: " + RoomId); - Homeserver = await MRUStorage.GetCurrentSessionOrNavigate(); - if (Homeserver is null) return; - var room = Homeserver.GetRoom(RoomId); - MessagesResponse? msgs = null; - do { - msgs = await room.GetMessagesAsync(limit: 1000, from: msgs?.End, dir: "b"); - Messages.Add(msgs); - Console.WriteLine($"Got {msgs.Chunk.Count} messages"); - msgs.Chunk.Reverse(); - Events.InsertRange(0, msgs.Chunk); - } while (msgs.End is not null); - - - await base.OnInitializedAsync(); - } - - private StateEventResponse GetProfileEventBefore(StateEventResponse Event) => Events.TakeWhile(x => x != Event).Last(e => e.Type == "m.room.member" && e.StateKey == Event.Sender); - - private Type ComponentType(StateEvent Event) => Event.TypedContent switch { - RoomCanonicalAliasEventContent => typeof(TimelineCanonicalAliasItem), - RoomHistoryVisibilityEventContent => typeof(TimelineHistoryVisibilityItem), - RoomTopicEventContent => typeof(TimelineRoomTopicItem), - RoomMemberEventContent => typeof(TimelineMemberItem), - RoomMessageEventContent => typeof(TimelineMessageItem), - RoomCreateEventContent => typeof(TimelineRoomCreateItem), - RoomNameEventContent => typeof(TimelineRoomNameItem), - _ => typeof(TimelineUnknownItem) - }; - -} diff --git a/MatrixRoomUtils.Web/Pages/ServerInfo.razor b/MatrixRoomUtils.Web/Pages/ServerInfo.razor deleted file mode 100644 index 71a1980..0000000 --- a/MatrixRoomUtils.Web/Pages/ServerInfo.razor +++ /dev/null @@ -1,235 +0,0 @@ -@page "/ServerInfo/{Homeserver}" -@using LibMatrix.Homeservers -@using LibMatrix.Responses -@using ArcaneLibs.Extensions -

ServerInfo

-
-@if (ServerVersionResponse is not null) { -

Server version: @ServerVersionResponse.Server.Name @ServerVersionResponse.Server.Version

- 
@ServerVersionResponse?.ToJson(ignoreNull: true)
-
-} -@if (ClientVersionsResponse is not null) { -

Client versions:

-
- JSON data - 
@ClientVersionsResponse?.ToJson(ignoreNull: true)
-
- Spec versions - - - - - - - @foreach (var (version, info) in ClientVersions) { - - - - - - } - - @foreach (var version in ClientVersionsResponse.Versions) { - if (!ClientVersions.ContainsKey(version)) { - - - - - - } - } -
VersionRelease date
@(ClientVersionsResponse.Versions.Contains(version) ? "\u2714" : "\u274c")@info.Name@info.Released
@("\u2714")Unknown version: @version
- Unstable features - - - - - - - @* @foreach (var (version, info) in ClientVersions) { *@ - @* *@ - @* *@ - @* *@ - @* *@ - @* *@ - @* *@ - @* } *@ - - @foreach (var version in ClientVersionsResponse.UnstableFeatures) { - if (!ClientVersions.ContainsKey(version.Key)) { - - - - - - } - } -
SupportedEnabledName
@("\u2714")@(ClientVersionsResponse.Versions.Contains(version) ? "\u2714" : "\u274c")@info.Released
@("\u2714")@(version.Value ? "\u2714" : "\u274c")@version.Key
-} - - -@code { - - [Parameter] - public string? Homeserver { get; set; } - - public ServerVersionResponse? ServerVersionResponse { get; set; } - public ClientVersionsResponse? ClientVersionsResponse { get; set; } - - protected override async Task OnParametersSetAsync() { - if (Homeserver is not null) { - var rhs = await hsProvider.GetRemoteHomeserver(Homeserver); - ServerVersionResponse = await (rhs.FederationClient?.GetServerVersionAsync() ?? Task.FromResult(null)); - ClientVersionsResponse = await rhs.GetClientVersionsAsync(); - } - base.OnParametersSetAsync(); - } - - private class ClientVersionInfo { - public string Name { get; set; } - public string SpecUrl { get; set; } - public DateTime Released { get; set; } - } - - private Dictionary ClientVersions = new() { - { - "legacy", - new() { - Name = "Legacy: Last draft before formal release of r0.0.0", - Released = DateTime.Parse("2014-07-01 00:00:00 +0000"), - SpecUrl = "https://spec.matrix.org/legacy/legacy/" - } - }, - { - "r0.0.0", - new() { - Name = "r0.0.0: Initial release: media repo, sync v2", - Released = DateTime.Parse("2014-07-01 00:00:00 +0000"), - SpecUrl = "https://spec.matrix.org/legacy/r0.0.0/" - } - }, - { - "r0.0.1", - new() { - Name = "r0.0.1: User-interactive authentication, groups, read receipts, presence", - Released = DateTime.Parse("2014-07-01 00:00:00 +0000"), - SpecUrl = "https://spec.matrix.org/legacy/r0.0.1/" - } - }, - { - "r0.1.0", - new() { - Name = "r0.1.0: Device management, account data, push rules, VoIP", - Released = DateTime.Parse("2014-07-01 00:00:00 +0000"), - SpecUrl = "https://spec.matrix.org/legacy/r0.1.0/" - } - }, - { - "r0.2.0", - new() { - Name = "r0.2.0: Clarifications", - Released = DateTime.Parse("2014-07-01 00:00:00 +0000"), - SpecUrl = "https://spec.matrix.org/legacy/client_server/r0.2.0.html" - } - }, - { - "r0.3.0", - new() { - Name = "r0.3.0: Device management", - Released = DateTime.Parse("2014-07-01 00:00:00 +0000"), - SpecUrl = "https://spec.matrix.org/legacy/client_server/r0.3.0.html" - } - }, - { - "r0.4.0", - new() { - Name = "r0.4.0: Room directory", - Released = DateTime.Parse("2014-07-01 00:00:00 +0000"), - SpecUrl = "https://spec.matrix.org/legacy/r0.4.0/" - } - }, - { - "r0.5.0", - new() { - Name = "r0.5.0: Push rules, VoIP, groups, read receipts, presence", - Released = DateTime.Parse("2014-07-01 00:00:00 +0000"), - SpecUrl = "https://spec.matrix.org/legacy/r0.5.0/" - } - }, - { - "r0.6.0", - new() { - Name = "r0.6.0: Unbinding 3PIDs, clean up bindings from register", - Released = DateTime.Parse("2014-07-01 00:00:00 +0000"), - SpecUrl = "https://spec.matrix.org/legacy/r0.6.0/" - } - }, - { - "r0.6.1", - new(){ - Name = "r0.6.1: Moderation policies, better alias handling", - Released = DateTime.Parse("2014-07-01 00:00:00 +0000"), - SpecUrl = "https://spec.matrix.org/legacy/r0.6.1/" - } - }, - { - "v1.1", - new() { - Name = "v1.1: Key backup, knocking", - Released = DateTime.Parse("2021-11-09 00:00:00 +0000"), - SpecUrl = "https://spec.matrix.org/v1.1/" - } - }, { - "v1.2", - new() { - Name = "v1.2: ", - Released = DateTime.Parse("2022-02-02 00:00:00 +0000"), - SpecUrl = "https://spec.matrix.org/v1.2/" - } - }, { - "v1.3", - new() { - Name = "v1.3: ", - Released = DateTime.Parse("2022-06-15 00:00:00 +0100"), - SpecUrl = "https://spec.matrix.org/v1.3/" - } - }, { - "v1.4", - new() { - Name = "v1.4: ", - Released = DateTime.Parse("2022-09-29 00:00:00 +0100"), - SpecUrl = "https://spec.matrix.org/v1.4/" - } - }, { - "v1.5", - new() { - Name = "v1.5: ", - Released = DateTime.Parse("2022-11-17 08:22:11 -0700"), - SpecUrl = "https://spec.matrix.org/v1.5/" - } - }, { - "v1.6", - new () { - Name = "v1.6: ", - Released = DateTime.Parse("2023-02-14 08:25:40 -0700"), - SpecUrl = "https://spec.matrix.org/v1.6" - } - }, { - "v1.7", - new () { - Name = "v1.7: ", - Released = DateTime.Parse("2023-05-25 09:47:21 -0600"), - SpecUrl = "https://spec.matrix.org/v1.7" - } - }, { - "v1.8", - new () { - Name = "v1.8: Room version 11", - Released = DateTime.Parse("2023-08-23 09:23:53 -0600"), - SpecUrl = "https://spec.matrix.org/v1.8" - } - } - }; - -} \ No newline at end of file diff --git a/MatrixRoomUtils.Web/Pages/Tools/CopyPowerlevel.razor b/MatrixRoomUtils.Web/Pages/Tools/CopyPowerlevel.razor deleted file mode 100644 index bcbc974..0000000 --- a/MatrixRoomUtils.Web/Pages/Tools/CopyPowerlevel.razor +++ /dev/null @@ -1,84 +0,0 @@ -@page "/CopyPowerlevel" -@using System.Diagnostics -@using ArcaneLibs.Extensions -@using LibMatrix -@using LibMatrix.EventTypes.Spec.State -@using LibMatrix.Homeservers -@using LibMatrix.RoomTypes -

Copy powerlevel

-
- -

Users:

-@foreach (var hs in hss) { -

@hs.WhoAmI.UserId

-} - -
-Execute -
-@foreach (var line in Enumerable.Reverse(log)) { -

@line

-} - -@code { - private List log { get; set; } = new(); - List hss { get; set; } = new(); - - protected override async Task OnInitializedAsync() { - var hs = await MRUStorage.GetCurrentSessionOrNavigate(); - if (hs is null) return; - var sessions = await MRUStorage.GetAllTokens(); - foreach (var userAuth in sessions) { - var session = await MRUStorage.GetSession(userAuth); - if (session is not null) { - hss.Add(session); - StateHasChanged(); - } - } - - StateHasChanged(); - Console.WriteLine("Rerendered!"); - await base.OnInitializedAsync(); - } - - private async Task Execute() { - foreach (var hs in hss) { - var rooms = await hs.GetJoinedRooms(); - var tasks = rooms.Select(x=>Execute(hs, x)).ToAsyncEnumerable(); - await foreach (var a in tasks) { - if (!string.IsNullOrWhiteSpace(a)) { - log.Add(a); - StateHasChanged(); - } - } - } - } - - private async Task Execute(AuthenticatedHomeserverGeneric hs, GenericRoom room) { - try { - var pls = await room.GetPowerLevelsAsync(); - // if (pls.GetUserPowerLevel(hs.WhoAmI.UserId) == pls.UsersDefault) return "I am default PL in " + room.RoomId; - if (!pls.UserHasStatePermission(hs.WhoAmI.UserId, RoomPowerLevelEventContent.EventId)) return "I do not have permission to send PL in " + room.RoomId; - foreach (var ahs in hss) { - if (pls.GetUserPowerLevel(hs.WhoAmI.UserId) == pls.GetUserPowerLevel(ahs.WhoAmI.UserId)) { - log.Add("I am same PL in " + room.RoomId); - continue; - } - - pls.SetUserPowerLevel(ahs.WhoAmI.UserId, pls.GetUserPowerLevel(hs.WhoAmI.UserId)); - await room.SendStateEventAsync(RoomPowerLevelEventContent.EventId, pls); - log.Add($"Updated powerlevel of {room.RoomId} to {pls.GetUserPowerLevel(ahs.WhoAmI.UserId)}"); - } - - } - catch (MatrixException e) { - return $"Failed to update PLs in {room.RoomId}: {e.Message}"; - } - catch (Exception e) { - return $"Failed to update PLs in {room.RoomId}: {e.Message}"; - } - StateHasChanged(); - return ""; - } - -} \ No newline at end of file diff --git a/MatrixRoomUtils.Web/Pages/Tools/KnownHomeserverList.razor b/MatrixRoomUtils.Web/Pages/Tools/KnownHomeserverList.razor deleted file mode 100644 index dbf2f5f..0000000 --- a/MatrixRoomUtils.Web/Pages/Tools/KnownHomeserverList.razor +++ /dev/null @@ -1,54 +0,0 @@ -@page "/KnownHomeserverList" -@using System.Diagnostics -@using ArcaneLibs.Extensions -@using LibMatrix.Homeservers -@using LibMatrix.RoomTypes -

Known Homeserver List

-
- -@if (!IsFinished) { -

- Loading... -

-} - -@foreach (var (homeserver, members) in counts.OrderByDescending(x => x.Value)) { -

@homeserver - @members

-} -
- -@code { - Dictionary> homeservers { get; set; } = new(); - Dictionary counts { get; set; } = new(); - // List Homeservers = new(); - bool IsFinished { get; set; } - // HomeserverInfoQueryProgress QueryProgress { get; set; } = new(); - AuthenticatedHomeserverGeneric? hs { get; set; } - - protected override async Task OnInitializedAsync() { - hs = await MRUStorage.GetCurrentSessionOrNavigate(); - if (hs is null) return; - var fetchTasks = (await hs.GetJoinedRooms()).Select(x=>x.GetMembersByHomeserverAsync()).ToAsyncEnumerable(); - await foreach (var result in fetchTasks) { - foreach (var (resHomeserver, resMembers) in result) { - if (!homeservers.TryAdd(resHomeserver, resMembers)) { - homeservers[resHomeserver].AddRange(resMembers); - } - counts[resHomeserver] = homeservers[resHomeserver].Count; - } - // StateHasChanged(); - // await Task.Delay(250); - } - - foreach (var resHomeserver in homeservers.Keys) { - homeservers[resHomeserver] = homeservers[resHomeserver].Distinct().ToList(); - counts[resHomeserver] = homeservers[resHomeserver].Count; - } - - IsFinished = true; - StateHasChanged(); - Console.WriteLine("Rerendered!"); - await base.OnInitializedAsync(); - } - -} \ No newline at end of file diff --git a/MatrixRoomUtils.Web/Pages/Tools/MassJoinRoom.razor b/MatrixRoomUtils.Web/Pages/Tools/MassJoinRoom.razor deleted file mode 100644 index 816b7db..0000000 --- a/MatrixRoomUtils.Web/Pages/Tools/MassJoinRoom.razor +++ /dev/null @@ -1,110 +0,0 @@ -@page "/MassRoomJoin" -@using System.Diagnostics -@using ArcaneLibs.Extensions -@using LibMatrix -@using LibMatrix.EventTypes.Spec.State -@using LibMatrix.Homeservers -@using LibMatrix.RoomTypes -

Mass join room

-
-

Room:

- - -

Users:

-@foreach (var hs in hss) { -

@hs.WhoAmI.UserId

-} - -
-Execute -
-@foreach (var line in Enumerable.Reverse(log)) { -

@line

-} - -@code { - private List log { get; set; } = new(); - List hss { get; set; } = new(); - string roomId { get; set; } - - protected override async Task OnInitializedAsync() { - var hs = await MRUStorage.GetCurrentSessionOrNavigate(); - if (hs is null) return; - var sessions = await MRUStorage.GetAllTokens(); - foreach (var userAuth in sessions) { - var session = await MRUStorage.GetSession(userAuth); - if (session is not null) { - hss.Add(session); - StateHasChanged(); - } - } - - StateHasChanged(); - Console.WriteLine("Rerendered!"); - await base.OnInitializedAsync(); - } - - private async Task Execute() { - // foreach (var hs in hss) { - // var rooms = await hs.GetJoinedRooms(); - var tasks = hss.Select(ExecuteInvite).ToAsyncEnumerable(); - await foreach (var a in tasks) { - if (!string.IsNullOrWhiteSpace(a)) { - log.Add(a); - StateHasChanged(); - } - } - tasks = hss.Select(ExecuteJoin).ToAsyncEnumerable(); - await foreach (var a in tasks) { - if (!string.IsNullOrWhiteSpace(a)) { - log.Add(a); - StateHasChanged(); - } - } - // } - } - - private async Task ExecuteInvite(AuthenticatedHomeserverGeneric hs) { - var room = hs.GetRoom(roomId); - try { - try { - var joinRule = await room.GetJoinRuleAsync(); - if (joinRule.JoinRule == RoomJoinRulesEventContent.JoinRules.Public) return "Room is public, no invite needed"; - } - catch { } - var pls = await room.GetPowerLevelsAsync(); - if (pls.GetUserPowerLevel(hs.WhoAmI.UserId) < pls.Invite) return "I do not have permission to send invite in " + room.RoomId; - await room.InviteUsersAsync(hss.Select(x => x.WhoAmI.UserId).ToList()); - log.Add($"Invited to {room.RoomId} to {pls.GetUserPowerLevel(hs.WhoAmI.UserId)}"); - } - catch (MatrixException e) { - return $"Failed to invite in {room.RoomId}: {e.Message}"; - } - catch (Exception e) { - return $"Failed to invite in {room.RoomId}: {e.Message}"; - } - StateHasChanged(); - return ""; - } - - private async Task ExecuteJoin(AuthenticatedHomeserverGeneric hs) { - var room = hs.GetRoom(roomId); - try { - try { - var mse = await room.GetStateOrNullAsync(RoomMemberEventContent.EventId, hs.WhoAmI.UserId); - if (mse?.Membership == "join") return $"User {hs.WhoAmI.UserId} already in room"; - } - catch { } - await room.JoinAsync(); - } - catch (MatrixException e) { - return $"Failed to join {hs.WhoAmI.UserId} to {room.RoomId}: {e.Message}"; - } - catch (Exception e) { - return $"Failed to join {hs.WhoAmI.UserId} to {room.RoomId}: {e.Message}"; - } - StateHasChanged(); - return ""; - } - -} \ No newline at end of file diff --git a/MatrixRoomUtils.Web/Pages/Tools/MediaLocator.razor b/MatrixRoomUtils.Web/Pages/Tools/MediaLocator.razor deleted file mode 100644 index 20aa639..0000000 --- a/MatrixRoomUtils.Web/Pages/Tools/MediaLocator.razor +++ /dev/null @@ -1,111 +0,0 @@ -@page "/MediaLocator" -@using LibMatrix.Homeservers -@inject HttpClient Http -

Media locator

-
- -This is going to expose your IP address to all these homeservers! -
- Checked homeserver list (@homeservers.Count entries) -
    - @foreach (var hs in homeservers) { -
  • @hs
    • - } -
-
- -
-MXC URL: - - - -@if (successResults.Count > 0) { -

Successes

-
    - @foreach (var result in successResults) { -
  • @result
    • - } -
-} - -@if (errorResults.Count > 0) { -

Errors

-
    - @foreach (var result in errorResults) { -
  • @result
    • - } -
-} - - -@code { - string mxcUrl { get; set; } - readonly List successResults = new(); - readonly List errorResults = new(); - readonly List homeservers = new(); - - protected override async Task OnInitializedAsync() { - await base.OnInitializedAsync(); - homeservers.AddRange(new[] { - "matrix.org", - "feline.support", - "rory.gay", - "the-apothecary.club", - "envs.net", - "projectsegfau.lt" - }); - } - - Task executeSearch() { - var sem = new SemaphoreSlim(128, 128); - homeservers.ForEach(async hs => { - await sem.WaitAsync(); - var httpClient = new HttpClient { BaseAddress = new Uri(hs) }; - httpClient.Timeout = TimeSpan.FromSeconds(5); - var rmu = mxcUrl.Replace("mxc://", $"{hs}/_matrix/media/v3/download/"); - try { - var res = await httpClient.SendAsync(new HttpRequestMessage(HttpMethod.Head, rmu)); - if (res.IsSuccessStatusCode) { - successResults.Add($"{hs}: found - {res.Content.Headers.ContentLength} bytes"); - StateHasChanged(); - return; - } - errorResults.Add($"Error: {hs} - {res.StatusCode}\n" + await res.Content.ReadAsStringAsync()); - } - catch (Exception e) { - errorResults.Add($"Error: {e}"); - } - finally { - sem.Release(); - } - StateHasChanged(); - }); - return Task.CompletedTask; - } - - async Task addMoreHomeservers() { - var res = await Http.GetAsync("/homeservers.txt"); - var content = await res.Content.ReadAsStringAsync(); - homeservers.Clear(); - var lines = content.Split("\n"); - - var rhs = new RemoteHomeserver("rory.gay"); - var sem = new SemaphoreSlim(128, 128); - lines.ToList().ForEach(async line => { - await sem.WaitAsync(); - try { - homeservers.Add((await hsResolver.ResolveHomeserverFromWellKnown(line)).Client); - StateHasChanged(); - } - catch (Exception e) { - Console.WriteLine(e); - } - finally { - sem.Release(); - } - }); - - StateHasChanged(); - } - -} diff --git a/MatrixRoomUtils.Web/Pages/Tools/SpaceDebug.razor b/MatrixRoomUtils.Web/Pages/Tools/SpaceDebug.razor deleted file mode 100644 index 5b4815d..0000000 --- a/MatrixRoomUtils.Web/Pages/Tools/SpaceDebug.razor +++ /dev/null @@ -1,113 +0,0 @@ -@page "/SpaceDebug" -@using LibMatrix.Filters -@using LibMatrix.Helpers -

SpaceDebug

-
- -

@Status

- -Has parent: -
- -@foreach (var (roomId, parents) in SpaceParents) { -

@roomId's parents

-
    - @foreach (var parent in parents) { -
  • @parent
    • - } -
-} - -Space children: - -@foreach (var (roomId, children) in SpaceChildren) { -

@roomId's children

-
    - @foreach (var child in children) { -
  • @child
    • - } -
-} - -@code { - private string _status = "Loading..."; - - public string Status { - get => _status; - set { - _status = value; - StateHasChanged(); - } - } - - public Dictionary> SpaceChildren { get; set; } = new(); - public Dictionary> SpaceParents { get; set; } = new(); - - protected override async Task OnInitializedAsync() { - Status = "Getting homeserver..."; - var hs = await MRUStorage.GetCurrentSessionOrNavigate(); - if (hs is null) return; - - var syncHelper = new SyncHelper(hs) { - Filter = new SyncFilter() { - Presence = new(0), - Room = new() { - AccountData = new(limit: 0), - Ephemeral = new(limit: 0), - State = new(limit: 1000, types: new() { "m.space.child", "m.space.parent" }), - Timeline = new(limit: 0) - }, - AccountData = new(limit: 0) - } - }; - - Status = "Syncing..."; - - var syncs = syncHelper.EnumerateSyncAsync(); - await foreach (var sync in syncs) { - if (sync is null) { - Status = "Sync failed"; - continue; - } - - if (sync.Rooms is null) { - Status = "No rooms in sync..."; - break; - } - - if (sync.Rooms.Join is null) { - Status = "No joined rooms in sync..."; - break; - } - - if (sync.Rooms.Join.Count == 0) { - Status = "Joined rooms list was empty..."; - break; - } - - // nextBatch = sync.NextBatch; - foreach (var (roomId, data) in sync.Rooms!.Join!) { - data.State?.Events?.ForEach(e => { - if (e.Type == "m.space.child") { - if (!SpaceChildren.ContainsKey(roomId)) SpaceChildren[roomId] = new(); - if (e.RawContent is null) e.StateKey += " (null)"; - else if (e.RawContent.Count == 0) e.StateKey += " (empty)"; - SpaceChildren[roomId].Add(e.StateKey); - } - if (e.Type == "m.space.parent") { - if (!SpaceParents.ContainsKey(roomId)) SpaceParents[roomId] = new(); - if (e.RawContent is null) e.StateKey += " (null)"; - else if (e.RawContent.Count == 0) e.StateKey += " (empty)"; - SpaceParents[roomId].Add(e.StateKey); - } - }); - } - Status = $"Synced {sync.Rooms.Join.Count} rooms, found {SpaceChildren.Count} spaces, {SpaceParents.Count} parents"; - } - Status = $"Synced: found {SpaceChildren.Count}->{SpaceChildren.Sum(x => x.Value.Count)} spaces, {SpaceParents.Count}->{SpaceParents.Sum(x => x.Value.Count)} parents!"; - - await base.OnInitializedAsync(); - } - - -} diff --git a/MatrixRoomUtils.Web/Pages/User/DMManager.razor b/MatrixRoomUtils.Web/Pages/User/DMManager.razor deleted file mode 100644 index a327793..0000000 --- a/MatrixRoomUtils.Web/Pages/User/DMManager.razor +++ /dev/null @@ -1,62 +0,0 @@ -@page "/User/DirectMessages" -@using LibMatrix.EventTypes.Spec.State -@using LibMatrix.Responses -@using MatrixRoomUtils.Abstractions -

Direct Messages

-
- -@foreach (var (targetUser, rooms) in DMRooms) { -
- - @foreach (var room in rooms) { - - } -
-} - -@code { - private string? _status; - private AuthenticatedHomeserverGeneric? Homeserver { get; set; } - private Dictionary> DMRooms { get; set; } = new(); - - public string? Status { - get => _status; - set { - _status = value; - StateHasChanged(); - } - } - - protected override async Task OnInitializedAsync() { - Homeserver = await MRUStorage.GetCurrentSessionOrNavigate(); - if (Homeserver is null) return; - Status = "Loading global profile..."; - if (Homeserver.WhoAmI?.UserId is null) return; - - Status = "Loading DM list from account data..."; - var dms = await Homeserver.GetAccountDataAsync>>("m.direct"); - DMRooms.Clear(); - foreach (var (userId, rooms) in dms) { - var roomList = new List(); - DMRooms.Add(await Homeserver.GetProfileAsync(userId), roomList); - foreach (var room in rooms) { - var roomInfo = new RoomInfo() { Room = Homeserver.GetRoom(room) }; - roomList.Add(roomInfo); - roomInfo.StateEvents.Add(new() { - Type = RoomNameEventContent.EventId, - TypedContent = new RoomNameEventContent() { - Name = await Homeserver.GetRoom(room).GetNameOrFallbackAsync(4) - }, - RoomId = room, Sender = null, EventId = null - }); - } - StateHasChanged(); - } - - StateHasChanged(); - Status = null; - - await base.OnInitializedAsync(); - } - -} \ No newline at end of file diff --git a/MatrixRoomUtils.Web/Pages/User/DMSpace.razor b/MatrixRoomUtils.Web/Pages/User/DMSpace.razor deleted file mode 100644 index 21cc264..0000000 --- a/MatrixRoomUtils.Web/Pages/User/DMSpace.razor +++ /dev/null @@ -1,86 +0,0 @@ -@page "/User/DMSpace/Setup" -@using LibMatrix.Homeservers -@using LibMatrix -@using MatrixRoomUtils.LibDMSpace -@using MatrixRoomUtils.LibDMSpace.StateEvents -@using MatrixRoomUtils.Web.Pages.User.DMSpaceStages -

DM Space Management

-
- - @switch (Stage) { - case -1: -

Initialising...

- break; - case 0: - - break; - case 1: - - break; - case 2: - - break; - case 3: - - break; - default: -

Stage is unknown value: @Stage!

- break; - } - - -@code { - private int _stage = -1; - - [Parameter, SupplyParameterFromQuery(Name = "stage")] - public int Stage { - get => _stage; - set { - _stage = value; - Console.WriteLine($"Stage is now {value}"); - StateHasChanged(); - } - } - - public AuthenticatedHomeserverGeneric? Homeserver { get; set; } - - public DMSpaceConfiguration? DmSpaceConfiguration { get; set; } - - [Parameter] - public DMSpace? DmSpace { get; set; } - - protected override async Task OnInitializedAsync() { - if (NavigationManager.Uri.Contains("?stage=")) { - NavigationManager.NavigateTo("/User/DMSpace", true); - } - DmSpace = this; - Homeserver ??= await MRUStorage.GetCurrentSessionOrNavigate(); - if (Homeserver is null) return; - try { - DmSpaceConfiguration = await Homeserver.GetAccountDataAsync("gay.rory.dm_space"); - var room = Homeserver.GetRoom(DmSpaceConfiguration.DMSpaceId); - await room.GetStateAsync(DMSpaceInfo.EventId); - Stage = 1; - } - catch (MatrixException e) { - if (e.ErrorCode == "M_NOT_FOUND") { - Stage = 0; - DmSpaceConfiguration = new(); - } - else throw; - } - catch (Exception e) { - throw; - } - finally { - StateHasChanged(); - } - await base.OnInitializedAsync(); - } - - protected override async Task OnParametersSetAsync() { - StateHasChanged(); - await base.OnParametersSetAsync(); - } - -} \ No newline at end of file diff --git a/MatrixRoomUtils.Web/Pages/User/DMSpaceStages/DMSpaceStage0.razor b/MatrixRoomUtils.Web/Pages/User/DMSpaceStages/DMSpaceStage0.razor deleted file mode 100644 index 49fd5b4..0000000 --- a/MatrixRoomUtils.Web/Pages/User/DMSpaceStages/DMSpaceStage0.razor +++ /dev/null @@ -1,11 +0,0 @@ - - Welcome to the DM Space tool! - -

This wizard will help you set up a DM space.

-

This is useful for eg. sharing DM rooms across multiple accounts.

-
-Get started - -@code { - -} \ No newline at end of file diff --git a/MatrixRoomUtils.Web/Pages/User/DMSpaceStages/DMSpaceStage1.razor b/MatrixRoomUtils.Web/Pages/User/DMSpaceStages/DMSpaceStage1.razor deleted file mode 100644 index 5958fc5..0000000 --- a/MatrixRoomUtils.Web/Pages/User/DMSpaceStages/DMSpaceStage1.razor +++ /dev/null @@ -1,128 +0,0 @@ -@using LibMatrix.Homeservers -@using LibMatrix.RoomTypes -@using LibMatrix -@using LibMatrix.Responses -@using MatrixRoomUtils.LibDMSpace -@using MatrixRoomUtils.LibDMSpace.StateEvents -@using Microsoft.Extensions.Primitives -@using ArcaneLibs.Extensions - - DM Space setup tool - stage 1: Configure space - -

You will need a space to use for DM rooms.

-@if (DmSpace is not null) { -

- Selected space: - - @foreach (var (id, name) in spaces) { - - } - -

-

- - Create sub-spaces per user -

-} -else { - Error: DmSpaceConfiguration is null! -} - -
-Next - -@if (!string.IsNullOrWhiteSpace(Status)) { -

@Status

-} - -@code { - - private string? Status { - get => _status; - set { - _status = value; - StateHasChanged(); - } - } - - private Dictionary spaces = new() { { "", "New space" } }; - private string? _status; - - [CascadingParameter] - public DMSpace? DmSpace { get; set; } - - public DMSpaceInfo? DmSpaceInfo { get; set; } = new(); - - protected override async Task OnInitializedAsync() { - await base.OnInitializedAsync(); - } - - SemaphoreSlim _semaphoreSlim = new(1, 1); - protected override async Task OnParametersSetAsync() { - if (DmSpace is null) - return; - await _semaphoreSlim.WaitAsync(); - DmSpace.DmSpaceConfiguration ??= new(); - if (spaces.Count == 1) { - Status = "Looking for spaces..."; - var userRoomsEnum = DmSpace.Homeserver.GetJoinedRoomsByType("m.space"); - List userRooms = new(); - await foreach (var room in userRoomsEnum) { - userRooms.Add(room); - } - var roomChecks = userRooms.Select(GetFeasibleSpaces).ToAsyncEnumerable(); - await foreach(var room in roomChecks) - if(room.HasValue) - spaces.TryAdd(room.Value.id, room.Value.name); - - Status = "Done!"; - } - _semaphoreSlim.Release(); - await base.OnParametersSetAsync(); - } - - private async Task Execute() { - if (string.IsNullOrWhiteSpace(DmSpace.DmSpaceConfiguration.DMSpaceId)) { - var crr = CreateRoomRequest.CreatePrivate(DmSpace.Homeserver, "Direct Messages"); - crr.CreationContentBaseType.Type = "m.space"; - DmSpace.DmSpaceConfiguration.DMSpaceId = (await DmSpace.Homeserver.CreateRoom(crr)).RoomId; - } - await DmSpace.Homeserver!.SetAccountDataAsync(DMSpaceConfiguration.EventId, DmSpace.DmSpaceConfiguration); - var space = DmSpace.Homeserver.GetRoom(DmSpace.DmSpaceConfiguration.DMSpaceId); - await space.SendStateEventAsync(DMSpaceInfo.EventId, DmSpaceInfo); - - NavigationManager.NavigateTo("/User/DMSpace/Setup?stage=2"); - } - - public async Task<(string id, string name)?> GetFeasibleSpaces(GenericRoom room) { - try { - var pls = await room.GetPowerLevelsAsync(); - if (!pls.UserHasStatePermission(DmSpace.Homeserver.WhoAmI.UserId, "m.space.child")) { - Console.WriteLine($"No permission to send m.space.child in {room.RoomId}..."); - return null; - } - var roomName = await room.GetNameAsync(); - Status = $"Found viable space: {roomName}"; - if (string.IsNullOrWhiteSpace(DmSpace.DmSpaceConfiguration.DMSpaceId)) { - try { - var dsi = await DmSpace.Homeserver.GetRoom(room.RoomId).GetStateOrNullAsync(DMSpaceInfo.EventId) ?? new DMSpaceInfo(); - if (await room.GetStateOrNullAsync(DMSpaceInfo.EventId) is not null && dsi is not null) { - DmSpace.DmSpaceConfiguration.DMSpaceId = room.RoomId; - DmSpaceInfo = dsi; - } - } - catch (MatrixException e) { - if (e.ErrorCode == "M_NOT_FOUND") Console.WriteLine($"{room.RoomId} is not a DM space."); - else throw; - } - } - return (room.RoomId, roomName); - } - catch (MatrixException e) { - if (e.ErrorCode == "M_NOT_FOUND") Console.WriteLine($"m.room.power_levels does not exist in {room.RoomId}!!!"); - else throw; - } - return null; - } - -} \ No newline at end of file diff --git a/MatrixRoomUtils.Web/Pages/User/DMSpaceStages/DMSpaceStage2.razor b/MatrixRoomUtils.Web/Pages/User/DMSpaceStages/DMSpaceStage2.razor deleted file mode 100644 index 60c68ac..0000000 --- a/MatrixRoomUtils.Web/Pages/User/DMSpaceStages/DMSpaceStage2.razor +++ /dev/null @@ -1,242 +0,0 @@ -@using LibMatrix.Homeservers -@using LibMatrix.RoomTypes -@using LibMatrix -@using LibMatrix.EventTypes.Spec.State -@using LibMatrix.Responses -@using MatrixRoomUtils.LibDMSpace -@using MatrixRoomUtils.LibDMSpace.StateEvents -@using ArcaneLibs.Extensions -@using System.Text.Json.Serialization -@using MatrixRoomUtils.Abstractions - - DM Space setup tool - stage 2: Fix DM room attribution - -

This is just to make sure that your DMs are attributed to the right person!

- -@if (!string.IsNullOrWhiteSpace(Status)) { -

@Status

-} - -@if (DmSpace is not null) { - @foreach (var (userId, room) in dmRooms.OrderBy(x => x.Key.Id)) { - - @foreach (var roomInfo in room) { - - Reassign - - } - } -} -else { - Error: DmSpaceConfiguration is null! -} - -
-Next - -@{ - var _offset = 0; -} -@foreach (var (room, usersList) in duplicateDmRooms) { - -

Found room assigned to multiple users:

-

Users:

- @foreach (var userProfileResponse in usersList) { - - Assign to - - -
- } - -} - -@if (DmToReassign is not null) { - - - @foreach (var userProfileResponse in roomMembers[DmToReassign]) { - - Assign to - - -
- } - -} - -@code { - - private string newMxid { get; set; } = ""; - - private RoomInfo? DmToReassign { - get => _dmToReassign; - set { - _dmToReassign = value; - StateHasChanged(); - } - } - - private string? Status { - get => _status; - set { - _status = value; - StateHasChanged(); - } - } - - private string? _status; - private RoomInfo? _dmToReassign; - - [CascadingParameter] - public DMSpace? DmSpace { get; set; } - - private Dictionary> dmRooms { get; set; } = new(); - private Dictionary> duplicateDmRooms { get; set; } = new(); - private Dictionary> roomMembers { get; set; } = new(); - - protected override async Task OnInitializedAsync() { - await base.OnInitializedAsync(); - } - - SemaphoreSlim _semaphore = new(1, 1); - - protected override async Task OnParametersSetAsync() { - if (DmSpace is null) - return; - await _semaphore.WaitAsync(); - DmToReassign = null; - var hs = DmSpace.Homeserver; - Status = "Loading DM list from account data..."; - var dms = await DmSpace.Homeserver.GetAccountDataAsync>>("m.direct"); - Status = "Optimising DM list from account data..."; - var joinedRooms = (await hs.GetJoinedRooms()).Select(x => x.RoomId).ToList(); - foreach (var (user, rooms) in dms) { - for (var i = rooms.Count - 1; i >= 0; i--) { - var roomId = rooms[i]; - if (!joinedRooms.Contains(roomId)) - rooms.RemoveAt(i); - } - dms[user] = rooms.Distinct().ToList(); - } - dms.RemoveAll((x, y) => y is {Count: 0}); - await DmSpace.Homeserver.SetAccountDataAsync("m.direct", dms); - dmRooms.Clear(); - - Status = "DM list optimised, fetching info..."; - var results = dms.Select(async x => { - var (userId, rooms) = x; - UserProfileWithId userProfile; - try { - var profile = await DmSpace.Homeserver.GetProfileAsync(userId); - userProfile = new() { - AvatarUrl = profile.AvatarUrl, - Id = userId, - DisplayName = profile.DisplayName - }; - } - catch { - userProfile = new() { - AvatarUrl = "mxc://feline.support/uUxBwaboPkMGtbZcAGZaIzpK", - DisplayName = userId, - Id = userId - }; - } - var roomList = new List(); - var tasks = rooms.Select(x => GetRoomInfo(hs.GetRoom(x))).ToAsyncEnumerable(); - await foreach (var result in tasks) - roomList.Add(result); - return (userProfile, roomList); - // StateHasChanged(); - }).ToAsyncEnumerable(); - await foreach (var res in results) { - dmRooms.Add(res.userProfile, res.roomList); - // Status = $"Listed {dmRooms.Count} users"; - } - _semaphore.Release(); - var duplicateDmRoomIds = new Dictionary>(); - foreach (var (user, rooms) in dmRooms) { - foreach (var roomInfo in rooms) { - if (!duplicateDmRoomIds.ContainsKey(roomInfo.Room.RoomId)) - duplicateDmRoomIds.Add(roomInfo.Room.RoomId, new()); - duplicateDmRoomIds[roomInfo.Room.RoomId].Add(user); - } - } - duplicateDmRoomIds.RemoveAll((x, y) => y.Count == 1); - foreach (var (roomId, users) in duplicateDmRoomIds) { - duplicateDmRooms.Add(dmRooms.First(x => x.Value.Any(x => x.Room.RoomId == roomId)).Value.First(x => x.Room.RoomId == roomId), users); - } - - // StateHasChanged(); - Status = null; - await base.OnParametersSetAsync(); - } - - private async Task Execute() { - NavigationManager.NavigateTo("/User/DMSpace/Setup?stage=3"); - } - - private async Task GetRoomInfo(GenericRoom room) { - var roomInfo = new RoomInfo() { - Room = room - }; - roomMembers[roomInfo] = new(); - roomInfo.CreationEventContent = await room.GetCreateEventAsync(); - try { - roomInfo.RoomName = await room.GetNameAsync(); - } - catch { } - - var membersEnum = room.GetMembersEnumerableAsync(true); - await foreach (var member in membersEnum) - if (member.TypedContent is RoomMemberEventContent memberEvent) - roomMembers[roomInfo].Add(new() { DisplayName = memberEvent.DisplayName, AvatarUrl = memberEvent.AvatarUrl, Id = member.StateKey }); - - if (string.IsNullOrWhiteSpace(roomInfo.RoomName) || roomInfo.RoomName == room.RoomId) { - List displayNames = new List(); - foreach (var member in roomMembers[roomInfo]) - if (!string.IsNullOrWhiteSpace(member.DisplayName)) - displayNames.Add(member.DisplayName); - roomInfo.RoomName = string.Join(", ", displayNames); - } - try { - string? roomIcon = (await room.GetAvatarUrlAsync())?.Url; - if (room is not null) - roomInfo.RoomIcon = roomIcon; - } - catch { } - return roomInfo; - } - - private async Task> GetRoomInfoForRooms(List rooms) { - var tasks = rooms.Select(GetRoomInfo).ToList(); - await Task.WhenAll(tasks); - return tasks.Select(x => x.Result).ToList(); - } - - private async Task SetRoomAssignment(string roomId, string userId) { - var hs = DmSpace.Homeserver; - Status = "Loading DM list from account data..."; - var dms = await DmSpace.Homeserver.GetAccountDataAsync>>("m.direct"); - Status = "Updating DM list from account data..."; - - foreach (var (user, rooms) in dms) { - rooms.RemoveAll(x => x == roomId); - dms[user] = rooms.Distinct().ToList(); - } - if(!dms.ContainsKey(userId)) - dms.Add(userId, new()); - dms[userId].Add(roomId); - dms.RemoveAll((x, y) => y is {Count: 0}); - await DmSpace.Homeserver.SetAccountDataAsync("m.direct", dms); - - duplicateDmRooms.RemoveAll((x, y) => x.Room.RoomId == roomId); - StateHasChanged(); - if (duplicateDmRooms.Count == 0) await OnParametersSetAsync(); - } - - private class UserProfileWithId : UserProfileResponse { - [JsonIgnore] - public string Id { get; set; } - } - -} \ No newline at end of file diff --git a/MatrixRoomUtils.Web/Pages/User/DMSpaceStages/DMSpaceStage3.razor b/MatrixRoomUtils.Web/Pages/User/DMSpaceStages/DMSpaceStage3.razor deleted file mode 100644 index 42573e6..0000000 --- a/MatrixRoomUtils.Web/Pages/User/DMSpaceStages/DMSpaceStage3.razor +++ /dev/null @@ -1,191 +0,0 @@ -@using LibMatrix.Homeservers -@using LibMatrix.RoomTypes -@using LibMatrix -@using LibMatrix.EventTypes.Spec.State -@using LibMatrix.Responses -@using MatrixRoomUtils.LibDMSpace -@using MatrixRoomUtils.LibDMSpace.StateEvents -@using ArcaneLibs.Extensions -@using System.Text.Json.Serialization -@using MatrixRoomUtils.Abstractions - - - DM Space setup tool - stage 3: Preview space layout - -

This gives you a preview of how your settings would impact layout!

- -@if (!string.IsNullOrWhiteSpace(Status)) { -

@Status

-} - -@if (DmSpace is not null) { - @if (dmSpaceInfo is not null && dmSpaceRoomInfo is not null) { -

- - Create sub-spaces per user -

- @if (!dmSpaceInfo.LayerByUser) { - - @foreach (var (userId, room) in dmRooms.OrderBy(x => x.Key.RoomName)) { - @foreach (var roomInfo in room) { -
- -
- } - } - } - else { - - @foreach (var (userId, room) in dmRooms.OrderBy(x => x.Key.RoomName)) { -
- -
- @foreach (var roomInfo in room) { -
- -
- } - } - } - } - else { - Error: dmSpaceInfo is null! - } -} -else { - Error: DmSpaceConfiguration is null! -} - -
-Next - -@code { - - private string? Status { - get => _status; - set { - _status = value; - StateHasChanged(); - } - } - - private string? _status; - - [CascadingParameter] - public DMSpace? DmSpace { get; set; } - - private Dictionary> dmRooms { get; set; } = new(); - private DMSpaceInfo? dmSpaceInfo { get; set; } - private RoomInfo? dmSpaceRoomInfo { get; set; } - - protected override async Task OnInitializedAsync() { - await base.OnInitializedAsync(); - } - - SemaphoreSlim _semaphore = new(1, 1); - - protected override async Task OnParametersSetAsync() { - if (DmSpace is null) - return; - await _semaphore.WaitAsync(); - var hs = DmSpace.Homeserver; - var dmSpaceRoom = new DMSpaceRoom(hs, DmSpace.DmSpaceConfiguration.DMSpaceId); - dmSpaceRoomInfo = new() { - RoomName = await dmSpaceRoom.GetNameAsync(), - CreationEventContent = await dmSpaceRoom.GetCreateEventAsync(), - RoomIcon = "mxc://feline.support/uUxBwaboPkMGtbZcAGZaIzpK", - Room = dmSpaceRoom - }; - dmSpaceInfo = await dmSpaceRoom.GetDmSpaceInfo(); - Status = "Loading DM list from account data..."; - var dms = await DmSpace.Homeserver.GetAccountDataAsync>>("m.direct"); - dmRooms.Clear(); - - Status = "DM list optimised, fetching info..."; - var results = dms.Select(async x => { - var (userId, rooms) = x; - UserProfileWithId userProfile; - try { - var profile = await DmSpace.Homeserver.GetProfileAsync(userId); - userProfile = new() { - AvatarUrl = profile.AvatarUrl, - Id = userId, - DisplayName = profile.DisplayName - }; - } - catch { - userProfile = new() { - AvatarUrl = "mxc://feline.support/uUxBwaboPkMGtbZcAGZaIzpK", - DisplayName = userId, - Id = userId - }; - } - var roomList = new List(); - var tasks = rooms.Select(x => GetRoomInfo(hs.GetRoom(x))).ToAsyncEnumerable(); - await foreach (var result in tasks) - roomList.Add(result); - return (userProfile, roomList); - }).ToAsyncEnumerable(); - await foreach (var res in results) { - dmRooms.Add(new RoomInfo() { - Room = dmSpaceRoom, - RoomIcon = res.userProfile.AvatarUrl, - RoomName = res.userProfile.DisplayName, - CreationEventContent = await dmSpaceRoom.GetCreateEventAsync() - }, res.roomList); - } - _semaphore.Release(); - Status = null; - await base.OnParametersSetAsync(); - } - - private async Task Execute() { - var hs = DmSpace.Homeserver; - var dmSpaceRoom = new DMSpaceRoom(hs, DmSpace.DmSpaceConfiguration.DMSpaceId); - NavigationManager.NavigateTo("/User/DMSpace/Setup?stage=3"); - } - - private async Task GetRoomInfo(GenericRoom room) { - var roomInfo = new RoomInfo() { - Room = room - }; - var roomMembers = new List(); - roomInfo.CreationEventContent = await room.GetCreateEventAsync(); - try { - roomInfo.RoomName = await room.GetNameAsync(); - } - catch { } - - var membersEnum = room.GetMembersEnumerableAsync(true); - await foreach (var member in membersEnum) - if (member.TypedContent is RoomMemberEventContent memberEvent) - roomMembers.Add(new() { DisplayName = memberEvent.DisplayName, AvatarUrl = memberEvent.AvatarUrl, Id = member.StateKey }); - - if (string.IsNullOrWhiteSpace(roomInfo.RoomName) || roomInfo.RoomName == room.RoomId) { - List displayNames = new List(); - foreach (var member in roomMembers) - if (!string.IsNullOrWhiteSpace(member.DisplayName)) - displayNames.Add(member.DisplayName); - roomInfo.RoomName = string.Join(", ", displayNames); - } - try { - string? roomIcon = (await room.GetAvatarUrlAsync())?.Url; - if (room is not null) - roomInfo.RoomIcon = roomIcon; - } - catch { } - return roomInfo; - } - - private async Task> GetRoomInfoForRooms(List rooms) { - var tasks = rooms.Select(GetRoomInfo).ToList(); - await Task.WhenAll(tasks); - return tasks.Select(x => x.Result).ToList(); - } - - private class UserProfileWithId : UserProfileResponse { - [JsonIgnore] - public string Id { get; set; } - } - -} \ No newline at end of file diff --git a/MatrixRoomUtils.Web/Pages/User/Profile.razor b/MatrixRoomUtils.Web/Pages/User/Profile.razor deleted file mode 100644 index 73d7c6e..0000000 --- a/MatrixRoomUtils.Web/Pages/User/Profile.razor +++ /dev/null @@ -1,134 +0,0 @@ -@page "/User/Profile" -@using LibMatrix.Homeservers -@using LibMatrix.EventTypes.Spec.State -@using ArcaneLibs.Extensions -@using LibMatrix.Responses -

Manage Profile - @Homeserver?.WhoAmI?.UserId

-
- -@if (NewProfile is not null) { -

Profile

-
-
- -
- Display name:
- Avatar URL: -
- Update profile - Update profile (restore room overrides) -
-
- @if (!string.IsNullOrWhiteSpace(Status)) { -

@Status

- } - -
- - @*
*@ -

Room profiles

- - @foreach (var (roomId, roomProfile) in RoomProfiles.OrderBy(x => RoomNames.TryGetValue(x.Key, out var _name) ? _name : x.Key)) { -
- @(RoomNames.TryGetValue(roomId, out var name) ? name : roomId) - -
- Display name:
- Avatar URL: -
- Update profile -
-
- @if (!string.IsNullOrWhiteSpace(Status)) { -

@Status

- } -
-
- } - //
-} - -@code { - private string? _status = null; - - private AuthenticatedHomeserverGeneric? Homeserver { get; set; } - private UserProfileResponse? NewProfile { get; set; } - private UserProfileResponse? OldProfile { get; set; } - - private string? Status { - get => _status; - set { - _status = value; - StateHasChanged(); - } - } - - private Dictionary RoomProfiles { get; set; } = new(); - private Dictionary RoomNames { get; set; } = new(); - - protected override async Task OnInitializedAsync() { - Homeserver = await MRUStorage.GetCurrentSessionOrNavigate(); - if (Homeserver is null) return; - Status = "Loading global profile..."; - if (Homeserver.WhoAmI?.UserId is null) return; - NewProfile = (await Homeserver.GetProfileAsync(Homeserver.WhoAmI.UserId)); //.DeepClone(); - OldProfile = (await Homeserver.GetProfileAsync(Homeserver.WhoAmI.UserId)); //.DeepClone(); - Status = "Loading room profiles..."; - var roomProfiles = Homeserver.GetRoomProfilesAsync(); - await foreach (var (roomId, roomProfile) in roomProfiles) { - // Status = $"Got profile for {roomId}..."; - RoomProfiles[roomId] = roomProfile; //.DeepClone(); - } - - StateHasChanged(); - Status = "Room profiles loaded, loading room names..."; - - var roomNameTasks = RoomProfiles.Keys.Select(x => Homeserver.GetRoom(x)).Select(async x => { - var name = await x.GetNameOrFallbackAsync(); - return new KeyValuePair(x.RoomId, name); - }).ToAsyncEnumerable(); - - await foreach (var (roomId, roomName) in roomNameTasks) { - // Status = $"Got room name for {roomId}: {roomName}"; - RoomNames[roomId] = roomName; - } - - StateHasChanged(); - Status = null; - - await base.OnInitializedAsync(); - } - - private async Task AvatarChanged(InputFileChangeEventArgs arg) { - var res = await Homeserver.UploadFile(arg.File.Name, arg.File.OpenReadStream(Int64.MaxValue), arg.File.ContentType); - Console.WriteLine(res); - NewProfile.AvatarUrl = res; - StateHasChanged(); - } - - private async Task UpdateProfile(bool restoreRoomProfiles = false) { - Status = "Busy processing global profile update, please do not leave this page..."; - StateHasChanged(); - await Homeserver.UpdateProfileAsync(NewProfile, restoreRoomProfiles); - Status = null; - StateHasChanged(); - await OnInitializedAsync(); - } - - private async Task RoomAvatarChanged(InputFileChangeEventArgs arg, string roomId) { - var res = await Homeserver.UploadFile(arg.File.Name, arg.File.OpenReadStream(Int64.MaxValue), arg.File.ContentType); - Console.WriteLine(res); - RoomProfiles[roomId].AvatarUrl = res; - StateHasChanged(); - } - - private async Task UpdateRoomProfile(string roomId) { - Status = "Busy processing room profile update, please do not leave this page..."; - StateHasChanged(); - var room = Homeserver.GetRoom(roomId); - await room.SendStateEventAsync("m.room.member", Homeserver.WhoAmI.UserId, RoomProfiles[roomId]); - Status = null; - StateHasChanged(); - } - -} \ No newline at end of file -- cgit 1.5.1