eleksir/aleesa-telegram-bot
1
Fork 0
Code Activity

Try not to die if tg api call timeouts or api returns garbage

Browse Source
This commit is contained in:
eleksir
2021-03-30 20:04:21 +03:00
parent c6ce5b1421
commit b8fb89358e
1 changed files with 14 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
lib/Teapot/Bot/Brain.pm
View File

@@ -6,6 +6,7 @@ use Mojo::Base -base;
use strict; use strict;
use warnings; use warnings;
use English qw ( -no_match_vars );
use Mojo::IOLoop; use Mojo::IOLoop;
use Mojo::UserAgent; use Mojo::UserAgent;
@@ -76,7 +77,7 @@ sub think {
$self->init(); $self->init();
$self->_add_getUpdates_handler; $self->_add_getUpdates_handler;
Mojo::IOLoop->start until Mojo::IOLoop->is_running; do { Mojo::IOLoop->start } until Mojo::IOLoop->is_running;
return; return;
} }
@@ -402,11 +403,18 @@ sub _add_getUpdates_handler {
$self->ua->get($updateURL => sub { $self->ua->get($updateURL => sub {
my ($ua, $tx) = @_; my ($ua, $tx) = @_;
my $res = $tx->res->json; my $res = eval { $tx->res->json; };
my $items = $res->{result};
foreach my $item (@{$items}) { # it looks like we can catch an error here if timeout or something bad occurs,
$last_update_id = $item->{update_id}; # try not to die in this case or we risk to stuck with $http_active=1 forever
$self->_process_message($item); if ((defined $res) && $res ne '') {
my $items = $res->{result};
foreach my $item (@{$items}) {
$last_update_id = $item->{update_id};
$self->_process_message($item);
}
} else {
cluck "Something nasty happen while handling updates from $updateURL : $EVAL_ERROR";
} }
$http_active = 0; $http_active = 0;