Changeset 250 in code for trunk/logger.go

Timestamp:

Apr 8, 2020, 8:19:33 AM (5 years ago)

Author:

contact

Message:

Parse timestamp from message tags in messageLogger.Append

File:

• trunk/logger.go (modified) (2 diffs)

trunk/logger.go

@@ -42 +42 @@
         }
 
-        // TODO: parse time from msg.Tags["time"], if available
+        var t time.Time
+        if tag, ok := msg.Tags["time"]; ok {
+                var err error
+                t, err = time.Parse(serverTimeLayout, string(tag))
+                if err != nil {
+                        return fmt.Errorf("failed to parse message time tag: %v", err)
+                }
+                t = t.In(time.Local)
+        } else {
+                t = time.Now()
+        }
 
         // TODO: enforce maximum open file handles (LRU cache of file handles)
         // TODO: handle non-monotonic clock behaviour
-        now := time.Now()
-        path := logPath(ml.network, ml.entity, now)
+        path := logPath(ml.network, ml.entity, t)
         if ml.path != path {
                 if ml.file != nil {
@@ -67 +76 @@
         }
 
-        _, err := fmt.Fprintf(ml.file, "[%02d:%02d:%02d] %s\n", now.Hour(), now.Minute(), now.Second(), s)
+        _, err := fmt.Fprintf(ml.file, "[%02d:%02d:%02d] %s\n", t.Hour(), t.Minute(), t.Second(), s)
         if err != nil {
                 return fmt.Errorf("failed to log message to %q: %v", ml.path, err)