Compare commits
3 Commits
master
...
group-ban-
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
f6cc919e2d | ||
|
|
3a6adc520a | ||
|
|
6a8a2e22a8 |
@@ -1150,11 +1150,11 @@ public partial class LightlessHub
|
|||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
|
|
||||||
var (isOwnerOrMod, _) = await TryValidateGroupModeratorOrOwner(dto.GID).ConfigureAwait(false);
|
var (isOwner, _) = await TryValidateOwner(dto.GID).ConfigureAwait(false);
|
||||||
if (!isOwnerOrMod)
|
if (!isOwner)
|
||||||
{
|
{
|
||||||
_logger.LogCallWarning(LightlessHubLogger.Args("Unauthorized syncshell broadcast change", "User", UserUID, "GID", dto.GID));
|
_logger.LogCallWarning(LightlessHubLogger.Args("Unauthorized syncshell broadcast change", "User", UserUID, "GID", dto.GID));
|
||||||
await Clients.Caller.Client_ReceiveServerMessage(MessageSeverity.Error, "You must be the owner or moderator of the syncshell to broadcast it.");
|
await Clients.Caller.Client_ReceiveServerMessage(MessageSeverity.Error, "You must be the owner of the syncshell to broadcast it.");
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -72,7 +72,7 @@ public class LightlessCensus : IHostedService
|
|||||||
|
|
||||||
Dictionary<ushort, short> worldDcs = new();
|
Dictionary<ushort, short> worldDcs = new();
|
||||||
|
|
||||||
var dcs = await client.GetStringAsync("https://raw.githubusercontent.com/xivapi/ffxiv-datamining/master/csv/en/WorldDCGroupType.csv", cancellationToken).ConfigureAwait(false);
|
var dcs = await client.GetStringAsync("https://raw.githubusercontent.com/xivapi/ffxiv-datamining/master/csv/WorldDCGroupType.csv", cancellationToken).ConfigureAwait(false);
|
||||||
// dc: https://raw.githubusercontent.com/xivapi/ffxiv-datamining/master/csv/WorldDCGroupType.csv
|
// dc: https://raw.githubusercontent.com/xivapi/ffxiv-datamining/master/csv/WorldDCGroupType.csv
|
||||||
// id, name, region
|
// id, name, region
|
||||||
|
|
||||||
@@ -92,7 +92,7 @@ public class LightlessCensus : IHostedService
|
|||||||
_dcs[id] = name;
|
_dcs[id] = name;
|
||||||
}
|
}
|
||||||
|
|
||||||
var worlds = await client.GetStringAsync("https://raw.githubusercontent.com/xivapi/ffxiv-datamining/master/csv/en/World.csv", cancellationToken).ConfigureAwait(false);
|
var worlds = await client.GetStringAsync("https://raw.githubusercontent.com/xivapi/ffxiv-datamining/master/csv/World.csv", cancellationToken).ConfigureAwait(false);
|
||||||
// world: https://raw.githubusercontent.com/xivapi/ffxiv-datamining/master/csv/World.csv
|
// world: https://raw.githubusercontent.com/xivapi/ffxiv-datamining/master/csv/World.csv
|
||||||
// id, internalname, name, region, usertype, datacenter, ispublic
|
// id, internalname, name, region, usertype, datacenter, ispublic
|
||||||
|
|
||||||
@@ -114,7 +114,7 @@ public class LightlessCensus : IHostedService
|
|||||||
_logger.LogInformation("World: ID: {id}, Name: {name}, DC: {dc}", id, name, dc);
|
_logger.LogInformation("World: ID: {id}, Name: {name}, DC: {dc}", id, name, dc);
|
||||||
}
|
}
|
||||||
|
|
||||||
var races = await client.GetStringAsync("https://raw.githubusercontent.com/xivapi/ffxiv-datamining/master/csv/en/Race.csv", cancellationToken).ConfigureAwait(false);
|
var races = await client.GetStringAsync("https://raw.githubusercontent.com/xivapi/ffxiv-datamining/master/csv/Race.csv", cancellationToken).ConfigureAwait(false);
|
||||||
// race: https://raw.githubusercontent.com/xivapi/ffxiv-datamining/master/csv/Race.csv
|
// race: https://raw.githubusercontent.com/xivapi/ffxiv-datamining/master/csv/Race.csv
|
||||||
// id, masc name, fem name, other crap I don't care about
|
// id, masc name, fem name, other crap I don't care about
|
||||||
|
|
||||||
@@ -134,7 +134,7 @@ public class LightlessCensus : IHostedService
|
|||||||
_logger.LogInformation("Race: ID: {id}, Name: {name}", id, name);
|
_logger.LogInformation("Race: ID: {id}, Name: {name}", id, name);
|
||||||
}
|
}
|
||||||
|
|
||||||
var tribe = await client.GetStringAsync("https://raw.githubusercontent.com/xivapi/ffxiv-datamining/master/csv/en/Tribe.csv", cancellationToken).ConfigureAwait(false);
|
var tribe = await client.GetStringAsync("https://raw.githubusercontent.com/xivapi/ffxiv-datamining/master/csv/Tribe.csv", cancellationToken).ConfigureAwait(false);
|
||||||
// tribe: https://raw.githubusercontent.com/xivapi/ffxiv-datamining/master/csv/Tribe.csv
|
// tribe: https://raw.githubusercontent.com/xivapi/ffxiv-datamining/master/csv/Tribe.csv
|
||||||
// id masc name, fem name, other crap I don't care about
|
// id masc name, fem name, other crap I don't care about
|
||||||
|
|
||||||
|
|||||||
@@ -2,19 +2,15 @@
|
|||||||
using LightlessSyncShared.Data;
|
using LightlessSyncShared.Data;
|
||||||
using LightlessSyncShared.Models;
|
using LightlessSyncShared.Models;
|
||||||
using Microsoft.EntityFrameworkCore;
|
using Microsoft.EntityFrameworkCore;
|
||||||
using StackExchange.Redis.Extensions.Core.Abstractions;
|
|
||||||
|
|
||||||
namespace LightlessSyncServer.Services
|
namespace LightlessSyncServer.Services
|
||||||
{
|
{
|
||||||
public class PruneService(LightlessDbContext dbContext, IRedisDatabase redis) : IPruneService
|
public class PruneService(LightlessDbContext dbContext) : IPruneService
|
||||||
{
|
{
|
||||||
private readonly LightlessDbContext _dbContext = dbContext;
|
private readonly LightlessDbContext _dbContext = dbContext;
|
||||||
private readonly IRedisDatabase _redis = redis;
|
|
||||||
|
|
||||||
public async Task<int> CountPrunableUsersAsync(string groupGid, int days, CancellationToken ct)
|
public async Task<int> CountPrunableUsersAsync(string groupGid, int days, CancellationToken ct)
|
||||||
{
|
{
|
||||||
var onlineUids = await GetOnlineUidsAsync().ConfigureAwait(false);
|
|
||||||
|
|
||||||
var allGroupUsers = await _dbContext.GroupPairs
|
var allGroupUsers = await _dbContext.GroupPairs
|
||||||
.Include(p => p.GroupUser)
|
.Include(p => p.GroupUser)
|
||||||
.Include(p => p.Group)
|
.Include(p => p.Group)
|
||||||
@@ -24,14 +20,17 @@ namespace LightlessSyncServer.Services
|
|||||||
var inactivitySpan = GetInactivitySpan(days);
|
var inactivitySpan = GetInactivitySpan(days);
|
||||||
var now = DateTime.UtcNow;
|
var now = DateTime.UtcNow;
|
||||||
|
|
||||||
var usersToPrune = GetPruneUserList(allGroupUsers, onlineUids, inactivitySpan, now);
|
var usersToPrune = allGroupUsers.Where(p =>
|
||||||
return usersToPrune.Count;
|
!p.IsPinned &&
|
||||||
|
!p.IsModerator &&
|
||||||
|
!string.Equals(p.Group.OwnerUID, p.GroupUserUID, StringComparison.Ordinal) &&
|
||||||
|
p.GroupUser.LastLoggedIn < now - inactivitySpan);
|
||||||
|
|
||||||
|
return usersToPrune.Count();
|
||||||
}
|
}
|
||||||
|
|
||||||
public async Task<IReadOnlyList<GroupPair>> ExecutePruneAsync(string groupGid, int days, CancellationToken ct)
|
public async Task<IReadOnlyList<GroupPair>> ExecutePruneAsync(string groupGid, int days, CancellationToken ct)
|
||||||
{
|
{
|
||||||
var onlineUids = await GetOnlineUidsAsync().ConfigureAwait(false);
|
|
||||||
|
|
||||||
var allGroupUsers = await _dbContext.GroupPairs
|
var allGroupUsers = await _dbContext.GroupPairs
|
||||||
.Include(p => p.GroupUser)
|
.Include(p => p.GroupUser)
|
||||||
.Include(p => p.Group)
|
.Include(p => p.Group)
|
||||||
@@ -41,7 +40,12 @@ namespace LightlessSyncServer.Services
|
|||||||
var inactivitySpan = GetInactivitySpan(days);
|
var inactivitySpan = GetInactivitySpan(days);
|
||||||
var now = DateTime.UtcNow;
|
var now = DateTime.UtcNow;
|
||||||
|
|
||||||
var usersToPrune = GetPruneUserList(allGroupUsers, onlineUids, inactivitySpan, now);
|
var usersToPrune = allGroupUsers.Where(p =>
|
||||||
|
!p.IsPinned &&
|
||||||
|
!p.IsModerator &&
|
||||||
|
!string.Equals(p.Group.OwnerUID, p.GroupUserUID, StringComparison.Ordinal) &&
|
||||||
|
p.GroupUser.LastLoggedIn < now - inactivitySpan)
|
||||||
|
.ToList();
|
||||||
|
|
||||||
_dbContext.GroupPairs.RemoveRange(usersToPrune);
|
_dbContext.GroupPairs.RemoveRange(usersToPrune);
|
||||||
await _dbContext.SaveChangesAsync(ct).ConfigureAwait(false);
|
await _dbContext.SaveChangesAsync(ct).ConfigureAwait(false);
|
||||||
@@ -49,52 +53,8 @@ namespace LightlessSyncServer.Services
|
|||||||
return usersToPrune;
|
return usersToPrune;
|
||||||
}
|
}
|
||||||
|
|
||||||
private static List<GroupPair> GetPruneUserList(
|
private static TimeSpan GetInactivitySpan(int days) => days == 0
|
||||||
List<GroupPair> allGroupUsers,
|
? TimeSpan.FromMinutes(15)
|
||||||
HashSet<string> onlineUids,
|
: TimeSpan.FromDays(days);
|
||||||
TimeSpan inactivitySpan,
|
|
||||||
DateTime now)
|
|
||||||
{
|
|
||||||
return
|
|
||||||
[
|
|
||||||
.. allGroupUsers.Where(p =>
|
|
||||||
!p.IsPinned &&
|
|
||||||
!p.IsModerator &&
|
|
||||||
!string.Equals(p.Group.OwnerUID, p.GroupUserUID, StringComparison.Ordinal) &&
|
|
||||||
!onlineUids.Contains(p.GroupUserUID) &&
|
|
||||||
p.GroupUser.LastLoggedIn < now - inactivitySpan),
|
|
||||||
];
|
|
||||||
}
|
|
||||||
|
|
||||||
private async Task<HashSet<string>> GetOnlineUidsAsync()
|
|
||||||
{
|
|
||||||
var keys = await _redis.SearchKeysAsync("UID:*").ConfigureAwait(false);
|
|
||||||
|
|
||||||
var set = new HashSet<string>(StringComparer.Ordinal);
|
|
||||||
|
|
||||||
foreach (var k in keys)
|
|
||||||
{
|
|
||||||
if (string.IsNullOrEmpty(k)) continue;
|
|
||||||
|
|
||||||
const string prefix = "UID:";
|
|
||||||
if (k.StartsWith(prefix, StringComparison.Ordinal))
|
|
||||||
{
|
|
||||||
var uid = k.Substring(prefix.Length);
|
|
||||||
if (!string.IsNullOrEmpty(uid))
|
|
||||||
set.Add(uid);
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
var idx = k.IndexOf(':', StringComparison.Ordinal);
|
|
||||||
if (idx >= 0 && idx < k.Length - 1)
|
|
||||||
set.Add(k[(idx + 1)..]);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
return set;
|
|
||||||
}
|
|
||||||
|
|
||||||
private static TimeSpan GetInactivitySpan(int days) =>
|
|
||||||
days == 0 ? TimeSpan.FromHours(2) : TimeSpan.FromDays(days);
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -24,7 +24,7 @@ namespace LightlessSyncServer.Worker
|
|||||||
var hubContext = scope.ServiceProvider.GetRequiredService<IHubContext<LightlessHub>>();
|
var hubContext = scope.ServiceProvider.GetRequiredService<IHubContext<LightlessHub>>();
|
||||||
|
|
||||||
var groups = await db.Groups
|
var groups = await db.Groups
|
||||||
.Where(g => g.AutoPruneEnabled)
|
.Where(g => g.AutoPruneEnabled && g.AutoPruneDays > 0)
|
||||||
.ToListAsync(stoppingToken).ConfigureAwait(false);
|
.ToListAsync(stoppingToken).ConfigureAwait(false);
|
||||||
|
|
||||||
foreach (var group in groups)
|
foreach (var group in groups)
|
||||||
|
|||||||
Reference in New Issue
Block a user