tr/traffic-event event end date nullable

noi-techpark · Jan 2, 2025 · 24f9c01 · 24f9c01
1 parent bacd031
commit 24f9c01
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 2 deletions.
diff --git a/transformers/traffic-event-prov-bz/src/go.mod b/transformers/traffic-event-prov-bz/src/go.mod
@@ -5,7 +5,7 @@ go 1.23.4
 require (
 	github.com/google/uuid v1.6.0
 	github.com/kelseyhightower/envconfig v1.4.0
-	github.com/noi-techpark/go-bdp-client v1.0.1-0.20250102125324-86dce4375872
+	github.com/noi-techpark/go-bdp-client v1.0.1-0.20250102130145-ed07a83e9ac3
 	github.com/noi-techpark/go-opendatahub-ingest v0.0.0-20241217152708-001fb6f116e0
 	github.com/twpayne/go-geom v1.5.7
 	github.com/wI2L/jsondiff v0.6.1

diff --git a/transformers/traffic-event-prov-bz/src/go.sum b/transformers/traffic-event-prov-bz/src/go.sum
@@ -22,6 +22,8 @@ github.com/noi-techpark/go-bdp-client v1.0.1-0.20241230091831-3fd536c600ac h1:1f
 github.com/noi-techpark/go-bdp-client v1.0.1-0.20241230091831-3fd536c600ac/go.mod h1:aooKwED49M7Au+9Y/o8wW/4yggIvaVRHc0JJvPnS10c=
 github.com/noi-techpark/go-bdp-client v1.0.1-0.20250102125324-86dce4375872 h1:bQ1heZUAytQDI7uyQYFy+U4DWHyrYFc9UwGbJYfNQVc=
 github.com/noi-techpark/go-bdp-client v1.0.1-0.20250102125324-86dce4375872/go.mod h1:aooKwED49M7Au+9Y/o8wW/4yggIvaVRHc0JJvPnS10c=
+github.com/noi-techpark/go-bdp-client v1.0.1-0.20250102130145-ed07a83e9ac3 h1:dDPSoMrEBtc4zLDnmfJNGOK47G+Kf7VccgOjM87SsGI=
+github.com/noi-techpark/go-bdp-client v1.0.1-0.20250102130145-ed07a83e9ac3/go.mod h1:aooKwED49M7Au+9Y/o8wW/4yggIvaVRHc0JJvPnS10c=
 github.com/noi-techpark/go-opendatahub-ingest v0.0.0-20241217152708-001fb6f116e0 h1:+jstfT0wGjInqpaimKTcQofYio83PJxM6CyqjK920zs=
 github.com/noi-techpark/go-opendatahub-ingest v0.0.0-20241217152708-001fb6f116e0/go.mod h1:x/eTKLIBpI0ITcXvfBYxPVc6PHAQN237Uvv0afM0bOg=
 github.com/rabbitmq/amqp091-go v1.10.0 h1:STpn5XsHlHGcecLmMFCtg7mqq0RnD+zFr4uzukfVhBw=

diff --git a/transformers/traffic-event-prov-bz/src/main.go b/transformers/traffic-event-prov-bz/src/main.go
@@ -91,7 +91,8 @@ func mapEvent(d trafficEvent) (bdplib.Event, error) {
 		if err != nil {
 			return e, fmt.Errorf("error parsing EndDate (%s): %w", d.EndDate, err)
 		}
-		e.EventEnd = endDate.UTC().UnixMilli() + 1 // +1 because we exclude the upper bound.
+		end := endDate.UTC().UnixMilli() + 1 // +1 because we exclude the upper bound.
+		e.EventEnd = &end
 	}
 
 	e.MetaData = map[string]any{}