about summary refs log tree commit diff
path: root/LibMatrix/RoomTypes/GenericRoom.cs
diff options
context:
space:
mode:
authorYour Name <you@example.com>2024-05-13 23:54:10 +0200
committerYour Name <you@example.com>2024-05-13 23:54:10 +0200
commit11c7786ea23d82d31cc54abe57d35fdd74cf1bd5 (patch)
treea5a244d1e97959ac98bd2b95cf2fa94edac0fe2d /LibMatrix/RoomTypes/GenericRoom.cs
parentFix some race conditions and some optimisation in HomeserverEmulator (diff)
downloadLibMatrix-11c7786ea23d82d31cc54abe57d35fdd74cf1bd5.tar.xz
Clearer error messages, fix bug in hs resolution
Diffstat (limited to 'LibMatrix/RoomTypes/GenericRoom.cs')
-rw-r--r--LibMatrix/RoomTypes/GenericRoom.cs36
1 files changed, 18 insertions, 18 deletions
diff --git a/LibMatrix/RoomTypes/GenericRoom.cs b/LibMatrix/RoomTypes/GenericRoom.cs

index 742f5d9..f15327c 100644 --- a/LibMatrix/RoomTypes/GenericRoom.cs +++ b/LibMatrix/RoomTypes/GenericRoom.cs
@@ -228,43 +228,43 @@ public class GenericRoom { } public async IAsyncEnumerable<StateEventResponse> GetMembersEnumerableAsync(bool joinedOnly = true) { - var sw = Stopwatch.StartNew(); + // var sw = Stopwatch.StartNew(); var res = await Homeserver.ClientHttpClient.GetAsync($"/_matrix/client/v3/rooms/{RoomId}/members"); - if (sw.ElapsedMilliseconds > 1000) - Console.WriteLine($"Members call responded in {sw.GetElapsedAndRestart()}"); - else sw.Restart(); + // if (sw.ElapsedMilliseconds > 1000) + // Console.WriteLine($"Members call responded in {sw.GetElapsedAndRestart()}"); + // else sw.Restart(); // var resText = await res.Content.ReadAsStringAsync(); // Console.WriteLine($"Members call response read in {sw.GetElapsedAndRestart()}"); var result = await JsonSerializer.DeserializeAsync<ChunkedStateEventResponse>(await res.Content.ReadAsStreamAsync(), new JsonSerializerOptions() { TypeInfoResolver = ChunkedStateEventResponseSerializerContext.Default }); - if (sw.ElapsedMilliseconds > 100) - Console.WriteLine($"Members call deserialised in {sw.GetElapsedAndRestart()}"); - else sw.Restart(); + // if (sw.ElapsedMilliseconds > 100) + // Console.WriteLine($"Members call deserialised in {sw.GetElapsedAndRestart()}"); + // else sw.Restart(); foreach (var resp in result.Chunk) { if (resp?.Type != "m.room.member") continue; if (joinedOnly && resp.RawContent?["membership"]?.GetValue<string>() != "join") continue; yield return resp; } - if (sw.ElapsedMilliseconds > 100) - Console.WriteLine($"Members call iterated in {sw.GetElapsedAndRestart()}"); + // if (sw.ElapsedMilliseconds > 100) + // Console.WriteLine($"Members call iterated in {sw.GetElapsedAndRestart()}"); } public async Task<FrozenSet<StateEventResponse>> GetMembersListAsync(bool joinedOnly = true) { - var sw = Stopwatch.StartNew(); + // var sw = Stopwatch.StartNew(); var res = await Homeserver.ClientHttpClient.GetAsync($"/_matrix/client/v3/rooms/{RoomId}/members"); - if (sw.ElapsedMilliseconds > 1000) - Console.WriteLine($"Members call responded in {sw.GetElapsedAndRestart()}"); - else sw.Restart(); + // if (sw.ElapsedMilliseconds > 1000) + // Console.WriteLine($"Members call responded in {sw.GetElapsedAndRestart()}"); + // else sw.Restart(); // var resText = await res.Content.ReadAsStringAsync(); // Console.WriteLine($"Members call response read in {sw.GetElapsedAndRestart()}"); var result = await JsonSerializer.DeserializeAsync<ChunkedStateEventResponse>(await res.Content.ReadAsStreamAsync(), new JsonSerializerOptions() { TypeInfoResolver = ChunkedStateEventResponseSerializerContext.Default }); - if (sw.ElapsedMilliseconds > 100) - Console.WriteLine($"Members call deserialised in {sw.GetElapsedAndRestart()}"); - else sw.Restart(); + // if (sw.ElapsedMilliseconds > 100) + // Console.WriteLine($"Members call deserialised in {sw.GetElapsedAndRestart()}"); + // else sw.Restart(); var members = new List<StateEventResponse>(); foreach (var resp in result.Chunk) { if (resp?.Type != "m.room.member") continue; @@ -272,8 +272,8 @@ public class GenericRoom { members.Add(resp); } - if (sw.ElapsedMilliseconds > 100) - Console.WriteLine($"Members call iterated in {sw.GetElapsedAndRestart()}"); + // if (sw.ElapsedMilliseconds > 100) + // Console.WriteLine($"Members call iterated in {sw.GetElapsedAndRestart()}"); return members.ToFrozenSet(); }