Mirrors/travelynx
2
0
Fork 0
mirror of https://github.com/derf/travelynx synced 2024-12-02 17:29:11 +00:00
Code Issues Projects Releases Packages Wiki Activity

fix caching fuckup introduced in 2e5a1b0a79

Browse source
This commit is contained in:
Daniel Friesel 2021-12-12 17:24:24 +01:00
parent 7bb1f4fea0
commit 879b3b3815
1 changed files with 14 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

22
lib/Travelynx/Helper/DBDB.pm
View file

@ -34,7 +34,7 @@ sub has_wagonorder_p {
my $cache = $self->{cache};
my $promise = Mojo::Promise->new;
if ( my $content = $cache->get($url) ) {
if ( my $content = $cache->get("HEAD $url") ) {
if ( $content eq 'n' ) {
return $promise->reject;
}
@ -48,18 +48,18 @@ sub has_wagonorder_p {
sub {
my ($tx) = @_;
if ( $tx->result->is_success ) {
$cache->set( $url, 'a' );
$cache->set( "HEAD $url", 'a' );
$promise->resolve('a');
}
else {
$cache->set( $url, 'n' );
$cache->set( "HEAD $url", 'n' );
$promise->reject;
}
return;
}
)->catch(
sub {
$cache->set( $url, 'n' );
$cache->set( "HEAD $url", 'n' );
$promise->reject;
return;
}
@ -90,11 +90,17 @@ sub get_wagonorder_p {
->then(
sub {
my ($tx) = @_;
my $body = decode( 'utf-8', $tx->res->body );
my $json = JSON->new->decode($body);
$cache->freeze( $url, $json );
$promise->resolve($json);
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(