Files
2020-04-13 15:16:46 +01:00

32 lines
1.0 KiB
C#

using AutoBet.DataRecorded.RaceResultsDataCollector;
using BritishHorseRacingApi;
using Microsoft.EntityFrameworkCore;
using SwiftyMessageHub.Core;
using System;
using System.Linq;
using System.Threading.Tasks;
namespace AutoBet.DataRecorded.MessageControllers
{
public class PostRaceDataCollectorController : MessageController
{
[MessageRoute]
public async Task LoadRaces(PostRaceDataCollectorDetails details)
{
var api = new ApiClient();
Console.WriteLine("Loading races");
using (var db = new Db.HorseRacingDataContext())
{
var results = await db.Races.Where(e => e.RaceDate.Date == details.DateToCollect.Date)
.Where(e => !db.RunnerResults.Any(e1 => e1.RaceId == e.RaceId))
.ToListAsync();
foreach (var result in results)
{
await CurrentContext.Hub.SendMessage(result);
}
}
}
}
}