From 599ff9f5f2f86fa499d5c8895ff683ba67ff395b Mon Sep 17 00:00:00 2001 From: Birte Kristina Friesel Date: Thu, 16 Nov 2023 19:52:45 +0100 Subject: Move HAFAS stop parser to Stop package --- lib/Travel/Status/DE/HAFAS/Journey.pm | 94 ++++------------------------------- lib/Travel/Status/DE/HAFAS/Stop.pm | 90 +++++++++++++++++++++++++++++++++ 2 files changed, 100 insertions(+), 84 deletions(-) (limited to 'lib/Travel/Status') 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) = @_; -- cgit v1.2.3