Union/ProjectLighthouse
1
0
Fork 0
mirror of https://github.com/LBPUnion/ProjectLighthouse.git synced 2025-08-06 11:58:38 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

Add command to flush redis database

Browse source
This commit is contained in:
jvyden 2022-06-10 02:42:24 -04:00
commit 02abb7bcab
No known key found for this signature in database
GPG key ID: 18BCF2BE0262B278
2 changed files with 35 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

20
ProjectLighthouse/Administration/Maintenance/Commands/FlushRedisCommand.cs Normal file
View file

@ -0,0 +1,20 @@
using System.Threading.Tasks;
using LBPUnion.ProjectLighthouse.Logging;
using LBPUnion.ProjectLighthouse.StorableLists;
namespace LBPUnion.ProjectLighthouse.Administration.Maintenance.Commands;
public class FlushRedisCommand : ICommand
{
public string Name() => "Flush Redis";
public string[] Aliases() => new[] {
"flush", "flush-redis",
};
public string Arguments() => "";
public int RequiredArgs() => 0;
public async Task Run(string[] args, Logger logger)
{
await RedisDatabase.FlushAll();
}
}

17
ProjectLighthouse/StorableLists/RedisDatabase.cs
View file

@ -39,8 +39,7 @@ public static class RedisDatabase
return; return;
} }
await connection.RecreateIndexAsync(typeof(Room)); await createIndexes(connection);
await connection.RecreateIndexAsync(typeof(UserFriendData));
} }
catch(Exception e) catch(Exception e)
{ {
@ -52,6 +51,20 @@ public static class RedisDatabase
Logger.Success("Initialized Redis.", LogArea.Redis); Logger.Success("Initialized Redis.", LogArea.Redis);
} }
public static async Task FlushAll()
{
IRedisConnection connection = getConnection();
await connection.ExecuteAsync("FLUSHALL");
await createIndexes(connection);
}
private static async Task createIndexes(IRedisConnection connection)
{
await connection.RecreateIndexAsync(typeof(Room));
await connection.RecreateIndexAsync(typeof(UserFriendData));
}
private static IRedisConnection getConnection() private static IRedisConnection getConnection()
{ {
Logger.Debug("Getting a Redis connection", LogArea.Redis); Logger.Debug("Getting a Redis connection", LogArea.Redis);