Compare commits
12 Commits
c8e28cdd64
...
fix-prune
| Author | SHA1 | Date | |
|---|---|---|---|
| c3784de9cd | |||
|
|
5aaa6ff35c | ||
|
|
2ef0725f4e | ||
| 1716750347 | |||
|
|
6e540ad0c6 | ||
|
|
863042d1fe | ||
|
|
b29475ea41 | ||
|
|
53e089a65b | ||
|
|
c3e87eb7df | ||
|
|
a533fca195 | ||
|
|
717d8e46f1 | ||
|
|
d3790013c6 |
4
.gitignore
vendored
4
.gitignore
vendored
@@ -351,4 +351,6 @@ MigrationBackup/
|
|||||||
|
|
||||||
# docker run data
|
# docker run data
|
||||||
Docker/run/data/
|
Docker/run/data/
|
||||||
*.idea
|
|
||||||
|
#idea files
|
||||||
|
*.idea
|
||||||
Submodule LightlessAPI updated: fdd492a8f4...4ecd5375e6
@@ -40,6 +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_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_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_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");
|
public Task Client_SendLocationToClient(LocationDto locationDto, DateTimeOffset expireAt) => throw new PlatformNotSupportedException("Calling clientside method on server not supported");
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -585,11 +585,6 @@ public partial class LightlessHub
|
|||||||
|
|
||||||
return await result.Distinct().AsNoTracking().ToListAsync().ConfigureAwait(false);
|
return await result.Distinct().AsNoTracking().ToListAsync().ConfigureAwait(false);
|
||||||
}
|
}
|
||||||
|
|
||||||
private async Task CleanVisibilityCacheFromRedis()
|
|
||||||
{
|
|
||||||
await _redis.RemoveAsync($"Visibility:{UserUID}", CommandFlags.FireAndForget).ConfigureAwait(false);
|
|
||||||
}
|
|
||||||
|
|
||||||
public record UserInfo(
|
public record UserInfo(
|
||||||
string Alias,
|
string Alias,
|
||||||
|
|||||||
@@ -504,7 +504,6 @@ public partial class LightlessHub
|
|||||||
preferredPermissions.DisableVFX = dto.GroupUserPreferredPermissions.IsDisableVFX();
|
preferredPermissions.DisableVFX = dto.GroupUserPreferredPermissions.IsDisableVFX();
|
||||||
preferredPermissions.DisableAnimations = dto.GroupUserPreferredPermissions.IsDisableAnimations();
|
preferredPermissions.DisableAnimations = dto.GroupUserPreferredPermissions.IsDisableAnimations();
|
||||||
preferredPermissions.IsPaused = false;
|
preferredPermissions.IsPaused = false;
|
||||||
preferredPermissions.ShareLocation = dto.GroupUserPreferredPermissions.IsSharingLocation();
|
|
||||||
DbContext.Update(preferredPermissions);
|
DbContext.Update(preferredPermissions);
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -550,8 +549,7 @@ public partial class LightlessHub
|
|||||||
DisableSounds = preferredPermissions.DisableSounds,
|
DisableSounds = preferredPermissions.DisableSounds,
|
||||||
DisableVFX = preferredPermissions.DisableVFX,
|
DisableVFX = preferredPermissions.DisableVFX,
|
||||||
IsPaused = preferredPermissions.IsPaused,
|
IsPaused = preferredPermissions.IsPaused,
|
||||||
Sticky = false,
|
Sticky = false
|
||||||
ShareLocation = preferredPermissions.ShareLocation,
|
|
||||||
};
|
};
|
||||||
|
|
||||||
await DbContext.Permissions.AddAsync(ownPermissionsToOther).ConfigureAwait(false);
|
await DbContext.Permissions.AddAsync(ownPermissionsToOther).ConfigureAwait(false);
|
||||||
@@ -563,7 +561,6 @@ public partial class LightlessHub
|
|||||||
existingPermissionsOnDb.DisableVFX = preferredPermissions.DisableVFX;
|
existingPermissionsOnDb.DisableVFX = preferredPermissions.DisableVFX;
|
||||||
existingPermissionsOnDb.IsPaused = false;
|
existingPermissionsOnDb.IsPaused = false;
|
||||||
existingPermissionsOnDb.Sticky = false;
|
existingPermissionsOnDb.Sticky = false;
|
||||||
existingPermissionsOnDb.ShareLocation = preferredPermissions.ShareLocation;
|
|
||||||
|
|
||||||
DbContext.Update(existingPermissionsOnDb);
|
DbContext.Update(existingPermissionsOnDb);
|
||||||
|
|
||||||
@@ -579,7 +576,6 @@ public partial class LightlessHub
|
|||||||
ownPermissionsToOther.DisableVFX = preferredPermissions.DisableVFX;
|
ownPermissionsToOther.DisableVFX = preferredPermissions.DisableVFX;
|
||||||
ownPermissionsToOther.DisableSounds = preferredPermissions.DisableSounds;
|
ownPermissionsToOther.DisableSounds = preferredPermissions.DisableSounds;
|
||||||
ownPermissionsToOther.IsPaused = false;
|
ownPermissionsToOther.IsPaused = false;
|
||||||
ownPermissionsToOther.ShareLocation = preferredPermissions.ShareLocation;
|
|
||||||
|
|
||||||
DbContext.Update(ownPermissionsToOther);
|
DbContext.Update(ownPermissionsToOther);
|
||||||
}
|
}
|
||||||
@@ -601,8 +597,7 @@ public partial class LightlessHub
|
|||||||
DisableSounds = otherPreferred.DisableSounds,
|
DisableSounds = otherPreferred.DisableSounds,
|
||||||
DisableVFX = otherPreferred.DisableVFX,
|
DisableVFX = otherPreferred.DisableVFX,
|
||||||
IsPaused = otherPreferred.IsPaused,
|
IsPaused = otherPreferred.IsPaused,
|
||||||
Sticky = false,
|
Sticky = false
|
||||||
ShareLocation = otherPreferred.ShareLocation,
|
|
||||||
};
|
};
|
||||||
|
|
||||||
await DbContext.AddAsync(otherExistingPermsOnDb).ConfigureAwait(false);
|
await DbContext.AddAsync(otherExistingPermsOnDb).ConfigureAwait(false);
|
||||||
@@ -614,7 +609,6 @@ public partial class LightlessHub
|
|||||||
otherExistingPermsOnDb.DisableSounds = otherPreferred.DisableSounds;
|
otherExistingPermsOnDb.DisableSounds = otherPreferred.DisableSounds;
|
||||||
otherExistingPermsOnDb.DisableVFX = otherPreferred.DisableVFX;
|
otherExistingPermsOnDb.DisableVFX = otherPreferred.DisableVFX;
|
||||||
otherExistingPermsOnDb.IsPaused = otherPreferred.IsPaused;
|
otherExistingPermsOnDb.IsPaused = otherPreferred.IsPaused;
|
||||||
otherExistingPermsOnDb.ShareLocation = otherPreferred.ShareLocation;
|
|
||||||
|
|
||||||
DbContext.Update(otherExistingPermsOnDb);
|
DbContext.Update(otherExistingPermsOnDb);
|
||||||
}
|
}
|
||||||
@@ -628,7 +622,6 @@ public partial class LightlessHub
|
|||||||
otherPermissionToSelf.DisableSounds = otherPreferred.DisableSounds;
|
otherPermissionToSelf.DisableSounds = otherPreferred.DisableSounds;
|
||||||
otherPermissionToSelf.DisableVFX = otherPreferred.DisableVFX;
|
otherPermissionToSelf.DisableVFX = otherPreferred.DisableVFX;
|
||||||
otherPermissionToSelf.IsPaused = otherPreferred.IsPaused;
|
otherPermissionToSelf.IsPaused = otherPreferred.IsPaused;
|
||||||
otherPermissionToSelf.ShareLocation = otherPreferred.ShareLocation;
|
|
||||||
|
|
||||||
DbContext.Update(otherPermissionToSelf);
|
DbContext.Update(otherPermissionToSelf);
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -66,7 +66,6 @@ public partial class LightlessHub
|
|||||||
prevPermissions.DisableSounds = newPerm.IsDisableSounds();
|
prevPermissions.DisableSounds = newPerm.IsDisableSounds();
|
||||||
prevPermissions.DisableVFX = newPerm.IsDisableVFX();
|
prevPermissions.DisableVFX = newPerm.IsDisableVFX();
|
||||||
prevPermissions.Sticky = newPerm.IsSticky() || setSticky;
|
prevPermissions.Sticky = newPerm.IsSticky() || setSticky;
|
||||||
prevPermissions.ShareLocation = newPerm.IsSharingLocation();
|
|
||||||
DbContext.Update(prevPermissions);
|
DbContext.Update(prevPermissions);
|
||||||
|
|
||||||
// send updated data to pair
|
// send updated data to pair
|
||||||
@@ -113,7 +112,6 @@ public partial class LightlessHub
|
|||||||
groupPreferredPermissions.DisableAnimations = group.Value.IsDisableAnimations();
|
groupPreferredPermissions.DisableAnimations = group.Value.IsDisableAnimations();
|
||||||
groupPreferredPermissions.IsPaused = group.Value.IsPaused();
|
groupPreferredPermissions.IsPaused = group.Value.IsPaused();
|
||||||
groupPreferredPermissions.DisableVFX = group.Value.IsDisableVFX();
|
groupPreferredPermissions.DisableVFX = group.Value.IsDisableVFX();
|
||||||
groupPreferredPermissions.ShareLocation = group.Value.IsSharingLocation();
|
|
||||||
|
|
||||||
var nonStickyPairs = allUsers.Where(u => !u.Value.OwnPermissions.Sticky).ToList();
|
var nonStickyPairs = allUsers.Where(u => !u.Value.OwnPermissions.Sticky).ToList();
|
||||||
var affectedGroupPairs = nonStickyPairs.Where(u => u.Value.GIDs.Contains(group.Key, StringComparer.Ordinal)).ToList();
|
var affectedGroupPairs = nonStickyPairs.Where(u => u.Value.GIDs.Contains(group.Key, StringComparer.Ordinal)).ToList();
|
||||||
@@ -128,7 +126,6 @@ public partial class LightlessHub
|
|||||||
perm.DisableAnimations = groupPreferredPermissions.DisableAnimations;
|
perm.DisableAnimations = groupPreferredPermissions.DisableAnimations;
|
||||||
perm.IsPaused = groupPreferredPermissions.IsPaused;
|
perm.IsPaused = groupPreferredPermissions.IsPaused;
|
||||||
perm.DisableVFX = groupPreferredPermissions.DisableVFX;
|
perm.DisableVFX = groupPreferredPermissions.DisableVFX;
|
||||||
perm.ShareLocation = groupPreferredPermissions.ShareLocation;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
UserPermissions permissions = UserPermissions.NoneSet;
|
UserPermissions permissions = UserPermissions.NoneSet;
|
||||||
@@ -136,7 +133,6 @@ public partial class LightlessHub
|
|||||||
permissions.SetDisableAnimations(groupPreferredPermissions.DisableAnimations);
|
permissions.SetDisableAnimations(groupPreferredPermissions.DisableAnimations);
|
||||||
permissions.SetDisableSounds(groupPreferredPermissions.DisableSounds);
|
permissions.SetDisableSounds(groupPreferredPermissions.DisableSounds);
|
||||||
permissions.SetDisableVFX(groupPreferredPermissions.DisableVFX);
|
permissions.SetDisableVFX(groupPreferredPermissions.DisableVFX);
|
||||||
permissions.SetShareLocation(groupPreferredPermissions.ShareLocation);
|
|
||||||
|
|
||||||
await Clients.Users(affectedGroupPairs
|
await Clients.Users(affectedGroupPairs
|
||||||
.Select(k => k.Key))
|
.Select(k => k.Key))
|
||||||
|
|||||||
@@ -12,8 +12,6 @@ using LightlessSyncShared.Utils;
|
|||||||
using Microsoft.AspNetCore.Authorization;
|
using Microsoft.AspNetCore.Authorization;
|
||||||
using Microsoft.AspNetCore.SignalR;
|
using Microsoft.AspNetCore.SignalR;
|
||||||
using Microsoft.EntityFrameworkCore;
|
using Microsoft.EntityFrameworkCore;
|
||||||
using SixLabors.ImageSharp;
|
|
||||||
using SixLabors.ImageSharp.PixelFormats;
|
|
||||||
using StackExchange.Redis;
|
using StackExchange.Redis;
|
||||||
using System.Text;
|
using System.Text;
|
||||||
using System.Text.Json;
|
using System.Text.Json;
|
||||||
@@ -86,8 +84,7 @@ public partial class LightlessHub
|
|||||||
DisableSounds = ownDefaultPermissions.DisableIndividualSounds,
|
DisableSounds = ownDefaultPermissions.DisableIndividualSounds,
|
||||||
DisableVFX = ownDefaultPermissions.DisableIndividualVFX,
|
DisableVFX = ownDefaultPermissions.DisableIndividualVFX,
|
||||||
IsPaused = false,
|
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);
|
var existingDbPerms = await DbContext.Permissions.SingleOrDefaultAsync(u => u.UserUID == UserUID && u.OtherUserUID == otherUser.UID, cancellationToken: RequestAbortedToken).ConfigureAwait(false);
|
||||||
@@ -102,7 +99,6 @@ public partial class LightlessHub
|
|||||||
existingDbPerms.DisableVFX = permissions.DisableVFX;
|
existingDbPerms.DisableVFX = permissions.DisableVFX;
|
||||||
existingDbPerms.IsPaused = false;
|
existingDbPerms.IsPaused = false;
|
||||||
existingDbPerms.Sticky = true;
|
existingDbPerms.Sticky = true;
|
||||||
existingDbPerms.ShareLocation = permissions.ShareLocation;
|
|
||||||
|
|
||||||
DbContext.Permissions.Update(existingDbPerms);
|
DbContext.Permissions.Update(existingDbPerms);
|
||||||
}
|
}
|
||||||
@@ -1235,82 +1231,118 @@ public partial class LightlessHub
|
|||||||
return true;
|
return true;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
[Authorize(Policy = "Identified")]
|
[Authorize(Policy = "Identified")]
|
||||||
public async Task UpdateLocation(LocationDto dto, bool offline = false)
|
public async Task UpdateLocation(LocationDto dto, bool offline = false)
|
||||||
{
|
{
|
||||||
_logger.LogCallInfo(LightlessHubLogger.Args(UserUID,dto));
|
_logger.LogCallInfo(LightlessHubLogger.Args(UserUID,dto));
|
||||||
if (string.IsNullOrEmpty(dto.user.UID))
|
if (string.IsNullOrEmpty(dto.User.UID))
|
||||||
{
|
{
|
||||||
_logger.LogCallWarning(LightlessHubLogger.Args("LocationDto with no userinfo :",UserUID, dto));
|
_logger.LogCallWarning(LightlessHubLogger.Args("LocationDto with no userinfo :",UserUID, dto));
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
if (!string.Equals(UserUID, dto.user.UID, StringComparison.Ordinal))
|
if (!string.Equals(UserUID, dto.User.UID, StringComparison.Ordinal))
|
||||||
{
|
{
|
||||||
_logger.LogCallWarning(LightlessHubLogger.Args("LocationDto with another UID :",UserUID, dto));
|
_logger.LogCallWarning(LightlessHubLogger.Args("LocationDto with another UID :",UserUID, dto));
|
||||||
return;
|
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}";
|
var key = $"Location:{UserUID}";
|
||||||
|
|
||||||
if (offline)
|
if (offline)
|
||||||
{
|
{
|
||||||
await _redis.RemoveAsync(key, StackExchange.Redis.CommandFlags.FireAndForget).ConfigureAwait(false);
|
var allUsers = await GetSharingUsers().ConfigureAwait(false);
|
||||||
await Clients.Users(allUsers).Client_SendLocationToClient(dto).ConfigureAwait(false);
|
await _redis.RemoveAsync(key, CommandFlags.FireAndForget).ConfigureAwait(false);
|
||||||
|
await Clients.Users(allUsers.Keys).Client_SendLocationToClient(dto, DateTimeOffset.MinValue).ConfigureAwait(false);
|
||||||
}
|
}
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
var currentLocation = await _redis.GetAsync<LocationDto>(key).ConfigureAwait(false);
|
var currentLocation = await _redis.GetAsync<LocationDto>(key).ConfigureAwait(false);
|
||||||
|
if (currentLocation != dto)
|
||||||
await _redis.AddAsync(key, dto).ConfigureAwait(false);
|
|
||||||
if (allUsers.Count != 0 && currentLocation != dto)
|
|
||||||
{
|
{
|
||||||
await Clients.Users(allUsers).Client_SendLocationToClient(dto).ConfigureAwait(false);
|
var allUsers = await GetSharingUsers().ConfigureAwait(false);
|
||||||
|
await _redis.AddAsync(key, dto).ConfigureAwait(false);
|
||||||
|
var sendTasks = allUsers.Select(pair => Clients.User(pair.Key).Client_SendLocationToClient(dto, pair.Value));
|
||||||
|
await Task.WhenAll(sendTasks).ConfigureAwait(false);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
private async Task<Dictionary<string, DateTimeOffset>> GetSharingUsers()
|
||||||
|
{
|
||||||
|
return await DbContext.Permissions.AsNoTracking()
|
||||||
|
.Where(x => x.UserUID == UserUID && x.ShareLocationUntil > DateTimeOffset.UtcNow)
|
||||||
|
.ToDictionaryAsync(x => x.OtherUserUID, x => x.ShareLocationUntil, RequestAbortedToken)
|
||||||
|
.ConfigureAwait(false);
|
||||||
|
}
|
||||||
|
|
||||||
[Authorize(Policy = "Identified")]
|
[Authorize(Policy = "Identified")]
|
||||||
public async Task<List<LocationDto>> RequestAllLocationInfo()
|
public async Task<(List<LocationWithTimeDto>, List<SharingStatusDto>)> RequestAllLocationInfo()
|
||||||
{
|
{
|
||||||
_logger.LogCallInfo();
|
_logger.LogCallInfo();
|
||||||
var uids = DbContext.Permissions.AsNoTracking().Where(x => x.OtherUserUID == UserUID && x.ShareLocation == true)
|
var locationWithTime = await GetLocationWithTime().ConfigureAwait(false);
|
||||||
.Select(x => x.UserUID).ToList();
|
var sharingStatus = await GetSharingStatus().ConfigureAwait(false);
|
||||||
var data =await _redis.GetAllAsync<LocationDto>(uids.Select(x => $"Location:{x}").ToHashSet(StringComparer.Ordinal))
|
return (locationWithTime, sharingStatus);
|
||||||
|
}
|
||||||
|
|
||||||
|
private async Task<List<LocationWithTimeDto>> GetLocationWithTime()
|
||||||
|
{
|
||||||
|
var dictionary = await DbContext.Permissions.AsNoTracking()
|
||||||
|
.Where(x => x.OtherUserUID == UserUID && x.ShareLocationUntil > DateTimeOffset.UtcNow)
|
||||||
|
.ToDictionaryAsync(x => x.UserUID, x => x.ShareLocationUntil, cancellationToken: RequestAbortedToken)
|
||||||
.ConfigureAwait(false);
|
.ConfigureAwait(false);
|
||||||
return data.Where(x => x.Value is not null).Select(x => x.Value).ToList();
|
if (dictionary.Count == 0)
|
||||||
|
{
|
||||||
|
return [];
|
||||||
|
}
|
||||||
|
|
||||||
|
var redisKeys = dictionary.Keys.Select(uid => $"Location:{uid}").ToHashSet(StringComparer.Ordinal);
|
||||||
|
var data = await _redis.GetAllAsync<LocationDto>(redisKeys).ConfigureAwait(false);
|
||||||
|
var result = new List<LocationWithTimeDto>();
|
||||||
|
|
||||||
|
foreach (var (userUid, expireAt) in dictionary)
|
||||||
|
{
|
||||||
|
var redisKey = $"Location:{userUid}";
|
||||||
|
|
||||||
|
if (data.TryGetValue(redisKey, out var locationDto) && locationDto is not null)
|
||||||
|
{
|
||||||
|
result.Add(new LocationWithTimeDto(locationDto, expireAt));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
return result;
|
||||||
|
}
|
||||||
|
|
||||||
|
private async Task<List<SharingStatusDto>> GetSharingStatus()
|
||||||
|
{
|
||||||
|
return await DbContext.Permissions.AsNoTracking()
|
||||||
|
.Where(x => x.UserUID == UserUID && x.ShareLocationUntil > DateTimeOffset.UtcNow)
|
||||||
|
.Select(x => new SharingStatusDto(new UserData(x.OtherUserUID), x.ShareLocationUntil))
|
||||||
|
.ToListAsync(cancellationToken: RequestAbortedToken).ConfigureAwait(false);
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
[Authorize(Policy = "Identified")]
|
||||||
|
public async Task<bool> ToggleLocationSharing(LocationSharingToggleDto dto)
|
||||||
|
{
|
||||||
|
_logger.LogCallInfo(LightlessHubLogger.Args(UserUID,dto));
|
||||||
|
try
|
||||||
|
{
|
||||||
|
await DbContext.Permissions.Where(x => x.UserUID == UserUID && dto.users.Contains(x.OtherUserUID))
|
||||||
|
.ExecuteUpdateAsync(setter =>
|
||||||
|
setter.SetProperty(x => x.ShareLocationUntil, dto.duration.ToUniversalTime()),
|
||||||
|
cancellationToken: RequestAbortedToken).ConfigureAwait(false);
|
||||||
|
|
||||||
|
//update user's location for target users
|
||||||
|
var currentLocation = await _redis.GetAsync<LocationDto>($"Location:{UserUID}").ConfigureAwait(false);
|
||||||
|
await Clients.Users(dto.users).Client_SendLocationToClient(currentLocation, dto.duration.ToUniversalTime())
|
||||||
|
.ConfigureAwait(false);
|
||||||
|
}
|
||||||
|
catch (Exception ex)
|
||||||
|
{
|
||||||
|
_logger.LogError(ex, "ToggleLocationSharing error:");
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
return true;
|
||||||
}
|
}
|
||||||
|
|
||||||
[GeneratedRegex(@"^([a-z0-9_ '+&,\.\-\{\}]+\/)+([a-z0-9_ '+&,\.\-\{\}]+\.[a-z]{3,4})$", RegexOptions.IgnoreCase | RegexOptions.Compiled | RegexOptions.ECMAScript)]
|
[GeneratedRegex(@"^([a-z0-9_ '+&,\.\-\{\}]+\/)+([a-z0-9_ '+&,\.\-\{\}]+\.[a-z]{3,4})$", RegexOptions.IgnoreCase | RegexOptions.Compiled | RegexOptions.ECMAScript)]
|
||||||
|
|||||||
@@ -219,11 +219,10 @@ public partial class LightlessHub : Hub<ILightlessHub>, ILightlessHub
|
|||||||
await RemoveUserFromRedis().ConfigureAwait(false);
|
await RemoveUserFromRedis().ConfigureAwait(false);
|
||||||
|
|
||||||
_lightlessCensus.ClearStatistics(UserUID);
|
_lightlessCensus.ClearStatistics(UserUID);
|
||||||
|
|
||||||
await SendOfflineToAllPairedUsers().ConfigureAwait(false);
|
|
||||||
|
|
||||||
await UpdateLocation(new LocationDto(new UserData(UserUID), new LocationInfo()), offline: true).ConfigureAwait(false);
|
await UpdateLocation(new LocationDto(new UserData(UserUID), new LocationInfo()), offline: true).ConfigureAwait(false);
|
||||||
await CleanVisibilityCacheFromRedis().ConfigureAwait(false);
|
|
||||||
|
await SendOfflineToAllPairedUsers().ConfigureAwait(false);
|
||||||
|
|
||||||
DbContext.RemoveRange(DbContext.Files.Where(f => !f.Uploaded && f.UploaderUID == UserUID));
|
DbContext.RemoveRange(DbContext.Files.Where(f => !f.Uploaded && f.UploaderUID == UserUID));
|
||||||
await DbContext.SaveChangesAsync().ConfigureAwait(false);
|
await DbContext.SaveChangesAsync().ConfigureAwait(false);
|
||||||
|
|||||||
@@ -67,7 +67,6 @@ public class PairService
|
|||||||
DisableVFX = defaultPerms.DisableIndividualVFX,
|
DisableVFX = defaultPerms.DisableIndividualVFX,
|
||||||
IsPaused = false,
|
IsPaused = false,
|
||||||
Sticky = true,
|
Sticky = true,
|
||||||
ShareLocation = false,
|
|
||||||
});
|
});
|
||||||
modified = true;
|
modified = true;
|
||||||
}
|
}
|
||||||
@@ -89,7 +88,6 @@ public class PairService
|
|||||||
DisableVFX = defaultPerms.DisableIndividualVFX,
|
DisableVFX = defaultPerms.DisableIndividualVFX,
|
||||||
IsPaused = false,
|
IsPaused = false,
|
||||||
Sticky = true,
|
Sticky = true,
|
||||||
ShareLocation = false,
|
|
||||||
});
|
});
|
||||||
modified = true;
|
modified = true;
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -2,15 +2,19 @@
|
|||||||
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) : IPruneService
|
public class PruneService(LightlessDbContext dbContext, IRedisDatabase redis) : 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)
|
||||||
@@ -20,17 +24,14 @@ namespace LightlessSyncServer.Services
|
|||||||
var inactivitySpan = GetInactivitySpan(days);
|
var inactivitySpan = GetInactivitySpan(days);
|
||||||
var now = DateTime.UtcNow;
|
var now = DateTime.UtcNow;
|
||||||
|
|
||||||
var usersToPrune = allGroupUsers.Where(p =>
|
var usersToPrune = GetPruneUserList(allGroupUsers, onlineUids, inactivitySpan, now);
|
||||||
!p.IsPinned &&
|
return usersToPrune.Count;
|
||||||
!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)
|
||||||
@@ -40,12 +41,7 @@ namespace LightlessSyncServer.Services
|
|||||||
var inactivitySpan = GetInactivitySpan(days);
|
var inactivitySpan = GetInactivitySpan(days);
|
||||||
var now = DateTime.UtcNow;
|
var now = DateTime.UtcNow;
|
||||||
|
|
||||||
var usersToPrune = allGroupUsers.Where(p =>
|
var usersToPrune = GetPruneUserList(allGroupUsers, onlineUids, inactivitySpan, now);
|
||||||
!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);
|
||||||
@@ -53,8 +49,52 @@ namespace LightlessSyncServer.Services
|
|||||||
return usersToPrune;
|
return usersToPrune;
|
||||||
}
|
}
|
||||||
|
|
||||||
private static TimeSpan GetInactivitySpan(int days) => days == 0
|
private static List<GroupPair> GetPruneUserList(
|
||||||
? TimeSpan.FromMinutes(15)
|
List<GroupPair> allGroupUsers,
|
||||||
: TimeSpan.FromDays(days);
|
HashSet<string> onlineUids,
|
||||||
|
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);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -129,7 +129,6 @@ public static class Extensions
|
|||||||
permissions.SetDisableSounds(groupPair.DisableSounds);
|
permissions.SetDisableSounds(groupPair.DisableSounds);
|
||||||
permissions.SetPaused(groupPair.IsPaused);
|
permissions.SetPaused(groupPair.IsPaused);
|
||||||
permissions.SetDisableVFX(groupPair.DisableVFX);
|
permissions.SetDisableVFX(groupPair.DisableVFX);
|
||||||
permissions.SetShareLocation(groupPair.ShareLocation);
|
|
||||||
return permissions;
|
return permissions;
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -150,7 +149,6 @@ public static class Extensions
|
|||||||
perm.SetDisableAnimations(permissions.DisableAnimations);
|
perm.SetDisableAnimations(permissions.DisableAnimations);
|
||||||
perm.SetDisableSounds(permissions.DisableSounds);
|
perm.SetDisableSounds(permissions.DisableSounds);
|
||||||
perm.SetDisableVFX(permissions.DisableVFX);
|
perm.SetDisableVFX(permissions.DisableVFX);
|
||||||
perm.SetShareLocation(permissions.ShareLocation);
|
|
||||||
if (setSticky)
|
if (setSticky)
|
||||||
perm.SetSticky(permissions.Sticky);
|
perm.SetSticky(permissions.Sticky);
|
||||||
return perm;
|
return perm;
|
||||||
|
|||||||
@@ -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 && g.AutoPruneDays > 0)
|
.Where(g => g.AutoPruneEnabled)
|
||||||
.ToListAsync(stoppingToken).ConfigureAwait(false);
|
.ToListAsync(stoppingToken).ConfigureAwait(false);
|
||||||
|
|
||||||
foreach (var group in groups)
|
foreach (var group in groups)
|
||||||
|
|||||||
@@ -1,40 +0,0 @@
|
|||||||
using Microsoft.EntityFrameworkCore.Migrations;
|
|
||||||
|
|
||||||
#nullable disable
|
|
||||||
|
|
||||||
namespace LightlessSyncServer.Migrations
|
|
||||||
{
|
|
||||||
/// <inheritdoc />
|
|
||||||
public partial class LocationSharing : Migration
|
|
||||||
{
|
|
||||||
/// <inheritdoc />
|
|
||||||
protected override void Up(MigrationBuilder migrationBuilder)
|
|
||||||
{
|
|
||||||
migrationBuilder.AddColumn<bool>(
|
|
||||||
name: "share_location",
|
|
||||||
table: "user_permission_sets",
|
|
||||||
type: "boolean",
|
|
||||||
nullable: false,
|
|
||||||
defaultValue: false);
|
|
||||||
|
|
||||||
migrationBuilder.AddColumn<bool>(
|
|
||||||
name: "share_location",
|
|
||||||
table: "group_pair_preferred_permissions",
|
|
||||||
type: "boolean",
|
|
||||||
nullable: false,
|
|
||||||
defaultValue: false);
|
|
||||||
}
|
|
||||||
|
|
||||||
/// <inheritdoc />
|
|
||||||
protected override void Down(MigrationBuilder migrationBuilder)
|
|
||||||
{
|
|
||||||
migrationBuilder.DropColumn(
|
|
||||||
name: "share_location",
|
|
||||||
table: "user_permission_sets");
|
|
||||||
|
|
||||||
migrationBuilder.DropColumn(
|
|
||||||
name: "share_location",
|
|
||||||
table: "group_pair_preferred_permissions");
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
@@ -12,8 +12,8 @@ using Npgsql.EntityFrameworkCore.PostgreSQL.Metadata;
|
|||||||
namespace LightlessSyncServer.Migrations
|
namespace LightlessSyncServer.Migrations
|
||||||
{
|
{
|
||||||
[DbContext(typeof(LightlessDbContext))]
|
[DbContext(typeof(LightlessDbContext))]
|
||||||
[Migration("20251227120132_LocationSharing")]
|
[Migration("20251229015535_ShareLocation")]
|
||||||
partial class LocationSharing
|
partial class ShareLocation
|
||||||
{
|
{
|
||||||
/// <inheritdoc />
|
/// <inheritdoc />
|
||||||
protected override void BuildTargetModel(ModelBuilder modelBuilder)
|
protected override void BuildTargetModel(ModelBuilder modelBuilder)
|
||||||
@@ -587,10 +587,6 @@ namespace LightlessSyncServer.Migrations
|
|||||||
.HasColumnType("boolean")
|
.HasColumnType("boolean")
|
||||||
.HasColumnName("is_paused");
|
.HasColumnName("is_paused");
|
||||||
|
|
||||||
b.Property<bool>("ShareLocation")
|
|
||||||
.HasColumnType("boolean")
|
|
||||||
.HasColumnName("share_location");
|
|
||||||
|
|
||||||
b.HasKey("UserUID", "GroupGID")
|
b.HasKey("UserUID", "GroupGID")
|
||||||
.HasName("pk_group_pair_preferred_permissions");
|
.HasName("pk_group_pair_preferred_permissions");
|
||||||
|
|
||||||
@@ -948,9 +944,9 @@ namespace LightlessSyncServer.Migrations
|
|||||||
.HasColumnType("boolean")
|
.HasColumnType("boolean")
|
||||||
.HasColumnName("is_paused");
|
.HasColumnName("is_paused");
|
||||||
|
|
||||||
b.Property<bool>("ShareLocation")
|
b.Property<DateTimeOffset>("ShareLocationUntil")
|
||||||
.HasColumnType("boolean")
|
.HasColumnType("timestamp with time zone")
|
||||||
.HasColumnName("share_location");
|
.HasColumnName("share_location_until");
|
||||||
|
|
||||||
b.Property<bool>("Sticky")
|
b.Property<bool>("Sticky")
|
||||||
.HasColumnType("boolean")
|
.HasColumnType("boolean")
|
||||||
@@ -0,0 +1,30 @@
|
|||||||
|
using System;
|
||||||
|
using Microsoft.EntityFrameworkCore.Migrations;
|
||||||
|
|
||||||
|
#nullable disable
|
||||||
|
|
||||||
|
namespace LightlessSyncServer.Migrations
|
||||||
|
{
|
||||||
|
/// <inheritdoc />
|
||||||
|
public partial class ShareLocation : Migration
|
||||||
|
{
|
||||||
|
/// <inheritdoc />
|
||||||
|
protected override void Up(MigrationBuilder migrationBuilder)
|
||||||
|
{
|
||||||
|
migrationBuilder.AddColumn<DateTimeOffset>(
|
||||||
|
name: "share_location_until",
|
||||||
|
table: "user_permission_sets",
|
||||||
|
type: "timestamp with time zone",
|
||||||
|
nullable: false,
|
||||||
|
defaultValue: new DateTimeOffset(new DateTime(1, 1, 1, 0, 0, 0, 0, DateTimeKind.Unspecified), new TimeSpan(0, 0, 0, 0, 0)));
|
||||||
|
}
|
||||||
|
|
||||||
|
/// <inheritdoc />
|
||||||
|
protected override void Down(MigrationBuilder migrationBuilder)
|
||||||
|
{
|
||||||
|
migrationBuilder.DropColumn(
|
||||||
|
name: "share_location_until",
|
||||||
|
table: "user_permission_sets");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
@@ -584,10 +584,6 @@ namespace LightlessSyncServer.Migrations
|
|||||||
.HasColumnType("boolean")
|
.HasColumnType("boolean")
|
||||||
.HasColumnName("is_paused");
|
.HasColumnName("is_paused");
|
||||||
|
|
||||||
b.Property<bool>("ShareLocation")
|
|
||||||
.HasColumnType("boolean")
|
|
||||||
.HasColumnName("share_location");
|
|
||||||
|
|
||||||
b.HasKey("UserUID", "GroupGID")
|
b.HasKey("UserUID", "GroupGID")
|
||||||
.HasName("pk_group_pair_preferred_permissions");
|
.HasName("pk_group_pair_preferred_permissions");
|
||||||
|
|
||||||
@@ -945,9 +941,9 @@ namespace LightlessSyncServer.Migrations
|
|||||||
.HasColumnType("boolean")
|
.HasColumnType("boolean")
|
||||||
.HasColumnName("is_paused");
|
.HasColumnName("is_paused");
|
||||||
|
|
||||||
b.Property<bool>("ShareLocation")
|
b.Property<DateTimeOffset>("ShareLocationUntil")
|
||||||
.HasColumnType("boolean")
|
.HasColumnType("timestamp with time zone")
|
||||||
.HasColumnName("share_location");
|
.HasColumnName("share_location_until");
|
||||||
|
|
||||||
b.Property<bool>("Sticky")
|
b.Property<bool>("Sticky")
|
||||||
.HasColumnType("boolean")
|
.HasColumnType("boolean")
|
||||||
|
|||||||
@@ -10,5 +10,4 @@ public class GroupPairPreferredPermission
|
|||||||
public bool DisableAnimations { get; set; }
|
public bool DisableAnimations { get; set; }
|
||||||
public bool DisableSounds { get; set; }
|
public bool DisableSounds { get; set; }
|
||||||
public bool DisableVFX { get; set; }
|
public bool DisableVFX { get; set; }
|
||||||
public bool ShareLocation { get; set; }
|
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -15,5 +15,5 @@ public class UserPermissionSet
|
|||||||
public bool DisableAnimations { get; set; } = false;
|
public bool DisableAnimations { get; set; } = false;
|
||||||
public bool DisableVFX { get; set; } = false;
|
public bool DisableVFX { get; set; } = false;
|
||||||
public bool DisableSounds { get; set; } = false;
|
public bool DisableSounds { get; set; } = false;
|
||||||
public bool ShareLocation { get; set; } = false;
|
public DateTimeOffset ShareLocationUntil { get; set; } = DateTimeOffset.MinValue;
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user