summaryrefslogtreecommitdiff
path: root/lib
diff options
context:
space:
mode:
Diffstat (limited to 'lib')
-rw-r--r--lib/Travel/Status/DE/HAFAS/Journey.pm94
-rw-r--r--lib/Travel/Status/DE/HAFAS/Stop.pm90
2 files changed, 100 insertions, 84 deletions
diff --git a/lib/Travel/Status/DE/HAFAS/Journey.pm b/lib/Travel/Status/DE/HAFAS/Journey.pm
index 5f96c8f..37f8262 100644
--- a/lib/Travel/Status/DE/HAFAS/Journey.pm
+++ b/lib/Travel/Status/DE/HAFAS/Journey.pm
@@ -108,76 +108,20 @@ sub new {
my @stops;
my $route_end;
for my $stop ( @{ $journey->{stopL} // [] } ) {
- my $loc = $locL[ $stop->{locX} ];
- my $sched_arr = $stop->{aTimeS};
- my $rt_arr = $stop->{aTimeR};
- my $sched_dep = $stop->{dTimeS};
- my $rt_dep = $stop->{dTimeR};
-
- # dIn. / aOut. -> may passengers enter / exit the train?
-
- my $sched_platform = $stop->{aPlatfS} // $stop->{dPlatfS};
- my $rt_platform = $stop->{aPlatfR} // $stop->{dPlatfR};
- my $changed_platform = $stop->{aPlatfCh} // $stop->{dPlatfCh};
-
- for my $timestr ( $sched_arr, $rt_arr, $sched_dep, $rt_dep ) {
- if ( not defined $timestr ) {
- next;
- }
-
- $timestr = handle_day_change(
- input => $timestr,
- date => $date,
- strp_obj => $hafas->{strptime_obj},
- ref => $datetime_ref
- );
-
- }
-
- my $arr_delay
- = ( $sched_arr and $rt_arr )
- ? ( $rt_arr->epoch - $sched_arr->epoch ) / 60
- : undef;
-
- my $dep_delay
- = ( $sched_dep and $rt_dep )
- ? ( $rt_dep->epoch - $sched_dep->epoch ) / 60
- : undef;
-
- my $arr_cancelled = $stop->{aCncl};
- my $dep_cancelled = $stop->{dCncl};
-
- my $tco = {};
- for my $tco_id ( @{ $stop->{dTrnCmpSX}{tcocX} // [] } ) {
- my $tco_kv = $tcocL[$tco_id];
- $tco->{ $tco_kv->{c} } = $tco_kv->{r};
- }
+ my $loc = $locL[ $stop->{locX} ];
push(
@stops,
{
- loc => $loc,
- extra => {
- sched_arr => $sched_arr,
- rt_arr => $rt_arr,
- arr => $rt_arr // $sched_arr,
- arr_delay => $arr_delay,
- arr_cancelled => $arr_cancelled,
- sched_dep => $sched_dep,
- rt_dep => $rt_dep,
- dep => $rt_dep // $sched_dep,
- dep_delay => $dep_delay,
- dep_cancelled => $dep_cancelled,
- delay => $dep_delay // $arr_delay,
- direction => $stop->{dDirTxt},
- sched_platform => $sched_platform,
- rt_platform => $rt_platform,
- is_changed_platform => $changed_platform,
- platform => $rt_platform // $sched_platform,
- load => $tco,
- }
+ loc => $loc,
+ stop => $stop,
+ common => $opt{common},
+ date => $date,
+ datetime_ref => $datetime_ref,
+ strp_obj => $hafas->{strptime_obj},
}
);
+
$route_end = $loc->{name};
}
@@ -242,7 +186,7 @@ sub new {
next;
}
- $timestr = handle_day_change(
+ $timestr = Travel::Status::DE::HAFAS::Stop::handle_day_change(
input => $timestr,
date => $date,
strp_obj => $hafas->{strptime_obj},
@@ -289,24 +233,6 @@ sub new {
# }}}
-sub handle_day_change {
- my (%opt) = @_;
- my $date = $opt{date};
- my $timestr = $opt{input};
- if ( length($timestr) == 8 ) {
-
- # arrival time includes a day offset
- my $offset_date = $opt{ref}->clone;
- $offset_date->add( days => substr( $timestr, 0, 2, q{} ) );
- $offset_date = $offset_date->strftime('%Y%m%d');
- $timestr = $opt{strp_obj}->parse_datetime("${offset_date}T${timestr}");
- }
- else {
- $timestr = $opt{strp_obj}->parse_datetime("${date}T${timestr}");
- }
- return $timestr;
-}
-
# {{{ Accessors
# Legacy
@@ -353,7 +279,7 @@ sub route {
my ($self) = @_;
if ( $self->{route} ) {
- if ( $self->{route}[0] and $self->{route}[0]{extra} ) {
+ if ( $self->{route}[0] and $self->{route}[0]{stop} ) {
$self->{route}
= [ map { Travel::Status::DE::HAFAS::Stop->new( %{$_} ) }
@{ $self->{route} } ];
diff --git a/lib/Travel/Status/DE/HAFAS/Stop.pm b/lib/Travel/Status/DE/HAFAS/Stop.pm
index 008dd4e..2ea73b5 100644
--- a/lib/Travel/Status/DE/HAFAS/Stop.pm
+++ b/lib/Travel/Status/DE/HAFAS/Stop.pm
@@ -43,11 +43,101 @@ sub new {
bless( $ref, $obj );
+ if ( $opt{stop} ) {
+ $ref->parse_stop( $opt{stop}, $opt{common}, $opt{date},
+ $opt{datetime_ref}, $opt{strp_obj} );
+ }
+
return $ref;
}
+sub parse_stop {
+ my ( $self, $stop, $common, $date, $datetime_ref, $strp_obj ) = @_;
+
+ my $sched_arr = $stop->{aTimeS};
+ my $rt_arr = $stop->{aTimeR};
+ my $sched_dep = $stop->{dTimeS};
+ my $rt_dep = $stop->{dTimeR};
+
+ # dIn. / aOut. -> may passengers enter / exit the train?
+
+ my $sched_platform = $stop->{aPlatfS} // $stop->{dPlatfS};
+ my $rt_platform = $stop->{aPlatfR} // $stop->{dPlatfR};
+ my $changed_platform = $stop->{aPlatfCh} // $stop->{dPlatfCh};
+
+ for my $timestr ( $sched_arr, $rt_arr, $sched_dep, $rt_dep ) {
+ if ( not defined $timestr ) {
+ next;
+ }
+
+ $timestr = handle_day_change(
+ input => $timestr,
+ date => $date,
+ strp_obj => $strp_obj,
+ ref => $datetime_ref
+ );
+
+ }
+
+ my $arr_delay
+ = ( $sched_arr and $rt_arr )
+ ? ( $rt_arr->epoch - $sched_arr->epoch ) / 60
+ : undef;
+
+ my $dep_delay
+ = ( $sched_dep and $rt_dep )
+ ? ( $rt_dep->epoch - $sched_dep->epoch ) / 60
+ : undef;
+
+ my $arr_cancelled = $stop->{aCncl};
+ my $dep_cancelled = $stop->{dCncl};
+
+ my $tco = {};
+ for my $tco_id ( @{ $stop->{dTrnCmpSX}{tcocX} // [] } ) {
+ my $tco_kv = $common->{tcocL}[$tco_id];
+ $tco->{ $tco_kv->{c} } = $tco_kv->{r};
+ }
+
+ $self->{sched_arr} = $sched_arr;
+ $self->{rt_arr} = $rt_arr;
+ $self->{arr} = $rt_arr // $sched_arr;
+ $self->{arr_delay} = $arr_delay;
+ $self->{arr_cancelled} = $arr_cancelled;
+ $self->{sched_dep} = $sched_dep;
+ $self->{rt_dep} = $rt_dep;
+ $self->{dep} = $rt_dep // $sched_dep;
+ $self->{dep_delay} = $dep_delay;
+ $self->{dep_cancelled} = $dep_cancelled;
+ $self->{delay} = $dep_delay // $arr_delay;
+ $self->{direction} = $stop->{dDirTxt};
+ $self->{sched_platform} = $sched_platform;
+ $self->{rt_platform} = $rt_platform;
+ $self->{is_changed_platform} = $changed_platform;
+ $self->{platform} = $rt_platform // $sched_platform;
+ $self->{load} = $tco;
+
+}
+
# }}}
+sub handle_day_change {
+ my (%opt) = @_;
+ my $date = $opt{date};
+ my $timestr = $opt{input};
+ if ( length($timestr) == 8 ) {
+
+ # arrival time includes a day offset
+ my $offset_date = $opt{ref}->clone;
+ $offset_date->add( days => substr( $timestr, 0, 2, q{} ) );
+ $offset_date = $offset_date->strftime('%Y%m%d');
+ $timestr = $opt{strp_obj}->parse_datetime("${offset_date}T${timestr}");
+ }
+ else {
+ $timestr = $opt{strp_obj}->parse_datetime("${date}T${timestr}");
+ }
+ return $timestr;
+}
+
sub TO_JSON {
my ($self) = @_;
generated by cgit v1.2.3 (git 2.39.1) at 2024-11-10 16:18:10 +0000