Lightless-Sync/LightlessServer
8
0
Fork 0
Code Issues 3 Pull Requests 1 Actions Packages Projects Releases Wiki Activity

Discord-bot + server updates

Browse Source
This commit is contained in:
defnotken
2025-12-18 18:16:23 -06:00
parent dda45e8e73
commit 8c1af6f31c
9 changed files with 88 additions and 59 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
LightlessSyncServer/LightlessSyncAuthService/LightlessSyncAuthService.csproj
View File

@@ -1,7 +1,7 @@
<Project Sdk="Microsoft.NET.Sdk.Web"> <Project Sdk="Microsoft.NET.Sdk.Web">
<PropertyGroup> <PropertyGroup>
<TargetFramework>net9.0</TargetFramework> <TargetFramework>net10.0</TargetFramework>
<Nullable>enable</Nullable> <Nullable>enable</Nullable>
<ImplicitUsings>enable</ImplicitUsings> <ImplicitUsings>enable</ImplicitUsings>
</PropertyGroup> </PropertyGroup>

2
LightlessSyncServer/LightlessSyncServer/Hubs/LightlessHub.Functions.cs
View File

@@ -152,7 +152,7 @@ public partial class LightlessHub
BroadcastRedisEntry? entry; BroadcastRedisEntry? entry;
try try
{ {
entry = JsonSerializer.Deserialize<BroadcastRedisEntry>(broadcastValue!); entry = JsonSerializer.Deserialize<BroadcastRedisEntry>(broadcastValue.ToString()!);
} }
catch (Exception ex) catch (Exception ex)
{ {

14
LightlessSyncServer/LightlessSyncServer/Hubs/LightlessHub.User.cs
View File

@@ -336,7 +336,7 @@ public partial class LightlessHub
BroadcastRedisEntry? entry; BroadcastRedisEntry? entry;
try try
{ {
entry = JsonSerializer.Deserialize<BroadcastRedisEntry>(broadcastValue.Value!); entry = JsonSerializer.Deserialize<BroadcastRedisEntry>(broadcastValue.Value.ToString()!);
} }
catch (Exception ex) catch (Exception ex)
{ {
@@ -438,7 +438,7 @@ public partial class LightlessHub
{ {
try try
{ {
existingEntry = JsonSerializer.Deserialize<BroadcastRedisEntry>(existingValue!); existingEntry = JsonSerializer.Deserialize<BroadcastRedisEntry>(existingValue.ToString()!);
} }
catch (Exception ex) catch (Exception ex)
{ {
@@ -477,7 +477,7 @@ public partial class LightlessHub
BroadcastRedisEntry? entry; BroadcastRedisEntry? entry;
try try
{ {
entry = JsonSerializer.Deserialize<BroadcastRedisEntry>(value!); entry = JsonSerializer.Deserialize<BroadcastRedisEntry>(value.ToString()!);
} }
catch (Exception ex) catch (Exception ex)
{ {
@@ -536,7 +536,7 @@ public partial class LightlessHub
BroadcastRedisEntry? entry; BroadcastRedisEntry? entry;
try try
{ {
entry = JsonSerializer.Deserialize<BroadcastRedisEntry>(value.Value!); entry = JsonSerializer.Deserialize<BroadcastRedisEntry>(value.Value.ToString()!);
} }
catch (Exception ex) catch (Exception ex)
{ {
@@ -590,7 +590,7 @@ public partial class LightlessHub
BroadcastRedisEntry? entry; BroadcastRedisEntry? entry;
try try
{ {
entry = JsonSerializer.Deserialize<BroadcastRedisEntry>(result.Value!); entry = JsonSerializer.Deserialize<BroadcastRedisEntry>(result.Value.ToString()!);
} }
catch catch
{ {
@@ -645,7 +645,7 @@ public partial class LightlessHub
BroadcastRedisEntry? entry; BroadcastRedisEntry? entry;
try try
{ {
entry = JsonSerializer.Deserialize<BroadcastRedisEntry>(value!); entry = JsonSerializer.Deserialize<BroadcastRedisEntry>(value.ToString()!);
} }
catch catch
{ {
@@ -728,7 +728,7 @@ public partial class LightlessHub
try try
{ {
entry = JsonSerializer.Deserialize<BroadcastRedisEntry>(raw!); entry = JsonSerializer.Deserialize<BroadcastRedisEntry>(raw.ToString()!);
if (entry is not null && !string.Equals(entry.HashedCID, cid, StringComparison.Ordinal)) 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)); _logger.LogCallWarning(LightlessHubLogger.Args("mismatched broadcast cid in batch", "Requested", cid, "EntryCID", entry.HashedCID));

2
LightlessSyncServer/LightlessSyncServer/LightlessSyncServer.csproj
View File

@@ -1,7 +1,7 @@
<Project Sdk="Microsoft.NET.Sdk.Web"> <Project Sdk="Microsoft.NET.Sdk.Web">
<PropertyGroup> <PropertyGroup>
<TargetFramework>net9.0</TargetFramework> <TargetFramework>net10.0</TargetFramework>
<UserSecretsId>aspnet-LightlessSyncServer-BA82A12A-0B30-463C-801D-B7E81318CD50</UserSecretsId> <UserSecretsId>aspnet-LightlessSyncServer-BA82A12A-0B30-463C-801D-B7E81318CD50</UserSecretsId>
<AssemblyVersion>1.1.0.0</AssemblyVersion> <AssemblyVersion>1.1.0.0</AssemblyVersion>
<ImplicitUsings>enable</ImplicitUsings> <ImplicitUsings>enable</ImplicitUsings>

14
LightlessSyncServer/LightlessSyncServices/Discord/DiscordBot.cs
View File

@@ -1,9 +1,6 @@
using System.Collections.Generic;
using System;
using System.Globalization; using System.Globalization;
using System.Text; using System.Text;
using System.Text.Json; using System.Text.Json;
using System.Linq;
using Discord; using Discord;
using Discord.Interactions; using Discord.Interactions;
using Discord.Rest; using Discord.Rest;
@@ -872,16 +869,17 @@ internal class DiscordBot : IHostedService
string? SenderHashedCid, string? SenderHashedCid,
string Message); 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 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 _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);
} }
} }
} }

103
LightlessSyncServer/LightlessSyncServices/Discord/LightlessModule.cs
View File

@@ -43,33 +43,54 @@ public class LightlessModule : InteractionModuleBase
try try
{ {
EmbedBuilder eb = new();
using var scope = _services.CreateScope(); using var scope = _services.CreateScope();
var db = scope.ServiceProvider.GetRequiredService<LightlessDbContext>(); var db = scope.ServiceProvider.GetRequiredService<LightlessDbContext>();
await using (db.ConfigureAwait(false)) 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); string uidToGet = await GetUserUID(db, secondaryUid, discordUser?.Id ?? null, uid).ConfigureAwait(false);
var profileData = await GetUserProfileData(db, uidToGet).ConfigureAwait(false); var profileData = await GetUserProfileData(db, uidToGet).ConfigureAwait(false);
List<Embed> embeds = new() { mainEmbed };
if (profileEmbed != null)
{
embeds.Add(profileEmbed);
}
if (profileData != null) if (profileData != null)
{ {
byte[] profileImage = GetProfileImage(profileData); byte[] profileImage = GetProfileImage(profileData);
byte[] bannerImage = GetBannerImage(profileData); byte[] bannerImage = GetBannerImage(profileData);
using MemoryStream profileImgStream = new(profileImage); using MemoryStream profileImgStream = new(profileImage);
using MemoryStream bannerImgStream = new(bannerImage); 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( await RespondWithFilesAsync(
new[] { new FileAttachment(profileImgStream, "profileimage.png"), new FileAttachment(bannerImgStream, "bannerimage.png") }, new[] { new FileAttachment(profileImgStream, "profileimage.png"), new FileAttachment(bannerImgStream, "bannerimage.png") },
embeds: new[] { eb.Build() }, embeds: embeds.ToArray(),
ephemeral: true).ConfigureAwait(false); ephemeral: true).ConfigureAwait(false);
} }
else else
{ {
await RespondAsync( await RespondAsync(
embeds: new[] { eb.Build() }, embeds: embeds.ToArray(),
ephemeral: true).ConfigureAwait(false); ephemeral: true).ConfigureAwait(false);
} }
} }
@@ -449,7 +470,7 @@ public class LightlessModule : InteractionModuleBase
return embed.Build(); 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; bool showForSecondaryUser = secondaryUserUid != null;
@@ -459,18 +480,20 @@ public class LightlessModule : InteractionModuleBase
if (primaryUser == null) if (primaryUser == null)
{ {
EmbedBuilder eb = new();
eb.WithTitle("No account"); eb.WithTitle("No account");
eb.WithDescription("No Lightless account was found associated to your Discord user"); 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; bool isAdminCall = primaryUser.User.IsModerator || primaryUser.User.IsAdmin;
if ((optionalUser != null || uid != null) && !isAdminCall) if ((optionalUser != null || uid != null) && !isAdminCall)
{ {
EmbedBuilder eb = new();
eb.WithTitle("Unauthorized"); eb.WithTitle("Unauthorized");
eb.WithDescription("You are not authorized to view another users' information"); eb.WithDescription("You are not authorized to view another users' information");
return eb; return (eb.Build(), null);
} }
else if ((optionalUser != null || uid != null) && isAdminCall) else if ((optionalUser != null || uid != null) && isAdminCall)
{ {
@@ -486,9 +509,10 @@ public class LightlessModule : InteractionModuleBase
if (userInDb == null) if (userInDb == null)
{ {
EmbedBuilder eb = new();
eb.WithTitle("No account"); eb.WithTitle("No account");
eb.WithDescription("The Discord user has no valid Lightless account"); eb.WithDescription("The Discord user has no valid Lightless account");
return eb; return (eb.Build(), null);
} }
userToCheckForDiscordId = userInDb.DiscordId; 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; dbUser = (await db.Auth.Include(u => u.User).SingleOrDefaultAsync(u => u.PrimaryUserUID == dbUser.UID && u.UserUID == secondaryUserUid))?.User;
if (dbUser == null) if (dbUser == null)
{ {
EmbedBuilder eb = new();
eb.WithTitle("No such secondary UID"); eb.WithTitle("No such secondary UID");
eb.WithDescription($"A secondary UID {secondaryUserUid} was not found attached to your primary UID {primaryUser.User.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 profile = await db.UserProfileData.Where(u => u.UserUID == dbUser.UID).SingleOrDefaultAsync().ConfigureAwait(false);
var identity = await _connectionMultiplexer.GetDatabase().StringGetAsync("UID:" + dbUser.UID).ConfigureAwait(false); var identity = await _connectionMultiplexer.GetDatabase().StringGetAsync("UID:" + dbUser.UID).ConfigureAwait(false);
eb.WithTitle("User Information"); EmbedBuilder mainEmbed = new();
eb.WithDescription("This is the user information for Discord User <@" + userToCheckForDiscordId + ">" + Environment.NewLine + Environment.NewLine 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."); + "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)) if (!string.IsNullOrEmpty(dbUser.Alias))
{ {
eb.AddField("Vanity UID", dbUser.Alias); mainEmbed.AddField("Vanity UID", dbUser.Alias);
} }
if (showForSecondaryUser) if (showForSecondaryUser)
{ {
eb.AddField("Primary UID for " + dbUser.UID, auth.PrimaryUserUID); mainEmbed.AddField("Primary UID for " + dbUser.UID, auth.PrimaryUserUID);
} }
else else
{ {
var secondaryUIDs = await db.Auth.Where(p => p.PrimaryUserUID == dbUser.UID).Select(p => p.UserUID).ToListAsync(); var secondaryUIDs = await db.Auth.Where(p => p.PrimaryUserUID == dbUser.UID).Select(p => p.UserUID).ToListAsync();
if (secondaryUIDs.Any()) if (secondaryUIDs.Any())
{ {
eb.AddField("Secondary UIDs", string.Join(Environment.NewLine, secondaryUIDs)); mainEmbed.AddField("Secondary UIDs", string.Join(Environment.NewLine, secondaryUIDs));
} }
} }
if(profile != null) mainEmbed.AddField("Last Online (UTC)", dbUser.LastLoggedIn.ToString("U"));
{ mainEmbed.AddField("Currently online ", !string.IsNullOrEmpty(identity));
eb.AddField("Profile Description", string.IsNullOrEmpty(profile.UserDescription) ? "(No description set)" : profile.UserDescription); mainEmbed.AddField("Hashed Secret Key", auth.HashedKey);
eb.AddField("Profile NSFW", profile.IsNSFW); mainEmbed.AddField("Joined Syncshells", groupsJoined.Count);
eb.AddField("Profile Disabled", profile.ProfileDisabled); mainEmbed.AddField("Owned Syncshells", groups.Count);
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);
foreach (var group in groups) foreach (var group in groups)
{ {
var syncShellUserCount = await db.GroupPairs.CountAsync(g => g.GroupGID == group.GID).ConfigureAwait(false); var syncShellUserCount = await db.GroupPairs.CountAsync(g => g.GroupGID == group.GID).ConfigureAwait(false);
if (!string.IsNullOrEmpty(group.Alias)) 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)) 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) 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) 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) if (userInDb == null)
{ {

5
LightlessSyncServer/LightlessSyncServices/LightlessSyncServices.csproj
View File

@@ -1,7 +1,7 @@
<Project Sdk="Microsoft.NET.Sdk.Web"> <Project Sdk="Microsoft.NET.Sdk.Web">
<PropertyGroup> <PropertyGroup>
<TargetFramework>net9.0</TargetFramework> <TargetFramework>net10.0</TargetFramework>
<ImplicitUsings>enable</ImplicitUsings> <ImplicitUsings>enable</ImplicitUsings>
</PropertyGroup> </PropertyGroup>
@@ -21,7 +21,7 @@
</ItemGroup> </ItemGroup>
<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"> <PackageReference Include="IDisposableAnalyzers" Version="4.0.8">
<PrivateAssets>all</PrivateAssets> <PrivateAssets>all</PrivateAssets>
<IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets> <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
@@ -32,6 +32,7 @@
</PackageReference> </PackageReference>
<PackageReference Include="Microsoft.Extensions.Configuration.Binder" Version="9.0.0" /> <PackageReference Include="Microsoft.Extensions.Configuration.Binder" Version="9.0.0" />
<PackageReference Include="Microsoft.Extensions.Hosting.Systemd" 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>
<ItemGroup> <ItemGroup>

3
LightlessSyncServer/LightlessSyncShared/LightlessSyncShared.csproj
View File

@@ -1,7 +1,7 @@
<Project Sdk="Microsoft.NET.Sdk"> <Project Sdk="Microsoft.NET.Sdk">
<PropertyGroup> <PropertyGroup>
<TargetFramework>net9.0</TargetFramework> <TargetFramework>net10.0</TargetFramework>
<ImplicitUsings>enable</ImplicitUsings> <ImplicitUsings>enable</ImplicitUsings>
</PropertyGroup> </PropertyGroup>
@@ -47,7 +47,6 @@
<PackageReference Include="StackExchange.Redis.Extensions.Core" Version="10.2.0" /> <PackageReference Include="StackExchange.Redis.Extensions.Core" Version="10.2.0" />
<PackageReference Include="StackExchange.Redis.Extensions.System.Text.Json" 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.IdentityModel.Tokens.Jwt" Version="8.3.0" />
<PackageReference Include="System.Linq.Async" Version="6.0.1" />
</ItemGroup> </ItemGroup>
<ItemGroup> <ItemGroup>

2
LightlessSyncServer/LightlessSyncStaticFilesServer/LightlessSyncStaticFilesServer.csproj
View File

@@ -1,7 +1,7 @@
<Project Sdk="Microsoft.NET.Sdk.Web"> <Project Sdk="Microsoft.NET.Sdk.Web">
<PropertyGroup> <PropertyGroup>
<TargetFramework>net9.0</TargetFramework> <TargetFramework>net10.0</TargetFramework>
<ImplicitUsings>enable</ImplicitUsings> <ImplicitUsings>enable</ImplicitUsings>
</PropertyGroup> </PropertyGroup>