Merge pull request #6 from eleven-software/update-format

Geeker1 · web-flow · commit 3e0250c66701 · 2023-05-08T15:03:51.000+01:00
Update Time format to include offset
diff --git a/transform/eleven/eleven.go b/transform/eleven/eleven.go
@@ -20,14 +20,14 @@ func New() transform.Transformer {
 
 	timeFormat := os.Getenv(EnvTimeFormat)
 	if timeFormat == "" {
-		timeFormat = "2006-01-02T15:04:05.000Z"
+		timeFormat = "2006-01-02T15:04:05.000Z07:00"
 	}
 
 	return func(rec *types.Record) (*types.Record, error) {
 		rec.Fields["product"] = product
 		rec.Fields["component"] = component
 
-		formattedTime := rec.Time.Format(timeFormat)
+		formattedTime := rec.Time.UTC().Format(timeFormat)
 		rec.Fields["when"] = formattedTime
 		return rec, nil
 	}

Original file line number	Diff line number	Diff line change
`@@ -20,14 +20,14 @@ func New() transform.Transformer {`
`20`	`20`
`21`	`21`	`timeFormat := os.Getenv(EnvTimeFormat)`
`22`	`22`	`if timeFormat == "" {`
`23`		`- timeFormat = "2006-01-02T15:04:05.000Z"`
	`23`	`+ timeFormat = "2006-01-02T15:04:05.000Z07:00"`
`24`	`24`	`}`
`25`	`25`
`26`	`26`	`return func(rec types.Record) (types.Record, error) {`
`27`	`27`	`rec.Fields["product"] = product`
`28`	`28`	`rec.Fields["component"] = component`
`29`	`29`
`30`		`- formattedTime := rec.Time.Format(timeFormat)`
	`30`	`+ formattedTime := rec.Time.UTC().Format(timeFormat)`
`31`	`31`	`rec.Fields["when"] = formattedTime`
`32`	`32`	`return rec, nil`
`33`	`33`	`}`