9 Commits

Author SHA1 Message Date
cake
8e7d7bf489 Revert DTO, Changed messagepackprotocol again. 2025-12-06 23:39:24 +01:00
cake
9b2fea6fa4 Updated DTO 2025-12-06 22:58:30 +01:00
cake
efb5a8072b Added MessagePackObject in dto. 2025-12-06 20:16:03 +01:00
cake
8ea337ab2d Fixed some problems. 2025-12-06 18:02:39 +01:00
cake
b1d7ee5b34 Auto-pruning of syncshell, added metrics for pruning, return of count of users in fullgroupdto. 2025-12-05 22:01:48 +01:00
0170ac377d Initial Chat Merge
Reviewed-on: #13
2025-11-11 18:56:38 +01:00
9d9e8e9be6 Merge branch 'main' into chat 2025-11-11 18:56:23 +01:00
azyges
bb88bea5aa revert api bump from testing 2025-10-29 07:55:17 +09:00
azyges
67cb24a069 i hate chats 2025-10-29 07:43:49 +09:00
4 changed files with 105 additions and 2 deletions

View File

@@ -0,0 +1,85 @@
using System;
using System.Collections.Generic;
using LightlessSync.API.Data;
using LightlessSync.API.Dto.User;
using MessagePack;
namespace LightlessSync.API.Dto.Chat;
public enum ChatChannelType : byte
{
Zone = 0,
Group = 1
}
public enum ChatSenderKind : byte
{
Anonymous = 0,
IdentifiedUser = 1
}
[MessagePackObject]
public readonly record struct ChatChannelDescriptor
{
[Key(0)] public ChatChannelType Type { get; init; }
[Key(1)] public ushort WorldId { get; init; }
[Key(2)] public ushort ZoneId { get; init; }
[Key(3)] public string? CustomKey { get; init; }
public ChatChannelDescriptor WithNormalizedCustomKey() =>
this with { CustomKey = string.IsNullOrWhiteSpace(CustomKey) ? string.Empty : CustomKey };
}
[MessagePackObject(keyAsPropertyName: true)]
public readonly record struct ChatPresenceUpdateDto(ChatChannelDescriptor Channel, ushort TerritoryId, bool IsActive);
[MessagePackObject(keyAsPropertyName: true)]
public readonly record struct ChatSendRequestDto(ChatChannelDescriptor Channel, string Message);
[MessagePackObject(keyAsPropertyName: true)]
public readonly record struct ChatSenderDescriptor(
ChatSenderKind Kind,
string Token,
string? DisplayName,
string? HashedCid,
UserData? User,
bool CanResolveProfile);
[MessagePackObject(keyAsPropertyName: true)]
public readonly record struct ChatMessageDto(
ChatChannelDescriptor Channel,
ChatSenderDescriptor Sender,
string Message,
DateTime SentAtUtc,
string MessageId);
[MessagePackObject(keyAsPropertyName: true)]
public readonly record struct ChatReportSubmitDto(
ChatChannelDescriptor Channel,
string MessageId,
string Reason,
string? AdditionalContext);
[MessagePackObject(keyAsPropertyName: true)]
public readonly record struct ChatParticipantResolveRequestDto(
ChatChannelDescriptor Channel,
string Token);
[MessagePackObject(keyAsPropertyName: true)]
public readonly record struct ChatParticipantResolveResultDto(
ChatChannelDescriptor Channel,
ChatSenderDescriptor Sender,
UserProfileDto? Profile);
[MessagePackObject(keyAsPropertyName: true)]
public readonly record struct ZoneChatChannelInfoDto(
ChatChannelDescriptor Channel,
string DisplayName,
IReadOnlyList<string> Territories);
[MessagePackObject(keyAsPropertyName: true)]
public readonly record struct GroupChatChannelInfoDto(
ChatChannelDescriptor Channel,
string DisplayName,
string GroupId,
bool IsOwner);

View File

@@ -7,8 +7,9 @@ namespace LightlessSync.API.Dto.Group;
[MessagePackObject(keyAsPropertyName: true)]
public record GroupFullInfoDto(GroupData Group, UserData Owner, GroupPermissions GroupPermissions,
GroupUserPreferredPermissions GroupUserPermissions, GroupPairUserInfo GroupUserInfo,
Dictionary<string, GroupPairUserInfo> GroupPairUserInfos) : GroupInfoDto(Group, Owner, GroupPermissions)
Dictionary<string, GroupPairUserInfo> GroupPairUserInfos, int GroupUserCount) : GroupInfoDto(Group, Owner, GroupPermissions)
{
public GroupUserPreferredPermissions GroupUserPermissions { get; set; } = GroupUserPermissions;
public GroupPairUserInfo GroupUserInfo { get; set; } = GroupUserInfo;
public int GroupUserCount { get; set; } = GroupUserCount;
}

View File

@@ -0,0 +1,7 @@
using LightlessSync.API.Data;
using MessagePack;
namespace LightlessSync.API.Dto.Group;
[MessagePackObject(keyAsPropertyName: true)]
public record GroupPruneSettingsDto(GroupData Group, bool AutoPruneEnabled, int AutoPruneDays);

View File

@@ -1,6 +1,7 @@
using LightlessSync.API.Data;
using LightlessSync.API.Data.Enum;
using LightlessSync.API.Dto;
using LightlessSync.API.Dto.Chat;
using LightlessSync.API.Dto.CharaData;
using LightlessSync.API.Dto.Group;
using LightlessSync.API.Dto.User;
@@ -21,7 +22,7 @@ public interface ILightlessHub
Task Client_GroupPairJoined(GroupPairFullInfoDto groupPairInfoDto);
Task Client_GroupPairLeft(GroupPairDto groupPairDto);
Task Client_GroupSendFullInfo(GroupFullInfoDto groupInfo);
Task Client_GroupSendProfile (GroupProfileDto groupInfo);
Task Client_GroupSendProfile(GroupProfileDto groupInfo);
Task Client_GroupSendInfo(GroupInfoDto groupInfo);
Task Client_ReceiveServerMessage(MessageSeverity messageSeverity, string message);
Task Client_ReceiveBroadcastPairRequest(UserPairNotificationDto dto);
@@ -43,8 +44,11 @@ public interface ILightlessHub
Task Client_GposeLobbyPushCharacterData(CharaDataDownloadDto charaDownloadDto);
Task Client_GposeLobbyPushPoseData(UserData userData, PoseData poseData);
Task Client_GposeLobbyPushWorldData(UserData userData, WorldData worldData);
Task Client_ChatReceive(ChatMessageDto message);
Task<ConnectionDto> GetConnectionDto();
Task<IReadOnlyList<ZoneChatChannelInfoDto>> GetZoneChatChannels();
Task<IReadOnlyList<GroupChatChannelInfoDto>> GetGroupChatChannels();
Task GroupBanUser(GroupPairDto dto, string reason);
Task GroupChangeGroupPermissionState(GroupPermissionDto dto);
@@ -64,6 +68,8 @@ public interface ILightlessHub
Task<GroupProfileDto> GroupGetProfile(GroupDto dto);
Task GroupSetProfile(GroupProfileDto dto);
Task GroupSetUserInfo(GroupPairUserInfoDto groupPair);
Task<GroupPruneSettingsDto> GroupGetPruneSettings(GroupDto dto);
Task GroupSetPruneSettings(GroupPruneSettingsDto dto);
Task<List<GroupFullInfoDto>> GroupsGetAll();
Task GroupUnbanUser(GroupPairDto groupPair);
Task<int> GroupPrune(GroupDto group, int days, bool execute);
@@ -105,4 +111,8 @@ public interface ILightlessHub
Task GposeLobbyPushCharacterData(CharaDataDownloadDto charaDownloadDto);
Task GposeLobbyPushPoseData(PoseData poseData);
Task GposeLobbyPushWorldData(WorldData worldData);
Task UpdateChatPresence(ChatPresenceUpdateDto presence);
Task SendChatMessage(ChatSendRequestDto request);
Task ReportChatMessage(ChatReportSubmitDto request);
Task<ChatParticipantResolveResultDto?> ResolveChatParticipant(ChatParticipantResolveRequestDto request);
}