diff --git a/test/integration/http/direct_v1_test.go b/test/integration/http/direct_v1_test.go index 9b8253ce0..fd096344d 100644 --- a/test/integration/http/direct_v1_test.go +++ b/test/integration/http/direct_v1_test.go @@ -13,7 +13,7 @@ import ( "time" cloudevents "github.com/cloudevents/sdk-go/v2" - "github.com/cloudevents/sdk-go/v2/types" + // "github.com/cloudevents/sdk-go/v2/types" ) func TestSenderReceiver_binary_v1(t *testing.T) { @@ -101,7 +101,6 @@ func TestSenderReceiver_binary_v1(t *testing.T) { func TestSenderReceiver_structured_v1(t *testing.T) { now := time.Now() - testCases := DirectTapTestCases{ "Structured v1.0": { now: now, @@ -131,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"}`, types.FormatTime(now.UTC())), + 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, }, }, @@ -177,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.UTC().Format(time.RFC3339Nano)), + 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 c5f2dc03c..6efe97239 100644 --- a/v2/event/event_marshal.go +++ b/v2/event/event_marshal.go @@ -11,6 +11,7 @@ import ( "fmt" "io" "strings" + "time" jsoniter "github.com/json-iterator/go" ) @@ -76,7 +77,7 @@ func WriteJson(in *Event, writer io.Writer) error { if eventContext.Time != nil { stream.WriteMore() stream.WriteObjectField("time") - stream.WriteString(eventContext.Time.String()) + stream.WriteString(eventContext.Time.Format(time.RFC3339Nano)) } case *EventContextV1: // Set a bunch of variables we need later @@ -120,7 +121,7 @@ func WriteJson(in *Event, writer io.Writer) error { if eventContext.Time != nil { stream.WriteMore() stream.WriteObjectField("time") - stream.WriteString(eventContext.Time.String()) + stream.WriteString(eventContext.Time.Format(time.RFC3339Nano)) } default: return fmt.Errorf("missing event context")