Add GuildSettingsManager to centrally manage guild settings

This commit is contained in:
runebaas 2020-06-19 04:10:26 +02:00
parent 83dc2c8e49
commit fb676e8918
No known key found for this signature in database
GPG key ID: 2677AF508D0300D6
6 changed files with 138 additions and 100 deletions

View file

@ -1,15 +1,13 @@
using System; using System;
using System.Linq;
using System.Text; using System.Text;
using System.Threading.Tasks; using System.Threading.Tasks;
using Discord; using Discord;
using Discord.Commands; using Discord.Commands;
using Discord.WebSocket; using Discord.WebSocket;
using Geekbot.net.Database;
using Geekbot.net.Database.Models;
using Geekbot.net.Lib.CommandPreconditions; using Geekbot.net.Lib.CommandPreconditions;
using Geekbot.net.Lib.ErrorHandling; using Geekbot.net.Lib.ErrorHandling;
using Geekbot.net.Lib.Extensions; using Geekbot.net.Lib.Extensions;
using Geekbot.net.Lib.GuildSettingsManager;
using Geekbot.net.Lib.Localization; using Geekbot.net.Lib.Localization;
namespace Geekbot.net.Commands.Admin namespace Geekbot.net.Commands.Admin
@ -21,15 +19,14 @@ namespace Geekbot.net.Commands.Admin
{ {
private readonly DiscordSocketClient _client; private readonly DiscordSocketClient _client;
private readonly IErrorHandler _errorHandler; private readonly IErrorHandler _errorHandler;
private readonly DatabaseContext _database; private readonly IGuildSettingsManager _guildSettingsManager;
private readonly ITranslationHandler _translation; private readonly ITranslationHandler _translation;
public Admin(DatabaseContext database, DiscordSocketClient client, IErrorHandler errorHandler, public Admin(DiscordSocketClient client, IErrorHandler errorHandler, IGuildSettingsManager guildSettingsManager, ITranslationHandler translationHandler)
ITranslationHandler translationHandler)
{ {
_database = database;
_client = client; _client = client;
_errorHandler = errorHandler; _errorHandler = errorHandler;
_guildSettingsManager = guildSettingsManager;
_translation = translationHandler; _translation = translationHandler;
} }
@ -37,10 +34,9 @@ namespace Geekbot.net.Commands.Admin
[Summary("Set a Welcome Message (use '$user' to mention the new joined user).")] [Summary("Set a Welcome Message (use '$user' to mention the new joined user).")]
public async Task SetWelcomeMessage([Remainder, Summary("message")] string welcomeMessage) public async Task SetWelcomeMessage([Remainder, Summary("message")] string welcomeMessage)
{ {
var guild = await GetGuildSettings(Context.Guild.Id); var guild = _guildSettingsManager.GetSettings(Context.Guild.Id);
guild.WelcomeMessage = welcomeMessage; guild.WelcomeMessage = welcomeMessage;
_database.GuildSettings.Update(guild); await _guildSettingsManager.UpdateSettings(guild);
await _database.SaveChangesAsync();
var formatedMessage = welcomeMessage.Replace("$user", Context.User.Mention); var formatedMessage = welcomeMessage.Replace("$user", Context.User.Mention);
await ReplyAsync($"Welcome message has been changed\r\nHere is an example of how it would look:\r\n{formatedMessage}"); await ReplyAsync($"Welcome message has been changed\r\nHere is an example of how it would look:\r\n{formatedMessage}");
@ -54,10 +50,9 @@ namespace Geekbot.net.Commands.Admin
{ {
var m = await channel.SendMessageAsync("..."); var m = await channel.SendMessageAsync("...");
var guild = await GetGuildSettings(Context.Guild.Id); var guild = _guildSettingsManager.GetSettings(Context.Guild.Id);
guild.WelcomeChannel = channel.Id.AsLong(); guild.WelcomeChannel = channel.Id.AsLong();
_database.GuildSettings.Update(guild); await _guildSettingsManager.UpdateSettings(guild);
await _database.SaveChangesAsync();
await m.DeleteAsync(); await m.DeleteAsync();
@ -77,10 +72,9 @@ namespace Geekbot.net.Commands.Admin
{ {
var m = await channel.SendMessageAsync("verifying..."); var m = await channel.SendMessageAsync("verifying...");
var guild = await GetGuildSettings(Context.Guild.Id); var guild = _guildSettingsManager.GetSettings(Context.Guild.Id);
guild.ModChannel = channel.Id.AsLong(); guild.ModChannel = channel.Id.AsLong();
_database.GuildSettings.Update(guild); await _guildSettingsManager.UpdateSettings(guild);
await _database.SaveChangesAsync();
var sb = new StringBuilder(); var sb = new StringBuilder();
sb.AppendLine("Successfully saved mod channel, you can now do the following"); sb.AppendLine("Successfully saved mod channel, you can now do the following");
@ -100,13 +94,12 @@ namespace Geekbot.net.Commands.Admin
{ {
try try
{ {
var guild = await GetGuildSettings(Context.Guild.Id); var guild = _guildSettingsManager.GetSettings(Context.Guild.Id);
var modChannel = await GetModChannel(guild.ModChannel.AsUlong()); var modChannel = await GetModChannel(guild.ModChannel.AsUlong());
if (modChannel == null) return; if (modChannel == null) return;
guild.ShowLeave = !guild.ShowLeave; guild.ShowLeave = !guild.ShowLeave;
_database.GuildSettings.Update(guild); await _guildSettingsManager.UpdateSettings(guild);
await _database.SaveChangesAsync();
await modChannel.SendMessageAsync(guild.ShowLeave await modChannel.SendMessageAsync(guild.ShowLeave
? "Saved - now sending messages here when someone leaves" ? "Saved - now sending messages here when someone leaves"
: "Saved - stopping sending messages here when someone leaves" : "Saved - stopping sending messages here when someone leaves"
@ -124,13 +117,12 @@ namespace Geekbot.net.Commands.Admin
{ {
try try
{ {
var guild = await GetGuildSettings(Context.Guild.Id); var guild = _guildSettingsManager.GetSettings(Context.Guild.Id);
var modChannel = await GetModChannel(guild.ModChannel.AsUlong()); var modChannel = await GetModChannel(guild.ModChannel.AsUlong());
if (modChannel == null) return; if (modChannel == null) return;
guild.ShowDelete = !guild.ShowDelete; guild.ShowDelete = !guild.ShowDelete;
_database.GuildSettings.Update(guild); await _guildSettingsManager.UpdateSettings(guild);
await _database.SaveChangesAsync();
await modChannel.SendMessageAsync(guild.ShowDelete await modChannel.SendMessageAsync(guild.ShowDelete
? "Saved - now sending messages here when someone deletes a message" ? "Saved - now sending messages here when someone deletes a message"
: "Saved - stopping sending messages here when someone deletes a message" : "Saved - stopping sending messages here when someone deletes a message"
@ -152,10 +144,9 @@ namespace Geekbot.net.Commands.Admin
var success = await _translation.SetLanguage(Context.Guild.Id, language); var success = await _translation.SetLanguage(Context.Guild.Id, language);
if (success) if (success)
{ {
var guild = await GetGuildSettings(Context.Guild.Id); var guild = _guildSettingsManager.GetSettings(Context.Guild.Id);
guild.Language = language; guild.Language = language;
_database.GuildSettings.Update(guild); await _guildSettingsManager.UpdateSettings(guild);
await _database.SaveChangesAsync();
var transContext = await _translation.GetGuildContext(Context); var transContext = await _translation.GetGuildContext(Context);
await ReplyAsync(transContext.GetString("NewLanguageSet")); await ReplyAsync(transContext.GetString("NewLanguageSet"));
@ -178,10 +169,9 @@ namespace Geekbot.net.Commands.Admin
try try
{ {
var language = languageRaw.ToLower(); var language = languageRaw.ToLower();
var guild = await GetGuildSettings(Context.Guild.Id); var guild = _guildSettingsManager.GetSettings(Context.Guild.Id);
guild.WikiLang = language; guild.WikiLang = language;
_database.GuildSettings.Update(guild); await _guildSettingsManager.UpdateSettings(guild);
await _database.SaveChangesAsync();
await ReplyAsync($"Now using the {language} wikipedia"); await ReplyAsync($"Now using the {language} wikipedia");
} }
@ -197,10 +187,9 @@ namespace Geekbot.net.Commands.Admin
{ {
try try
{ {
var guild = await GetGuildSettings(Context.Guild.Id); var guild = _guildSettingsManager.GetSettings(Context.Guild.Id);
guild.Ping = !guild.Ping; guild.Ping = !guild.Ping;
_database.GuildSettings.Update(guild); await _guildSettingsManager.UpdateSettings(guild);
await _database.SaveChangesAsync();
await ReplyAsync(guild.Ping ? "i will reply to ping now" : "No more pongs..."); await ReplyAsync(guild.Ping ? "i will reply to ping now" : "No more pongs...");
} }
catch (Exception e) catch (Exception e)
@ -215,10 +204,9 @@ namespace Geekbot.net.Commands.Admin
{ {
try try
{ {
var guild = await GetGuildSettings(Context.Guild.Id); var guild = _guildSettingsManager.GetSettings(Context.Guild.Id);
guild.Hui = !guild.Hui; guild.Hui = !guild.Hui;
_database.GuildSettings.Update(guild); await _guildSettingsManager.UpdateSettings(guild);
await _database.SaveChangesAsync();
await ReplyAsync(guild.Hui ? "i will reply to hui now" : "No more hui's..."); await ReplyAsync(guild.Hui ? "i will reply to hui now" : "No more hui's...");
} }
catch (Exception e) catch (Exception e)
@ -227,41 +215,20 @@ namespace Geekbot.net.Commands.Admin
} }
} }
private async Task<GuildSettingsModel> GetGuildSettings(ulong guildId)
{
var guild = _database.GuildSettings.FirstOrDefault(g => g.GuildId.Equals(guildId.AsLong()));
if (guild != null) return guild;
Console.WriteLine("Adding non-exist Guild Settings to database");
_database.GuildSettings.Add(new GuildSettingsModel()
{
GuildId = guildId.AsLong(),
Hui = false,
Ping = false,
Language = "EN",
ShowDelete = false,
ShowLeave = false,
WikiLang = "en"
});
await _database.SaveChangesAsync();
return _database.GuildSettings.FirstOrDefault(g => g.GuildId.Equals(guildId.AsLong()));
}
private async Task<ISocketMessageChannel> GetModChannel(ulong channelId) private async Task<ISocketMessageChannel> GetModChannel(ulong channelId)
{ {
try try
{ {
if(channelId == ulong.MinValue) throw new Exception(); if (channelId == ulong.MinValue) throw new Exception();
var modChannel = (ISocketMessageChannel) _client.GetChannel(channelId); var modChannel = (ISocketMessageChannel) _client.GetChannel(channelId);
if(modChannel == null) throw new Exception(); if (modChannel == null) throw new Exception();
return modChannel; return modChannel;
} }
catch catch
{ {
await ReplyAsync( await ReplyAsync("Modchannel doesn't seem to exist, please set one with `!admin modchannel [channelId]`");
"Modchannel doesn't seem to exist, please set one with `!admin modchannel [channelId]`");
return null; return null;
} }
} }
} }
} }

View file

@ -1,6 +1,5 @@
using System; using System;
using System.Collections.Generic; using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks; using System.Threading.Tasks;
using Discord; using Discord;
using Discord.Commands; using Discord.Commands;
@ -8,7 +7,7 @@ using Discord.Rest;
using Discord.WebSocket; using Discord.WebSocket;
using Geekbot.net.Database; using Geekbot.net.Database;
using Geekbot.net.Database.Models; using Geekbot.net.Database.Models;
using Geekbot.net.Lib.Extensions; using Geekbot.net.Lib.GuildSettingsManager;
using Geekbot.net.Lib.Logger; using Geekbot.net.Lib.Logger;
namespace Geekbot.net.Handlers namespace Geekbot.net.Handlers
@ -20,10 +19,12 @@ namespace Geekbot.net.Handlers
private readonly IServiceProvider _servicesProvider; private readonly IServiceProvider _servicesProvider;
private readonly CommandService _commands; private readonly CommandService _commands;
private readonly RestApplication _applicationInfo; private readonly RestApplication _applicationInfo;
private readonly IGuildSettingsManager _guildSettingsManager;
private readonly List<ulong> _ignoredServers; private readonly List<ulong> _ignoredServers;
private readonly DatabaseContext _database; private readonly DatabaseContext _database;
public CommandHandler(DatabaseContext database, IDiscordClient client, IGeekbotLogger logger, IServiceProvider servicesProvider, CommandService commands, RestApplication applicationInfo) public CommandHandler(DatabaseContext database, IDiscordClient client, IGeekbotLogger logger, IServiceProvider servicesProvider, CommandService commands, RestApplication applicationInfo,
IGuildSettingsManager guildSettingsManager)
{ {
_database = database; _database = database;
_client = client; _client = client;
@ -31,6 +32,7 @@ namespace Geekbot.net.Handlers
_servicesProvider = servicesProvider; _servicesProvider = servicesProvider;
_commands = commands; _commands = commands;
_applicationInfo = applicationInfo; _applicationInfo = applicationInfo;
_guildSettingsManager = guildSettingsManager;
// Some guilds only want very specific functionally without any of the commands, a quick hack that solves that "short term" // Some guilds only want very specific functionally without any of the commands, a quick hack that solves that "short term"
// ToDo: create a clean solution for this... // ToDo: create a clean solution for this...
@ -111,7 +113,7 @@ namespace Geekbot.net.Handlers
private GuildSettingsModel GetGuildSettings(ulong guildId) private GuildSettingsModel GetGuildSettings(ulong guildId)
{ {
return _database.GuildSettings.FirstOrDefault(guild => guild.GuildId.Equals(guildId.AsLong())); return _guildSettingsManager.GetSettings(guildId, false);
} }
} }
} }

View file

@ -0,0 +1,68 @@
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using Geekbot.net.Database;
using Geekbot.net.Database.Models;
using Geekbot.net.Lib.Extensions;
namespace Geekbot.net.Lib.GuildSettingsManager
{
public class GuildSettingsManager : IGuildSettingsManager
{
private readonly DatabaseContext _database;
private readonly Dictionary<ulong, GuildSettingsModel> _settings;
public GuildSettingsManager(DatabaseContext database)
{
_database = database;
_settings = new Dictionary<ulong, GuildSettingsModel>();
}
public GuildSettingsModel GetSettings(ulong guildId, bool createIfNonExist = true)
{
return _settings.ContainsKey(guildId) ? _settings[guildId] : GetFromDatabase(guildId, createIfNonExist);
}
public async Task UpdateSettings(GuildSettingsModel settings)
{
_database.GuildSettings.Update(settings);
if (_settings.ContainsKey(settings.GuildId.AsUlong()))
{
_settings[settings.GuildId.AsUlong()] = settings;
}
else
{
_settings.Add(settings.GuildId.AsUlong(), settings);
}
await _database.SaveChangesAsync();
}
private GuildSettingsModel GetFromDatabase(ulong guildId, bool createIfNonExist)
{
var settings = _database.GuildSettings.FirstOrDefault(guild => guild.GuildId.Equals(guildId.AsLong()));
if (createIfNonExist && settings == null)
{
settings = CreateSettings(guildId);
}
_settings.Add(guildId, settings);
return settings;
}
private GuildSettingsModel CreateSettings(ulong guildId)
{
_database.GuildSettings.Add(new GuildSettingsModel
{
GuildId = guildId.AsLong(),
Hui = false,
Ping = false,
Language = "EN",
ShowDelete = false,
ShowLeave = false,
WikiLang = "en"
});
_database.SaveChanges();
return _database.GuildSettings.FirstOrDefault(g => g.GuildId.Equals(guildId.AsLong()));
}
}
}

View file

@ -0,0 +1,11 @@
using System.Threading.Tasks;
using Geekbot.net.Database.Models;
namespace Geekbot.net.Lib.GuildSettingsManager
{
public interface IGuildSettingsManager
{
GuildSettingsModel GetSettings(ulong guildId, bool createIfNonExist = true);
Task UpdateSettings(GuildSettingsModel settings);
}
}

View file

@ -4,9 +4,7 @@ using System.IO;
using System.Linq; using System.Linq;
using System.Threading.Tasks; using System.Threading.Tasks;
using Discord.Commands; using Discord.Commands;
using Geekbot.net.Database; using Geekbot.net.Lib.GuildSettingsManager;
using Geekbot.net.Database.Models;
using Geekbot.net.Lib.Extensions;
using Geekbot.net.Lib.Logger; using Geekbot.net.Lib.Logger;
using YamlDotNet.Core; using YamlDotNet.Core;
using YamlDotNet.Serialization; using YamlDotNet.Serialization;
@ -15,15 +13,15 @@ namespace Geekbot.net.Lib.Localization
{ {
public class TranslationHandler : ITranslationHandler public class TranslationHandler : ITranslationHandler
{ {
private readonly DatabaseContext _database;
private readonly IGeekbotLogger _logger; private readonly IGeekbotLogger _logger;
private readonly IGuildSettingsManager _guildSettingsManager;
private readonly Dictionary<ulong, string> _serverLanguages; private readonly Dictionary<ulong, string> _serverLanguages;
private Dictionary<string, Dictionary<string, Dictionary<string, string>>> _translations; private Dictionary<string, Dictionary<string, Dictionary<string, string>>> _translations;
public TranslationHandler(DatabaseContext database, IGeekbotLogger logger) public TranslationHandler(IGeekbotLogger logger, IGuildSettingsManager guildSettingsManager)
{ {
_database = database;
_logger = logger; _logger = logger;
_guildSettingsManager = guildSettingsManager;
_logger.Information(LogSource.Geekbot, "Loading Translations"); _logger.Information(LogSource.Geekbot, "Loading Translations");
LoadTranslations(); LoadTranslations();
_serverLanguages = new Dictionary<ulong, string>(); _serverLanguages = new Dictionary<ulong, string>();
@ -107,7 +105,7 @@ namespace Geekbot.net.Lib.Localization
} }
catch catch
{ {
lang = (await GetGuild(guildId)).Language ?? "EN"; lang = _guildSettingsManager.GetSettings(guildId, false)?.Language ?? "EN";
_serverLanguages[guildId] = lang; _serverLanguages[guildId] = lang;
return lang; return lang;
} }
@ -178,9 +176,9 @@ namespace Geekbot.net.Lib.Localization
try try
{ {
if (!SupportedLanguages.Contains(language)) return false; if (!SupportedLanguages.Contains(language)) return false;
var guild = await GetGuild(guildId); var guild = _guildSettingsManager.GetSettings(guildId);
guild.Language = language; guild.Language = language;
_database.GuildSettings.Update(guild); await _guildSettingsManager.UpdateSettings(guild);
_serverLanguages[guildId] = language; _serverLanguages[guildId] = language;
return true; return true;
} }
@ -192,17 +190,5 @@ namespace Geekbot.net.Lib.Localization
} }
public List<string> SupportedLanguages { get; private set; } public List<string> SupportedLanguages { get; private set; }
private async Task<GuildSettingsModel> GetGuild(ulong guildId)
{
var guild = _database.GuildSettings.FirstOrDefault(g => g.GuildId.Equals(guildId.AsLong()));
if (guild != null) return guild;
_database.GuildSettings.Add(new GuildSettingsModel
{
GuildId = guildId.AsLong()
});
await _database.SaveChangesAsync();
return _database.GuildSettings.FirstOrDefault(g => g.GuildId.Equals(guildId.AsLong()));
}
} }
} }

View file

@ -13,6 +13,7 @@ using Geekbot.net.Lib.Clients;
using Geekbot.net.Lib.Converters; using Geekbot.net.Lib.Converters;
using Geekbot.net.Lib.ErrorHandling; using Geekbot.net.Lib.ErrorHandling;
using Geekbot.net.Lib.GlobalSettings; using Geekbot.net.Lib.GlobalSettings;
using Geekbot.net.Lib.GuildSettingsManager;
using Geekbot.net.Lib.Highscores; using Geekbot.net.Lib.Highscores;
using Geekbot.net.Lib.KvInMemoryStore; using Geekbot.net.Lib.KvInMemoryStore;
using Geekbot.net.Lib.Levels; using Geekbot.net.Lib.Levels;
@ -40,6 +41,7 @@ namespace Geekbot.net
private IUserRepository _userRepository; private IUserRepository _userRepository;
private RunParameters _runParameters; private RunParameters _runParameters;
private IReactionListener _reactionListener; private IReactionListener _reactionListener;
private IGuildSettingsManager _guildSettingsManager;
private static void Main(string[] args) private static void Main(string[] args)
{ {
@ -156,6 +158,7 @@ namespace Geekbot.net
_userRepository = new UserRepository(_databaseInitializer.Initialize(), _logger); _userRepository = new UserRepository(_databaseInitializer.Initialize(), _logger);
_reactionListener = new ReactionListener(_databaseInitializer.Initialize()); _reactionListener = new ReactionListener(_databaseInitializer.Initialize());
_guildSettingsManager = new GuildSettingsManager(_databaseInitializer.Initialize());
var fortunes = new FortunesProvider(_logger); var fortunes = new FortunesProvider(_logger);
var mediaProvider = new MediaProvider(_logger); var mediaProvider = new MediaProvider(_logger);
var malClient = new MalClient(_globalSettings, _logger); var malClient = new MalClient(_globalSettings, _logger);
@ -165,7 +168,7 @@ namespace Geekbot.net
var wikipediaClient = new WikipediaClient(); var wikipediaClient = new WikipediaClient();
var randomNumberGenerator = new RandomNumberGenerator(); var randomNumberGenerator = new RandomNumberGenerator();
var kvMemoryStore = new KvInInMemoryStore(); var kvMemoryStore = new KvInInMemoryStore();
var translationHandler = new TranslationHandler(_databaseInitializer.Initialize(), _logger); var translationHandler = new TranslationHandler(_logger, _guildSettingsManager);
var errorHandler = new ErrorHandler(_logger, translationHandler, _runParameters.ExposeErrors); var errorHandler = new ErrorHandler(_logger, translationHandler, _runParameters.ExposeErrors);
services.AddSingleton(_userRepository); services.AddSingleton(_userRepository);
@ -183,6 +186,7 @@ namespace Geekbot.net
services.AddSingleton<IErrorHandler>(errorHandler); services.AddSingleton<IErrorHandler>(errorHandler);
services.AddSingleton<ITranslationHandler>(translationHandler); services.AddSingleton<ITranslationHandler>(translationHandler);
services.AddSingleton<IReactionListener>(_reactionListener); services.AddSingleton<IReactionListener>(_reactionListener);
services.AddSingleton<IGuildSettingsManager>(_guildSettingsManager);
services.AddSingleton(_client); services.AddSingleton(_client);
services.AddTransient<IHighscoreManager>(e => new HighscoreManager(_databaseInitializer.Initialize(), _userRepository)); services.AddTransient<IHighscoreManager>(e => new HighscoreManager(_databaseInitializer.Initialize(), _userRepository));
services.AddTransient(e => _databaseInitializer.Initialize()); services.AddTransient(e => _databaseInitializer.Initialize());
@ -197,7 +201,7 @@ namespace Geekbot.net
_commands = new CommandService(); _commands = new CommandService();
await _commands.AddModulesAsync(Assembly.GetEntryAssembly(), _servicesProvider); await _commands.AddModulesAsync(Assembly.GetEntryAssembly(), _servicesProvider);
var commandHandler = new CommandHandler(_databaseInitializer.Initialize(), _client, _logger, _servicesProvider, _commands, applicationInfo); var commandHandler = new CommandHandler(_databaseInitializer.Initialize(), _client, _logger, _servicesProvider, _commands, applicationInfo, _guildSettingsManager);
var userHandler = new UserHandler(_userRepository, _logger, _databaseInitializer.Initialize(), _client); var userHandler = new UserHandler(_userRepository, _logger, _databaseInitializer.Initialize(), _client);
var reactionHandler = new ReactionHandler(_reactionListener); var reactionHandler = new ReactionHandler(_reactionListener);
var statsHandler = new StatsHandler(_logger, _databaseInitializer.Initialize()); var statsHandler = new StatsHandler(_logger, _databaseInitializer.Initialize());