59 lines
2.1 KiB
C#
59 lines
2.1 KiB
C#
|
using HermesSocketLibrary.Socket.Data;
|
||
|
|
using HermesSocketServer.Services;
|
||
|
|
using Serilog;
|
||
|
|
|
||
|
|
namespace HermesSocketServer.Requests
|
||
|
|
{
|
||
|
|
public class RequestManager : IRequestManager
|
||
|
|
{
|
||
|
|
private readonly IDictionary<string, IRequest> _requests;
|
||
|
|
private readonly ChannelManager _channels;
|
||
|
|
private readonly Serilog.ILogger _logger;
|
||
|
|
|
||
|
|
|
||
|
|
public RequestManager(IEnumerable<IRequest> requests, ChannelManager channels, Serilog.ILogger logger)
|
||
|
|
{
|
||
|
|
_requests = requests.ToDictionary(r => r.Name, r => r);
|
||
|
|
_channels = channels;
|
||
|
|
_logger = logger;
|
||
|
|
}
|
||
|
|
|
||
|
|
public async Task<RequestResult> Grant(string sender, RequestMessage? message)
|
||
|
|
{
|
||
|
|
if (message == null || message.Type == null)
|
||
|
|
return RequestResult.Failed("Request type does not exist.");
|
||
|
|
|
||
|
|
var channel = _channels.Get(sender);
|
||
|
|
if (channel == null)
|
||
|
|
return RequestResult.Failed("Channel does not exist.");
|
||
|
|
|
||
|
|
if (!_requests.TryGetValue(message.Type, out IRequest? request) || request == null)
|
||
|
|
{
|
||
|
|
_logger.Warning($"Could not find request [type: {message.Type}]");
|
||
|
|
return RequestResult.Failed("Request does not exist.");
|
||
|
|
}
|
||
|
|
|
||
|
|
if (request.RequiredKeys.Any())
|
||
|
|
{
|
||
|
|
if (message.Data == null)
|
||
|
|
return RequestResult.Failed($"Request is lacking data entries.");
|
||
|
|
|
||
|
|
foreach (var key in request.RequiredKeys)
|
||
|
|
{
|
||
|
|
if (!message.Data.ContainsKey(key))
|
||
|
|
return RequestResult.Failed($"Request is missing '{key}' in its data entries.");
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
try
|
||
|
|
{
|
||
|
|
return await request.Grant(sender, message.Data);
|
||
|
|
}
|
||
|
|
catch (Exception e)
|
||
|
|
{
|
||
|
|
_logger.Error(e, $"Failed to grant a request during processing [type: {message.Type}]");
|
||
|
|
return RequestResult.Failed("Failed to grant request during processing: " + e.Message);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|