From 16e6eb63a992941b420f63ad9cef9caa5115b851 Mon Sep 17 00:00:00 2001
From: networkException <git@nwex.de>
Date: Mon, 9 Jun 2025 13:41:26 +0200
Subject: Add option to specify time_zone for normalization

This patch adds the option to MOTIS constructor calls to specify
the timzone that should be used to normalize timestamps.
---
 lib/Travel/Status/MOTIS/Stopover.pm       |  9 +++++----
 lib/Travel/Status/MOTIS/Trip.pm           | 16 ++++++++++------
 lib/Travel/Status/MOTIS/TripAtStopover.pm |  5 ++++-
 3 files changed, 19 insertions(+), 11 deletions(-)

(limited to 'lib/Travel/Status/MOTIS')

diff --git a/lib/Travel/Status/MOTIS/Stopover.pm b/lib/Travel/Status/MOTIS/Stopover.pm
index 2c0c978..6535e79 100644
--- a/lib/Travel/Status/MOTIS/Stopover.pm
+++ b/lib/Travel/Status/MOTIS/Stopover.pm
@@ -41,6 +41,7 @@ sub new {
 	my $json      = $opt{json};
 	my $realtime  = $opt{realtime} // 0;
 	my $cancelled = $opt{cancelled};
+	my $time_zone = $opt{time_zone};
 
 	my $ref = {
 		stop => Travel::Status::MOTIS::Stop->from_stopover( json => $json ),
@@ -52,25 +53,25 @@ sub new {
 	if ( $json->{scheduledArrival} ) {
 		$ref->{scheduled_arrival} = DateTime::Format::ISO8601->parse_datetime(
 			$json->{scheduledArrival} );
-		$ref->{scheduled_arrival}->set_time_zone('local');
+		$ref->{scheduled_arrival}->set_time_zone( $time_zone );
 	}
 
 	if ( $json->{arrival} and $realtime ) {
 		$ref->{realtime_arrival}
 		  = DateTime::Format::ISO8601->parse_datetime( $json->{arrival} );
-		$ref->{realtime_arrival}->set_time_zone('local');
+		$ref->{realtime_arrival}->set_time_zone( $time_zone );
 	}
 
 	if ( $json->{scheduledDeparture} ) {
 		$ref->{scheduled_departure} = DateTime::Format::ISO8601->parse_datetime(
 			$json->{scheduledDeparture} );
-		$ref->{scheduled_departure}->set_time_zone('local');
+		$ref->{scheduled_departure}->set_time_zone( $time_zone );
 	}
 
 	if ( $json->{departure} and $realtime ) {
 		$ref->{realtime_departure}
 		  = DateTime::Format::ISO8601->parse_datetime( $json->{departure} );
-		$ref->{realtime_departure}->set_time_zone('local');
+		$ref->{realtime_departure}->set_time_zone( $time_zone );
 	}
 
 	if ( $ref->{scheduled_arrival} and $ref->{realtime_arrival} ) {
diff --git a/lib/Travel/Status/MOTIS/Trip.pm b/lib/Travel/Status/MOTIS/Trip.pm
index 161b4f7..7ba57ff 100644
--- a/lib/Travel/Status/MOTIS/Trip.pm
+++ b/lib/Travel/Status/MOTIS/Trip.pm
@@ -39,6 +39,7 @@ sub new {
 	my ( $obj, %opt ) = @_;
 
 	my $json = $opt{json}{legs}[0];
+	my $time_zone = $opt{time_zone};
 
 	my $ref = {
 		id          => $json->{tripId},
@@ -54,16 +55,18 @@ sub new {
 		raw_stopovers =>
 		  [ $json->{from}, @{ $json->{intermediateStops} }, $json->{to} ],
 		raw_polyline => $json->{legGeometry}->{points},
+
+		time_zone    => $time_zone,
 	};
 
 	$ref->{scheduled_departure} = DateTime::Format::ISO8601->parse_datetime(
 		$json->{scheduledStartTime} );
-	$ref->{scheduled_departure}->set_time_zone('local');
+	$ref->{scheduled_departure}->set_time_zone( $time_zone );
 
 	if ( $json->{realTime} ) {
 		$ref->{realtime_departure}
 		  = DateTime::Format::ISO8601->parse_datetime( $json->{startTime} );
-		$ref->{realtime_departure}->set_time_zone('local');
+		$ref->{realtime_departure}->set_time_zone( $time_zone );
 	}
 
 	$ref->{departure} = $ref->{realtime_departure}
@@ -71,12 +74,12 @@ sub new {
 
 	$ref->{scheduled_arrival}
 	  = DateTime::Format::ISO8601->parse_datetime( $json->{scheduledEndTime} );
-	$ref->{scheduled_arrival}->set_time_zone('local');
+	$ref->{scheduled_arrival}->set_time_zone( $time_zone );
 
 	if ( $json->{realTime} ) {
 		$ref->{realtime_arrival}
 		  = DateTime::Format::ISO8601->parse_datetime( $json->{endTime} );
-		$ref->{realtime_arrival}->set_time_zone('local');
+		$ref->{realtime_arrival}->set_time_zone( $time_zone );
 	}
 
 	$ref->{arrival} = $ref->{realtime_arrival} // $ref->{scheduled_arrival};
@@ -154,8 +157,9 @@ sub stopovers {
 
 	@{ $self->{stopovers} } = map {
 		Travel::Status::MOTIS::Stopover->new(
-			json     => $_,
-			realtime => $self->{is_realtime}
+			json      => $_,
+			realtime  => $self->{is_realtime},
+			time_zone => $self->{time_zone},
 		)
 	} ( @{ $self->{raw_stopovers} // [] } );
 
diff --git a/lib/Travel/Status/MOTIS/TripAtStopover.pm b/lib/Travel/Status/MOTIS/TripAtStopover.pm
index 2d58f98..6153045 100644
--- a/lib/Travel/Status/MOTIS/TripAtStopover.pm
+++ b/lib/Travel/Status/MOTIS/TripAtStopover.pm
@@ -29,7 +29,8 @@ Travel::Status::MOTIS::TripAtStopover->mk_ro_accessors(
 sub new {
 	my ( $obj, %opt ) = @_;
 
-	my $json = $opt{json};
+	my $json      = $opt{json};
+	my $time_zone = $opt{time_zone};
 
 	my $ref = {
 		id          => $json->{tripId},
@@ -48,6 +49,8 @@ sub new {
 			# NOTE: $json->{place}->{cancelled} isn't set, we just override this here.
 			cancelled => $json->{cancelled},
 			realtime  => $json->{realTime},
+
+			time_zone => $time_zone,
 		),
 	};
 
-- 
cgit v1.2.3