From 0c5bfb274ff783d70941af8f3817894e759db10d Mon Sep 17 00:00:00 2001 From: Rory& Date: Thu, 2 May 2024 07:22:22 +0200 Subject: Some work --- BugMine.Sdk/BugMineClient.cs | 17 +++++++++++------ 1 file changed, 11 insertions(+), 6 deletions(-) (limited to 'BugMine.Sdk/BugMineClient.cs') diff --git a/BugMine.Sdk/BugMineClient.cs b/BugMine.Sdk/BugMineClient.cs index db47b85..21be614 100644 --- a/BugMine.Sdk/BugMineClient.cs +++ b/BugMine.Sdk/BugMineClient.cs @@ -11,10 +11,11 @@ namespace BugMine.Web.Classes; public class BugMineClient(AuthenticatedHomeserverGeneric homeserver) { public AuthenticatedHomeserverGeneric Homeserver { get; } = homeserver; - public async IAsyncEnumerable GetProjects() { + public async IAsyncEnumerable GetProjects(SemaphoreSlim? semaphore = null) { List> tasks = []; - await foreach (var room in homeserver.GetJoinedRoomsByType(BugMineProject.RoomType)) { - tasks.Add(room.AsBugMineProject()); + int count = 0; + await foreach (var room in homeserver.GetJoinedRoomsByType(BugMineProject.RoomType, 64)) { + tasks.Add(room.AsBugMineProject(semaphore)); } var results = tasks.ToAsyncEnumerable(); @@ -46,10 +47,14 @@ public class BugMineClient(AuthenticatedHomeserverGeneric homeserver) { ] }; - var response = await Homeserver.CreateRoom(crr); - // await response.SendStateEventAsync(ProjectInfo.EventId, request); + var newRoom = await Homeserver.CreateRoom(crr); + var timeline = await newRoom.GetMessagesAsync(); + + await newRoom.SendStateEventAsync(BugMineRoomMetadata.EventId, new BugMineRoomMetadata() { + RoomCreationEventId = timeline.Chunk.Single(m => m.Type == "m.room.create").EventId! + }); - return await response.AsBugMineProject(); + return await newRoom.AsBugMineProject(); } public async Task GetProject(string projectSlug) { -- cgit 1.5.1