From d7b6aff1a200d58442ddca02c57263c49df6165f Mon Sep 17 00:00:00 2001 From: Doug Davis Date: Wed, 23 Oct 2024 16:39:40 +0000 Subject: [PATCH] don't truncate to seconds Signed-off-by: Doug Davis --- test/integration/http/direct_v1_test.go | 8 ++++---- v2/event/event_marshal.go | 4 ++-- 2 files changed, 6 insertions(+), 6 deletions(-) diff --git a/test/integration/http/direct_v1_test.go b/test/integration/http/direct_v1_test.go index e597c2104..fd096344d 100644 --- a/test/integration/http/direct_v1_test.go +++ b/test/integration/http/direct_v1_test.go @@ -117,7 +117,7 @@ func TestSenderReceiver_structured_v1(t *testing.T) { Context: cloudevents.EventContextV1{ ID: "ABC-123", Type: "unit.test.client.sent", - Time: &cloudevents.Timestamp{Time: now.Truncate(time.Second)}, + Time: &cloudevents.Timestamp{Time: now}, Source: *cloudevents.ParseURIRef("/unit/test/client"), Subject: strptr("resource"), DataContentType: cloudevents.StringOfApplicationJSON(), @@ -130,7 +130,7 @@ func TestSenderReceiver_structured_v1(t *testing.T) { Header: map[string][]string{ "content-type": {"application/cloudevents+json"}, }, - Body: fmt.Sprintf(`{"data":{"hello":"unittest"},"id":"ABC-123","source":"/unit/test/client","specversion":"1.0","subject":"resource","time":%q,"type":"unit.test.client.sent"}`, now.Truncate(time.Second).Format(time.RFC3339)), + Body: fmt.Sprintf(`{"data":{"hello":"unittest"},"id":"ABC-123","source":"/unit/test/client","specversion":"1.0","subject":"resource","time":%q,"type":"unit.test.client.sent"}`, now.Format(time.RFC3339)), ContentLength: 182, }, }, @@ -163,7 +163,7 @@ func TestSenderReceiver_data_base64_v1(t *testing.T) { Context: cloudevents.EventContextV1{ ID: "ABC-123", Type: "unit.test.client.sent", - Time: &cloudevents.Timestamp{Time: now.Truncate(time.Second)}, + Time: &cloudevents.Timestamp{Time: now}, Source: *cloudevents.ParseURIRef("/unit/test/client"), Subject: strptr("resource"), DataContentType: cloudevents.StringOfTextPlain(), @@ -176,7 +176,7 @@ func TestSenderReceiver_data_base64_v1(t *testing.T) { Header: map[string][]string{ "content-type": {"application/cloudevents+json"}, }, - Body: fmt.Sprintf(`{"data_base64":"aGVsbG86IHVuaXR0ZXN0","id":"ABC-123","source":"/unit/test/client","specversion":"1.0","subject":"resource","time":%q,"type":"unit.test.client.sent"}`, now.Truncate(time.Second).Format(time.RFC3339)), + Body: fmt.Sprintf(`{"data_base64":"aGVsbG86IHVuaXR0ZXN0","id":"ABC-123","source":"/unit/test/client","specversion":"1.0","subject":"resource","time":%q,"type":"unit.test.client.sent"}`, now.Format(time.RFC3339)), ContentLength: 191, }, }, diff --git a/v2/event/event_marshal.go b/v2/event/event_marshal.go index 473b8d66a..6efe97239 100644 --- a/v2/event/event_marshal.go +++ b/v2/event/event_marshal.go @@ -77,7 +77,7 @@ func WriteJson(in *Event, writer io.Writer) error { if eventContext.Time != nil { stream.WriteMore() stream.WriteObjectField("time") - stream.WriteString(eventContext.Time.Format(time.RFC3339)) + stream.WriteString(eventContext.Time.Format(time.RFC3339Nano)) } case *EventContextV1: // Set a bunch of variables we need later @@ -121,7 +121,7 @@ func WriteJson(in *Event, writer io.Writer) error { if eventContext.Time != nil { stream.WriteMore() stream.WriteObjectField("time") - stream.WriteString(eventContext.Time.Format(time.RFC3339)) + stream.WriteString(eventContext.Time.Format(time.RFC3339Nano)) } default: return fmt.Errorf("missing event context")