From ca65ed1d9df9aff4de9f79da5cdbfaaab5018c92 Mon Sep 17 00:00:00 2001 From: "Enot (ded) Skelly" Date: Thu, 2 Jul 2026 13:09:26 -0700 Subject: [PATCH] fix(ingest): add more possible heard at timestamp formats --- internal/ingest/packet.go | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/internal/ingest/packet.go b/internal/ingest/packet.go index e7b920a..30dd97b 100644 --- a/internal/ingest/packet.go +++ b/internal/ingest/packet.go @@ -706,9 +706,15 @@ func (w *Worker) handlePacket(ctx context.Context, iata, pubkeyHex string, raw [ if err != nil { heardAt, err = time.Parse("2006-01-02T15:04:05.000000", envelope.Timestamp) } + if err != nil { + heardAt, err = time.Parse("2006-01-02T15:04:05.000000Z", envelope.Timestamp) + } if err != nil { heardAt, err = time.Parse("2006-01-02T15:04:05", envelope.Timestamp) } + if err != nil { + heardAt, err = time.Parse("2006-01-02T15:04:05Z", envelope.Timestamp) + } if err != nil { log.Printf("ingest[%s]: failed to parse timestamp %q: %v", w.cfg.BrokerName, envelope.Timestamp, err) heardAt = time.Now().UTC()