ckaczor/HomeMonitor
1
0
Fork 0
mirror of https://github.com/ckaczor/HomeMonitor.git synced 2026-01-25 09:35:39 -05:00
Code Issues 9 Packages Projects Releases Wiki Activity

Implement weather calculations in the service

Browse Source
This commit is contained in:
Chris Kaczor
2020-07-17 12:31:56 +00:00
parent 4c8649fe31
commit ec0b3c9eb1
10 changed files with 263 additions and 77 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
Weather/Service/MessageHandler.cs
View File

@@ -1,5 +1,6 @@
using ChrisKaczor.HomeMonitor.Weather.Models;
using ChrisKaczor.HomeMonitor.Weather.Service.Data;
using ChrisKaczor.HomeMonitor.Weather.Service.Models;
using JetBrains.Annotations;
using Microsoft.AspNetCore.SignalR.Client;
using Microsoft.Extensions.Configuration;
@@ -8,11 +9,9 @@ using Newtonsoft.Json;
using RabbitMQ.Client;
using RabbitMQ.Client.Events;
using System;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using ChrisKaczor.HomeMonitor.Weather.Service.Models;
namespace ChrisKaczor.HomeMonitor.Weather.Service
{
@@ -97,17 +96,19 @@ namespace ChrisKaczor.HomeMonitor.Weather.Service
_database.StoreWeatherData(weatherMessage);
weatherMessage.Rain = _database.GetReadingValueSum(WeatherValueType.Rain, weatherMessage.Timestamp.AddHours(-1), weatherMessage.Timestamp).Result;
if (_hubConnection == null)
return;
var weatherUpdate = new WeatherUpdate(weatherMessage, _database);
try
{
if (_hubConnection.State == HubConnectionState.Disconnected)
_hubConnection.StartAsync().Wait();
_hubConnection.InvokeAsync("SendLatestReading", JsonConvert.SerializeObject(weatherMessage)).Wait();
var json = JsonConvert.SerializeObject(weatherUpdate);
_hubConnection.InvokeAsync("SendLatestReading", json).Wait();
}
catch (Exception exception)
{