aspnet-core-signalr-angular/Core/FeedEngine.cs

using System;
using System.Collections.Generic;
using System.Net;
using System.Net.Http;
using LiveGameFeed.Data.Abstract;
using LiveGameFeed.Models;
using Microsoft.Extensions.Logging;
using RecurrentTasks;

namespace LiveGameFeed.Core
{
    public class FeedEngine : IRunnable
    {
        private ILogger logger;
        IMatchRepository _matchRepository;
        private string _apiURI = "http://localhost:5000/api/";

        public FeedEngine(IMatchRepository matchRepository,
                          ILogger<FeedEngine> logger)
        {
            this.logger = logger;
            this._matchRepository = matchRepository;
        }
        public void Run(TaskRunStatus taskRunStatus)
        {
            var msg = string.Format("Run at: {0}", DateTimeOffset.Now);
            logger.LogDebug(msg);
            UpdateScore();
        }

        private async void UpdateScore()
        {
            IEnumerable<Match> _matches = _matchRepository.GetAll();

            foreach (var match in _matches)
            {
                Random r = new Random();
                bool updateHost = r.Next(0, 2) == 1;
                int points = r.Next(2,4);

                if (updateHost)
                    match.HostScore += points;
                else
                    match.GuestScore += points;

                MatchScore score = new MatchScore()
                {
                    HostScore = match.HostScore,
                    GuestScore = match.GuestScore
                };

                // Update Score for all clients
                using (var client = new HttpClient())
                {
                    await client.PutAsJsonAsync<MatchScore>(_apiURI + "matches/" + match.Id, score);
                }

                // Update Feed for subscribed only clients

                FeedViewModel _feed = new FeedViewModel()
                {
                    MatchId = match.Id,
                    Description = points + " points for " + (updateHost == true ? match.Host : match.Guest + "!"),
                    CreatedAt = DateTime.Now 
                };
                using (var client = new HttpClient())
                {
                    await client.PostAsJsonAsync<FeedViewModel>(_apiURI + "feeds", _feed);
                }
            }
        }
    }
}