BugMine.Sdk/BugMineProject.cs


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

using ArcaneLibs.Extensions;
using LibMatrix.RoomTypes;

namespace BugMine.Web.Classes;

public class BugMineProject(GenericRoom room) {
    public const string RoomType = "gay.rory.bugmine.project";
    public GenericRoom Room { get; } = room;
    public ProjectInfo Info { get; set; }
    public BugMineRoomMetadata Metadata { get; set; }
    public string ProjectSlug { get; set; }

    public async Task<BugMineProject> InitializeAsync() {
        var infoTask = Room.GetStateAsync<ProjectInfo>(ProjectInfo.EventId);
        var metadataTask = Room.GetStateAsync<BugMineRoomMetadata>(BugMineRoomMetadata.EventId)!;
        var alias = await room.GetCanonicalAliasAsync();

        if (alias != null)
            ProjectSlug = alias.Alias?[1..] ?? room.RoomId;
        else ProjectSlug = room.RoomId;

        Info = (await infoTask)!;
        Metadata = (await metadataTask)!;
        return this;
    }

    public async Task<BugMineIssue> CreateIssue(BugMineIssueData issue) {
        // add relation to room creation event
        issue.RelatesTo = new() {
            EventId = Metadata.RoomCreationEventId,
            RelationType = "gay.rory.bugmine.issue"
        };
        var eventId = await Room.SendTimelineEventAsync(BugMineIssueData.EventId, issue);

        var evt = await room.GetEventAsync(eventId.EventId);
        Console.WriteLine(evt.ToJson(indent: false));
        return new BugMineIssue(Room, evt);
    }

    public async IAsyncEnumerable<BugMineIssue> GetIssues() {
        await foreach (var evt in room.GetRelatedEventsAsync(Metadata.RoomCreationEventId, "gay.rory.bugmine.issue", BugMineIssueData.EventId)) {
            yield return new BugMineIssue(Room, evt);
        }
    }
}

public static class ProjectRoomExtensions {
    public static async Task<BugMineProject> AsBugMineProject(this GenericRoom room, SemaphoreSlim? semaphore = null) {
        try {
            await (semaphore?.WaitAsync() ?? Task.CompletedTask);
            return await new BugMineProject(room).InitializeAsync();
        }
        finally {
            semaphore?.Release();
        }
    }
}