diff options
Diffstat (limited to 'lib/DBInfoscreen/Helper/Wagonorder.pm')
| -rw-r--r-- | lib/DBInfoscreen/Helper/Wagonorder.pm | 152 |
1 files changed, 118 insertions, 34 deletions
diff --git a/lib/DBInfoscreen/Helper/Wagonorder.pm b/lib/DBInfoscreen/Helper/Wagonorder.pm index 91006fc..9981244 100644 --- a/lib/DBInfoscreen/Helper/Wagonorder.pm +++ b/lib/DBInfoscreen/Helper/Wagonorder.pm @@ -1,13 +1,15 @@ package DBInfoscreen::Helper::Wagonorder; +# Copyright (C) 2011-2020 Birte Kristina Friesel +# +# SPDX-License-Identifier: AGPL-3.0-or-later + use strict; use warnings; use 5.020; use DateTime; -use Encode qw(decode encode); -use Mojo::JSON qw(decode_json); -use XML::LibXML; +use Mojo::Promise; sub new { my ( $class, %opt ) = @_; @@ -23,48 +25,130 @@ sub new { } -sub is_available { - my ( $self, $train, $wr_link ) = @_; +sub get_p { + my ( $self, %opt ) = @_; + + my %param; - if ( $self->check_wagonorder( $train->train_no, $wr_link ) ) { - return 1; + if ( $opt{param} ) { + %param = %{ $opt{param} }; + delete $param{e}; } - elsif ( $train->is_wing ) { - my $wing = $train->wing_of; - if ( $self->check_wagonorder( $wing->train_no, $wr_link ) ) { - return 1; - } + else { + my $datetime = $opt{datetime}->clone->set_time_zone('UTC'); + %param = ( + administrationId => 80, + category => $opt{train_type}, + date => $datetime->strftime('%Y-%m-%d'), + evaNumber => $opt{eva}, + number => $opt{train_number}, + time => $datetime->rfc3339 =~ s{(?=Z)}{.000}r + ); } - return; -} -sub check_wagonorder { - my ( $self, $train_no, $wr_link ) = @_; + my $url = sprintf( '%s?%s', +'https://www.bahn.de/web/api/reisebegleitung/wagenreihung/vehicle-sequence', + join( '&', map { $_ . '=' . $param{$_} } sort keys %param ) ); - my $url - = "https://lib.finalrewind.org/dbdb/has_wagonorder/${train_no}/${wr_link}"; - my $cache = $self->{cache}; + my $promise = Mojo::Promise->new; - if ( my $content = $self->{cache}->get($url) ) { - return $content eq 'y' ? 1 : undef; + if ( my $content = $self->{main_cache}->thaw($url) ) { + $self->{log}->debug("wagonorder->get_p($url): cached"); + if ( $content->{error} ) { + return $promise->reject( +"GET $url: HTTP $content->{error}{code} $content->{error}{message} (cachd)" + ); + } + return $promise->resolve( $content, \%param ); } - my $ua = $self->{user_agent}->request_timeout(2); + if ( my $content = $self->{realtime_cache}->thaw($url) ) { + $self->{log}->debug("wagonorder->get_p($url): cached"); + if ( $content->{error} ) { + return $promise->reject( +"GET $url: HTTP $content->{error}{code} $content->{error}{message} (cachd)" + ); + } + return $promise->resolve( $content, \%param ); + } + + $self->{user_agent}->request_timeout(10)->get_p( $url => $self->{header} ) + ->then( + sub { + my ($tx) = @_; + + if ( my $err = $tx->error ) { + my $json = { + error => { + id => $err->{code}, + msg => $err->{message} + } + }; + $self->{log}->debug( + "wagonorder->get_p($url): HTTP $err->{code} $err->{message}" + ); + $self->{realtime_cache}->freeze( $url, $json ); + $promise->reject("GET $url: HTTP $err->{code} $err->{message}"); + return; + } + + $self->{log}->debug("wagonorder->get_p($url): OK"); + my $json = $tx->res->json; + $json->{ts} = DateTime->now( time_zone => 'Europe/Berlin' ) + ->strftime('%d.%m.%Y %H:%M'); + + $self->{main_cache}->freeze( $url, $json ); + $promise->resolve( $json, \%param ); + return; + } + )->catch( + sub { + my ($err) = @_; + $self->{log}->warn("wagonorder->get_p($url): $err"); + $promise->reject("GET $url: $err"); + return; + } + )->wait; + return $promise; +} + +sub get_stationinfo_p { + my ( $self, $eva ) = @_; - my $res = eval { $ua->head( $url => $self->{header} )->result }; + my $url = "https://lib.finalrewind.org/dbdb/s/${eva}.json"; - if ($@) { - $self->{log}->debug("check_wagonorder($url): $@"); - return; - } - if ( $res->is_error ) { - $cache->set( $url, 'n' ); - return; - } - else { - $cache->set( $url, 'y' ); - return 1; + my $cache = $self->{main_cache}; + my $promise = Mojo::Promise->new; + + if ( my $content = $cache->thaw($url) ) { + return $promise->resolve($content); } + + $self->{user_agent}->request_timeout(5)->get_p( $url => $self->{header} ) + ->then( + sub { + my ($tx) = @_; + + if ( my $err = $tx->error ) { + $cache->freeze( $url, {} ); + $promise->reject("HTTP $err->{code} $err->{message}"); + return; + } + + my $json = $tx->result->json; + $cache->freeze( $url, $json ); + $promise->resolve($json); + return; + } + )->catch( + sub { + my ($err) = @_; + $cache->freeze( $url, {} ); + $promise->reject($err); + return; + } + )->wait; + return $promise; } 1; |