dandri/server
1
0
Fork 0
mirror of https://github.com/spacebarchat/server.git synced 2026-08-28 00:54:16 +00:00
Code Issues Packages Projects Releases Wiki Activity

Op14: Handle ranges, in theory

Browse Source
This commit is contained in:
Rory&
2026-06-23 08:51:08 +02:00
parent c4fb945980
commit 717646b101
1 changed files with 30 additions and 28 deletions
Download Patch File Download Diff File Expand all files Collapse all files
extra/admin-api/Spacebar.Offload/Controllers/Op14Controller.cs
+30 -28
View File
@@ -43,35 +43,37 @@ public class Op14Controller(ILogger<Op12Controller> logger, SpacebarAspNetAuthen
var memberList = await GetGuildMemberListAsync(db, payload.GuildId);
yield return new ReplicationMessage<GuildMemberListUpdate>()
{
UserId = user.Result.Id,
Event = GuildMemberListUpdate.EventId,
Origin = "Offload/LazyRequest",
CreatedAt = DateTime.UtcNow,
Payload = new GuildMemberListUpdate()
foreach (var (cid, ranges) in payload.Channels)
foreach (var range in ranges)
yield return new ReplicationMessage<GuildMemberListUpdate>()
{
GuildId = payload.GuildId,
// this doesnt appear to work currently, skip it
ListId = "everyone", // await GetMemberListIdAsync(db, guildId: payload.GuildId, channelId: long.Parse(payload.Channels.Keys.First())),
OnlineCount = memberList.TakeWhile(x => x is not GuildMemberListSyncItem.RoleEntry { Group.Id: "offline" }).Count(),
MemberCount = await db.Members.CountAsync(x => x.GuildId == payload.GuildId),
Operations =
[
new GuildMemberListUpdateOperation.SyncOperation()
{
Operation = GuildMemberListUpdateOperationType.Sync,
Items = memberList.ToList(),
Range = [0, memberList.Count]
}
],
Groups = memberList.OfType<GuildMemberListSyncItem.RoleEntry>().Select(x => x.Group).ToList()
}
// TODO: send presence updates
// TODO: handle subscriptions
// TODO: handle channel permissions
// TODO: handle channels at all
};
UserId = user.Result.Id,
Event = GuildMemberListUpdate.EventId,
Origin = "Offload/LazyRequest",
CreatedAt = DateTime.UtcNow,
Payload = new GuildMemberListUpdate()
{
GuildId = payload.GuildId,
// this doesnt appear to work currently, skip it
ListId = "everyone", // await GetMemberListIdAsync(db, guildId: payload.GuildId, channelId: long.Parse(cid)),
OnlineCount = memberList.TakeWhile(x => x is not GuildMemberListSyncItem.RoleEntry { Group.Id: "offline" }).Count(),
MemberCount = await db.Members.CountAsync(x => x.GuildId == payload.GuildId),
Operations =
[
new GuildMemberListUpdateOperation.SyncOperation()
{
Operation = GuildMemberListUpdateOperationType.Sync,
Items = memberList.Skip(range[0]).Take(range[1]).ToList(),
Range = [range[0], Math.Min(range[1], memberList.Count)]
}
],
Groups = memberList.OfType<GuildMemberListSyncItem.RoleEntry>().Select(x => x.Group).ToList()
}
// TODO: send presence updates
// TODO: handle subscriptions
// TODO: handle channel permissions
// TODO: handle channels at all
};
}
private async Task<string?> GetMemberListIdAsync(SpacebarDbContext db, long guildId, long channelId)