From d66fc88aba7b0218afb4214ab3662ca3e8f87f84 Mon Sep 17 00:00:00 2001 From: Chris Kaczor Date: Tue, 30 Jul 2019 14:21:50 -0400 Subject: [PATCH] Log all messages --- Weather/Service/MessageHandler.cs | 21 +++++---------------- 1 file changed, 5 insertions(+), 16 deletions(-) diff --git a/Weather/Service/MessageHandler.cs b/Weather/Service/MessageHandler.cs index ba57a05..1904ed8 100644 --- a/Weather/Service/MessageHandler.cs +++ b/Weather/Service/MessageHandler.cs @@ -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(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) {