Compare commits
38 Commits
auto-prune
...
9971b14177
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
9971b14177 | ||
| d39a922482 | |||
| 6216664e18 | |||
| 54992234d5 | |||
| 90e81fb955 | |||
|
|
4012b33f98 | ||
| 33fb6ba2eb | |||
|
|
d1526fa49e | ||
| 5b5f8edc3b | |||
|
|
8515364ffd | ||
|
|
4ec6169ebd | ||
|
|
ec26abaeb5 | ||
| 3350f2ebf6 | |||
|
|
670e0e01f1 | ||
|
|
12d51dc689 | ||
|
|
860bc955a4 | ||
| 76bdbe28da | |||
| f4753505aa | |||
| ce9b94a534 | |||
|
|
e58210e770 | ||
| 6d49389bd4 | |||
|
|
9a964b4933 | ||
|
|
2ca0fe0697 | ||
| 10bcf5dd1f | |||
|
|
dda22594f1 | ||
|
|
802077371b | ||
| 6321f385da | |||
|
|
7cd463d4b7 | ||
| dda45e8e73 | |||
|
|
7f01cc3661 | ||
|
|
67fe2a1f0f | ||
|
|
1734f0e32f | ||
| 2fb41d0b9f | |||
|
|
6294b1d496 | ||
|
|
143037165a | ||
|
|
989d079601 | ||
|
|
03ba9493fc | ||
| c731b265ff |
3
.gitignore
vendored
3
.gitignore
vendored
@@ -350,4 +350,5 @@ MigrationBackup/
|
||||
.ionide/
|
||||
|
||||
# docker run data
|
||||
Docker/run/data/
|
||||
Docker/run/data/
|
||||
*.idea
|
||||
|
||||
Submodule LightlessAPI updated: dfb0594a5b...9feb0b3c35
@@ -1,7 +1,7 @@
|
||||
<Project Sdk="Microsoft.NET.Sdk.Web">
|
||||
|
||||
<PropertyGroup>
|
||||
<TargetFramework>net9.0</TargetFramework>
|
||||
<TargetFramework>net10.0</TargetFramework>
|
||||
<Nullable>enable</Nullable>
|
||||
<ImplicitUsings>enable</ImplicitUsings>
|
||||
</PropertyGroup>
|
||||
|
||||
@@ -0,0 +1,16 @@
|
||||
using System.Collections.Generic;
|
||||
|
||||
namespace LightlessSyncServer.Configuration;
|
||||
|
||||
public sealed class ChatZoneOverridesOptions
|
||||
{
|
||||
public List<ChatZoneOverride>? Zones { get; set; }
|
||||
}
|
||||
|
||||
public sealed class ChatZoneOverride
|
||||
{
|
||||
public string Key { get; set; } = string.Empty;
|
||||
public string? DisplayName { get; set; }
|
||||
public List<string>? TerritoryNames { get; set; }
|
||||
public List<ushort>? TerritoryIds { get; set; }
|
||||
}
|
||||
@@ -1,11 +1,7 @@
|
||||
using System;
|
||||
using System.Collections.Concurrent;
|
||||
using System.Collections.Generic;
|
||||
using System.Linq;
|
||||
using System.Text.Json;
|
||||
using LightlessSync.API.Data.Enum;
|
||||
using LightlessSync.API.Dto.Chat;
|
||||
using LightlessSync.API.Dto.User;
|
||||
using LightlessSyncServer.Models;
|
||||
using LightlessSyncServer.Services;
|
||||
using LightlessSyncServer.Utils;
|
||||
@@ -13,12 +9,11 @@ using LightlessSyncShared.Models;
|
||||
using Microsoft.AspNetCore.Authorization;
|
||||
using Microsoft.AspNetCore.SignalR;
|
||||
using Microsoft.EntityFrameworkCore;
|
||||
|
||||
namespace LightlessSyncServer.Hubs;
|
||||
|
||||
public partial class LightlessHub
|
||||
{
|
||||
private const int MaxChatMessageLength = 400;
|
||||
private const int MaxChatMessageLength = 200;
|
||||
private const int ChatRateLimitMessages = 7;
|
||||
private static readonly TimeSpan ChatRateLimitWindow = TimeSpan.FromMinutes(1);
|
||||
private static readonly ConcurrentDictionary<string, ChatRateLimitState> ChatRateLimiters = new(StringComparer.Ordinal);
|
||||
@@ -46,8 +41,10 @@ public partial class LightlessHub
|
||||
|
||||
var groupInfos = await DbContext.Groups
|
||||
.AsNoTracking()
|
||||
.Where(g => g.OwnerUID == userUid
|
||||
.Where(g => g.ChatEnabled
|
||||
&& (g.OwnerUID == userUid
|
||||
|| DbContext.GroupPairs.Any(p => p.GroupGID == g.GID && p.GroupUserUID == userUid))
|
||||
)
|
||||
.ToListAsync()
|
||||
.ConfigureAwait(false);
|
||||
|
||||
@@ -67,7 +64,7 @@ public partial class LightlessHub
|
||||
descriptor,
|
||||
displayName,
|
||||
g.GID,
|
||||
g.OwnerUID == userUid);
|
||||
string.Equals(g.OwnerUID, userUid, StringComparison.Ordinal));
|
||||
})
|
||||
.OrderBy(info => info.DisplayName, StringComparer.OrdinalIgnoreCase)
|
||||
.ToList();
|
||||
@@ -85,14 +82,18 @@ public partial class LightlessHub
|
||||
|
||||
if (userRecord.ChatBanned)
|
||||
{
|
||||
_chatChannelService.RemovePresence(UserUID);
|
||||
TryInvokeChatService(() => _chatChannelService.RemovePresence(UserUID), "clearing presence for banned user");
|
||||
await NotifyChatBanAsync(UserUID).ConfigureAwait(false);
|
||||
return;
|
||||
}
|
||||
|
||||
if (!presence.IsActive)
|
||||
{
|
||||
_chatChannelService.RemovePresence(UserUID, channel);
|
||||
if (!TryInvokeChatService(() => _chatChannelService.RemovePresence(UserUID, channel), "removing chat presence", channel))
|
||||
{
|
||||
await Clients.Caller.Client_ReceiveServerMessage(MessageSeverity.Error, "We couldn't update your chat presence. Please try again.").ConfigureAwait(false);
|
||||
}
|
||||
|
||||
return;
|
||||
}
|
||||
|
||||
@@ -126,14 +127,22 @@ public partial class LightlessHub
|
||||
}
|
||||
}
|
||||
|
||||
_chatChannelService.UpdateZonePresence(
|
||||
UserUID,
|
||||
definition,
|
||||
channel.WorldId,
|
||||
presence.TerritoryId,
|
||||
hashedCid,
|
||||
isLightfinder,
|
||||
isActive: true);
|
||||
if (!TryInvokeChatService(
|
||||
() => _chatChannelService.UpdateZonePresence(
|
||||
UserUID,
|
||||
definition,
|
||||
channel.WorldId,
|
||||
presence.TerritoryId,
|
||||
hashedCid,
|
||||
isLightfinder,
|
||||
isActive: true),
|
||||
"updating zone chat presence",
|
||||
channel))
|
||||
{
|
||||
await Clients.Caller.Client_ReceiveServerMessage(MessageSeverity.Error, "Zone chat is temporarily unavailable. Please try again.").ConfigureAwait(false);
|
||||
return;
|
||||
}
|
||||
|
||||
break;
|
||||
|
||||
case ChatChannelType.Group:
|
||||
@@ -155,6 +164,13 @@ public partial class LightlessHub
|
||||
throw new HubException("Unsupported chat channel.");
|
||||
}
|
||||
|
||||
if (!group.ChatEnabled)
|
||||
{
|
||||
TryInvokeChatService(() => _chatChannelService.RemovePresence(UserUID, channel), "removing chat presence", channel);
|
||||
await Clients.Caller.Client_ReceiveServerMessage(MessageSeverity.Warning, "This Syncshell chat is disabled.").ConfigureAwait(false);
|
||||
return;
|
||||
}
|
||||
|
||||
var isMember = string.Equals(group.OwnerUID, UserUID, StringComparison.Ordinal)
|
||||
|| await DbContext.GroupPairs
|
||||
.AsNoTracking()
|
||||
@@ -168,13 +184,21 @@ public partial class LightlessHub
|
||||
|
||||
var displayName = string.IsNullOrWhiteSpace(group.Alias) ? group.GID : group.Alias;
|
||||
|
||||
_chatChannelService.UpdateGroupPresence(
|
||||
UserUID,
|
||||
group.GID,
|
||||
displayName,
|
||||
userData,
|
||||
IsValidHashedCid(UserCharaIdent) ? UserCharaIdent : null,
|
||||
isActive: true);
|
||||
if (!TryInvokeChatService(
|
||||
() => _chatChannelService.UpdateGroupPresence(
|
||||
UserUID,
|
||||
group.GID,
|
||||
displayName,
|
||||
userData,
|
||||
IsValidHashedCid(UserCharaIdent) ? UserCharaIdent : null,
|
||||
isActive: true),
|
||||
"updating group chat presence",
|
||||
channel))
|
||||
{
|
||||
await Clients.Caller.Client_ReceiveServerMessage(MessageSeverity.Error, "Syncshell chat is temporarily unavailable. Please try again.").ConfigureAwait(false);
|
||||
return;
|
||||
}
|
||||
|
||||
break;
|
||||
|
||||
default:
|
||||
@@ -192,6 +216,23 @@ public partial class LightlessHub
|
||||
|
||||
var channel = request.Channel.WithNormalizedCustomKey();
|
||||
|
||||
if (channel.Type == ChatChannelType.Group)
|
||||
{
|
||||
var groupId = channel.CustomKey ?? string.Empty;
|
||||
var chatEnabled = !string.IsNullOrEmpty(groupId) && await DbContext.Groups
|
||||
.AsNoTracking()
|
||||
.Where(g => g.GID == groupId)
|
||||
.Select(g => g.ChatEnabled)
|
||||
.SingleOrDefaultAsync(RequestAbortedToken)
|
||||
.ConfigureAwait(false);
|
||||
|
||||
if (!chatEnabled)
|
||||
{
|
||||
await Clients.Caller.Client_ReceiveServerMessage(MessageSeverity.Warning, "This Syncshell chat is disabled.").ConfigureAwait(false);
|
||||
return;
|
||||
}
|
||||
}
|
||||
|
||||
if (await HandleIfChatBannedAsync(UserUID).ConfigureAwait(false))
|
||||
{
|
||||
throw new HubException("Chat access has been revoked.");
|
||||
@@ -214,119 +255,101 @@ public partial class LightlessHub
|
||||
sanitizedMessage = sanitizedMessage[..MaxChatMessageLength];
|
||||
}
|
||||
|
||||
var recipients = _chatChannelService.GetMembers(presence.Channel);
|
||||
var recipientsList = recipients.ToList();
|
||||
if (recipientsList.Count == 0)
|
||||
if (channel.Type == ChatChannelType.Zone &&
|
||||
!ChatMessageFilter.TryValidate(sanitizedMessage, out var rejectionReason))
|
||||
{
|
||||
await Clients.Caller.Client_ReceiveServerMessage(MessageSeverity.Warning, rejectionReason).ConfigureAwait(false);
|
||||
return;
|
||||
}
|
||||
|
||||
var bannedRecipients = recipientsList.Count == 0
|
||||
? new List<string>()
|
||||
: await DbContext.Users.AsNoTracking()
|
||||
.Where(u => recipientsList.Contains(u.UID) && u.ChatBanned)
|
||||
.Select(u => u.UID)
|
||||
.ToListAsync(RequestAbortedToken)
|
||||
.ConfigureAwait(false);
|
||||
|
||||
HashSet<string>? bannedSet = null;
|
||||
if (bannedRecipients.Count > 0)
|
||||
try
|
||||
{
|
||||
bannedSet = new HashSet<string>(bannedRecipients, StringComparer.Ordinal);
|
||||
foreach (var bannedUid in bannedSet)
|
||||
var recipients = _chatChannelService.GetMembers(presence.Channel);
|
||||
var recipientsList = recipients.ToList();
|
||||
if (recipientsList.Count == 0)
|
||||
{
|
||||
_chatChannelService.RemovePresence(bannedUid);
|
||||
await NotifyChatBanAsync(bannedUid).ConfigureAwait(false);
|
||||
}
|
||||
}
|
||||
|
||||
var deliveryTargets = new Dictionary<string, (string Uid, bool IncludeSensitive)>(StringComparer.Ordinal);
|
||||
foreach (var uid in recipientsList)
|
||||
{
|
||||
if (bannedSet != null && bannedSet.Contains(uid))
|
||||
{
|
||||
continue;
|
||||
return;
|
||||
}
|
||||
|
||||
if (_userConnections.TryGetValue(uid, out var connectionId))
|
||||
var bannedRecipients = recipientsList.Count == 0
|
||||
? new List<string>()
|
||||
: await DbContext.Users.AsNoTracking()
|
||||
.Where(u => recipientsList.Contains(u.UID) && u.ChatBanned)
|
||||
.Select(u => u.UID)
|
||||
.ToListAsync(RequestAbortedToken)
|
||||
.ConfigureAwait(false);
|
||||
|
||||
HashSet<string>? bannedSet = null;
|
||||
if (bannedRecipients.Count > 0)
|
||||
{
|
||||
var includeSensitive = await AllowsLightfinderDetailsAsync(presence.Channel, uid).ConfigureAwait(false);
|
||||
if (deliveryTargets.TryGetValue(connectionId, out var existing))
|
||||
bannedSet = new HashSet<string>(bannedRecipients, StringComparer.Ordinal);
|
||||
foreach (var bannedUid in bannedSet)
|
||||
{
|
||||
deliveryTargets[connectionId] = (existing.Uid, existing.IncludeSensitive || includeSensitive);
|
||||
_chatChannelService.RemovePresence(bannedUid);
|
||||
await NotifyChatBanAsync(bannedUid).ConfigureAwait(false);
|
||||
}
|
||||
}
|
||||
|
||||
var deliveryTargets = new Dictionary<string, (string Uid, bool IncludeSensitive)>(StringComparer.Ordinal);
|
||||
foreach (var uid in recipientsList)
|
||||
{
|
||||
if (bannedSet != null && bannedSet.Contains(uid))
|
||||
{
|
||||
continue;
|
||||
}
|
||||
|
||||
if (_userConnections.TryGetValue(uid, out var connectionId))
|
||||
{
|
||||
if (_chatChannelService.IsTokenMuted(uid, presence.Channel, presence.Participant.Token))
|
||||
{
|
||||
continue;
|
||||
}
|
||||
|
||||
var includeSensitive = await AllowsLightfinderDetailsAsync(presence.Channel, uid).ConfigureAwait(false);
|
||||
if (deliveryTargets.TryGetValue(connectionId, out var existing))
|
||||
{
|
||||
deliveryTargets[connectionId] = (existing.Uid, existing.IncludeSensitive || includeSensitive);
|
||||
}
|
||||
else
|
||||
{
|
||||
deliveryTargets[connectionId] = (uid, includeSensitive);
|
||||
}
|
||||
}
|
||||
else
|
||||
{
|
||||
deliveryTargets[connectionId] = (uid, includeSensitive);
|
||||
_chatChannelService.RemovePresence(uid);
|
||||
}
|
||||
}
|
||||
else
|
||||
|
||||
if (deliveryTargets.Count == 0)
|
||||
{
|
||||
_chatChannelService.RemovePresence(uid);
|
||||
return;
|
||||
}
|
||||
}
|
||||
|
||||
if (deliveryTargets.Count == 0)
|
||||
var timestamp = DateTime.UtcNow;
|
||||
var messageId = _chatChannelService.RecordMessage(presence.Channel, presence.Participant, sanitizedMessage, timestamp);
|
||||
var sendTasks = new List<Task>(deliveryTargets.Count);
|
||||
|
||||
foreach (var (connectionId, target) in deliveryTargets)
|
||||
{
|
||||
var sender = BuildSenderDescriptor(presence.Channel, presence.Participant, target.IncludeSensitive);
|
||||
var payload = new ChatMessageDto(
|
||||
presence.Channel,
|
||||
sender,
|
||||
sanitizedMessage,
|
||||
timestamp,
|
||||
messageId);
|
||||
|
||||
sendTasks.Add(Clients.Client(connectionId).Client_ChatReceive(payload));
|
||||
}
|
||||
|
||||
await Task.WhenAll(sendTasks).ConfigureAwait(false);
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
return;
|
||||
_logger.LogError(ex, "Failed to deliver chat message for {User} in {Channel}", UserUID, DescribeChannel(presence.Channel));
|
||||
await Clients.Caller.Client_ReceiveServerMessage(MessageSeverity.Error, "Something went wrong while sending your message. Please try again.").ConfigureAwait(false);
|
||||
}
|
||||
|
||||
var timestamp = DateTime.UtcNow;
|
||||
var messageId = _chatChannelService.RecordMessage(presence.Channel, presence.Participant, sanitizedMessage, timestamp);
|
||||
var sendTasks = new List<Task>(deliveryTargets.Count);
|
||||
|
||||
foreach (var (connectionId, target) in deliveryTargets)
|
||||
{
|
||||
var sender = BuildSenderDescriptor(presence.Channel, presence.Participant, target.IncludeSensitive);
|
||||
var payload = new ChatMessageDto(
|
||||
presence.Channel,
|
||||
sender,
|
||||
sanitizedMessage,
|
||||
timestamp,
|
||||
messageId);
|
||||
|
||||
sendTasks.Add(Clients.Client(connectionId).Client_ChatReceive(payload));
|
||||
}
|
||||
|
||||
await Task.WhenAll(sendTasks).ConfigureAwait(false);
|
||||
}
|
||||
|
||||
[Authorize(Policy = "Identified")]
|
||||
public async Task<ChatParticipantResolveResultDto?> ResolveChatParticipant(ChatParticipantResolveRequestDto request)
|
||||
{
|
||||
var channel = request.Channel.WithNormalizedCustomKey();
|
||||
|
||||
if (!_chatChannelService.TryGetPresence(UserUID, channel, out _))
|
||||
{
|
||||
throw new HubException("Join the chat channel before resolving participants.");
|
||||
}
|
||||
|
||||
if (!_chatChannelService.TryResolveParticipant(channel, request.Token, out var participant))
|
||||
{
|
||||
return null;
|
||||
}
|
||||
|
||||
var viewerAllowsDetails = await ViewerAllowsLightfinderDetailsAsync(channel).ConfigureAwait(false);
|
||||
var includeSensitiveInfo = channel.Type == ChatChannelType.Group || viewerAllowsDetails;
|
||||
|
||||
var sender = BuildSenderDescriptor(channel, participant, includeSensitiveInfo);
|
||||
|
||||
if (!includeSensitiveInfo)
|
||||
{
|
||||
return new ChatParticipantResolveResultDto(channel, sender, null);
|
||||
}
|
||||
|
||||
UserProfileDto? profile = null;
|
||||
if (channel.Type == ChatChannelType.Group)
|
||||
{
|
||||
profile = await LoadChatParticipantProfileAsync(participant.UserUid).ConfigureAwait(false);
|
||||
}
|
||||
else if (participant.IsLightfinder && !string.IsNullOrEmpty(participant.HashedCid))
|
||||
{
|
||||
profile = await LoadChatParticipantProfileAsync(participant.UserUid).ConfigureAwait(false);
|
||||
}
|
||||
|
||||
return new ChatParticipantResolveResultDto(channel, sender, profile);
|
||||
}
|
||||
|
||||
[Authorize(Policy = "Identified")]
|
||||
@@ -334,12 +357,6 @@ public partial class LightlessHub
|
||||
{
|
||||
var channel = request.Channel.WithNormalizedCustomKey();
|
||||
|
||||
if (!_chatChannelService.TryGetPresence(UserUID, channel, out _))
|
||||
{
|
||||
await Clients.Caller.Client_ReceiveServerMessage(MessageSeverity.Error, "Join the chat channel before reporting messages.").ConfigureAwait(false);
|
||||
return;
|
||||
}
|
||||
|
||||
if (!_chatChannelService.TryGetMessage(request.MessageId, out var messageEntry))
|
||||
{
|
||||
await Clients.Caller.Client_ReceiveServerMessage(MessageSeverity.Error, "Unable to locate the reported message. It may have already expired.").ConfigureAwait(false);
|
||||
@@ -406,7 +423,7 @@ public partial class LightlessHub
|
||||
return;
|
||||
}
|
||||
|
||||
if (!string.IsNullOrEmpty(messageEntry.SenderUserUid))
|
||||
/* if (!string.IsNullOrEmpty(messageEntry.SenderUserUid))
|
||||
{
|
||||
var targetAlreadyPending = await DbContext.ReportedChatMessages
|
||||
.AsNoTracking()
|
||||
@@ -418,7 +435,7 @@ public partial class LightlessHub
|
||||
await Clients.Caller.Client_ReceiveServerMessage(MessageSeverity.Information, "This user already has a report pending review.").ConfigureAwait(false);
|
||||
return;
|
||||
}
|
||||
}
|
||||
} */
|
||||
|
||||
var snapshotEntries = _chatChannelService.GetRecentMessages(messageEntry.Channel, 25);
|
||||
var snapshotItems = snapshotEntries
|
||||
@@ -446,7 +463,6 @@ public partial class LightlessHub
|
||||
MessageId = messageEntry.MessageId,
|
||||
MessageSentAtUtc = messageEntry.SentAtUtc,
|
||||
MessageContent = messageEntry.Message,
|
||||
SenderToken = messageEntry.SenderToken,
|
||||
SenderHashedCid = messageEntry.SenderHashedCid,
|
||||
SenderDisplayName = messageEntry.SenderUser?.AliasOrUID,
|
||||
SenderWasLightfinder = messageEntry.SenderIsLightfinder,
|
||||
@@ -461,6 +477,91 @@ public partial class LightlessHub
|
||||
await Clients.Caller.Client_ReceiveServerMessage(MessageSeverity.Information, "Thank you. Your report has been queued for moderator review.").ConfigureAwait(false);
|
||||
}
|
||||
|
||||
[Authorize(Policy = "Identified")]
|
||||
public async Task SetChatParticipantMute(ChatParticipantMuteRequestDto request)
|
||||
{
|
||||
var channel = request.Channel.WithNormalizedCustomKey();
|
||||
|
||||
if (!_chatChannelService.TryGetPresence(UserUID, channel, out _))
|
||||
{
|
||||
throw new HubException("Join the chat channel before updating mutes.");
|
||||
}
|
||||
|
||||
if (string.IsNullOrWhiteSpace(request.Token))
|
||||
{
|
||||
throw new HubException("Invalid participant.");
|
||||
}
|
||||
|
||||
if (!_chatChannelService.TryGetActiveParticipant(channel, request.Token, out var participant))
|
||||
{
|
||||
throw new HubException("Unable to locate that participant in this channel.");
|
||||
}
|
||||
|
||||
if (string.Equals(participant.UserUid, UserUID, StringComparison.Ordinal))
|
||||
{
|
||||
await Clients.Caller.Client_ReceiveServerMessage(MessageSeverity.Warning, "You cannot mute yourself.").ConfigureAwait(false);
|
||||
return;
|
||||
}
|
||||
|
||||
ChatMuteUpdateResult result;
|
||||
try
|
||||
{
|
||||
result = _chatChannelService.SetMutedParticipant(UserUID, channel, participant, request.Mute);
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
_logger.LogError(ex, "Failed to update mute for {User} in {Channel}", UserUID, DescribeChannel(channel));
|
||||
await Clients.Caller.Client_ReceiveServerMessage(MessageSeverity.Error, "Unable to update mute settings right now. Please try again.").ConfigureAwait(false);
|
||||
return;
|
||||
}
|
||||
|
||||
if (result == ChatMuteUpdateResult.ChannelLimitReached)
|
||||
{
|
||||
await Clients.Caller.Client_ReceiveServerMessage(MessageSeverity.Warning, $"You can mute at most {ChatChannelService.MaxMutedParticipantsPerChannel} participants per channel. Unmute someone before adding another mute.").ConfigureAwait(false);
|
||||
return;
|
||||
}
|
||||
|
||||
if (result != ChatMuteUpdateResult.Changed)
|
||||
{
|
||||
return;
|
||||
}
|
||||
|
||||
if (request.Mute)
|
||||
{
|
||||
await Clients.Caller.Client_ReceiveServerMessage(MessageSeverity.Information, "You will no longer receive this participant's messages in the current channel.").ConfigureAwait(false);
|
||||
}
|
||||
else
|
||||
{
|
||||
await Clients.Caller.Client_ReceiveServerMessage(MessageSeverity.Information, "You will receive this participant's messages again.").ConfigureAwait(false);
|
||||
}
|
||||
}
|
||||
|
||||
private static string DescribeChannel(ChatChannelDescriptor descriptor) =>
|
||||
$"{descriptor.Type}:{descriptor.WorldId}:{descriptor.CustomKey}";
|
||||
|
||||
private bool TryInvokeChatService(Action action, string operationDescription, ChatChannelDescriptor? descriptor = null, string? targetUserUid = null)
|
||||
{
|
||||
try
|
||||
{
|
||||
action();
|
||||
return true;
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
var logUser = targetUserUid ?? UserUID;
|
||||
if (descriptor is ChatChannelDescriptor described)
|
||||
{
|
||||
_logger.LogError(ex, "Chat service failed while {Operation} for {User} in {Channel}", operationDescription, logUser, DescribeChannel(described));
|
||||
}
|
||||
else
|
||||
{
|
||||
_logger.LogError(ex, "Chat service failed while {Operation} for {User}", operationDescription, logUser);
|
||||
}
|
||||
|
||||
return false;
|
||||
}
|
||||
}
|
||||
|
||||
private ChatSenderDescriptor BuildSenderDescriptor(ChatChannelDescriptor descriptor, ChatParticipantInfo participant, bool includeSensitiveInfo = false)
|
||||
{
|
||||
var kind = descriptor.Type == ChatChannelType.Group
|
||||
@@ -487,7 +588,7 @@ public partial class LightlessHub
|
||||
? participant.HashedCid
|
||||
: null;
|
||||
|
||||
var canResolveProfile = kind == ChatSenderKind.IdentifiedUser || participant.IsLightfinder;
|
||||
var canResolveProfile = includeSensitiveInfo && (kind == ChatSenderKind.IdentifiedUser || participant.IsLightfinder);
|
||||
|
||||
return new ChatSenderDescriptor(
|
||||
kind,
|
||||
@@ -498,44 +599,6 @@ public partial class LightlessHub
|
||||
canResolveProfile);
|
||||
}
|
||||
|
||||
private async Task<UserProfileDto?> LoadChatParticipantProfileAsync(string userUid)
|
||||
{
|
||||
if (string.IsNullOrEmpty(userUid))
|
||||
return null;
|
||||
|
||||
var targetUser = await DbContext.Users
|
||||
.AsNoTracking()
|
||||
.SingleOrDefaultAsync(u => u.UID == userUid, cancellationToken: RequestAbortedToken)
|
||||
.ConfigureAwait(false);
|
||||
|
||||
if (targetUser is null)
|
||||
return null;
|
||||
|
||||
var userData = targetUser.ToUserData();
|
||||
|
||||
var profileData = await DbContext.UserProfileData
|
||||
.AsNoTracking()
|
||||
.SingleOrDefaultAsync(p => p.UserUID == userUid, cancellationToken: RequestAbortedToken)
|
||||
.ConfigureAwait(false);
|
||||
|
||||
if (profileData is null)
|
||||
{
|
||||
return new UserProfileDto(userData, Disabled: false, IsNSFW: null, ProfilePictureBase64: null, BannerPictureBase64: null, Description: null, Tags: Array.Empty<int>());
|
||||
}
|
||||
|
||||
if (profileData.FlaggedForReport)
|
||||
{
|
||||
return new UserProfileDto(userData, Disabled: true, IsNSFW: null, ProfilePictureBase64: null, BannerPictureBase64: null, Description: "This profile is flagged for report and pending evaluation", Tags: Array.Empty<int>());
|
||||
}
|
||||
|
||||
if (profileData.ProfileDisabled)
|
||||
{
|
||||
return new UserProfileDto(userData, Disabled: true, IsNSFW: null, ProfilePictureBase64: null, BannerPictureBase64: null, Description: "This profile was permanently disabled", Tags: Array.Empty<int>());
|
||||
}
|
||||
|
||||
return profileData.ToDTO();
|
||||
}
|
||||
|
||||
private async Task<bool> ViewerAllowsLightfinderDetailsAsync(ChatChannelDescriptor descriptor)
|
||||
{
|
||||
if (descriptor.Type == ChatChannelType.Group)
|
||||
@@ -570,7 +633,11 @@ public partial class LightlessHub
|
||||
var (entry, expiry) = await TryGetBroadcastEntryAsync(presence.Participant.HashedCid!).ConfigureAwait(false);
|
||||
if (!IsActiveBroadcastForUser(entry, expiry, userUid))
|
||||
{
|
||||
_chatChannelService.RefreshLightfinderState(userUid, null, isLightfinder: false);
|
||||
TryInvokeChatService(
|
||||
() => _chatChannelService.RefreshLightfinderState(userUid, null, isLightfinder: false),
|
||||
"refreshing lightfinder state",
|
||||
descriptor,
|
||||
userUid);
|
||||
return false;
|
||||
}
|
||||
|
||||
@@ -590,7 +657,7 @@ public partial class LightlessHub
|
||||
if (!isBanned)
|
||||
return false;
|
||||
|
||||
_chatChannelService.RemovePresence(userUid);
|
||||
TryInvokeChatService(() => _chatChannelService.RemovePresence(userUid), "clearing presence for chat-banned user", targetUserUid: userUid);
|
||||
await NotifyChatBanAsync(userUid).ConfigureAwait(false);
|
||||
return true;
|
||||
}
|
||||
|
||||
@@ -40,5 +40,6 @@ namespace LightlessSyncServer.Hubs
|
||||
public Task Client_GposeLobbyPushPoseData(UserData userData, PoseData poseData) => throw new PlatformNotSupportedException("Calling clientside method on server not supported");
|
||||
public Task Client_GposeLobbyPushWorldData(UserData userData, WorldData worldData) => throw new PlatformNotSupportedException("Calling clientside method on server not supported");
|
||||
public Task Client_ChatReceive(ChatMessageDto message) => throw new PlatformNotSupportedException("Calling clientside method on server not supported");
|
||||
public Task Client_SendLocationToClient(LocationDto locationDto) => throw new PlatformNotSupportedException("Calling clientside method on server not supported");
|
||||
}
|
||||
}
|
||||
@@ -152,7 +152,7 @@ public partial class LightlessHub
|
||||
BroadcastRedisEntry? entry;
|
||||
try
|
||||
{
|
||||
entry = JsonSerializer.Deserialize<BroadcastRedisEntry>(broadcastValue!);
|
||||
entry = JsonSerializer.Deserialize<BroadcastRedisEntry>(broadcastValue.ToString()!);
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
@@ -585,6 +585,11 @@ public partial class LightlessHub
|
||||
|
||||
return await result.Distinct().AsNoTracking().ToListAsync().ConfigureAwait(false);
|
||||
}
|
||||
|
||||
private async Task CleanVisibilityCacheFromRedis()
|
||||
{
|
||||
await _redis.RemoveAsync($"Visibility:{UserUID}", CommandFlags.FireAndForget).ConfigureAwait(false);
|
||||
}
|
||||
|
||||
public record UserInfo(
|
||||
string Alias,
|
||||
|
||||
@@ -1,6 +1,7 @@
|
||||
using LightlessSync.API.Data;
|
||||
using LightlessSync.API.Data.Enum;
|
||||
using LightlessSync.API.Data.Extensions;
|
||||
using LightlessSync.API.Dto.Chat;
|
||||
using LightlessSync.API.Dto.Group;
|
||||
using LightlessSync.API.Dto.User;
|
||||
using LightlessSyncServer.Models;
|
||||
@@ -11,10 +12,8 @@ using LightlessSyncShared.Utils;
|
||||
using Microsoft.AspNetCore.Authorization;
|
||||
using Microsoft.AspNetCore.SignalR;
|
||||
using Microsoft.EntityFrameworkCore;
|
||||
using Newtonsoft.Json.Linq;
|
||||
using SixLabors.ImageSharp;
|
||||
using SixLabors.ImageSharp.PixelFormats;
|
||||
using System.Reflection;
|
||||
using System.Collections.Concurrent;
|
||||
using System.Security.Cryptography;
|
||||
|
||||
namespace LightlessSyncServer.Hubs;
|
||||
@@ -52,6 +51,8 @@ public partial class LightlessHub
|
||||
_logger.LogCallInfo(LightlessHubLogger.Args(dto, "Success"));
|
||||
}
|
||||
|
||||
private static readonly ConcurrentDictionary<string, DateTime> GroupChatToggleCooldowns = new(StringComparer.Ordinal);
|
||||
|
||||
[Authorize(Policy = "Identified")]
|
||||
public async Task GroupChangeGroupPermissionState(GroupPermissionDto dto)
|
||||
{
|
||||
@@ -60,15 +61,73 @@ public partial class LightlessHub
|
||||
var (hasRights, group) = await TryValidateGroupModeratorOrOwner(dto.Group.GID).ConfigureAwait(false);
|
||||
if (!hasRights) return;
|
||||
|
||||
group.InvitesEnabled = !dto.Permissions.HasFlag(GroupPermissions.DisableInvites);
|
||||
group.PreferDisableSounds = dto.Permissions.HasFlag(GroupPermissions.PreferDisableSounds);
|
||||
group.PreferDisableAnimations = dto.Permissions.HasFlag(GroupPermissions.PreferDisableAnimations);
|
||||
group.PreferDisableVFX = dto.Permissions.HasFlag(GroupPermissions.PreferDisableVFX);
|
||||
var permissions = dto.Permissions;
|
||||
var isOwner = string.Equals(group.OwnerUID, UserUID, StringComparison.Ordinal);
|
||||
var chatEnabled = group.ChatEnabled;
|
||||
var chatChanged = false;
|
||||
|
||||
if (!isOwner)
|
||||
{
|
||||
permissions.SetDisableChat(!group.ChatEnabled);
|
||||
}
|
||||
else
|
||||
{
|
||||
var requestedChatEnabled = !permissions.IsDisableChat();
|
||||
if (requestedChatEnabled != group.ChatEnabled)
|
||||
{
|
||||
var now = DateTime.UtcNow;
|
||||
if (GroupChatToggleCooldowns.TryGetValue(group.GID, out var lockedUntil) && lockedUntil > now)
|
||||
{
|
||||
var remaining = lockedUntil - now;
|
||||
var minutes = Math.Max(1, (int)Math.Ceiling(remaining.TotalMinutes));
|
||||
await Clients.Caller.Client_ReceiveServerMessage(
|
||||
MessageSeverity.Warning,
|
||||
$"Syncshell chat can be toggled again in {minutes} minute{(minutes == 1 ? string.Empty : "s")}."
|
||||
).ConfigureAwait(false);
|
||||
permissions.SetDisableChat(!group.ChatEnabled);
|
||||
}
|
||||
else
|
||||
{
|
||||
chatEnabled = requestedChatEnabled;
|
||||
group.ChatEnabled = chatEnabled;
|
||||
GroupChatToggleCooldowns[group.GID] = now.AddMinutes(5);
|
||||
chatChanged = true;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
group.InvitesEnabled = !permissions.HasFlag(GroupPermissions.DisableInvites);
|
||||
group.PreferDisableSounds = permissions.HasFlag(GroupPermissions.PreferDisableSounds);
|
||||
group.PreferDisableAnimations = permissions.HasFlag(GroupPermissions.PreferDisableAnimations);
|
||||
group.PreferDisableVFX = permissions.HasFlag(GroupPermissions.PreferDisableVFX);
|
||||
|
||||
await DbContext.SaveChangesAsync(RequestAbortedToken).ConfigureAwait(false);
|
||||
|
||||
var groupPairs = DbContext.GroupPairs.Where(p => p.GroupGID == dto.Group.GID).Select(p => p.GroupUserUID).ToList();
|
||||
await Clients.Users(groupPairs).Client_GroupChangePermissions(new GroupPermissionDto(dto.Group, dto.Permissions)).ConfigureAwait(false);
|
||||
await Clients.Users(groupPairs).Client_GroupChangePermissions(new GroupPermissionDto(dto.Group, permissions)).ConfigureAwait(false);
|
||||
|
||||
if (isOwner && chatChanged && !chatEnabled)
|
||||
{
|
||||
var groupDisplayName = string.IsNullOrWhiteSpace(group.Alias) ? group.GID : group.Alias;
|
||||
var descriptor = new ChatChannelDescriptor
|
||||
{
|
||||
Type = ChatChannelType.Group,
|
||||
WorldId = 0,
|
||||
ZoneId = 0,
|
||||
CustomKey = group.GID
|
||||
};
|
||||
|
||||
foreach (var uid in groupPairs)
|
||||
{
|
||||
TryInvokeChatService(() => _chatChannelService.RemovePresence(uid, descriptor), "removing group chat presence", descriptor, uid);
|
||||
}
|
||||
|
||||
await Clients.Users(groupPairs)
|
||||
.Client_ReceiveServerMessage(
|
||||
MessageSeverity.Information,
|
||||
$"Syncshell chat for '{groupDisplayName}' has been disabled.")
|
||||
.ConfigureAwait(false);
|
||||
}
|
||||
}
|
||||
|
||||
[Authorize(Policy = "Identified")]
|
||||
@@ -235,6 +294,7 @@ public partial class LightlessHub
|
||||
PreferDisableAnimations = defaultPermissions.DisableGroupAnimations,
|
||||
PreferDisableSounds = defaultPermissions.DisableGroupSounds,
|
||||
PreferDisableVFX = defaultPermissions.DisableGroupVFX,
|
||||
ChatEnabled = true,
|
||||
CreatedDate = currentTime,
|
||||
};
|
||||
|
||||
@@ -444,6 +504,7 @@ public partial class LightlessHub
|
||||
preferredPermissions.DisableVFX = dto.GroupUserPreferredPermissions.IsDisableVFX();
|
||||
preferredPermissions.DisableAnimations = dto.GroupUserPreferredPermissions.IsDisableAnimations();
|
||||
preferredPermissions.IsPaused = false;
|
||||
preferredPermissions.ShareLocation = dto.GroupUserPreferredPermissions.IsSharingLocation();
|
||||
DbContext.Update(preferredPermissions);
|
||||
}
|
||||
|
||||
@@ -489,7 +550,8 @@ public partial class LightlessHub
|
||||
DisableSounds = preferredPermissions.DisableSounds,
|
||||
DisableVFX = preferredPermissions.DisableVFX,
|
||||
IsPaused = preferredPermissions.IsPaused,
|
||||
Sticky = false
|
||||
Sticky = false,
|
||||
ShareLocation = preferredPermissions.ShareLocation,
|
||||
};
|
||||
|
||||
await DbContext.Permissions.AddAsync(ownPermissionsToOther).ConfigureAwait(false);
|
||||
@@ -501,6 +563,7 @@ public partial class LightlessHub
|
||||
existingPermissionsOnDb.DisableVFX = preferredPermissions.DisableVFX;
|
||||
existingPermissionsOnDb.IsPaused = false;
|
||||
existingPermissionsOnDb.Sticky = false;
|
||||
existingPermissionsOnDb.ShareLocation = preferredPermissions.ShareLocation;
|
||||
|
||||
DbContext.Update(existingPermissionsOnDb);
|
||||
|
||||
@@ -516,6 +579,7 @@ public partial class LightlessHub
|
||||
ownPermissionsToOther.DisableVFX = preferredPermissions.DisableVFX;
|
||||
ownPermissionsToOther.DisableSounds = preferredPermissions.DisableSounds;
|
||||
ownPermissionsToOther.IsPaused = false;
|
||||
ownPermissionsToOther.ShareLocation = preferredPermissions.ShareLocation;
|
||||
|
||||
DbContext.Update(ownPermissionsToOther);
|
||||
}
|
||||
@@ -537,7 +601,8 @@ public partial class LightlessHub
|
||||
DisableSounds = otherPreferred.DisableSounds,
|
||||
DisableVFX = otherPreferred.DisableVFX,
|
||||
IsPaused = otherPreferred.IsPaused,
|
||||
Sticky = false
|
||||
Sticky = false,
|
||||
ShareLocation = otherPreferred.ShareLocation,
|
||||
};
|
||||
|
||||
await DbContext.AddAsync(otherExistingPermsOnDb).ConfigureAwait(false);
|
||||
@@ -549,6 +614,7 @@ public partial class LightlessHub
|
||||
otherExistingPermsOnDb.DisableSounds = otherPreferred.DisableSounds;
|
||||
otherExistingPermsOnDb.DisableVFX = otherPreferred.DisableVFX;
|
||||
otherExistingPermsOnDb.IsPaused = otherPreferred.IsPaused;
|
||||
otherExistingPermsOnDb.ShareLocation = otherPreferred.ShareLocation;
|
||||
|
||||
DbContext.Update(otherExistingPermsOnDb);
|
||||
}
|
||||
@@ -562,6 +628,7 @@ public partial class LightlessHub
|
||||
otherPermissionToSelf.DisableSounds = otherPreferred.DisableSounds;
|
||||
otherPermissionToSelf.DisableVFX = otherPreferred.DisableVFX;
|
||||
otherPermissionToSelf.IsPaused = otherPreferred.IsPaused;
|
||||
otherPermissionToSelf.ShareLocation = otherPreferred.ShareLocation;
|
||||
|
||||
DbContext.Update(otherPermissionToSelf);
|
||||
}
|
||||
@@ -864,12 +931,6 @@ public partial class LightlessHub
|
||||
{
|
||||
groupProfileDb.Group ??= group;
|
||||
|
||||
if (groupProfileDb?.ProfileDisabled ?? false)
|
||||
{
|
||||
await Clients.Caller.Client_ReceiveServerMessage(MessageSeverity.Error, "Your profile was permanently disabled and cannot be edited").ConfigureAwait(false);
|
||||
return;
|
||||
}
|
||||
|
||||
groupProfileDb.UpdateProfileFromDto(dto, sanitizedProfileImage, sanitizedBannerImage);
|
||||
}
|
||||
|
||||
|
||||
@@ -66,6 +66,7 @@ public partial class LightlessHub
|
||||
prevPermissions.DisableSounds = newPerm.IsDisableSounds();
|
||||
prevPermissions.DisableVFX = newPerm.IsDisableVFX();
|
||||
prevPermissions.Sticky = newPerm.IsSticky() || setSticky;
|
||||
prevPermissions.ShareLocation = newPerm.IsSharingLocation();
|
||||
DbContext.Update(prevPermissions);
|
||||
|
||||
// send updated data to pair
|
||||
@@ -112,6 +113,7 @@ public partial class LightlessHub
|
||||
groupPreferredPermissions.DisableAnimations = group.Value.IsDisableAnimations();
|
||||
groupPreferredPermissions.IsPaused = group.Value.IsPaused();
|
||||
groupPreferredPermissions.DisableVFX = group.Value.IsDisableVFX();
|
||||
groupPreferredPermissions.ShareLocation = group.Value.IsSharingLocation();
|
||||
|
||||
var nonStickyPairs = allUsers.Where(u => !u.Value.OwnPermissions.Sticky).ToList();
|
||||
var affectedGroupPairs = nonStickyPairs.Where(u => u.Value.GIDs.Contains(group.Key, StringComparer.Ordinal)).ToList();
|
||||
@@ -126,6 +128,7 @@ public partial class LightlessHub
|
||||
perm.DisableAnimations = groupPreferredPermissions.DisableAnimations;
|
||||
perm.IsPaused = groupPreferredPermissions.IsPaused;
|
||||
perm.DisableVFX = groupPreferredPermissions.DisableVFX;
|
||||
perm.ShareLocation = groupPreferredPermissions.ShareLocation;
|
||||
}
|
||||
|
||||
UserPermissions permissions = UserPermissions.NoneSet;
|
||||
@@ -133,6 +136,7 @@ public partial class LightlessHub
|
||||
permissions.SetDisableAnimations(groupPreferredPermissions.DisableAnimations);
|
||||
permissions.SetDisableSounds(groupPreferredPermissions.DisableSounds);
|
||||
permissions.SetDisableVFX(groupPreferredPermissions.DisableVFX);
|
||||
permissions.SetShareLocation(groupPreferredPermissions.ShareLocation);
|
||||
|
||||
await Clients.Users(affectedGroupPairs
|
||||
.Select(k => k.Key))
|
||||
|
||||
@@ -86,7 +86,8 @@ public partial class LightlessHub
|
||||
DisableSounds = ownDefaultPermissions.DisableIndividualSounds,
|
||||
DisableVFX = ownDefaultPermissions.DisableIndividualVFX,
|
||||
IsPaused = false,
|
||||
Sticky = true
|
||||
Sticky = true,
|
||||
ShareLocation = false,
|
||||
};
|
||||
|
||||
var existingDbPerms = await DbContext.Permissions.SingleOrDefaultAsync(u => u.UserUID == UserUID && u.OtherUserUID == otherUser.UID, cancellationToken: RequestAbortedToken).ConfigureAwait(false);
|
||||
@@ -101,6 +102,7 @@ public partial class LightlessHub
|
||||
existingDbPerms.DisableVFX = permissions.DisableVFX;
|
||||
existingDbPerms.IsPaused = false;
|
||||
existingDbPerms.Sticky = true;
|
||||
existingDbPerms.ShareLocation = permissions.ShareLocation;
|
||||
|
||||
DbContext.Permissions.Update(existingDbPerms);
|
||||
}
|
||||
@@ -336,7 +338,7 @@ public partial class LightlessHub
|
||||
BroadcastRedisEntry? entry;
|
||||
try
|
||||
{
|
||||
entry = JsonSerializer.Deserialize<BroadcastRedisEntry>(broadcastValue.Value!);
|
||||
entry = JsonSerializer.Deserialize<BroadcastRedisEntry>(broadcastValue.Value.ToString()!);
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
@@ -438,7 +440,7 @@ public partial class LightlessHub
|
||||
{
|
||||
try
|
||||
{
|
||||
existingEntry = JsonSerializer.Deserialize<BroadcastRedisEntry>(existingValue!);
|
||||
existingEntry = JsonSerializer.Deserialize<BroadcastRedisEntry>(existingValue.ToString()!);
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
@@ -464,7 +466,9 @@ public partial class LightlessHub
|
||||
await db.StringSetAsync(broadcastKey, json, _broadcastConfiguration.BroadcastEntryTtl).ConfigureAwait(false);
|
||||
await db.StringSetAsync(ownershipKey, hashedCid, _broadcastConfiguration.BroadcastEntryTtl).ConfigureAwait(false);
|
||||
_logger.LogCallInfo(LightlessHubLogger.Args("broadcast enabled", hashedCid, "GID", gid));
|
||||
_chatChannelService.RefreshLightfinderState(UserUID, hashedCid, isLightfinder: true);
|
||||
TryInvokeChatService(
|
||||
() => _chatChannelService.RefreshLightfinderState(UserUID, hashedCid, isLightfinder: true),
|
||||
"refreshing lightfinder state (enable)");
|
||||
}
|
||||
else
|
||||
{
|
||||
@@ -475,7 +479,7 @@ public partial class LightlessHub
|
||||
BroadcastRedisEntry? entry;
|
||||
try
|
||||
{
|
||||
entry = JsonSerializer.Deserialize<BroadcastRedisEntry>(value!);
|
||||
entry = JsonSerializer.Deserialize<BroadcastRedisEntry>(value.ToString()!);
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
@@ -505,7 +509,9 @@ public partial class LightlessHub
|
||||
}
|
||||
|
||||
_logger.LogCallInfo(LightlessHubLogger.Args("broadcast disabled", hashedCid, "GID", entry.GID));
|
||||
_chatChannelService.RefreshLightfinderState(UserUID, null, isLightfinder: false);
|
||||
TryInvokeChatService(
|
||||
() => _chatChannelService.RefreshLightfinderState(UserUID, null, isLightfinder: false),
|
||||
"refreshing lightfinder state (disable)");
|
||||
}
|
||||
}
|
||||
|
||||
@@ -532,7 +538,7 @@ public partial class LightlessHub
|
||||
BroadcastRedisEntry? entry;
|
||||
try
|
||||
{
|
||||
entry = JsonSerializer.Deserialize<BroadcastRedisEntry>(value.Value!);
|
||||
entry = JsonSerializer.Deserialize<BroadcastRedisEntry>(value.Value.ToString()!);
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
@@ -586,7 +592,7 @@ public partial class LightlessHub
|
||||
BroadcastRedisEntry? entry;
|
||||
try
|
||||
{
|
||||
entry = JsonSerializer.Deserialize<BroadcastRedisEntry>(result.Value!);
|
||||
entry = JsonSerializer.Deserialize<BroadcastRedisEntry>(result.Value.ToString()!);
|
||||
}
|
||||
catch
|
||||
{
|
||||
@@ -641,7 +647,7 @@ public partial class LightlessHub
|
||||
BroadcastRedisEntry? entry;
|
||||
try
|
||||
{
|
||||
entry = JsonSerializer.Deserialize<BroadcastRedisEntry>(value!);
|
||||
entry = JsonSerializer.Deserialize<BroadcastRedisEntry>(value.ToString()!);
|
||||
}
|
||||
catch
|
||||
{
|
||||
@@ -724,7 +730,7 @@ public partial class LightlessHub
|
||||
|
||||
try
|
||||
{
|
||||
entry = JsonSerializer.Deserialize<BroadcastRedisEntry>(raw!);
|
||||
entry = JsonSerializer.Deserialize<BroadcastRedisEntry>(raw.ToString()!);
|
||||
if (entry is not null && !string.Equals(entry.HashedCID, cid, StringComparison.Ordinal))
|
||||
{
|
||||
_logger.LogCallWarning(LightlessHubLogger.Args("mismatched broadcast cid in batch", "Requested", cid, "EntryCID", entry.HashedCID));
|
||||
@@ -1167,12 +1173,6 @@ public partial class LightlessHub
|
||||
return;
|
||||
}
|
||||
|
||||
if (profileData.ProfileDisabled)
|
||||
{
|
||||
await Clients.Caller.Client_ReceiveServerMessage(MessageSeverity.Error, "Your profile was permanently disabled and cannot be edited").ConfigureAwait(false);
|
||||
return;
|
||||
}
|
||||
|
||||
profileData.UpdateProfileFromDto(dto, profileResult.Base64Image, bannerResult.Base64Image);
|
||||
}
|
||||
else
|
||||
@@ -1234,6 +1234,84 @@ public partial class LightlessHub
|
||||
errorMessage = string.Empty;
|
||||
return true;
|
||||
}
|
||||
|
||||
|
||||
[Authorize(Policy = "Identified")]
|
||||
public async Task UpdateLocation(LocationDto dto, bool offline = false)
|
||||
{
|
||||
_logger.LogCallInfo(LightlessHubLogger.Args(UserUID,dto));
|
||||
if (string.IsNullOrEmpty(dto.user.UID))
|
||||
{
|
||||
_logger.LogCallWarning(LightlessHubLogger.Args("LocationDto with no userinfo :",UserUID, dto));
|
||||
return;
|
||||
}
|
||||
|
||||
if (!string.Equals(UserUID, dto.user.UID, StringComparison.Ordinal))
|
||||
{
|
||||
_logger.LogCallWarning(LightlessHubLogger.Args("LocationDto with another UID :",UserUID, dto));
|
||||
return;
|
||||
}
|
||||
|
||||
var visibilityCacheKey = $"Visibility:{UserUID}";
|
||||
|
||||
var allUsers = await _redis.GetAsync<List<string>>(visibilityCacheKey).ConfigureAwait(false);
|
||||
if (allUsers == null)
|
||||
{
|
||||
var permissibleGroupGIDsQuery = DbContext.GroupPairPreferredPermissions.AsNoTracking()
|
||||
.Where(gpp => gpp.UserUID == dto.user.UID && !gpp.IsPaused && gpp.ShareLocation == true)
|
||||
.Select(gpp => gpp.GroupGID);
|
||||
|
||||
var groupUserUIDsQuery = DbContext.GroupPairs.AsNoTracking()
|
||||
.Where(gp => permissibleGroupGIDsQuery.Contains(gp.GroupGID))
|
||||
.Select(gp => gp.GroupUserUID);
|
||||
|
||||
var directlySharedUserUIDsQuery = DbContext.Permissions.AsNoTracking()
|
||||
.Where(p => p.UserUID == dto.user.UID && !p.IsPaused && p.ShareLocation == true)
|
||||
.Select(p => p.OtherUserUID);
|
||||
|
||||
allUsers = await directlySharedUserUIDsQuery
|
||||
.Union(groupUserUIDsQuery)
|
||||
.Distinct()
|
||||
.ToListAsync().ConfigureAwait(false);
|
||||
|
||||
await _redis.AddAsync(
|
||||
visibilityCacheKey,
|
||||
allUsers,
|
||||
TimeSpan.FromMinutes(30),
|
||||
StackExchange.Redis.When.Always,
|
||||
StackExchange.Redis.CommandFlags.FireAndForget
|
||||
).ConfigureAwait(false);
|
||||
}
|
||||
|
||||
var key = $"Location:{UserUID}";
|
||||
|
||||
if (offline)
|
||||
{
|
||||
await _redis.RemoveAsync(key, StackExchange.Redis.CommandFlags.FireAndForget).ConfigureAwait(false);
|
||||
await Clients.Users(allUsers).Client_SendLocationToClient(dto).ConfigureAwait(false);
|
||||
}
|
||||
else
|
||||
{
|
||||
var currentLocation = await _redis.GetAsync<LocationDto>(key).ConfigureAwait(false);
|
||||
|
||||
await _redis.AddAsync(key, dto).ConfigureAwait(false);
|
||||
if (allUsers.Count != 0 && currentLocation != dto)
|
||||
{
|
||||
await Clients.Users(allUsers).Client_SendLocationToClient(dto).ConfigureAwait(false);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
[Authorize(Policy = "Identified")]
|
||||
public async Task<List<LocationDto>> RequestAllLocationInfo()
|
||||
{
|
||||
_logger.LogCallInfo();
|
||||
var uids = DbContext.Permissions.AsNoTracking().Where(x => x.OtherUserUID == UserUID && x.ShareLocation == true)
|
||||
.Select(x => x.UserUID).ToList();
|
||||
var data =await _redis.GetAllAsync<LocationDto>(uids.Select(x => $"Location:{x}").ToHashSet(StringComparer.Ordinal))
|
||||
.ConfigureAwait(false);
|
||||
return data.Where(x => x.Value is not null).Select(x => x.Value).ToList();
|
||||
}
|
||||
|
||||
[GeneratedRegex(@"^([a-z0-9_ '+&,\.\-\{\}]+\/)+([a-z0-9_ '+&,\.\-\{\}]+\.[a-z]{3,4})$", RegexOptions.IgnoreCase | RegexOptions.Compiled | RegexOptions.ECMAScript)]
|
||||
private static partial Regex GamePathRegex();
|
||||
|
||||
@@ -16,6 +16,8 @@ using Microsoft.AspNetCore.SignalR;
|
||||
using Microsoft.EntityFrameworkCore;
|
||||
using StackExchange.Redis.Extensions.Core.Abstractions;
|
||||
using System.Collections.Concurrent;
|
||||
using LightlessSync.API.Dto.CharaData;
|
||||
using LightlessSync.API.Dto.User;
|
||||
using LightlessSyncServer.Services.Interfaces;
|
||||
|
||||
namespace LightlessSyncServer.Hubs;
|
||||
@@ -219,6 +221,9 @@ public partial class LightlessHub : Hub<ILightlessHub>, ILightlessHub
|
||||
_lightlessCensus.ClearStatistics(UserUID);
|
||||
|
||||
await SendOfflineToAllPairedUsers().ConfigureAwait(false);
|
||||
|
||||
await UpdateLocation(new LocationDto(new UserData(UserUID), new LocationInfo()), offline: true).ConfigureAwait(false);
|
||||
await CleanVisibilityCacheFromRedis().ConfigureAwait(false);
|
||||
|
||||
DbContext.RemoveRange(DbContext.Files.Where(f => !f.Uploaded && f.UploaderUID == UserUID));
|
||||
await DbContext.SaveChangesAsync().ConfigureAwait(false);
|
||||
@@ -227,7 +232,7 @@ public partial class LightlessHub : Hub<ILightlessHub>, ILightlessHub
|
||||
catch { }
|
||||
finally
|
||||
{
|
||||
_chatChannelService.RemovePresence(UserUID);
|
||||
TryInvokeChatService(() => _chatChannelService.RemovePresence(UserUID), "removing chat presence on disconnect");
|
||||
_userConnections.Remove(UserUID, out _);
|
||||
}
|
||||
}
|
||||
|
||||
@@ -1,7 +1,7 @@
|
||||
<Project Sdk="Microsoft.NET.Sdk.Web">
|
||||
|
||||
<PropertyGroup>
|
||||
<TargetFramework>net9.0</TargetFramework>
|
||||
<TargetFramework>net10.0</TargetFramework>
|
||||
<UserSecretsId>aspnet-LightlessSyncServer-BA82A12A-0B30-463C-801D-B7E81318CD50</UserSecretsId>
|
||||
<AssemblyVersion>1.1.0.0</AssemblyVersion>
|
||||
<ImplicitUsings>enable</ImplicitUsings>
|
||||
|
||||
@@ -1,6 +1,4 @@
|
||||
using System;
|
||||
using System.Collections.Generic;
|
||||
using LightlessSync.API.Data;
|
||||
using LightlessSync.API.Data;
|
||||
using LightlessSync.API.Dto.Chat;
|
||||
|
||||
namespace LightlessSyncServer.Models;
|
||||
@@ -32,7 +30,6 @@ public readonly record struct ChatMessageLogEntry(
|
||||
string MessageId,
|
||||
ChatChannelDescriptor Channel,
|
||||
DateTime SentAtUtc,
|
||||
string SenderToken,
|
||||
string SenderUserUid,
|
||||
UserData? SenderUser,
|
||||
bool SenderIsLightfinder,
|
||||
|
||||
@@ -1,5 +1,4 @@
|
||||
using System.Collections.Generic;
|
||||
using LightlessSync.API.Dto.Chat;
|
||||
using LightlessSync.API.Dto.Chat;
|
||||
|
||||
namespace LightlessSyncServer.Models;
|
||||
|
||||
@@ -61,7 +60,6 @@ internal static class ChatZoneDefinitions
|
||||
},
|
||||
TerritoryIds: TerritoryRegistry.GetIds(
|
||||
"Ul'dah - Steps of Nald",
|
||||
"Ul'dah - Steps of Thal"))
|
||||
"Ul'dah - Steps of Thal")),
|
||||
};
|
||||
|
||||
}
|
||||
|
||||
@@ -1,15 +1,13 @@
|
||||
using System;
|
||||
using System.Collections.Generic;
|
||||
using System.Linq;
|
||||
using System.Security.Cryptography;
|
||||
using System.Security.Cryptography;
|
||||
using LightlessSync.API.Data;
|
||||
using LightlessSync.API.Dto.Chat;
|
||||
using LightlessSyncServer.Configuration;
|
||||
using LightlessSyncServer.Models;
|
||||
using Microsoft.Extensions.Logging;
|
||||
using Microsoft.Extensions.Options;
|
||||
|
||||
namespace LightlessSyncServer.Services;
|
||||
|
||||
public sealed class ChatChannelService
|
||||
public sealed class ChatChannelService : IDisposable
|
||||
{
|
||||
private readonly ILogger<ChatChannelService> _logger;
|
||||
private readonly Dictionary<string, ZoneChannelDefinition> _zoneDefinitions;
|
||||
@@ -18,16 +16,137 @@ public sealed class ChatChannelService
|
||||
private readonly Dictionary<ChannelKey, Dictionary<string, ChatParticipantInfo>> _participantsByChannel = new();
|
||||
private readonly Dictionary<ChannelKey, LinkedList<ChatMessageLogEntry>> _messagesByChannel = new();
|
||||
private readonly Dictionary<string, (ChannelKey Channel, LinkedListNode<ChatMessageLogEntry> Node)> _messageIndex = new(StringComparer.Ordinal);
|
||||
private readonly Dictionary<string, Dictionary<ChannelKey, HashSet<string>>> _mutedTokensByUser = new(StringComparer.Ordinal);
|
||||
private readonly Dictionary<string, Dictionary<ChannelKey, HashSet<string>>> _mutedUidsByUser = new(StringComparer.Ordinal);
|
||||
private readonly object _syncRoot = new();
|
||||
private const int MaxMessagesPerChannel = 200;
|
||||
internal const int MaxMutedParticipantsPerChannel = 8;
|
||||
|
||||
public ChatChannelService(ILogger<ChatChannelService> logger)
|
||||
public ChatChannelService(ILogger<ChatChannelService> logger, IOptions<ChatZoneOverridesOptions>? zoneOverrides = null)
|
||||
{
|
||||
_logger = logger;
|
||||
_zoneDefinitions = ChatZoneDefinitions.Defaults
|
||||
.ToDictionary(definition => definition.Key, StringComparer.OrdinalIgnoreCase);
|
||||
_zoneDefinitions = BuildZoneDefinitions(zoneOverrides?.Value);
|
||||
}
|
||||
|
||||
private Dictionary<string, ZoneChannelDefinition> BuildZoneDefinitions(ChatZoneOverridesOptions? overrides)
|
||||
{
|
||||
var definitions = ChatZoneDefinitions.Defaults
|
||||
.ToDictionary(definition => definition.Key, StringComparer.OrdinalIgnoreCase);
|
||||
|
||||
if (overrides?.Zones is null || overrides.Zones.Count == 0)
|
||||
{
|
||||
return definitions;
|
||||
}
|
||||
|
||||
foreach (var entry in overrides.Zones)
|
||||
{
|
||||
if (entry is null)
|
||||
{
|
||||
continue;
|
||||
}
|
||||
|
||||
if (!TryCreateZoneDefinition(entry, out var definition))
|
||||
{
|
||||
continue;
|
||||
}
|
||||
|
||||
definitions[definition.Key] = definition;
|
||||
}
|
||||
|
||||
return definitions;
|
||||
}
|
||||
|
||||
private bool TryCreateZoneDefinition(ChatZoneOverride entry, out ZoneChannelDefinition definition)
|
||||
{
|
||||
definition = default;
|
||||
|
||||
var key = NormalizeZoneKey(entry.Key);
|
||||
if (string.IsNullOrEmpty(key))
|
||||
{
|
||||
_logger.LogWarning("Skipped chat zone override with missing key.");
|
||||
return false;
|
||||
}
|
||||
|
||||
var territoryIds = new HashSet<ushort>();
|
||||
if (entry.TerritoryIds is not null)
|
||||
{
|
||||
foreach (var candidate in entry.TerritoryIds)
|
||||
{
|
||||
if (candidate > 0)
|
||||
{
|
||||
territoryIds.Add(candidate);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
var territoryNames = new HashSet<string>(StringComparer.OrdinalIgnoreCase);
|
||||
if (entry.TerritoryNames is not null)
|
||||
{
|
||||
foreach (var name in entry.TerritoryNames)
|
||||
{
|
||||
if (string.IsNullOrWhiteSpace(name))
|
||||
continue;
|
||||
|
||||
var trimmed = name.Trim();
|
||||
territoryNames.Add(trimmed);
|
||||
if (TerritoryRegistry.TryGetIds(trimmed, out var ids))
|
||||
{
|
||||
territoryIds.UnionWith(ids);
|
||||
}
|
||||
else
|
||||
{
|
||||
_logger.LogWarning("Chat zone override {Zone} references unknown territory '{Territory}'.", key, trimmed);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
if (territoryIds.Count == 0)
|
||||
{
|
||||
_logger.LogWarning("Skipped chat zone override for {Zone}: no territory IDs resolved.", key);
|
||||
return false;
|
||||
}
|
||||
|
||||
if (territoryNames.Count == 0)
|
||||
{
|
||||
foreach (var territoryId in territoryIds)
|
||||
{
|
||||
if (TerritoryRegistry.ById.TryGetValue(territoryId, out var territory))
|
||||
{
|
||||
territoryNames.Add(territory.Name);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
if (territoryNames.Count == 0)
|
||||
{
|
||||
territoryNames.Add("Territory");
|
||||
}
|
||||
|
||||
var descriptor = new ChatChannelDescriptor
|
||||
{
|
||||
Type = ChatChannelType.Zone,
|
||||
WorldId = 0,
|
||||
ZoneId = 0,
|
||||
CustomKey = key
|
||||
};
|
||||
|
||||
var displayName = string.IsNullOrWhiteSpace(entry.DisplayName)
|
||||
? key
|
||||
: entry.DisplayName.Trim();
|
||||
|
||||
definition = new ZoneChannelDefinition(
|
||||
key,
|
||||
displayName,
|
||||
descriptor,
|
||||
territoryNames.ToArray(),
|
||||
territoryIds);
|
||||
|
||||
return true;
|
||||
}
|
||||
|
||||
private static string NormalizeZoneKey(string? value) =>
|
||||
string.IsNullOrWhiteSpace(value) ? string.Empty : value.Trim();
|
||||
|
||||
public IReadOnlyList<ZoneChatChannelInfoDto> GetZoneChannelInfos() =>
|
||||
_zoneDefinitions.Values
|
||||
.Select(definition => new ZoneChatChannelInfoDto(
|
||||
@@ -154,7 +273,6 @@ public sealed class ChatChannelService
|
||||
messageId,
|
||||
channel,
|
||||
sentAtUtc,
|
||||
participant.Token,
|
||||
participant.UserUid,
|
||||
participant.User,
|
||||
participant.IsLightfinder,
|
||||
@@ -260,23 +378,6 @@ public sealed class ChatChannelService
|
||||
}
|
||||
}
|
||||
|
||||
public bool TryResolveParticipant(ChatChannelDescriptor channel, string token, out ChatParticipantInfo participant)
|
||||
{
|
||||
var key = ChannelKey.FromDescriptor(channel);
|
||||
|
||||
lock (_syncRoot)
|
||||
{
|
||||
if (_participantsByChannel.TryGetValue(key, out var participants) &&
|
||||
participants.TryGetValue(token, out participant))
|
||||
{
|
||||
return true;
|
||||
}
|
||||
}
|
||||
|
||||
participant = default;
|
||||
return false;
|
||||
}
|
||||
|
||||
public void RefreshLightfinderState(string userUid, string? hashedCid, bool isLightfinder)
|
||||
{
|
||||
ArgumentException.ThrowIfNullOrEmpty(userUid);
|
||||
@@ -413,6 +514,8 @@ public sealed class ChatChannelService
|
||||
|
||||
participantsByToken[token] = finalParticipant;
|
||||
|
||||
ApplyUIDMuteIfPresent(normalizedDescriptor, finalParticipant);
|
||||
|
||||
_logger.LogDebug("Chat presence updated for {User} in {Channel}", userUid, Describe(key));
|
||||
return entryToStore;
|
||||
}
|
||||
@@ -446,9 +549,113 @@ public sealed class ChatChannelService
|
||||
}
|
||||
}
|
||||
|
||||
ClearMutesForChannel(userUid, key);
|
||||
return true;
|
||||
}
|
||||
|
||||
internal bool TryGetActiveParticipant(ChatChannelDescriptor channel, string token, out ChatParticipantInfo participant)
|
||||
{
|
||||
var key = ChannelKey.FromDescriptor(channel.WithNormalizedCustomKey());
|
||||
|
||||
lock (_syncRoot)
|
||||
{
|
||||
if (_participantsByChannel.TryGetValue(key, out var participants) &&
|
||||
participants.TryGetValue(token, out participant))
|
||||
{
|
||||
return true;
|
||||
}
|
||||
}
|
||||
|
||||
participant = default;
|
||||
return false;
|
||||
}
|
||||
|
||||
internal bool IsTokenMuted(string userUid, ChatChannelDescriptor channel, string token)
|
||||
{
|
||||
var key = ChannelKey.FromDescriptor(channel.WithNormalizedCustomKey());
|
||||
|
||||
lock (_syncRoot)
|
||||
{
|
||||
if (!_mutedTokensByUser.TryGetValue(userUid, out var channels) ||
|
||||
!channels.TryGetValue(key, out var tokens))
|
||||
{
|
||||
return false;
|
||||
}
|
||||
|
||||
if (tokens.Contains(token))
|
||||
{
|
||||
return true;
|
||||
}
|
||||
|
||||
if (_participantsByChannel.TryGetValue(key, out var participants) &&
|
||||
participants.TryGetValue(token, out var participant))
|
||||
{
|
||||
return IsUIDMutedLocked(userUid, key, participant.UserUid);
|
||||
}
|
||||
|
||||
return false;
|
||||
}
|
||||
}
|
||||
|
||||
public ChatMuteUpdateResult SetMutedParticipant(string userUid, ChatChannelDescriptor channel, ChatParticipantInfo participant, bool mute)
|
||||
{
|
||||
ArgumentException.ThrowIfNullOrEmpty(userUid);
|
||||
ArgumentException.ThrowIfNullOrEmpty(participant.Token);
|
||||
ArgumentException.ThrowIfNullOrEmpty(participant.UserUid);
|
||||
|
||||
var key = ChannelKey.FromDescriptor(channel.WithNormalizedCustomKey());
|
||||
|
||||
lock (_syncRoot)
|
||||
{
|
||||
if (!_mutedTokensByUser.TryGetValue(userUid, out var channels))
|
||||
{
|
||||
if (!mute)
|
||||
{
|
||||
return ChatMuteUpdateResult.NoChange;
|
||||
}
|
||||
|
||||
channels = new Dictionary<ChannelKey, HashSet<string>>();
|
||||
_mutedTokensByUser[userUid] = channels;
|
||||
}
|
||||
|
||||
if (!channels.TryGetValue(key, out var tokens))
|
||||
{
|
||||
if (!mute)
|
||||
{
|
||||
return ChatMuteUpdateResult.NoChange;
|
||||
}
|
||||
|
||||
tokens = new HashSet<string>(StringComparer.Ordinal);
|
||||
channels[key] = tokens;
|
||||
}
|
||||
|
||||
if (mute)
|
||||
{
|
||||
if (!tokens.Contains(participant.Token) && tokens.Count >= MaxMutedParticipantsPerChannel)
|
||||
{
|
||||
return ChatMuteUpdateResult.ChannelLimitReached;
|
||||
}
|
||||
|
||||
var added = tokens.Add(participant.Token);
|
||||
EnsureUIDMuteLocked(userUid, key, participant.UserUid);
|
||||
return added ? ChatMuteUpdateResult.Changed : ChatMuteUpdateResult.NoChange;
|
||||
}
|
||||
|
||||
var removed = tokens.Remove(participant.Token);
|
||||
if (tokens.Count == 0)
|
||||
{
|
||||
channels.Remove(key);
|
||||
if (channels.Count == 0)
|
||||
{
|
||||
_mutedTokensByUser.Remove(userUid);
|
||||
}
|
||||
}
|
||||
|
||||
RemoveUIDMuteLocked(userUid, key, participant.UserUid);
|
||||
return removed ? ChatMuteUpdateResult.Changed : ChatMuteUpdateResult.NoChange;
|
||||
}
|
||||
}
|
||||
|
||||
private static string GenerateToken()
|
||||
{
|
||||
Span<byte> buffer = stackalloc byte[8];
|
||||
@@ -458,4 +665,103 @@ public sealed class ChatChannelService
|
||||
|
||||
private static string Describe(ChannelKey key)
|
||||
=> $"{key.Type}:{key.WorldId}:{key.CustomKey}";
|
||||
|
||||
private void ClearMutesForChannel(string userUid, ChannelKey key)
|
||||
{
|
||||
if (_mutedTokensByUser.TryGetValue(userUid, out var tokenChannels) &&
|
||||
tokenChannels.Remove(key) &&
|
||||
tokenChannels.Count == 0)
|
||||
{
|
||||
_mutedTokensByUser.Remove(userUid);
|
||||
}
|
||||
|
||||
if (_mutedUidsByUser.TryGetValue(userUid, out var uidChannels) &&
|
||||
uidChannels.Remove(key) &&
|
||||
uidChannels.Count == 0)
|
||||
{
|
||||
_mutedUidsByUser.Remove(userUid);
|
||||
}
|
||||
}
|
||||
|
||||
private void ApplyUIDMuteIfPresent(ChatChannelDescriptor descriptor, ChatParticipantInfo participant)
|
||||
{
|
||||
var key = ChannelKey.FromDescriptor(descriptor);
|
||||
foreach (var kvp in _mutedUidsByUser)
|
||||
{
|
||||
var muter = kvp.Key;
|
||||
var channels = kvp.Value;
|
||||
if (!channels.TryGetValue(key, out var mutedUids) || !mutedUids.Contains(participant.UserUid))
|
||||
{
|
||||
continue;
|
||||
}
|
||||
|
||||
if (!_mutedTokensByUser.TryGetValue(muter, out var tokenChannels))
|
||||
{
|
||||
tokenChannels = new Dictionary<ChannelKey, HashSet<string>>();
|
||||
_mutedTokensByUser[muter] = tokenChannels;
|
||||
}
|
||||
|
||||
if (!tokenChannels.TryGetValue(key, out var tokens))
|
||||
{
|
||||
tokens = new HashSet<string>(StringComparer.Ordinal);
|
||||
tokenChannels[key] = tokens;
|
||||
}
|
||||
|
||||
tokens.Add(participant.Token);
|
||||
}
|
||||
}
|
||||
|
||||
private void EnsureUIDMuteLocked(string userUid, ChannelKey key, string targetUid)
|
||||
{
|
||||
if (!_mutedUidsByUser.TryGetValue(userUid, out var channels))
|
||||
{
|
||||
channels = new Dictionary<ChannelKey, HashSet<string>>();
|
||||
_mutedUidsByUser[userUid] = channels;
|
||||
}
|
||||
|
||||
if (!channels.TryGetValue(key, out var set))
|
||||
{
|
||||
set = new HashSet<string>(StringComparer.Ordinal);
|
||||
channels[key] = set;
|
||||
}
|
||||
|
||||
set.Add(targetUid);
|
||||
}
|
||||
|
||||
private void RemoveUIDMuteLocked(string userUid, ChannelKey key, string targetUid)
|
||||
{
|
||||
if (!_mutedUidsByUser.TryGetValue(userUid, out var channels) ||
|
||||
!channels.TryGetValue(key, out var set))
|
||||
{
|
||||
return;
|
||||
}
|
||||
|
||||
set.Remove(targetUid);
|
||||
if (set.Count == 0)
|
||||
{
|
||||
channels.Remove(key);
|
||||
if (channels.Count == 0)
|
||||
{
|
||||
_mutedUidsByUser.Remove(userUid);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
private bool IsUIDMutedLocked(string userUid, ChannelKey key, string targetUid)
|
||||
{
|
||||
return _mutedUidsByUser.TryGetValue(userUid, out var channels) &&
|
||||
channels.TryGetValue(key, out var set) &&
|
||||
set.Contains(targetUid);
|
||||
}
|
||||
|
||||
public void Dispose()
|
||||
{
|
||||
}
|
||||
}
|
||||
|
||||
public enum ChatMuteUpdateResult
|
||||
{
|
||||
NoChange,
|
||||
Changed,
|
||||
ChannelLimitReached
|
||||
}
|
||||
|
||||
@@ -67,6 +67,7 @@ public class PairService
|
||||
DisableVFX = defaultPerms.DisableIndividualVFX,
|
||||
IsPaused = false,
|
||||
Sticky = true,
|
||||
ShareLocation = false,
|
||||
});
|
||||
modified = true;
|
||||
}
|
||||
@@ -88,6 +89,7 @@ public class PairService
|
||||
DisableVFX = defaultPerms.DisableIndividualVFX,
|
||||
IsPaused = false,
|
||||
Sticky = true,
|
||||
ShareLocation = false,
|
||||
});
|
||||
modified = true;
|
||||
}
|
||||
|
||||
@@ -93,6 +93,7 @@ public class Startup
|
||||
services.Configure<ServerConfiguration>(Configuration.GetRequiredSection("LightlessSync"));
|
||||
services.Configure<LightlessConfigurationBase>(Configuration.GetRequiredSection("LightlessSync"));
|
||||
services.Configure<BroadcastOptions>(Configuration.GetSection("Broadcast"));
|
||||
services.Configure<ChatZoneOverridesOptions>(Configuration.GetSection("ChatZoneOverrides"));
|
||||
|
||||
services.AddSingleton<IBroadcastConfiguration, BroadcastConfiguration>();
|
||||
services.AddSingleton<ServerTokenGenerator>();
|
||||
|
||||
@@ -0,0 +1,26 @@
|
||||
using System;
|
||||
using System.Text.RegularExpressions;
|
||||
|
||||
namespace LightlessSyncServer.Utils;
|
||||
|
||||
internal static class ChatMessageFilter
|
||||
{
|
||||
private static readonly Regex UrlRegex = new(@"\b(?:https?://|www\.)\S+", RegexOptions.IgnoreCase | RegexOptions.Compiled);
|
||||
|
||||
public static bool TryValidate(string? message, out string rejectionReason)
|
||||
{
|
||||
rejectionReason = string.Empty;
|
||||
if (string.IsNullOrWhiteSpace(message))
|
||||
{
|
||||
return true;
|
||||
}
|
||||
|
||||
if (UrlRegex.IsMatch(message))
|
||||
{
|
||||
rejectionReason = "Links are not permitted in chat.";
|
||||
return false;
|
||||
}
|
||||
|
||||
return true;
|
||||
}
|
||||
}
|
||||
@@ -118,6 +118,7 @@ public static class Extensions
|
||||
permissions.SetPreferDisableSounds(group.PreferDisableSounds);
|
||||
permissions.SetPreferDisableVFX(group.PreferDisableVFX);
|
||||
permissions.SetDisableInvites(!group.InvitesEnabled);
|
||||
permissions.SetDisableChat(!group.ChatEnabled);
|
||||
return permissions;
|
||||
}
|
||||
|
||||
@@ -128,6 +129,7 @@ public static class Extensions
|
||||
permissions.SetDisableSounds(groupPair.DisableSounds);
|
||||
permissions.SetPaused(groupPair.IsPaused);
|
||||
permissions.SetDisableVFX(groupPair.DisableVFX);
|
||||
permissions.SetShareLocation(groupPair.ShareLocation);
|
||||
return permissions;
|
||||
}
|
||||
|
||||
@@ -148,6 +150,7 @@ public static class Extensions
|
||||
perm.SetDisableAnimations(permissions.DisableAnimations);
|
||||
perm.SetDisableSounds(permissions.DisableSounds);
|
||||
perm.SetDisableVFX(permissions.DisableVFX);
|
||||
perm.SetShareLocation(permissions.ShareLocation);
|
||||
if (setSticky)
|
||||
perm.SetSticky(permissions.Sticky);
|
||||
return perm;
|
||||
|
||||
@@ -30,4 +30,14 @@ public class LightlessHubLogger
|
||||
string formattedArgs = args != null && args.Length != 0 ? "|" + string.Join(":", args) : string.Empty;
|
||||
_logger.LogWarning("{uid}:{method}{args}", _hub.UserUID, methodName, formattedArgs);
|
||||
}
|
||||
|
||||
public void LogError(Exception exception, string message, params object[] args)
|
||||
{
|
||||
_logger.LogError(exception, message, args);
|
||||
}
|
||||
|
||||
public void LogError(string message, params object[] args)
|
||||
{
|
||||
_logger.LogError(message, args);
|
||||
}
|
||||
}
|
||||
|
||||
@@ -41,6 +41,9 @@
|
||||
"PairRequestRateLimit": 5,
|
||||
"PairRequestRateWindow": 60
|
||||
},
|
||||
"ChatZoneOverrides": {
|
||||
"Zones": []
|
||||
},
|
||||
"AllowedHosts": "*",
|
||||
"Kestrel": {
|
||||
"Endpoints": {
|
||||
|
||||
@@ -1,9 +1,6 @@
|
||||
using System.Collections.Generic;
|
||||
using System;
|
||||
using System.Globalization;
|
||||
using System.Text;
|
||||
using System.Text.Json;
|
||||
using System.Linq;
|
||||
using Discord;
|
||||
using Discord.Interactions;
|
||||
using Discord.Rest;
|
||||
@@ -162,7 +159,7 @@ internal class DiscordBot : IHostedService
|
||||
|
||||
try
|
||||
{
|
||||
await Task.Delay(TimeSpan.FromMinutes(10), token).ConfigureAwait(false);
|
||||
await Task.Delay(TimeSpan.FromMinutes(1), token).ConfigureAwait(false);
|
||||
}
|
||||
catch (OperationCanceledException)
|
||||
{
|
||||
@@ -204,7 +201,7 @@ internal class DiscordBot : IHostedService
|
||||
var embed = await BuildChatReportEmbedAsync(dbContext, report, token).ConfigureAwait(false);
|
||||
|
||||
var components = new ComponentBuilder()
|
||||
.WithButton("Actioned", $"{ChatReportButtonPrefix}-resolve-{report.ReportId}", ButtonStyle.Danger)
|
||||
.WithButton("Resolve", $"{ChatReportButtonPrefix}-resolve-{report.ReportId}", ButtonStyle.Danger)
|
||||
.WithButton("Dismiss", $"{ChatReportButtonPrefix}-dismiss-{report.ReportId}", ButtonStyle.Secondary)
|
||||
.WithButton("Ban From Chat", $"{ChatReportButtonPrefix}-banchat-{report.ReportId}", ButtonStyle.Danger);
|
||||
|
||||
@@ -395,7 +392,7 @@ internal class DiscordBot : IHostedService
|
||||
switch (action)
|
||||
{
|
||||
case "resolve":
|
||||
resolutionLabel = "Actioned";
|
||||
resolutionLabel = "Resolved";
|
||||
break;
|
||||
case "dismiss":
|
||||
resolutionLabel = "Dismissed";
|
||||
@@ -431,7 +428,7 @@ internal class DiscordBot : IHostedService
|
||||
|
||||
string responseText = action switch
|
||||
{
|
||||
"resolve" => "actioned",
|
||||
"resolve" => "resolved",
|
||||
"dismiss" => "dismissed",
|
||||
"banchat" => "chat access revoked",
|
||||
_ => "processed"
|
||||
@@ -473,7 +470,7 @@ internal class DiscordBot : IHostedService
|
||||
embedBuilder.Fields.RemoveAll(f => string.Equals(f.Name, "Resolution", StringComparison.OrdinalIgnoreCase));
|
||||
var resolutionText = action switch
|
||||
{
|
||||
"resolve" => "Actioned",
|
||||
"resolve" => "Resolved",
|
||||
"dismiss" => "Dismissed",
|
||||
"banchat" => "Chat access revoked",
|
||||
_ => "Processed"
|
||||
@@ -872,16 +869,17 @@ internal class DiscordBot : IHostedService
|
||||
string? SenderHashedCid,
|
||||
string Message);
|
||||
|
||||
private async Task UpdateStatusAsync(CancellationToken token)
|
||||
private async Task UpdateStatusAsync(CancellationToken cancellationToken)
|
||||
{
|
||||
while (!token.IsCancellationRequested)
|
||||
while (!cancellationToken.IsCancellationRequested)
|
||||
{
|
||||
var endPoint = _connectionMultiplexer.GetEndPoints().First();
|
||||
var onlineUsers = await _connectionMultiplexer.GetServer(endPoint).KeysAsync(pattern: "UID:*").CountAsync().ConfigureAwait(false);
|
||||
var keys = _connectionMultiplexer.GetServer(endPoint).KeysAsync(pattern: "UID:*");
|
||||
var onlineUsers = await keys.CountAsync(cancellationToken).ConfigureAwait(false);
|
||||
|
||||
_logger.LogInformation("Users online: " + onlineUsers);
|
||||
_logger.LogInformation("Users online: " + onlineUsers);
|
||||
await _discordClient.SetActivityAsync(new Game("Lightless for " + onlineUsers + " Users")).ConfigureAwait(false);
|
||||
await Task.Delay(TimeSpan.FromSeconds(10)).ConfigureAwait(false);
|
||||
await Task.Delay(TimeSpan.FromSeconds(10), cancellationToken).ConfigureAwait(false);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
@@ -43,33 +43,54 @@ public class LightlessModule : InteractionModuleBase
|
||||
|
||||
try
|
||||
{
|
||||
EmbedBuilder eb = new();
|
||||
|
||||
using var scope = _services.CreateScope();
|
||||
var db = scope.ServiceProvider.GetRequiredService<LightlessDbContext>();
|
||||
await using (db.ConfigureAwait(false))
|
||||
{
|
||||
eb = await HandleUserInfo(eb, db, Context.User.Id, secondaryUid, discordUser?.Id ?? null, uid);
|
||||
var (mainEmbed, profileEmbed) = await HandleUserInfo(db, Context.User.Id, secondaryUid, discordUser?.Id ?? null, uid);
|
||||
|
||||
string uidToGet = await GetUserUID(db, secondaryUid, discordUser?.Id ?? null, uid).ConfigureAwait(false);
|
||||
var profileData = await GetUserProfileData(db, uidToGet).ConfigureAwait(false);
|
||||
|
||||
List<Embed> embeds = new() { mainEmbed };
|
||||
if (profileEmbed != null)
|
||||
{
|
||||
embeds.Add(profileEmbed);
|
||||
}
|
||||
|
||||
if (profileData != null)
|
||||
{
|
||||
byte[] profileImage = GetProfileImage(profileData);
|
||||
byte[] bannerImage = GetBannerImage(profileData);
|
||||
using MemoryStream profileImgStream = new(profileImage);
|
||||
using MemoryStream bannerImgStream = new(bannerImage);
|
||||
eb.WithThumbnailUrl("attachment://profileimage.png");
|
||||
eb.WithImageUrl("attachment://bannerimage.png");
|
||||
|
||||
var mainEmbedData = embeds[0];
|
||||
var mainEmbedBuilder = new EmbedBuilder()
|
||||
.WithTitle(mainEmbedData.Title)
|
||||
.WithDescription(mainEmbedData.Description)
|
||||
.WithThumbnailUrl("attachment://profileimage.png")
|
||||
.WithImageUrl("attachment://bannerimage.png");
|
||||
|
||||
if (mainEmbedData.Fields != null)
|
||||
{
|
||||
foreach (var field in mainEmbedData.Fields)
|
||||
{
|
||||
mainEmbedBuilder.AddField(field.Name, field.Value, field.Inline);
|
||||
}
|
||||
}
|
||||
|
||||
embeds[0] = mainEmbedBuilder.Build();
|
||||
|
||||
await RespondWithFilesAsync(
|
||||
new[] { new FileAttachment(profileImgStream, "profileimage.png"), new FileAttachment(bannerImgStream, "bannerimage.png") },
|
||||
embeds: new[] { eb.Build() },
|
||||
embeds: embeds.ToArray(),
|
||||
ephemeral: true).ConfigureAwait(false);
|
||||
}
|
||||
else
|
||||
{
|
||||
await RespondAsync(
|
||||
embeds: new[] { eb.Build() },
|
||||
embeds: embeds.ToArray(),
|
||||
ephemeral: true).ConfigureAwait(false);
|
||||
}
|
||||
}
|
||||
@@ -449,7 +470,7 @@ public class LightlessModule : InteractionModuleBase
|
||||
return embed.Build();
|
||||
}
|
||||
|
||||
private async Task<EmbedBuilder> HandleUserInfo(EmbedBuilder eb, LightlessDbContext db, ulong id, string? secondaryUserUid = null, ulong? optionalUser = null, string? uid = null)
|
||||
private async Task<(Embed mainEmbed, Embed? profileEmbed)> HandleUserInfo(LightlessDbContext db, ulong id, string? secondaryUserUid = null, ulong? optionalUser = null, string? uid = null)
|
||||
{
|
||||
bool showForSecondaryUser = secondaryUserUid != null;
|
||||
|
||||
@@ -459,18 +480,20 @@ public class LightlessModule : InteractionModuleBase
|
||||
|
||||
if (primaryUser == null)
|
||||
{
|
||||
EmbedBuilder eb = new();
|
||||
eb.WithTitle("No account");
|
||||
eb.WithDescription("No Lightless account was found associated to your Discord user");
|
||||
return eb;
|
||||
return (eb.Build(), null);
|
||||
}
|
||||
|
||||
bool isAdminCall = primaryUser.User.IsModerator || primaryUser.User.IsAdmin;
|
||||
|
||||
if ((optionalUser != null || uid != null) && !isAdminCall)
|
||||
{
|
||||
EmbedBuilder eb = new();
|
||||
eb.WithTitle("Unauthorized");
|
||||
eb.WithDescription("You are not authorized to view another users' information");
|
||||
return eb;
|
||||
return (eb.Build(), null);
|
||||
}
|
||||
else if ((optionalUser != null || uid != null) && isAdminCall)
|
||||
{
|
||||
@@ -486,9 +509,10 @@ public class LightlessModule : InteractionModuleBase
|
||||
|
||||
if (userInDb == null)
|
||||
{
|
||||
EmbedBuilder eb = new();
|
||||
eb.WithTitle("No account");
|
||||
eb.WithDescription("The Discord user has no valid Lightless account");
|
||||
return eb;
|
||||
return (eb.Build(), null);
|
||||
}
|
||||
|
||||
userToCheckForDiscordId = userInDb.DiscordId;
|
||||
@@ -501,9 +525,10 @@ public class LightlessModule : InteractionModuleBase
|
||||
dbUser = (await db.Auth.Include(u => u.User).SingleOrDefaultAsync(u => u.PrimaryUserUID == dbUser.UID && u.UserUID == secondaryUserUid))?.User;
|
||||
if (dbUser == null)
|
||||
{
|
||||
EmbedBuilder eb = new();
|
||||
eb.WithTitle("No such secondary UID");
|
||||
eb.WithDescription($"A secondary UID {secondaryUserUid} was not found attached to your primary UID {primaryUser.User.UID}.");
|
||||
return eb;
|
||||
return (eb.Build(), null);
|
||||
}
|
||||
}
|
||||
|
||||
@@ -513,55 +538,61 @@ public class LightlessModule : InteractionModuleBase
|
||||
var profile = await db.UserProfileData.Where(u => u.UserUID == dbUser.UID).SingleOrDefaultAsync().ConfigureAwait(false);
|
||||
var identity = await _connectionMultiplexer.GetDatabase().StringGetAsync("UID:" + dbUser.UID).ConfigureAwait(false);
|
||||
|
||||
eb.WithTitle("User Information");
|
||||
eb.WithDescription("This is the user information for Discord User <@" + userToCheckForDiscordId + ">" + Environment.NewLine + Environment.NewLine
|
||||
EmbedBuilder mainEmbed = new();
|
||||
mainEmbed.WithTitle("User Information");
|
||||
mainEmbed.WithDescription("This is the user information for Discord User <@" + userToCheckForDiscordId + ">" + Environment.NewLine + Environment.NewLine
|
||||
+ "If you want to verify your secret key is valid, go to https://emn178.github.io/online-tools/sha256.html and copy your secret key into there and compare it to the Hashed Secret Key provided below.");
|
||||
eb.AddField("UID", dbUser.UID);
|
||||
mainEmbed.AddField("UID", dbUser.UID);
|
||||
if (!string.IsNullOrEmpty(dbUser.Alias))
|
||||
{
|
||||
eb.AddField("Vanity UID", dbUser.Alias);
|
||||
mainEmbed.AddField("Vanity UID", dbUser.Alias);
|
||||
}
|
||||
if (showForSecondaryUser)
|
||||
{
|
||||
eb.AddField("Primary UID for " + dbUser.UID, auth.PrimaryUserUID);
|
||||
mainEmbed.AddField("Primary UID for " + dbUser.UID, auth.PrimaryUserUID);
|
||||
}
|
||||
else
|
||||
{
|
||||
var secondaryUIDs = await db.Auth.Where(p => p.PrimaryUserUID == dbUser.UID).Select(p => p.UserUID).ToListAsync();
|
||||
if (secondaryUIDs.Any())
|
||||
{
|
||||
eb.AddField("Secondary UIDs", string.Join(Environment.NewLine, secondaryUIDs));
|
||||
mainEmbed.AddField("Secondary UIDs", string.Join(Environment.NewLine, secondaryUIDs));
|
||||
}
|
||||
}
|
||||
if(profile != null)
|
||||
{
|
||||
eb.AddField("Profile Description", string.IsNullOrEmpty(profile.UserDescription) ? "(No description set)" : profile.UserDescription);
|
||||
eb.AddField("Profile NSFW", profile.IsNSFW);
|
||||
eb.AddField("Profile Disabled", profile.ProfileDisabled);
|
||||
eb.AddField("Profile Flagged for Report", profile.FlaggedForReport);
|
||||
eb.AddField("Profile Tags", profile.Tags != null && profile.Tags.Length > 0 ? string.Join(", ", profile.Tags) : "(No tags set)");
|
||||
}
|
||||
eb.AddField("Last Online (UTC)", dbUser.LastLoggedIn.ToString("U"));
|
||||
eb.AddField("Currently online ", !string.IsNullOrEmpty(identity));
|
||||
eb.AddField("Hashed Secret Key", auth.HashedKey);
|
||||
eb.AddField("Joined Syncshells", groupsJoined.Count);
|
||||
eb.AddField("Owned Syncshells", groups.Count);
|
||||
mainEmbed.AddField("Last Online (UTC)", dbUser.LastLoggedIn.ToString("U"));
|
||||
mainEmbed.AddField("Currently online ", !string.IsNullOrEmpty(identity));
|
||||
mainEmbed.AddField("Hashed Secret Key", auth.HashedKey);
|
||||
mainEmbed.AddField("Joined Syncshells", groupsJoined.Count);
|
||||
mainEmbed.AddField("Owned Syncshells", groups.Count);
|
||||
foreach (var group in groups)
|
||||
{
|
||||
var syncShellUserCount = await db.GroupPairs.CountAsync(g => g.GroupGID == group.GID).ConfigureAwait(false);
|
||||
if (!string.IsNullOrEmpty(group.Alias))
|
||||
{
|
||||
eb.AddField("Owned Syncshell " + group.GID + " Vanity ID", group.Alias);
|
||||
mainEmbed.AddField("Owned Syncshell " + group.GID + " Vanity ID", group.Alias);
|
||||
}
|
||||
eb.AddField("Owned Syncshell " + group.GID + " User Count", syncShellUserCount);
|
||||
mainEmbed.AddField("Owned Syncshell " + group.GID + " User Count", syncShellUserCount);
|
||||
}
|
||||
|
||||
if (isAdminCall && !string.IsNullOrEmpty(identity))
|
||||
{
|
||||
eb.AddField("Character Ident", identity);
|
||||
mainEmbed.AddField("Character Ident", identity);
|
||||
}
|
||||
|
||||
return eb;
|
||||
Embed? profileEmbedResult = null;
|
||||
if (profile != null)
|
||||
{
|
||||
EmbedBuilder profileEmbedBuilder = new();
|
||||
profileEmbedBuilder.WithTitle("User Profile");
|
||||
profileEmbedBuilder.WithDescription("Profile Description: " + (string.IsNullOrEmpty(profile.UserDescription) ? "(No description set)" : profile.UserDescription));
|
||||
profileEmbedBuilder.AddField("Profile NSFW", profile.IsNSFW);
|
||||
profileEmbedBuilder.AddField("Profile Disabled", profile.ProfileDisabled);
|
||||
profileEmbedBuilder.AddField("Profile Flagged for Report", profile.FlaggedForReport);
|
||||
profileEmbedBuilder.AddField("Profile Tags", profile.Tags != null && profile.Tags.Length > 0 ? string.Join(", ", profile.Tags) : "(No tags set)");
|
||||
profileEmbedResult = profileEmbedBuilder.Build();
|
||||
}
|
||||
|
||||
return (mainEmbed.Build(), profileEmbedResult);
|
||||
}
|
||||
|
||||
private async Task<string> GetUserUID(LightlessDbContext db, string? secondaryUserUid = null, ulong? optionalUser = null, string? uid = null)
|
||||
@@ -578,7 +609,7 @@ public class LightlessModule : InteractionModuleBase
|
||||
}
|
||||
else if (uid != null)
|
||||
{
|
||||
userInDb = await db.LodeStoneAuth.Include(u => u.User).SingleOrDefaultAsync(u => u.User.UID == uid || u.User.Alias == uid).ConfigureAwait(false);
|
||||
userInDb = await db.LodeStoneAuth.Include(u => u.User).SingleOrDefaultAsync(u => u.User.UID == uid || u.User.Alias == uid). ConfigureAwait(false);
|
||||
}
|
||||
if (userInDb == null)
|
||||
{
|
||||
|
||||
@@ -1,7 +1,7 @@
|
||||
<Project Sdk="Microsoft.NET.Sdk.Web">
|
||||
|
||||
<PropertyGroup>
|
||||
<TargetFramework>net9.0</TargetFramework>
|
||||
<TargetFramework>net10.0</TargetFramework>
|
||||
<ImplicitUsings>enable</ImplicitUsings>
|
||||
</PropertyGroup>
|
||||
|
||||
@@ -21,7 +21,7 @@
|
||||
</ItemGroup>
|
||||
|
||||
<ItemGroup>
|
||||
<PackageReference Include="Discord.Net" Version="3.17.0" />
|
||||
<PackageReference Include="Discord.Net" Version="3.18.0" />
|
||||
<PackageReference Include="IDisposableAnalyzers" Version="4.0.8">
|
||||
<PrivateAssets>all</PrivateAssets>
|
||||
<IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
|
||||
@@ -32,6 +32,7 @@
|
||||
</PackageReference>
|
||||
<PackageReference Include="Microsoft.Extensions.Configuration.Binder" Version="9.0.0" />
|
||||
<PackageReference Include="Microsoft.Extensions.Hosting.Systemd" Version="9.0.0" />
|
||||
<PackageReference Include="System.Linq.Async" Version="7.0.0" />
|
||||
</ItemGroup>
|
||||
|
||||
<ItemGroup>
|
||||
|
||||
@@ -80,6 +80,9 @@ public class LightlessDbContext : DbContext
|
||||
.WithOne(p => p.Group)
|
||||
.HasForeignKey<GroupProfile>(p => p.GroupGID)
|
||||
.IsRequired(false);
|
||||
mb.Entity<Group>()
|
||||
.Property(g => g.ChatEnabled)
|
||||
.HasDefaultValue(true);
|
||||
mb.Entity<GroupPair>().ToTable("group_pairs");
|
||||
mb.Entity<GroupPair>().HasKey(u => new { u.GroupGID, u.GroupUserUID });
|
||||
mb.Entity<GroupPair>().HasIndex(c => c.GroupUserUID);
|
||||
|
||||
@@ -1,7 +1,7 @@
|
||||
<Project Sdk="Microsoft.NET.Sdk">
|
||||
|
||||
<PropertyGroup>
|
||||
<TargetFramework>net9.0</TargetFramework>
|
||||
<TargetFramework>net10.0</TargetFramework>
|
||||
<ImplicitUsings>enable</ImplicitUsings>
|
||||
</PropertyGroup>
|
||||
|
||||
@@ -47,7 +47,6 @@
|
||||
<PackageReference Include="StackExchange.Redis.Extensions.Core" Version="10.2.0" />
|
||||
<PackageReference Include="StackExchange.Redis.Extensions.System.Text.Json" Version="10.2.0" />
|
||||
<PackageReference Include="System.IdentityModel.Tokens.Jwt" Version="8.3.0" />
|
||||
<PackageReference Include="System.Linq.Async" Version="6.0.1" />
|
||||
</ItemGroup>
|
||||
|
||||
<ItemGroup>
|
||||
|
||||
1322
LightlessSyncServer/LightlessSyncShared/Migrations/20251219115131_ChatReportFixes.Designer.cs
generated
Normal file
1322
LightlessSyncServer/LightlessSyncShared/Migrations/20251219115131_ChatReportFixes.Designer.cs
generated
Normal file
File diff suppressed because it is too large
Load Diff
@@ -0,0 +1,29 @@
|
||||
using Microsoft.EntityFrameworkCore.Migrations;
|
||||
|
||||
#nullable disable
|
||||
|
||||
namespace LightlessSyncServer.Migrations
|
||||
{
|
||||
/// <inheritdoc />
|
||||
public partial class ChatReportFixes : Migration
|
||||
{
|
||||
/// <inheritdoc />
|
||||
protected override void Up(MigrationBuilder migrationBuilder)
|
||||
{
|
||||
migrationBuilder.DropColumn(
|
||||
name: "sender_token",
|
||||
table: "reported_chat_messages");
|
||||
}
|
||||
|
||||
/// <inheritdoc />
|
||||
protected override void Down(MigrationBuilder migrationBuilder)
|
||||
{
|
||||
migrationBuilder.AddColumn<string>(
|
||||
name: "sender_token",
|
||||
table: "reported_chat_messages",
|
||||
type: "text",
|
||||
nullable: false,
|
||||
defaultValue: "");
|
||||
}
|
||||
}
|
||||
}
|
||||
1328
LightlessSyncServer/LightlessSyncShared/Migrations/20251222024252_DisableChatGroups.Designer.cs
generated
Normal file
1328
LightlessSyncServer/LightlessSyncShared/Migrations/20251222024252_DisableChatGroups.Designer.cs
generated
Normal file
File diff suppressed because it is too large
Load Diff
@@ -0,0 +1,29 @@
|
||||
using Microsoft.EntityFrameworkCore.Migrations;
|
||||
|
||||
#nullable disable
|
||||
|
||||
namespace LightlessSyncServer.Migrations
|
||||
{
|
||||
/// <inheritdoc />
|
||||
public partial class DisableChatGroups : Migration
|
||||
{
|
||||
/// <inheritdoc />
|
||||
protected override void Up(MigrationBuilder migrationBuilder)
|
||||
{
|
||||
migrationBuilder.AddColumn<bool>(
|
||||
name: "chat_enabled",
|
||||
table: "groups",
|
||||
type: "boolean",
|
||||
nullable: false,
|
||||
defaultValue: true);
|
||||
}
|
||||
|
||||
/// <inheritdoc />
|
||||
protected override void Down(MigrationBuilder migrationBuilder)
|
||||
{
|
||||
migrationBuilder.DropColumn(
|
||||
name: "chat_enabled",
|
||||
table: "groups");
|
||||
}
|
||||
}
|
||||
}
|
||||
@@ -438,6 +438,12 @@ namespace LightlessSyncServer.Migrations
|
||||
.HasColumnType("boolean")
|
||||
.HasColumnName("auto_prune_enabled");
|
||||
|
||||
b.Property<bool>("ChatEnabled")
|
||||
.ValueGeneratedOnAdd()
|
||||
.HasColumnType("boolean")
|
||||
.HasDefaultValue(true)
|
||||
.HasColumnName("chat_enabled");
|
||||
|
||||
b.Property<DateTime>("CreatedDate")
|
||||
.ValueGeneratedOnAdd()
|
||||
.HasColumnType("timestamp with time zone")
|
||||
@@ -776,11 +782,6 @@ namespace LightlessSyncServer.Migrations
|
||||
.HasColumnType("text")
|
||||
.HasColumnName("sender_hashed_cid");
|
||||
|
||||
b.Property<string>("SenderToken")
|
||||
.IsRequired()
|
||||
.HasColumnType("text")
|
||||
.HasColumnName("sender_token");
|
||||
|
||||
b.Property<bool>("SenderWasLightfinder")
|
||||
.HasColumnType("boolean")
|
||||
.HasColumnName("sender_was_lightfinder");
|
||||
|
||||
@@ -19,5 +19,6 @@ public class Group
|
||||
public bool PreferDisableSounds { get; set; }
|
||||
public bool PreferDisableAnimations { get; set; }
|
||||
public bool PreferDisableVFX { get; set; }
|
||||
public bool ChatEnabled { get; set; } = true;
|
||||
public DateTime CreatedDate { get; set; } = DateTime.UtcNow;
|
||||
}
|
||||
|
||||
@@ -10,4 +10,5 @@ public class GroupPairPreferredPermission
|
||||
public bool DisableAnimations { get; set; }
|
||||
public bool DisableSounds { get; set; }
|
||||
public bool DisableVFX { get; set; }
|
||||
public bool ShareLocation { get; set; }
|
||||
}
|
||||
|
||||
@@ -40,9 +40,6 @@ public class ReportedChatMessage
|
||||
[Required]
|
||||
public string MessageContent { get; set; } = string.Empty;
|
||||
|
||||
[Required]
|
||||
public string SenderToken { get; set; } = string.Empty;
|
||||
|
||||
public string? SenderHashedCid { get; set; }
|
||||
|
||||
public string? SenderDisplayName { get; set; }
|
||||
|
||||
@@ -15,4 +15,5 @@ public class UserPermissionSet
|
||||
public bool DisableAnimations { get; set; } = false;
|
||||
public bool DisableVFX { get; set; } = false;
|
||||
public bool DisableSounds { get; set; } = false;
|
||||
public bool ShareLocation { get; set; } = false;
|
||||
}
|
||||
|
||||
@@ -1,7 +1,7 @@
|
||||
<Project Sdk="Microsoft.NET.Sdk.Web">
|
||||
|
||||
<PropertyGroup>
|
||||
<TargetFramework>net9.0</TargetFramework>
|
||||
<TargetFramework>net10.0</TargetFramework>
|
||||
<ImplicitUsings>enable</ImplicitUsings>
|
||||
</PropertyGroup>
|
||||
|
||||
|
||||
@@ -102,36 +102,37 @@ public sealed class CachedFileProvider : IDisposable
|
||||
|
||||
private bool TryCopyFromColdStorage(string hash, string destinationFilePath)
|
||||
{
|
||||
if (!_configuration.GetValueOrDefault(nameof(StaticFilesServerConfiguration.UseColdStorage), false)) return false;
|
||||
if (!_configuration.GetValueOrDefault(nameof(StaticFilesServerConfiguration.UseColdStorage), false)) return false;
|
||||
|
||||
string coldStorageDir = _configuration.GetValueOrDefault(nameof(StaticFilesServerConfiguration.ColdStorageDirectory), string.Empty);
|
||||
if (string.IsNullOrEmpty(coldStorageDir)) return false;
|
||||
string coldStorageDir = _configuration.GetValueOrDefault(nameof(StaticFilesServerConfiguration.ColdStorageDirectory), string.Empty);
|
||||
if (string.IsNullOrEmpty(coldStorageDir)) return false;
|
||||
|
||||
var coldStorageFilePath = FilePathUtil.GetFileInfoForHash(coldStorageDir, hash);
|
||||
if (coldStorageFilePath == null) return false;
|
||||
var coldStorageFilePath = FilePathUtil.GetFileInfoForHash(coldStorageDir, hash);
|
||||
if (coldStorageFilePath == null) return false;
|
||||
|
||||
try
|
||||
{
|
||||
_logger.LogDebug("Copying {hash} from cold storage: {path}", hash, coldStorageFilePath);
|
||||
var tempFileName = destinationFilePath + ".dl";
|
||||
File.Copy(coldStorageFilePath.FullName, tempFileName, true);
|
||||
File.Move(tempFileName, destinationFilePath, true);
|
||||
coldStorageFilePath.LastAccessTimeUtc = DateTime.UtcNow;
|
||||
var destinationFile = new FileInfo(destinationFilePath);
|
||||
destinationFile.LastAccessTimeUtc = DateTime.UtcNow;
|
||||
destinationFile.CreationTimeUtc = DateTime.UtcNow;
|
||||
destinationFile.LastWriteTimeUtc = DateTime.UtcNow;
|
||||
_metrics.IncGauge(MetricsAPI.GaugeFilesTotal);
|
||||
_metrics.IncGauge(MetricsAPI.GaugeFilesTotalSize, new FileInfo(destinationFilePath).Length);
|
||||
return true;
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
_logger.LogWarning(ex, "Could not copy {coldStoragePath} from cold storage", coldStorageFilePath);
|
||||
}
|
||||
try
|
||||
{
|
||||
_logger.LogDebug("Copying {hash} from cold storage: {path}", hash, coldStorageFilePath);
|
||||
var tempFileName = destinationFilePath + ".dl";
|
||||
File.Copy(coldStorageFilePath.FullName, tempFileName, true);
|
||||
File.Move(tempFileName, destinationFilePath, true);
|
||||
|
||||
return false;
|
||||
}
|
||||
File.SetLastAccessTimeUtc(coldStorageFilePath.FullName, DateTime.UtcNow);
|
||||
File.SetLastAccessTimeUtc(destinationFilePath, DateTime.UtcNow);
|
||||
File.SetCreationTimeUtc(destinationFilePath, DateTime.UtcNow);
|
||||
File.SetLastWriteTimeUtc(destinationFilePath, DateTime.UtcNow);
|
||||
|
||||
_metrics.IncGauge(MetricsAPI.GaugeFilesTotal);
|
||||
_metrics.IncGauge(MetricsAPI.GaugeFilesTotalSize, new FileInfo(destinationFilePath).Length);
|
||||
return true;
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
_logger.LogWarning(ex, "Could not copy {coldStoragePath} from cold storage", coldStorageFilePath);
|
||||
}
|
||||
|
||||
return false;
|
||||
}
|
||||
|
||||
public async Task DownloadFileWhenRequired(string hash)
|
||||
{
|
||||
@@ -170,15 +171,22 @@ public sealed class CachedFileProvider : IDisposable
|
||||
|
||||
public FileInfo? GetLocalFilePath(string hash)
|
||||
{
|
||||
var fi = FilePathUtil.GetFileInfoForHash(_hotStoragePath, hash);
|
||||
if (fi == null) return null;
|
||||
var fi = FilePathUtil.GetFileInfoForHash(_hotStoragePath, hash);
|
||||
if (fi == null) return null;
|
||||
|
||||
fi.LastAccessTimeUtc = DateTime.UtcNow;
|
||||
try
|
||||
{
|
||||
File.SetLastAccessTimeUtc(fi.FullName, DateTime.UtcNow);
|
||||
}
|
||||
catch (Exception ex)
|
||||
{
|
||||
_logger.LogWarning(ex, "Failed to update LastAccessTimeUtc for file {hash}", hash);
|
||||
}
|
||||
|
||||
_fileStatisticsService.LogFile(hash, fi.Length);
|
||||
_fileStatisticsService.LogFile(hash, fi.Length);
|
||||
|
||||
return new FileInfo(fi.FullName);
|
||||
}
|
||||
return new FileInfo(fi.FullName);
|
||||
}
|
||||
|
||||
public async Task<FileInfo?> DownloadAndGetLocalFileInfo(string hash)
|
||||
{
|
||||
|
||||
Reference in New Issue
Block a user