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

Log all messages

Browse Source
This commit is contained in:
Chris Kaczor
2019-07-30 14:21:50 -04:00
parent 7f963caa26
commit d66fc88aba
1 changed files with 5 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
Weather/Service/MessageHandler.cs
View File

@@ -1,4 +1,6 @@
using JetBrains.Annotations;
using ChrisKaczor.HomeMonitor.Weather.Models;
using ChrisKaczor.HomeMonitor.Weather.Service.Data;
using JetBrains.Annotations;
using Microsoft.AspNetCore.SignalR.Client;
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.Hosting;
@@ -9,8 +11,6 @@ using System;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using ChrisKaczor.HomeMonitor.Weather.Models;
using ChrisKaczor.HomeMonitor.Weather.Service.Data;
namespace ChrisKaczor.HomeMonitor.Weather.Service
{
@@ -25,9 +25,6 @@ namespace ChrisKaczor.HomeMonitor.Weather.Service
private HubConnection _hubConnection;
private static DateTime _lastLogTime = DateTime.MinValue;
private static long _messageCount;
public MessageHandler(IConfiguration configuration, Database database)
{
_configuration = configuration;
@@ -80,15 +77,7 @@ namespace ChrisKaczor.HomeMonitor.Weather.Service
var body = eventArgs.Body;
var message = Encoding.UTF8.GetString(body);
_messageCount++;
if ((DateTime.Now - _lastLogTime).TotalMinutes >= 1)
{
WriteLog($"Number of messages received since {_lastLogTime} = {_messageCount}");
_lastLogTime = DateTime.Now;
_messageCount = 0;
}
WriteLog($"Message received: {message}");
var weatherMessage = JsonConvert.DeserializeObject<WeatherMessage>(message);
@@ -109,7 +98,7 @@ namespace ChrisKaczor.HomeMonitor.Weather.Service
if (_hubConnection.State == HubConnectionState.Disconnected)
_hubConnection.StartAsync().Wait();
_hubConnection.InvokeAsync("SendLatestReading", message).Wait();
_hubConnection.InvokeAsync("SendLatestReading", message).Wait();
}
catch (Exception exception)
{