blob: 92e7955d9ab351df36b2b221f554698d84867823 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
|
@page "/RoomStateViewer"
@using System.Net.Http.Headers
@using System.Text.Json
@using MatrixRoomUtils.Core
@inject ILocalStorageService LocalStorage
@inject NavigationManager NavigationManager
<h3>Room state viewer</h3>
<h5>Room list</h5>
<hr/>
@if (PolicyRoomList.Count == 0)
{
<p>No policy rooms found.</p>
<p>Loading progress: @checkedRoomCount/@totalRoomCount</p>
}
else
{
@if (checkedRoomCount != totalRoomCount)
{
<p>Loading progress: @checkedRoomCount/@totalRoomCount</p>
}
foreach (var s in PolicyRoomList)
{
<a href="@(NavigationManager.Uri + "/" + s.RoomId.Replace('.', '~'))">@s.Name (@s.RoomId)</a>
<br/>
}
<div style="margin-bottom: 4em;"></div>
}
<LogView></LogView>
@code {
public List<PolicyRoomInfo> PolicyRoomList { get; set; } = new();
private int checkedRoomCount { get; set; } = 0;
private int totalRoomCount { get; set; } = 0;
protected override async Task OnInitializedAsync()
{
if (!RuntimeCache.WasLoaded) await LocalStorageWrapper.LoadFromLocalStorage(LocalStorage);
await base.OnInitializedAsync();
if (RuntimeCache.CurrentHomeServer == null)
{
NavigationManager.NavigateTo("/Login");
return;
}
await EnumeratePolicyRooms();
Console.WriteLine("Policy list editor initialized!");
}
private async Task EnumeratePolicyRooms()
{
var rooms = (await RuntimeCache.CurrentHomeServer.GetJoinedRooms()).Select(x=>x.RoomId).ToList();
totalRoomCount = rooms.Count;
StateHasChanged();
var semaphore = new SemaphoreSlim(128);
var tasks = new List<Task<PolicyRoomInfo?>>();
foreach (string room in rooms)
{
tasks.Add(GetPolicyRoomInfo(room, semaphore));
}
var results = await Task.WhenAll(tasks);
PolicyRoomList.AddRange(results.Where(x => x != null).Select(x=>x.Value));
StateHasChanged();
}
private async Task<PolicyRoomInfo?> GetPolicyRoomInfo(string room, SemaphoreSlim semaphore)
{
try
{
await semaphore.WaitAsync();
return new PolicyRoomInfo()
{
RoomId = room,
Name = await (await RuntimeCache.CurrentHomeServer.GetRoom(room)).GetNameAsync()
};
}
finally
{
checkedRoomCount++;
StateHasChanged();
semaphore.Release();
}
}
public struct PolicyRoomInfo
{
public string RoomId { get; set; }
public string Name { get; set; }
}
}
|
