1 files changed, 104 insertions, 0 deletions
diff --git a/MatrixUtils.Web/Pages/Tools/MigrateRoom.razor b/MatrixUtils.Web/Pages/Tools/MigrateRoom.razor
new file mode 100644
index 0000000..3234098
--- /dev/null
+++ b/MatrixUtils.Web/Pages/Tools/MigrateRoom.razor
@@ -0,0 +1,104 @@
+@page "/Tools/MigrateRoom"
+@using ArcaneLibs.Extensions
+@using LibMatrix
+@using LibMatrix.EventTypes.Spec.State
+@using LibMatrix.RoomTypes
+<h3>Migrate room</h3>
+<hr/>
+<span>Old room: </span>
+<FancyTextBox @bind-Value="@roomId"></FancyTextBox><br/>
+<span>New room: </span>
+<FancyTextBox @bind-Value="@newRoomId"></FancyTextBox><br/>
+
+<details>
+ <summary>Users:</summary>
+ @foreach (var user in users) {
+ <p>@user</p>
+ }
+</details>
+
+<br/>
+<LinkButton OnClick="Execute">Execute</LinkButton>
+<br/>
+@foreach (var line in Enumerable.Reverse(log)) {
+ <p>@line</p>
+}
+
+@code {
+ private string _roomId;
+ private List<string> log { get; set; } = new();
+ private List<string> users { get; set; } = new();
+
+ string roomId {
+ get => _roomId;
+ set {
+ _roomId = value;
+ TryFetchUsers();
+ }
+ }
+
+ private string newRoomId { get; set; }
+
+ protected override async Task OnInitializedAsync() {
+ var hs = await RMUStorage.GetCurrentSessionOrNavigate();
+ if (hs is null) return;
+
+ StateHasChanged();
+ Console.WriteLine("Rerendered!");
+ await base.OnInitializedAsync();
+ }
+
+ private async Task Execute() {
+ var hs = await RMUStorage.GetCurrentSessionOrNavigate();
+ if (hs is null) return;
+ var oldRoom = hs.GetRoom(roomId);
+ var newRoom = hs.GetRoom(newRoomId);
+ var members = await oldRoom.GetMembersListAsync();
+ var tasks = members.Select(x => ExecuteInvite(hs, newRoom, x.StateKey)).ToAsyncEnumerable();
+ // var tasks = hss.Select(ExecuteInvite).ToAsyncEnumerable();
+ await foreach (var a in tasks) {
+ if (!string.IsNullOrWhiteSpace(a)) {
+ log.Add(a);
+ StateHasChanged();
+ }
+ }
+ }
+
+ private async Task<string> ExecuteInvite(AuthenticatedHomeserverGeneric hs, GenericRoom newRoom, string mxid) {
+ try {
+ var pls = await newRoom.GetPowerLevelsAsync();
+ if (pls.GetUserPowerLevel(hs.WhoAmI.UserId) < pls.Invite) return "I do not have permission to send invite in " + newRoom.RoomId;
+ await newRoom.InviteUserAsync(mxid);
+ return $"Invited {mxid} to {newRoom.RoomId}";
+ }
+ catch (MatrixException e) {
+ log.Add($"Failed to invite {mxid} to {newRoom.RoomId}: {e.Message}");
+ if (e is { ErrorCode: "M_LIMIT_EXCEEDED" }) {
+ log.Add($"Retrying after {e.RetryAfterMs}");
+ await Task.Delay(e.RetryAfterMs!.Value);
+ return await ExecuteInvite(hs, newRoom, mxid);
+ }
+
+ return "";
+ }
+ catch (Exception e) {
+ return $"Failed to invite {mxid} to {newRoom.RoomId}: {e.Message}";
+ }
+
+ StateHasChanged();
+ return "";
+ }
+
+ private async Task TryFetchUsers() {
+ try {
+ var hs = await RMUStorage.GetCurrentSessionOrNavigate();
+ if (hs is null) return;
+ var room = hs.GetRoom(roomId);
+ var members = await room.GetMembersListAsync();
+ users = members.Select(x => x.StateKey).ToList();
+ StateHasChanged();
+ }
+ catch { }
+ }
+
+}
\ No newline at end of file
|
