summaryrefslogtreecommitdiff
path: root/lib/Travelynx/Helper/DBDB.pm
diff options
context:
space:
mode:
authorBirte Kristina Friesel <derf@finalrewind.org>2024-08-17 08:55:01 +0200
committerBirte Kristina Friesel <derf@finalrewind.org>2024-08-17 08:55:01 +0200
commitcbc1ac791c9e5829c1672088538fe5f5016fcce4 (patch)
tree3a0d9a478192b53cb2f77d128f515954717ea45e /lib/Travelynx/Helper/DBDB.pm
parent60a03632f734cae93e2b7e31eb371e9ebbfc21a1 (diff)
DBDB: put successful carriage formation requests into long-term cache2.8.25
Diffstat (limited to 'lib/Travelynx/Helper/DBDB.pm')
-rw-r--r--lib/Travelynx/Helper/DBDB.pm20
1 files changed, 10 insertions, 10 deletions
diff --git a/lib/Travelynx/Helper/DBDB.pm b/lib/Travelynx/Helper/DBDB.pm
index 20bcbca..79e9c0b 100644
--- a/lib/Travelynx/Helper/DBDB.pm
+++ b/lib/Travelynx/Helper/DBDB.pm
@@ -44,18 +44,19 @@ sub has_wagonorder_p {
'https://www.bahn.de/web/api/reisebegleitung/wagenreihung/vehicle-sequence',
join( '&', map { $_ . '=' . $param{$_} } sort keys %param ) );
- my $cache = $self->{realtime_cache};
my $promise = Mojo::Promise->new;
my $debug_prefix
= "has_wagonorder_p($opt{train_type} $opt{train_no} @ $opt{eva})";
- if ( my $content = $cache->get("HEAD $url") ) {
+ if ( my $content = $self->{main_cache}->get("HEAD $url")
+ // $self->{realtime_cache}->get("HEAD $url") )
+ {
if ( $content eq 'n' ) {
$self->{log}->debug("${debug_prefix}: n (cached)");
return $promise->reject;
}
else {
- $self->{log}->debug("${debug_prefix}: y (cached)");
+ $self->{log}->debug("${debug_prefix}: ${content} (cached)");
return $promise->resolve($content);
}
}
@@ -66,16 +67,16 @@ sub has_wagonorder_p {
my ($tx) = @_;
if ( $tx->result->is_success ) {
$self->{log}->debug("${debug_prefix}: a");
- $cache->set( "HEAD $url", 'a' );
+ $self->{main_cache}->set( "HEAD $url", 'a' );
my $body = decode( 'utf-8', $tx->res->body );
my $json = JSON->new->decode($body);
- $cache->freeze( $url, $json );
+ $self->{main_cache}->freeze( $url, $json );
$promise->resolve('a');
}
else {
my $code = $tx->res->code;
$self->{log}->debug("${debug_prefix}: n (HTTP $code)");
- $cache->set( "HEAD $url", 'n' );
+ $self->{realtime_cache}->set( "HEAD $url", 'n' );
$promise->reject;
}
return;
@@ -84,7 +85,7 @@ sub has_wagonorder_p {
sub {
my ($err) = @_;
$self->{log}->debug("${debug_prefix}: n ($err)");
- $cache->set( "HEAD $url", 'n' );
+ $self->{realtime_cache}->set( "HEAD $url", 'n' );
$promise->reject;
return;
}
@@ -111,10 +112,9 @@ sub get_wagonorder_p {
my $debug_prefix
= "get_wagonorder_p($opt{train_type} $opt{train_no} @ $opt{eva})";
- my $cache = $self->{realtime_cache};
my $promise = Mojo::Promise->new;
- if ( my $content = $cache->thaw($url) ) {
+ if ( my $content = $self->{main_cache}->thaw($url) ) {
$self->{log}->debug("${debug_prefix}: (cached)");
$promise->resolve($content);
return $promise;
@@ -129,7 +129,7 @@ sub get_wagonorder_p {
my $body = decode( 'utf-8', $tx->res->body );
my $json = JSON->new->decode($body);
$self->{log}->debug("${debug_prefix}: success");
- $cache->freeze( $url, $json );
+ $self->{main_cache}->freeze( $url, $json );
$promise->resolve($json);
}
else {