diff options
| author | Birte Kristina Friesel <derf@finalrewind.org> | 2025-10-26 21:39:46 +0100 | 
|---|---|---|
| committer | Birte Kristina Friesel <derf@finalrewind.org> | 2025-10-26 21:39:46 +0100 | 
| commit | f987ae593b0363312f211c87c4fbce296b99d128 (patch) | |
| tree | 9d6d05c9520592b8df080a04a33f7ae4db100dac /lib/Travelynx.pm | |
| parent | c0eb68d1549a390e8bbc6a8d76d65282902f289d (diff) | |
carriage formation: directly refer to Travel::Status::DE::DBRIS
Also removes old has_wagonorder / get_wagonorder split. That used to be
sensible when we had multiple backends, but has long since lost its meaning.
Diffstat (limited to 'lib/Travelynx.pm')
| -rwxr-xr-x | lib/Travelynx.pm | 31 | 
1 files changed, 11 insertions, 20 deletions
| diff --git a/lib/Travelynx.pm b/lib/Travelynx.pm index 46257ac..9fcba0c 100755 --- a/lib/Travelynx.pm +++ b/lib/Travelynx.pm @@ -1886,31 +1886,20 @@ sub startup {  			my $db = $self->pg->db;  			if ( $datetime and $train_no ) { -				$self->dbris->has_wagonorder_p(%opt)->then( +				$self->dbris->get_wagonorder_p(%opt)->then(  					sub { -						return $self->dbris->get_wagonorder_p(%opt); -					} -				)->then( -					sub { -						my ($wagonorder) = @_; +						my ($status) = @_; +						my $wr = $status->result;  						my $data      = {};  						my $user_data = {}; -						my $wr; -						eval { -							$wr -							  = Travel::Status::DE::DBRIS::Formation->new( -								json => $wagonorder ); -						}; -  						if (    $opt{is_departure} -							and $wr -							and not exists $wagonorder->{error} ) +							and $wr )  						{  							my $dt  							  = $opt{datetime}->clone->set_time_zone('UTC'); -							$data->{wagonorder_dep}   = $wagonorder; +							$data->{wagonorder_dep}   = $status->{raw_json};  							$data->{wagonorder_param} = {  								time      => $dt->rfc3339 =~ s{(?=Z)}{.000}r,  								number    => $opt{train_no}, @@ -1964,10 +1953,8 @@ sub startup {  								train_id  => $train_id,  							);  						} -						elsif ( $opt{is_arrival} -							and not exists $wagonorder->{error} ) -						{ -							$data->{wagonorder_arr} = $wagonorder; +						elsif ( $opt{is_arrival} ) { +							$data->{wagonorder_arr} = $status->{raw_json};  							$self->in_transit->update_data(  								uid      => $uid,  								db       => $db, @@ -1979,6 +1966,10 @@ sub startup {  					}  				)->catch(  					sub { +						my ($err) = @_; +						$self->log->debug( +							"add_wagonorder: promise rejected with ${err}"); +  						# no wagonorder? no problem.  						return;  					} | 
