2020-11-01 14:10:57 +01:00
|
|
|
using System;
|
|
|
|
|
using System.Threading.Tasks;
|
|
|
|
|
using WotBlitzStatisticsPro.DataAccess;
|
2020-11-17 12:36:02 +01:00
|
|
|
using WotBlitzStatisticsPro.Logic.AccountInformationPipeline.OperationContext;
|
2020-11-01 14:10:57 +01:00
|
|
|
using WotBlitzStatisticsPro.Logic.Pipeline;
|
|
|
|
|
|
|
|
|
|
namespace WotBlitzStatisticsPro.Logic.AccountInformationPipeline.Operations
|
|
|
|
|
{
|
2020-11-17 12:36:02 +01:00
|
|
|
public class ReadAccountInfoFromDbOperation : IOperation<IOperationContext>
|
2020-11-01 14:10:57 +01:00
|
|
|
{
|
|
|
|
|
private readonly IWargamingAccountDataAccessor _accountDataAccessor;
|
|
|
|
|
|
|
|
|
|
public ReadAccountInfoFromDbOperation(IWargamingAccountDataAccessor accountDataAccessor)
|
|
|
|
|
{
|
|
|
|
|
_accountDataAccessor = accountDataAccessor;
|
|
|
|
|
}
|
|
|
|
|
|
2020-12-27 12:39:25 +01:00
|
|
|
public async Task Invoke(IOperationContext context, Func<IOperationContext, Task>? next)
|
2020-11-01 14:10:57 +01:00
|
|
|
{
|
2020-11-17 12:36:02 +01:00
|
|
|
var contextData = context.Get<IDatabasePipelineContextData>();
|
|
|
|
|
|
|
|
|
|
contextData.DbAccountInfo = await _accountDataAccessor.ReadAccountInfo(context.Request.AccountId);
|
2020-12-27 12:39:25 +01:00
|
|
|
if (next != null) await next.Invoke(context);
|
2020-11-01 14:10:57 +01:00
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
}
|