61 lines
2.0 KiB
C#
61 lines
2.0 KiB
C#
using System.Collections.Concurrent;
|
|
using MareSynchronosShared.Metrics;
|
|
|
|
namespace MareSynchronosServices.Discord;
|
|
|
|
public class DiscordBotServices
|
|
{
|
|
public readonly string[] LodestoneServers = new[] { "eu", "na", "jp", "fr", "de" };
|
|
public ConcurrentDictionary<ulong, string> DiscordLodestoneMapping = new();
|
|
public ConcurrentDictionary<ulong, string> DiscordRelinkLodestoneMapping = new();
|
|
public ConcurrentDictionary<ulong, DateTime> LastVanityChange = new();
|
|
public ConcurrentDictionary<string, DateTime> LastVanityGidChange = new();
|
|
private readonly IServiceProvider _serviceProvider;
|
|
private CancellationTokenSource? verificationTaskCts;
|
|
|
|
public DiscordBotServices(IServiceProvider serviceProvider, ILogger<DiscordBotServices> logger, MareMetrics metrics)
|
|
{
|
|
_serviceProvider = serviceProvider;
|
|
Logger = logger;
|
|
Metrics = metrics;
|
|
}
|
|
|
|
public ILogger<DiscordBotServices> Logger { get; init; }
|
|
public MareMetrics Metrics { get; init; }
|
|
public ConcurrentQueue<KeyValuePair<ulong, Action<IServiceProvider>>> VerificationQueue { get; } = new();
|
|
|
|
public Task Start()
|
|
{
|
|
_ = ProcessVerificationQueue();
|
|
return Task.CompletedTask;
|
|
}
|
|
|
|
public Task Stop()
|
|
{
|
|
verificationTaskCts?.Cancel();
|
|
return Task.CompletedTask;
|
|
}
|
|
|
|
private async Task ProcessVerificationQueue()
|
|
{
|
|
verificationTaskCts = new CancellationTokenSource();
|
|
while (!verificationTaskCts.IsCancellationRequested)
|
|
{
|
|
if (VerificationQueue.TryDequeue(out var queueitem))
|
|
{
|
|
try
|
|
{
|
|
queueitem.Value.Invoke(_serviceProvider);
|
|
|
|
Logger.LogInformation("Sent login information to user");
|
|
}
|
|
catch (Exception e)
|
|
{
|
|
Logger.LogError(e, "Error during queue work");
|
|
}
|
|
}
|
|
|
|
await Task.Delay(TimeSpan.FromSeconds(2), verificationTaskCts.Token).ConfigureAwait(false);
|
|
}
|
|
}
|
|
} |