traewelling pull: skip API request for checked-in users
This commit is contained in:
parent
7587cf4277
commit
40ff05aefe
1 changed files with 14 additions and 1 deletions
|
@ -201,13 +201,26 @@ sub run {
|
||||||
my $request_count = 0;
|
my $request_count = 0;
|
||||||
for my $account_data ( $self->app->traewelling->get_pull_accounts ) {
|
for my $account_data ( $self->app->traewelling->get_pull_accounts ) {
|
||||||
|
|
||||||
|
my $in_transit = $self->app->in_transit->get(
|
||||||
|
uid => $account_data->{user_id},
|
||||||
|
);
|
||||||
|
if ($in_transit) {
|
||||||
|
$self->app->log->debug(
|
||||||
|
"Skipping Traewelling status pull for UID $account_data->{user_id}: already checked in"
|
||||||
|
);
|
||||||
|
next;
|
||||||
|
}
|
||||||
|
|
||||||
# $account_data->{user_id} is the travelynx uid
|
# $account_data->{user_id} is the travelynx uid
|
||||||
# $account_data->{user_name} is the Träwelling username
|
# $account_data->{user_name} is the Träwelling username
|
||||||
$request_count += 1;
|
$request_count += 1;
|
||||||
$self->app->log->debug(
|
$self->app->log->debug(
|
||||||
"Scheduling Traewelling status pull for UID $account_data->{user_id}"
|
"Scheduling Traewelling status pull for UID $account_data->{user_id}"
|
||||||
);
|
);
|
||||||
Mojo::Promise->timer( $request_count * 0.2 )->then(
|
|
||||||
|
# In 'work', the event loop is not running,
|
||||||
|
# so there's no need to multiply by $request_count at the moment
|
||||||
|
Mojo::Promise->timer(0.5)->then(
|
||||||
sub {
|
sub {
|
||||||
return $self->app->traewelling_api->get_status_p(
|
return $self->app->traewelling_api->get_status_p(
|
||||||
username => $account_data->{data}{user_name},
|
username => $account_data->{data}{user_name},
|
||||||
|
|
Loading…
Reference in a new issue