From 99852d760a18a9d87acc832fd0557f630f5e69eb Mon Sep 17 00:00:00 2001 From: Birte Kristina Friesel Date: Thu, 30 Jan 2025 22:26:16 +0100 Subject: parse and expose messages --- bin/dbris | 28 ++++++++++++++++++++++++++++ lib/Travel/Routing/DE/DBRIS/Connection.pm | 25 +++++++++++++++++++++++++ 2 files changed, 53 insertions(+) diff --git a/bin/dbris b/bin/dbris index e2ea2a6..ac11832 100755 --- a/bin/dbris +++ b/bin/dbris @@ -19,6 +19,7 @@ my $mots; my ( $first_class, $passengers ); my $developer_mode; my ( $json_output, $raw_json_output ); +my $verbose; my $use_cache = 1; my $show_full_route; my $cache; @@ -43,6 +44,7 @@ GetOptions( 'l|language=s' => \$language, 'p|passengers=s' => \$passengers, 't|time=s' => \$time, + 'v|verbose' => \$verbose, 'V|version' => \&show_version, 'cache!' => \$use_cache, 'devmode' => \$developer_mode, @@ -316,6 +318,19 @@ for my $connection ( $ris->connections ) { : q{}, $header, ); + + if ($verbose) { + for my $note ( $connection->notes ) { + printf( "| %s (%s)\n", $note->{value}, $note->{key} ); + } + + for my $msg ( $connection->messages ) { + printf( "| %s\n", $msg->{text} ); + } + } + + say q{}; + for my $segment ( $connection->segments ) { if ( $segment->is_transfer ) { for my $note ( $segment->transfer_notes ) { @@ -382,6 +397,19 @@ for my $connection ( $ris->connections ) { $segment->arr_name, $segment->arr_platform ? q{ } . $segment->arr_platform : q{}, ); + + if ($verbose) { + for my $msg ( $segment->messages_ris ) { + printf( "| %s (%s)\n", $msg->{value}, $msg->{key} ); + } + for my $msg ( $segment->messages_him ) { + printf( "| %s\n", $msg->{text} ); + } + for my $msg ( $segment->messages_prio ) { + printf( "| %s\n", $msg->{text} ); + } + } + say q{}; } say q{---------------------------------------}; diff --git a/lib/Travel/Routing/DE/DBRIS/Connection.pm b/lib/Travel/Routing/DE/DBRIS/Connection.pm index 2ad46d8..d7c74f0 100644 --- a/lib/Travel/Routing/DE/DBRIS/Connection.pm +++ b/lib/Travel/Routing/DE/DBRIS/Connection.pm @@ -94,6 +94,19 @@ sub new { $ref->{$key} = $ref->{segments}[-1]{$key}; } + for my $note ( @{ $json->{risNotizen} // [] } ) { + push( @{ $ref->{notes} }, $note ); + if ( $note->{key} eq 'text.realtime.connection.cancelled' ) { + $ref->{is_cancelled} = 1; + } + elsif ( $note->{key} eq 'text.realtime.connection.brokentrip' ) { + $ref->{is_unlikely} = 1; + } + } + for my $message ( @{ $json->{messages} // [] } ) { + push( @{ $ref->{messages} }, $message ); + } + bless( $ref, $obj ); return $ref; @@ -105,6 +118,18 @@ sub segments { return @{ $self->{segments} // [] }; } +sub notes { + my ($self) = @_; + + return @{ $self->{notes} // [] }; +} + +sub messages { + my ($self) = @_; + + return @{ $self->{messages} // [] }; +} + sub TO_JSON { my ($self) = @_; -- cgit v1.2.3