fix convertion from datetime to timestamps requires utc

Author: LiorBanaiKama

Analogy.LogServer.Clients/AnalogyMessageConsumer.cs

@@ -54,8 +54,9 @@ public AnalogyMessageConsumer(string address)
                 };
                 yield return msg;
                 if (token.IsCancellationRequested)
+                {
                     yield break;
-
+                }
             }
         }
         public Task Stop()

Analogy.LogServer.Clients/AnalogyMessageProducer.cs

@@ -49,7 +49,11 @@ public AnalogyMessageProducer(string address, ILogger logger)
         public async Task Log(string text, string source, AnalogyLogLevel level, string category = "",
             string machineName = null, string userName = null, string processName = null, int processId = 0, int threadId = 0, Dictionary<string, string> additionalInformation = null, [CallerMemberName] string memberName = "", [CallerLineNumber] int lineNumber = 0, [CallerFilePath] string filePath = "")
         {
-            if (!connected) return;
+            if (!connected)
+            {
+                return;
+            }
+
             var m = new AnalogyGRPCLogMessage()
             {
                 Text = text,
@@ -69,10 +73,12 @@ public async Task Log(string text, string source, AnalogyLogLevel level, string
                 User = userName ?? Environment.UserName,
             };
             if (additionalInformation != null)
+            {
                 foreach (KeyValuePair<string, string> keyValuePair in additionalInformation)
                 {
                     m.AdditionalInformation.Add(keyValuePair.Key, keyValuePair.Value);
                 }
+            }
 
             try
             {

Analogy.LogServer.Tests/TestForm.cs

@@ -18,7 +18,11 @@ public TestForm()
 
         private async void btnProducer_Click(object sender, EventArgs e)
         {
-            if (producing) return;
+            if (producing)
+            {
+                return;
+            }
+
             producing = true;
             btnProducer.Enabled = false;
             var p = new AnalogyMessageProducer($"http://{txtIP.Text}:6000", null);
@@ -36,7 +40,11 @@ private async void btnProducer_Click(object sender, EventArgs e)
 
         private async void btnConsumer_Click_1(object sender, EventArgs e)
         {
-            if (consuming) return;
+            if (consuming)
+            {
+                return;
+            }
+
             consuming = true;
             btnConsumer.Enabled = false;
 

Analogy.LogServer/Analogy.LogServer.csproj

@@ -17,7 +17,7 @@
 		<PublishRepositoryUrl>true</PublishRepositoryUrl>
 		<IncludeSymbols>true</IncludeSymbols>
 		<SymbolPackageFormat>snupkg</SymbolPackageFormat>
-		<Version>0.4.0</Version>
+		<Version>0.4.1</Version>
 		<Copyright>Lior Banai @ 2020</Copyright>
 	</PropertyGroup>
 	<ItemGroup>

Analogy.LogServer/GRPCLogConsumer.cs

@@ -44,8 +44,9 @@ public void RemoveGrpcConsumer(IServerStreamWriter<AnalogyGRPCLogMessage> respon
                 _sync.EnterWriteLock();
                 var exist = clients.Exists(c => c.stream == responseStream);
                 if (exist)
+                {
                     clients.RemoveAll(c => c.stream == responseStream);
-
+                }
             }
             finally
             {
@@ -63,7 +64,11 @@ public async Task ConsumeLog(AnalogyGRPCLogMessage msg)
                 for (int i = 0; i < clients.Count; i++)
                 {
                     var (stream, active) = clients[i];
-                    if (!active) continue;
+                    if (!active)
+                    {
+                        continue;
+                    }
+
                     try
                     {
                         await _semaphoreSlim.WaitAsync();

Analogy.LogServer/MessageHistoryContainer.cs

@@ -43,7 +43,7 @@ public void CleanMessages(int deleteOlderHours)
             try
             {
                 _sync.EnterWriteLock();
-                _OldMessages.RemoveAll(m => m.Date <= Timestamp.FromDateTime(DateTime.Now.AddHours(-deleteOlderHours)));
+                _OldMessages.RemoveAll(m => m.Date <= Timestamp.FromDateTime(DateTime.Now.AddHours(-deleteOlderHours).ToUniversalTime()));
             }
             finally
             {
@@ -58,7 +58,9 @@ public void CleanMessagesByHalf()
             {
                 _sync.EnterWriteLock();
                 if (_OldMessages.Any())
+                {
                     _OldMessages.RemoveRange(0, _OldMessages.Count / 2);
+                }
             }
             finally
             {

Analogy.LogServer/Services/GreeterService.cs

@@ -65,7 +65,9 @@ await responseStream.WriteAsync(new AnalogyGRPCLogMessage
             });
             var oldMessages = MessageHistoryContainer.GetOldMessages();
             if (oldMessages.Any())
+            {
                 await responseStream.WriteAllAsync(oldMessages);
+            }
 
             try
             {
@@ -90,7 +92,10 @@ private async Task HandleClientActions(IAsyncStreamReader<AnalogyGRPCLogMessage>
                             message.Date = Timestamp.FromDateTime(DateTime.UtcNow);
                         }
                         if (string.IsNullOrEmpty(message.Id))
+                        {
                             message.Id = Guid.NewGuid().ToString();
+                        }
+
                         MessageContainer.AddMessage(message);
                     }
                     catch (Exception e)