* Add postgres * Migrate users * Migrate geneticRequest * Try to fix Concurrent call * Fix asyncawait * Fix async and concurrent * Migrate backtests * Add cache for user by address * Fix backtest migration * Fix not open connection * Fix backtest command error * Fix concurrent * Fix all concurrency * Migrate TradingRepo * Fix scenarios * Migrate statistic repo * Save botbackup * Add settings et moneymanagement * Add bot postgres * fix a bit more backups * Fix bot model * Fix loading backup * Remove cache market for read positions * Add workers to postgre * Fix workers api * Reduce get Accounts for workers * Migrate synth to postgre * Fix backtest saved * Remove mongodb * botservice decorrelation * Fix tradingbot scope call * fix tradingbot * fix concurrent * Fix scope for genetics * Fix account over requesting * Fix bundle backtest worker * fix a lot of things * fix tab backtest * Remove optimized moneymanagement * Add light signal to not use User and too much property * Make money management lighter * insert indicators to awaitable * Migrate add strategies to await * Refactor scenario and indicator retrieval to use asynchronous methods throughout the application * add more async await * Add services * Fix and clean * Fix bot a bit * Fix bot and add message for cooldown * Remove fees * Add script to deploy db * Update dfeeploy script * fix script * Add idempotent script and backup * finish script migration * Fix did user and agent name on start bot
52 lines
1.5 KiB
C#
52 lines
1.5 KiB
C#
using Managing.Application.Abstractions.Repositories;
|
|
using Managing.Domain.Bots;
|
|
using Managing.Domain.Users;
|
|
using static Managing.Common.Enums;
|
|
|
|
namespace Managing.Application.ManageBot
|
|
{
|
|
public interface IBackupBotService
|
|
{
|
|
Task<BotBackup> GetBotBackup(string identifier);
|
|
Task SaveOrUpdateBotBackup(User user, string identifier, BotStatus status, TradingBotBackup data);
|
|
}
|
|
|
|
public class BackupBotService : IBackupBotService
|
|
{
|
|
private readonly IBotRepository _botRepository;
|
|
|
|
public BackupBotService(IBotRepository botRepository)
|
|
{
|
|
_botRepository = botRepository;
|
|
}
|
|
|
|
public async Task<BotBackup> GetBotBackup(string identifier)
|
|
{
|
|
return await _botRepository.GetBotByIdentifierAsync(identifier);
|
|
}
|
|
|
|
public async Task SaveOrUpdateBotBackup(User user, string identifier, BotStatus status, TradingBotBackup data)
|
|
{
|
|
var backup = await GetBotBackup(identifier);
|
|
|
|
if (backup != null)
|
|
{
|
|
backup.LastStatus = status;
|
|
backup.Data = data;
|
|
await _botRepository.UpdateBackupBot(backup);
|
|
}
|
|
else
|
|
{
|
|
var botBackup = new BotBackup
|
|
{
|
|
LastStatus = status,
|
|
User = user,
|
|
Identifier = identifier,
|
|
Data = data
|
|
};
|
|
|
|
await _botRepository.InsertBotAsync(botBackup);
|
|
}
|
|
}
|
|
}
|
|
} |