Fixed nanosecond to second conversions in target.

corentinaltepe · May 30, 2022 · 7c39a22 · 7c39a22
1 parent c9ec8b0
commit 7c39a22
Showing 1 changed file with 9 additions and 2 deletions.
diff --git a/src/NLog.Loki.gRPC/LokiTarget.cs b/src/NLog.Loki.gRPC/LokiTarget.cs
@@ -1,3 +1,4 @@
+using System;
 using System.Collections.Generic;
 using System.Linq;
 using System.Text;
@@ -49,12 +50,14 @@ protected override async Task WriteAsyncTask(LogEventInfo logEvent, Cancellation
     {
         var @event = GetLokiEvent(logEvent);
         var stream = new StreamAdapter { Labels = FormatLabels(@event.Labels.Labels) };
+        var nano = UnixDateTimeConverter.ToUnixTimeNs(@event.Timestamp);
         stream.Entries.Add(new EntryAdapter()
         {
             Line = @event.Line,
             Timestamp = new Google.Protobuf.WellKnownTypes.Timestamp
             {
-                Seconds = UnixDateTimeConverter.ToUnixTimeNs(@event.Timestamp) / 1000000000
+                Seconds = nano / 1_000_000_000,
+                Nanos = Convert.ToInt32(nano % 1_000_000_000),
             }
         });
 
@@ -78,14 +81,18 @@ protected override async Task WriteAsyncTask(IList<LogEventInfo> logEvents, Canc
                     orderedEvents = gp.OrderBy(e => e.Timestamp);
 
                 foreach(var @event in gp)
+                {
+                    var nano = UnixDateTimeConverter.ToUnixTimeNs(@event.Timestamp);
                     stream.Entries.Add(new EntryAdapter()
                     {
                         Line = @event.Line,
                         Timestamp = new Google.Protobuf.WellKnownTypes.Timestamp
                         {
-                            Seconds = UnixDateTimeConverter.ToUnixTimeNs(@event.Timestamp)
+                            Seconds = nano / 1_000_000_000,
+                            Nanos = Convert.ToInt32(nano % 1_000_000_000),
                         }
                     });
+                }
                 return stream;
             });