X-Git-Url: https://git.sommitrealweird.co.uk/twirssi-net-twitter-lite.git/blobdiff_plain/3e6f337d99e700b8f691805d7f0dc4b4c76881d0..d2f53eac09735b075b640217f197c2423955e749:/twirssi.pl?ds=inline diff --git a/twirssi.pl b/twirssi.pl index 0805eab..4a6b5dd 100644 --- a/twirssi.pl +++ b/twirssi.pl @@ -11,8 +11,8 @@ $Data::Dumper::Indent = 1; use vars qw($VERSION %IRSSI); -$VERSION = "1.6"; -my ($REV) = '$Rev: 334 $' =~ /(\d+)/; +$VERSION = "1.6.1"; +my ($REV) = '$Rev: 337 $' =~ /(\d+)/; %IRSSI = ( authors => 'Dan Boger', contact => 'zigdon@gmail.com', @@ -71,10 +71,17 @@ sub cmd_direct_as { return; } - unless ( $twits{$username} - ->new_direct_message( { user => $target, text => $text } ) ) - { - ¬ice("DM to $target failed"); + eval { + unless ( $twits{$username} + ->new_direct_message( { user => $target, text => $text } ) ) + { + ¬ice("DM to $target failed"); + return; + } + }; + + if ($@) { + ¬ice("DM caused an error. Aborted"); return; } @@ -135,8 +142,16 @@ sub cmd_tweet_as { return; } - unless ( $twits{$username}->update($data) ) { - ¬ice("Update failed"); + eval { + unless ( $twits{$username}->update($data) ) + { + ¬ice("Update failed"); + return; + } + }; + + if ($@) { + ¬ice("Update caused an error. Aborted."); return; } @@ -216,6 +231,7 @@ sub cmd_reply_as { } my $nick; + $id =~ s/[^\w\d\-:]+//g; ( $nick, $id ) = split /:/, $id; unless ( exists $id_map{$nick} ) { ¬ice("Can't find a tweet from $nick to reply to!"); @@ -223,7 +239,7 @@ sub cmd_reply_as { } $id = $id_map{__indexes}{$nick} unless $id; - unless ( $id_map{$nick}[$id] ) { + unless ( $id_map{ lc $nick }[$id] ) { ¬ice("Can't find a tweet numbered $id from $nick to reply to!"); return; } @@ -247,13 +263,23 @@ sub cmd_reply_as { return; } - unless ( - $twits{$username}->update( - { status => $data, in_reply_to_status_id => $id_map{$nick}[$id] } - ) - ) - { - ¬ice("Update failed"); + eval { + unless ( + $twits{$username}->update( + { + status => $data, + in_reply_to_status_id => $id_map{ lc $nick }[$id] + } + ) + ) + { + ¬ice("Update failed"); + return; + } + }; + + if ($@) { + ¬ice("Update caused an error. Aborted"); return; } @@ -297,8 +323,16 @@ sub gen_cmd { return; } - unless ( $twit->$api_name($data) ) { - ¬ice("$api_name failed"); + eval { + unless ( $twit->$api_name($data) ) + { + ¬ice("$api_name failed"); + return; + } + }; + + if ($@) { + ¬ice("$api_name caused an error. Aborted."); return; } @@ -516,13 +550,21 @@ sub load_friends { my $fh = shift; my $page = 1; my %new_friends; - while (1) { - print $fh "Loading friends page $page...\n" if ( $fh and &debug ); - my $friends = $twit->friends( { page => $page } ); - last unless $friends; - $new_friends{ $_->{screen_name} } = time foreach @$friends; - $page++; - last if @$friends == 0 or $page == 10; + eval { + while (1) + { + print $fh "Loading friends page $page...\n" if ( $fh and &debug ); + my $friends = $twit->friends( { page => $page } ); + last unless $friends; + $new_friends{ $_->{screen_name} } = time foreach @$friends; + $page++; + last if @$friends == 0 or $page == 10; + } + }; + + if ($@) { + ¬ice("Error during friends list update. Aborted."); + return; } my ( $added, $removed ) = ( 0, 0 ); @@ -601,9 +643,18 @@ sub do_updates { my ( $fh, $username, $obj ) = @_; print scalar localtime, " - Polling for updates for $username" if &debug; - my $tweets = - $obj->friends_timeline( { since => HTTP::Date::time2str($last_poll) } ) - || []; + my $tweets; + eval { + $tweets = $obj->friends_timeline( + { since => HTTP::Date::time2str($last_poll) } ) + || []; + }; + + if ($@) { + print $fh "type:error Error during friends_timeline call. Aborted.\n"; + return; + } + foreach my $t ( reverse @$tweets ) { my $text = decode_entities( $t->{text} ); $text =~ s/%/%%/g; @@ -637,8 +688,16 @@ sub do_updates { } print scalar localtime, " - Polling for replies" if &debug; - $tweets = $obj->replies( { since => HTTP::Date::time2str($last_poll) } ) - || []; + eval { + $tweets = $obj->replies( { since => HTTP::Date::time2str($last_poll) } ) + || []; + }; + + if ($@) { + print $fh "type:error Error during replies call. Aborted.\n"; + return; + } + foreach my $t ( reverse @$tweets ) { next if exists $friends{ $t->{user}{screen_name} }; @@ -695,9 +754,9 @@ sub monitor_child { and $meta{id} ) { $marker = ( $id_map{__indexes}{ $meta{nick} } + 1 ) % 100; - $id_map{ $meta{nick} }[$marker] = $meta{id}; - $id_map{__indexes}{ $meta{nick} } = $marker; - $marker = ":$marker"; + $id_map{ lc $meta{nick} }[$marker] = $meta{id}; + $id_map{__indexes}{ $meta{nick} } = $marker; + $marker = ":$marker"; } if ( $meta{type} eq 'tweet' ) { @@ -706,6 +765,8 @@ sub monitor_child { push @lines, "[$account\\--> %B\@$meta{nick}%n$marker] $_\n",; } elsif ( $meta{type} eq 'dm' ) { push @lines, "[$account%B\@$meta{nick}%n (%%WDM%%n)] $_\n",; + } elsif ( $meta{type} eq 'error' ) { + push @lines, "debug: $_\n" if &debug,; } elsif ( $meta{type} eq 'debug' ) { push @lines, "debug: $_\n" if &debug,; } @@ -766,8 +827,7 @@ sub sig_complete { and $linestart =~ /^\/reply(?:_as)?\s*$/ ) ) { # /twitter_reply gets a nick:num - @$complist = grep { $_ ne "__indexes" } grep /^\Q$word/i, - sort keys %id_map; + @$complist = grep /^\Q$word/i, sort keys %{ $id_map{__indexes} }; } # /tweet, /tweet_as, /dm, /dm_as - complete @nicks (and nicks as the first