mirror of
https://github.com/derf/travelynx
synced 2024-12-13 06:22:33 +00:00
show wagon order for regional trains too, if available
This commit is contained in:
parent
875dd4e0b5
commit
e6160d75de
1 changed files with 38 additions and 2 deletions
|
@ -1812,6 +1812,37 @@ sub startup {
|
||||||
}
|
}
|
||||||
);
|
);
|
||||||
|
|
||||||
|
$self->helper(
|
||||||
|
'has_wagonorder_p' => sub {
|
||||||
|
my ( $self, $ts, $train_no ) = @_;
|
||||||
|
my $api_ts = $ts->strftime('%Y%m%d%H%M');
|
||||||
|
my $url
|
||||||
|
= "https://lib.finalrewind.org/dbdb/has_wagonorder/${train_no}/${api_ts}";
|
||||||
|
my $cache = $self->app->cache_iris_main;
|
||||||
|
my $promise = Mojo::Promise->new;
|
||||||
|
|
||||||
|
if ( my $content = $cache->get($url) ) {
|
||||||
|
if ( $content eq 'n' ) {
|
||||||
|
$promise->reject;
|
||||||
|
return $promise;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
$self->ua->request_timeout(5)->head_p($url)->then(
|
||||||
|
sub {
|
||||||
|
$cache->set( $url, 'y' );
|
||||||
|
$promise->resolve;
|
||||||
|
}
|
||||||
|
)->catch(
|
||||||
|
sub {
|
||||||
|
$cache->set( $url, 'n' );
|
||||||
|
$promise->reject;
|
||||||
|
}
|
||||||
|
)->wait;
|
||||||
|
return $promise;
|
||||||
|
}
|
||||||
|
);
|
||||||
|
|
||||||
$self->helper(
|
$self->helper(
|
||||||
'get_wagonorder_p' => sub {
|
'get_wagonorder_p' => sub {
|
||||||
my ( $self, $ts, $train_no ) = @_;
|
my ( $self, $ts, $train_no ) = @_;
|
||||||
|
@ -2104,9 +2135,14 @@ sub startup {
|
||||||
}
|
}
|
||||||
)->wait;
|
)->wait;
|
||||||
|
|
||||||
if ( $train->type =~ m{[EI]C} and $train->sched_departure ) {
|
if ( $train->sched_departure ) {
|
||||||
$self->get_wagonorder_p( $train->sched_departure,
|
$self->has_wagonorder_p( $train->sched_departure,
|
||||||
$train->train_no )->then(
|
$train->train_no )->then(
|
||||||
|
sub {
|
||||||
|
return $self->get_wagonorder_p( $train->sched_departure,
|
||||||
|
$train->train_no );
|
||||||
|
}
|
||||||
|
)->then(
|
||||||
sub {
|
sub {
|
||||||
my ($wagonorder) = @_;
|
my ($wagonorder) = @_;
|
||||||
|
|
||||||
|
|
Loading…
Reference in a new issue