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()