WotBlitzStatisticsBlazor/WotBlitzStatisticsPro.Logic/AccountInformationPipeline/Operations/SaveAccountAndTanksOperation.cs

using System;
using System.Collections.Generic;
using System.Text;
using System.Threading.Tasks;
using Microsoft.Extensions.Logging;
using WotBlitzStatisticsPro.DataAccess;
using WotBlitzStatisticsPro.Logic.AccountInformationPipeline.OperationContext;
using WotBlitzStatisticsPro.Logic.Pipeline;

namespace WotBlitzStatisticsPro.Logic.AccountInformationPipeline.Operations
{
    public class SaveAccountAndTanksOperation : IOperation<IOperationContext>
    {
        private readonly IWargamingAccountDataAccessor _accountDataAccessor;
        private readonly ILogger<SaveAccountAndTanksOperation> _logger;

        public SaveAccountAndTanksOperation(
            IWargamingAccountDataAccessor accountDataAccessor,
            ILogger<SaveAccountAndTanksOperation> logger)
        {
            _accountDataAccessor = accountDataAccessor;
            _logger = logger;
        }

        public async Task Invoke(IOperationContext context, Func<IOperationContext, Task>? next)
        {
            var contextData = context.Get<AccountInformationPipelineContextData>();

            if (!contextData.NeedToSaveData)
            {
                _logger.LogInformation($"Proceeding without saving. Db LastBattleTime: {contextData.DbAccountInfo?.LastBattleTime}, WG LastBattleTime: {contextData.AccountInfo?.LastBattleTime}");
                if (next != null) await next.Invoke(context);
                return;
            }

            if (contextData?.AccountInfo == null ||
                contextData?.AccountInfoHistory == null ||
                contextData?.Tanks == null ||
                contextData?.TanksHistory == null)
            {
                return;
            }

            await _accountDataAccessor.AddOurUpdateAccountInfo(contextData.AccountInfo);
            await _accountDataAccessor.AddAccountInfoHistory(contextData.AccountInfoHistory);

            var tanksCount = 0;
            var tankIdsAsString = new StringBuilder();

            foreach (var tankInfo in contextData.Tanks)
            {
                var tankFromDb = await _accountDataAccessor.ReadTankInfo(tankInfo.AccountId, tankInfo.TankId);
                if (tankFromDb == null || tankInfo.LastBattleTime > tankFromDb.LastBattleTime)
                {
                    await _accountDataAccessor.AddOrUpdateTankInfo(tankInfo);
                    await _accountDataAccessor.AddTankInfoHistory(contextData.TanksHistory[tankInfo.TankId]);
                    tanksCount++;
                    tankIdsAsString.Append($" {tankInfo.TankId}; ");
                }
            }

            _logger.LogInformation($"Updated account {contextData.AccountInfo.AccountId} and {tanksCount} tanks: {tankIdsAsString}");

            if (next != null) await next.Invoke(context);
        }
    }
}