155 lines
3 KiB
Perl
155 lines
3 KiB
Perl
package Travelynx::Helper::DBDB;
|
|
|
|
# Copyright (C) 2020 Daniel Friesel
|
|
#
|
|
# SPDX-License-Identifier: AGPL-3.0-or-later
|
|
|
|
use strict;
|
|
use warnings;
|
|
use 5.020;
|
|
|
|
use Encode qw(decode);
|
|
use Mojo::Promise;
|
|
use JSON;
|
|
|
|
sub new {
|
|
my ( $class, %opt ) = @_;
|
|
|
|
my $version = $opt{version};
|
|
|
|
$opt{header}
|
|
= { 'User-Agent' =>
|
|
"travelynx/${version} on $opt{root_url} +https://finalrewind.org/projects/travelynx"
|
|
};
|
|
|
|
return bless( \%opt, $class );
|
|
|
|
}
|
|
|
|
sub has_wagonorder_p {
|
|
my ( $self, $ts, $train_no ) = @_;
|
|
my $api_ts = $ts->strftime('%Y%m%d%H%M');
|
|
my $url
|
|
= "https://www.apps-bahn.de/wr/wagenreihung/1.0/${train_no}/${api_ts}";
|
|
my $cache = $self->{cache};
|
|
my $promise = Mojo::Promise->new;
|
|
|
|
if ( my $content = $cache->get("HEAD $url") ) {
|
|
if ( $content eq 'n' ) {
|
|
return $promise->reject;
|
|
}
|
|
else {
|
|
return $promise->resolve($content);
|
|
}
|
|
}
|
|
|
|
$self->{user_agent}->request_timeout(5)->head_p( $url => $self->{header} )
|
|
->then(
|
|
sub {
|
|
my ($tx) = @_;
|
|
if ( $tx->result->is_success ) {
|
|
$cache->set( "HEAD $url", 'a' );
|
|
$promise->resolve('a');
|
|
}
|
|
else {
|
|
$cache->set( "HEAD $url", 'n' );
|
|
$promise->reject;
|
|
}
|
|
return;
|
|
}
|
|
)->catch(
|
|
sub {
|
|
$cache->set( "HEAD $url", 'n' );
|
|
$promise->reject;
|
|
return;
|
|
}
|
|
)->wait;
|
|
return $promise;
|
|
}
|
|
|
|
sub get_wagonorder_p {
|
|
my ( $self, $api, $ts, $train_no ) = @_;
|
|
my $api_ts = $ts->strftime('%Y%m%d%H%M');
|
|
my $url
|
|
= "https://ist-wr.noncd.db.de/wagenreihung/1.0/${train_no}/${api_ts}";
|
|
|
|
if ( $api !~ m{i} and $api =~ m{a} ) {
|
|
$url
|
|
= "https://www.apps-bahn.de/wr/wagenreihung/1.0/${train_no}/${api_ts}";
|
|
}
|
|
|
|
my $cache = $self->{cache};
|
|
my $promise = Mojo::Promise->new;
|
|
|
|
if ( my $content = $cache->thaw($url) ) {
|
|
$promise->resolve($content);
|
|
return $promise;
|
|
}
|
|
|
|
$self->{user_agent}->request_timeout(5)->get_p( $url => $self->{header} )
|
|
->then(
|
|
sub {
|
|
my ($tx) = @_;
|
|
|
|
if ( $tx->result->is_success ) {
|
|
my $body = decode( 'utf-8', $tx->res->body );
|
|
my $json = JSON->new->decode($body);
|
|
$cache->freeze( $url, $json );
|
|
$promise->resolve($json);
|
|
}
|
|
else {
|
|
my $code = $tx->code;
|
|
$promise->reject("HTTP ${code}");
|
|
}
|
|
return;
|
|
}
|
|
)->catch(
|
|
sub {
|
|
my ($err) = @_;
|
|
$promise->reject($err);
|
|
return;
|
|
}
|
|
)->wait;
|
|
return $promise;
|
|
}
|
|
|
|
sub get_stationinfo_p {
|
|
my ( $self, $eva ) = @_;
|
|
|
|
my $url = "https://lib.finalrewind.org/dbdb/s/${eva}.json";
|
|
|
|
my $cache = $self->{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;
|