Compare commits
3 Commits
fix-stuck-
...
group-ban-
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
f6cc919e2d | ||
|
|
3a6adc520a | ||
|
|
6a8a2e22a8 |
@@ -28,25 +28,72 @@ public partial class LightlessHub
|
|||||||
var (userHasRights, group) = await TryValidateGroupModeratorOrOwner(dto.Group.GID).ConfigureAwait(false);
|
var (userHasRights, group) = await TryValidateGroupModeratorOrOwner(dto.Group.GID).ConfigureAwait(false);
|
||||||
if (!userHasRights) return;
|
if (!userHasRights) return;
|
||||||
|
|
||||||
var (userExists, groupPair) = await TryValidateUserInGroup(dto.Group.GID, dto.User.UID).ConfigureAwait(false);
|
var targetUid = dto.User.UID?.Trim();
|
||||||
if (!userExists) return;
|
if (string.IsNullOrWhiteSpace(targetUid)) return;
|
||||||
|
|
||||||
if (groupPair.IsModerator || string.Equals(group.OwnerUID, dto.User.UID, StringComparison.Ordinal)) return;
|
if (string.Equals(group.OwnerUID, targetUid, StringComparison.Ordinal))
|
||||||
|
return;
|
||||||
|
|
||||||
var alias = string.IsNullOrEmpty(groupPair.GroupUser.Alias) ? "-" : groupPair.GroupUser.Alias;
|
var groupPair = await DbContext.GroupPairs
|
||||||
var ban = new GroupBan()
|
.Include(p => p.GroupUser)
|
||||||
|
.SingleOrDefaultAsync(p => p.GroupGID == dto.Group.GID && p.GroupUserUID == targetUid, cancellationToken: RequestAbortedToken).ConfigureAwait(false);
|
||||||
|
|
||||||
|
if (groupPair?.IsModerator == true)
|
||||||
|
return;
|
||||||
|
|
||||||
|
var now = DateTime.UtcNow;
|
||||||
|
|
||||||
|
var existingBan = await DbContext.Set<GroupBan>().SingleOrDefaultAsync(b => b.GroupGID == dto.Group.GID && b.BannedUserUID == targetUid, cancellationToken: RequestAbortedToken).ConfigureAwait(false);
|
||||||
|
var userExists = await DbContext.Users.AsNoTracking().AnyAsync(u => u.UID == targetUid || u.Alias == targetUid, RequestAbortedToken).ConfigureAwait(false);
|
||||||
|
|
||||||
|
if (!userExists && existingBan == null)
|
||||||
|
return;
|
||||||
|
|
||||||
|
const string marker = " (Alias at time of ban:";
|
||||||
|
string suffix;
|
||||||
|
|
||||||
|
if (existingBan?.BannedReason is { } existingReason)
|
||||||
{
|
{
|
||||||
BannedByUID = UserUID,
|
var idx = existingReason.IndexOf(marker, StringComparison.Ordinal);
|
||||||
BannedReason = $"{reason} (Alias at time of ban: {alias})",
|
suffix = idx >= 0 ? existingReason.Substring(startIndex: idx) : string.Empty;
|
||||||
BannedOn = DateTime.UtcNow,
|
}
|
||||||
BannedUserUID = dto.User.UID,
|
else
|
||||||
GroupGID = dto.Group.GID,
|
{
|
||||||
};
|
var alias = groupPair?.GroupUser?.Alias;
|
||||||
|
alias = string.IsNullOrWhiteSpace(alias) ? "-" : alias;
|
||||||
|
suffix = $" (Alias at time of ban: {alias})";
|
||||||
|
}
|
||||||
|
|
||||||
DbContext.Add(ban);
|
var baseReason = (reason ?? string.Empty).Trim();
|
||||||
await DbContext.SaveChangesAsync().ConfigureAwait(false);
|
var finalReason = string.IsNullOrEmpty(suffix) ? baseReason : (baseReason + suffix);
|
||||||
|
|
||||||
await GroupRemoveUser(dto).ConfigureAwait(false);
|
if (existingBan != null)
|
||||||
|
{
|
||||||
|
existingBan.BannedByUID = UserUID;
|
||||||
|
existingBan.BannedReason = finalReason;
|
||||||
|
|
||||||
|
DbContext.Update(existingBan);
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
var ban = new GroupBan
|
||||||
|
{
|
||||||
|
BannedByUID = UserUID,
|
||||||
|
BannedReason = finalReason,
|
||||||
|
BannedOn = now,
|
||||||
|
BannedUserUID = targetUid,
|
||||||
|
GroupGID = dto.Group.GID,
|
||||||
|
};
|
||||||
|
|
||||||
|
DbContext.Add(ban);
|
||||||
|
}
|
||||||
|
|
||||||
|
await DbContext.SaveChangesAsync(RequestAbortedToken).ConfigureAwait(false);
|
||||||
|
|
||||||
|
if (groupPair != null)
|
||||||
|
{
|
||||||
|
await GroupRemoveUser(dto).ConfigureAwait(false);
|
||||||
|
}
|
||||||
|
|
||||||
_logger.LogCallInfo(LightlessHubLogger.Args(dto, "Success"));
|
_logger.LogCallInfo(LightlessHubLogger.Args(dto, "Success"));
|
||||||
}
|
}
|
||||||
@@ -400,9 +447,9 @@ public partial class LightlessHub
|
|||||||
|
|
||||||
var banEntries = await DbContext.GroupBans.Include(b => b.BannedUser).Where(g => g.GroupGID == dto.Group.GID).AsNoTracking().ToListAsync(cancellationToken: RequestAbortedToken).ConfigureAwait(false);
|
var banEntries = await DbContext.GroupBans.Include(b => b.BannedUser).Where(g => g.GroupGID == dto.Group.GID).AsNoTracking().ToListAsync(cancellationToken: RequestAbortedToken).ConfigureAwait(false);
|
||||||
|
|
||||||
List<BannedGroupUserDto> bannedGroupUsers = banEntries.Select(b =>
|
List<BannedGroupUserDto> bannedGroupUsers = [.. banEntries.Select(b =>
|
||||||
new BannedGroupUserDto(group.ToGroupData(), b.BannedUser.ToUserData(), b.BannedReason, b.BannedOn,
|
new BannedGroupUserDto(group.ToGroupData(), b.BannedUser.ToUserData(), b.BannedReason, b.BannedOn,
|
||||||
b.BannedByUID)).ToList();
|
b.BannedByUID))];
|
||||||
|
|
||||||
_logger.LogCallInfo(LightlessHubLogger.Args(dto, bannedGroupUsers.Count));
|
_logger.LogCallInfo(LightlessHubLogger.Args(dto, bannedGroupUsers.Count));
|
||||||
|
|
||||||
@@ -862,85 +909,85 @@ public partial class LightlessHub
|
|||||||
[Authorize(Policy = "Identified")]
|
[Authorize(Policy = "Identified")]
|
||||||
public async Task GroupSetProfile(GroupProfileDto dto)
|
public async Task GroupSetProfile(GroupProfileDto dto)
|
||||||
{
|
{
|
||||||
_logger.LogCallInfo(LightlessHubLogger.Args(dto));
|
_logger.LogCallInfo(LightlessHubLogger.Args(dto));
|
||||||
|
|
||||||
var cancellationToken = RequestAbortedToken;
|
var cancellationToken = RequestAbortedToken;
|
||||||
|
|
||||||
if (dto.Group == null) return;
|
if (dto.Group == null) return;
|
||||||
|
|
||||||
var (hasRights, group) = await TryValidateGroupModeratorOrOwner(dto.Group.GID).ConfigureAwait(false);
|
var (hasRights, group) = await TryValidateGroupModeratorOrOwner(dto.Group.GID).ConfigureAwait(false);
|
||||||
if (!hasRights) return;
|
if (!hasRights) return;
|
||||||
|
|
||||||
var groupProfileDb = await DbContext.GroupProfiles
|
var groupProfileDb = await DbContext.GroupProfiles
|
||||||
.Include(g => g.Group)
|
.Include(g => g.Group)
|
||||||
.FirstOrDefaultAsync(g => g.GroupGID == dto.Group.GID, cancellationToken)
|
.FirstOrDefaultAsync(g => g.GroupGID == dto.Group.GID, cancellationToken)
|
||||||
|
.ConfigureAwait(false);
|
||||||
|
|
||||||
|
ImageCheckService.ImageLoadResult profileResult = new();
|
||||||
|
ImageCheckService.ImageLoadResult bannerResult = new();
|
||||||
|
|
||||||
|
//Avatar image validation
|
||||||
|
if (!string.IsNullOrEmpty(dto.PictureBase64))
|
||||||
|
{
|
||||||
|
profileResult = await ImageCheckService.ValidateImageAsync(dto.PictureBase64, banner: false, RequestAbortedToken).ConfigureAwait(false);
|
||||||
|
|
||||||
|
if (!profileResult.Success)
|
||||||
|
{
|
||||||
|
await Clients.Caller.Client_ReceiveServerMessage(MessageSeverity.Error, profileResult.ErrorMessage).ConfigureAwait(false);
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
//Banner image validation
|
||||||
|
if (!string.IsNullOrEmpty(dto.BannerBase64))
|
||||||
|
{
|
||||||
|
bannerResult = await ImageCheckService.ValidateImageAsync(dto.BannerBase64, banner: true, RequestAbortedToken).ConfigureAwait(false);
|
||||||
|
|
||||||
|
if (!bannerResult.Success)
|
||||||
|
{
|
||||||
|
await Clients.Caller.Client_ReceiveServerMessage(MessageSeverity.Error, bannerResult.ErrorMessage).ConfigureAwait(false);
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
var sanitizedProfileImage = profileResult?.Base64Image;
|
||||||
|
var sanitizedBannerImage = bannerResult?.Base64Image;
|
||||||
|
|
||||||
|
if (groupProfileDb == null)
|
||||||
|
{
|
||||||
|
groupProfileDb = new GroupProfile
|
||||||
|
{
|
||||||
|
GroupGID = dto.Group.GID,
|
||||||
|
Group = group,
|
||||||
|
ProfileDisabled = dto.IsDisabled ?? false,
|
||||||
|
IsNSFW = dto.IsNsfw ?? false,
|
||||||
|
|
||||||
|
};
|
||||||
|
|
||||||
|
groupProfileDb.UpdateProfileFromDto(dto, sanitizedProfileImage, sanitizedBannerImage);
|
||||||
|
await DbContext.GroupProfiles.AddAsync(groupProfileDb, cancellationToken).ConfigureAwait(false);
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
groupProfileDb.Group ??= group;
|
||||||
|
|
||||||
|
groupProfileDb.UpdateProfileFromDto(dto, sanitizedProfileImage, sanitizedBannerImage);
|
||||||
|
}
|
||||||
|
|
||||||
|
var userIds = await DbContext.GroupPairs
|
||||||
|
.Where(p => p.GroupGID == groupProfileDb.GroupGID)
|
||||||
|
.Select(p => p.GroupUserUID)
|
||||||
|
.ToListAsync(cancellationToken)
|
||||||
|
.ConfigureAwait(false);
|
||||||
|
|
||||||
|
if (userIds.Count > 0)
|
||||||
|
{
|
||||||
|
var profileDto = groupProfileDb.ToDTO();
|
||||||
|
await Clients.Users(userIds).Client_GroupSendProfile(profileDto)
|
||||||
.ConfigureAwait(false);
|
.ConfigureAwait(false);
|
||||||
|
}
|
||||||
|
|
||||||
ImageCheckService.ImageLoadResult profileResult = new();
|
await DbContext.SaveChangesAsync(cancellationToken).ConfigureAwait(false);
|
||||||
ImageCheckService.ImageLoadResult bannerResult = new();
|
|
||||||
|
|
||||||
//Avatar image validation
|
|
||||||
if (!string.IsNullOrEmpty(dto.PictureBase64))
|
|
||||||
{
|
|
||||||
profileResult = await ImageCheckService.ValidateImageAsync(dto.PictureBase64, banner: false, RequestAbortedToken).ConfigureAwait(false);
|
|
||||||
|
|
||||||
if (!profileResult.Success)
|
|
||||||
{
|
|
||||||
await Clients.Caller.Client_ReceiveServerMessage(MessageSeverity.Error, profileResult.ErrorMessage).ConfigureAwait(false);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
//Banner image validation
|
|
||||||
if (!string.IsNullOrEmpty(dto.BannerBase64))
|
|
||||||
{
|
|
||||||
bannerResult = await ImageCheckService.ValidateImageAsync(dto.BannerBase64, banner: true, RequestAbortedToken).ConfigureAwait(false);
|
|
||||||
|
|
||||||
if (!bannerResult.Success)
|
|
||||||
{
|
|
||||||
await Clients.Caller.Client_ReceiveServerMessage(MessageSeverity.Error, bannerResult.ErrorMessage).ConfigureAwait(false);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
var sanitizedProfileImage = profileResult?.Base64Image;
|
|
||||||
var sanitizedBannerImage = bannerResult?.Base64Image;
|
|
||||||
|
|
||||||
if (groupProfileDb == null)
|
|
||||||
{
|
|
||||||
groupProfileDb = new GroupProfile
|
|
||||||
{
|
|
||||||
GroupGID = dto.Group.GID,
|
|
||||||
Group = group,
|
|
||||||
ProfileDisabled = dto.IsDisabled ?? false,
|
|
||||||
IsNSFW = dto.IsNsfw ?? false,
|
|
||||||
|
|
||||||
};
|
|
||||||
|
|
||||||
groupProfileDb.UpdateProfileFromDto(dto, sanitizedProfileImage, sanitizedBannerImage);
|
|
||||||
await DbContext.GroupProfiles.AddAsync(groupProfileDb, cancellationToken).ConfigureAwait(false);
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
groupProfileDb.Group ??= group;
|
|
||||||
|
|
||||||
groupProfileDb.UpdateProfileFromDto(dto, sanitizedProfileImage, sanitizedBannerImage);
|
|
||||||
}
|
|
||||||
|
|
||||||
var userIds = await DbContext.GroupPairs
|
|
||||||
.Where(p => p.GroupGID == groupProfileDb.GroupGID)
|
|
||||||
.Select(p => p.GroupUserUID)
|
|
||||||
.ToListAsync(cancellationToken)
|
|
||||||
.ConfigureAwait(false);
|
|
||||||
|
|
||||||
if (userIds.Count > 0)
|
|
||||||
{
|
|
||||||
var profileDto = groupProfileDb.ToDTO();
|
|
||||||
await Clients.Users(userIds).Client_GroupSendProfile(profileDto)
|
|
||||||
.ConfigureAwait(false);
|
|
||||||
}
|
|
||||||
|
|
||||||
await DbContext.SaveChangesAsync(cancellationToken).ConfigureAwait(false);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
[Authorize(Policy = "Identified")]
|
[Authorize(Policy = "Identified")]
|
||||||
|
|||||||
Reference in New Issue
Block a user