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); } } } } }