don't truncate to seconds

Signed-off-by: Doug Davis <[email protected]>

Author: duglin

test/integration/http/direct_v1_test.go

@@ -13,7 +13,6 @@ import (
 	"time"
 
 	cloudevents "github.com/cloudevents/sdk-go/v2"
-	// "github.com/cloudevents/sdk-go/v2/types"
 )
 
 func TestSenderReceiver_binary_v1(t *testing.T) {
@@ -117,7 +116,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 +129,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 +162,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 +175,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,
 			},
 		},

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