X-Git-Url: https://git.sommitrealweird.co.uk//gitweb/?p=twirssi-net-twitter-lite.git;a=blobdiff_plain;f=twirssi.pl;h=e6142cd359218d4f00e5b5bfab2ec721d68f926c;hp=ced5f956938c6afc737599577e1e00d559c11412;hb=2492f53ab359ac856c8df4ff64305c4214cde461;hpb=2c4bb6a4f3a97c91dd7e2e595024358bc496f7a5 diff --git a/twirssi.pl b/twirssi.pl index ced5f95..e6142cd 100644 --- a/twirssi.pl +++ b/twirssi.pl @@ -6,13 +6,12 @@ use HTML::Entities; use File::Temp; use LWP::Simple; use Data::Dumper; -use Net::Twitter; $Data::Dumper::Indent = 1; use vars qw($VERSION %IRSSI); -$VERSION = "2.1.3beta"; -my ($REV) = '$Rev: 548 $' =~ /(\d+)/; +$VERSION = "2.2.1beta"; +my ($REV) = '$Rev: 599 $' =~ /(\d+)/; %IRSSI = ( authors => 'Dan Boger', contact => 'zigdon@gmail.com', @@ -21,13 +20,14 @@ my ($REV) = '$Rev: 548 $' =~ /(\d+)/; . 'Can optionally set your bitlbee /away message to same', license => 'GNU GPL v2', url => 'http://twirssi.com', - changed => '$Date: 2009-03-13 10:45:47 -0700 (Fri, 13 Mar 2009) $', + changed => '$Date: 2009-04-07 07:49:19 -0700 (Tue, 07 Apr 2009) $', ); my $window; my $twit; my %twits; my $user; +my $defservice; my $poll; my $last_poll; my %nicks; @@ -79,7 +79,7 @@ sub cmd_direct_as { return; } - return unless &valid_username($username); + return unless $username = &valid_username($username); eval { if ( $twits{$username} @@ -104,6 +104,105 @@ sub cmd_direct_as { } } +sub cmd_retweet { + my ( $data, $server, $win ) = @_; + + return unless &logged_in($twit); + + $data =~ s/^\s+|\s+$//; + unless ($data) { + ¬ice("Usage: /retweet [comment]"); + return; + } + + my ( $id, $data ) = split ' ', $data, 2; + + &cmd_retweet_as( "$user $id $data", $server, $win ); +} + +sub cmd_retweet_as { + my ( $data, $server, $win ) = @_; + + unless ( Irssi::settings_get_bool("twirssi_track_replies") ) { + ¬ice("twirssi_track_replies is required in order to reteet."); + return; + } + + return unless &logged_in($twit); + + $data =~ s/^\s+|\s+$//; + my ( $username, $id, $data ) = split ' ', $data, 3; + + unless ( $username ) { + ¬ice("Usage: /retweet_as [comment]"); + return; + } + + return unless $username = &valid_username($username); + + my $nick; + $id =~ s/[^\w\d\-:]+//g; + ( $nick, $id ) = split /:/, $id; + unless ( exists $id_map{ lc $nick } ) { + ¬ice("Can't find a tweet from $nick to retweet!"); + return; + } + + $id = $id_map{__indexes}{$nick} unless $id; + unless ( $id_map{ lc $nick }[$id] ) { + ¬ice("Can't find a tweet numbered $id from $nick to retweet!"); + return; + } + + unless ( $id_map{__tweets}{ lc $nick }[$id] ) { + ¬ice("The text of this tweet isn't saved, sorry!"); + return; + } + +# Irssi::settings_add_str( "twirssi", "twirssi_retweet_format", 'RT $n: $t ${-- $c$}' ); + my $text = Irssi::settings_get_str("twirssi_retweet_format"); + $text =~ s/\$n/\@$nick/g; + if ($data) { + $text =~ s/\${|\$}//g; + $text =~ s/\$c/$data/; + } else { + $text =~ s/\${.*?\$}//; + } + $text =~ s/\$t/$id_map{__tweets}{ lc $nick }[$id]/; + + $data = &shorten($text); + + return if &too_long($data); + + my $success = 1; + eval { + unless ( + $twits{$username}->update( + { + status => $data, + in_reply_to_status_id => $id_map{ lc $nick }[$id] + } + ) + ) + { + ¬ice("Update failed"); + $success = 0; + } + }; + return unless $success; + + if ($@) { + ¬ice("Update caused an error: $@. Aborted"); + return; + } + + foreach ( $data =~ /@([-\w]+)/ ) { + $nicks{$1} = time; + } + + ¬ice("Retweet sent"); +} + sub cmd_tweet { my ( $data, $server, $win ) = @_; @@ -115,7 +214,7 @@ sub cmd_tweet { return; } - &cmd_tweet_as( "$user $data", $server, $win ); + &cmd_tweet_as( "$user\@$defservice $data", $server, $win ); } sub cmd_tweet_as { @@ -132,7 +231,7 @@ sub cmd_tweet_as { return; } - return unless &valid_username($username); + return unless $username = &valid_username($username); $data = &shorten($data); @@ -173,10 +272,9 @@ sub cmd_reply { return; } - $data =~ s/^\s+|\s+$//; my ( $id, $data ) = split ' ', $data, 2; unless ( $id and $data ) { - ¬ice("Usage: /reply_as "); + ¬ice("Usage: /reply "); return; } @@ -203,7 +301,7 @@ sub cmd_reply_as { return; } - return unless &valid_username($username); + return unless $username = &valid_username($username); my $nick; $id =~ s/[^\w\d\-:]+//g; @@ -298,10 +396,16 @@ sub cmd_switch { my ( $data, $server, $win ) = @_; $data =~ s/^\s+|\s+$//g; + $data = &normalize_username($data); if ( exists $twits{$data} ) { ¬ice("Switching to $data"); $twit = $twits{$data}; - $user = $data; + if ( $data =~ /(.*)\@(.*)/ ) { + $user = $1; + $defservice = $2; + } else { + ¬ice("Couldn't figure out what service '$data' is on"); + } } else { ¬ice("Unknown user $data"); } @@ -312,7 +416,7 @@ sub cmd_logout { $data =~ s/^\s+|\s+$//g; $data = $user unless $data; - return unless &valid_username($data); + return unless $data = &valid_username($data); ¬ice("Logging out $data..."); $twits{$data}->end_session(); @@ -368,14 +472,29 @@ sub cmd_login { %friends = %nicks = (); - $twit = Net::Twitter->new( + my $service; + if ( $user =~ /^(.*)@(twitter|identica)$/ ) { + ( $user, $service ) = ( $1, $2 ); + } else { + $service = Irssi::settings_get_str("twirssi_default_service"); + } + $defservice = $service = ucfirst lc $service; + + eval "use Net::$service"; + if ($@) { + ¬ice( + "Failed to load Net::$service when trying to log in as $user: $@"); + return; + } + + $twit = "Net::$service"->new( username => $user, password => $pass, source => "twirssi" ); unless ( $twit->verify_credentials() ) { - ¬ice("Login as $user failed"); + ¬ice("Login as $user\@$service failed"); $twit = undef; if ( keys %twits ) { &cmd_switch( ( keys %twits )[0], $server, $win ); @@ -393,10 +512,10 @@ sub cmd_login { return; } - $twits{$user} = $twit; + $twits{"$user\@$service"} = $twit; Irssi::timeout_remove($poll) if $poll; $poll = Irssi::timeout_add( &get_poll_time * 1000, \&get_updates, "" ); - ¬ice("Logged in as $user, loading friends list..."); + ¬ice("Logged in as $user\@$service, loading friends list..."); &load_friends(); ¬ice( "loaded friends: ", scalar keys %friends ); if ( Irssi::settings_get_bool("twirssi_first_run") ) { @@ -646,9 +765,7 @@ sub get_updates { my $new_poll = time; my $error = 0; - $error += &do_updates( $fh, $user, $twit ); foreach ( keys %twits ) { - next if $_ eq $user; $error += &do_updates( $fh, $_, $twits{$_} ); } @@ -728,15 +845,14 @@ sub do_updates { if ($context) { my $ctext = decode_entities( $context->{text} ); $ctext = &hilight($ctext); + if ( $context->{truncated} and ref($obj) ne 'Net::Identica' ) { + $ctext .= + " -- http://twitter.com/$context->{user}{screen_name}" + . "/status/$context->{id}"; + } printf $fh "id:%d account:%s nick:%s type:tweet %s\n", $context->{id}, $username, $context->{user}{screen_name}, $ctext; - if ( $context->{truncated} ) { - printf $fh "id:%s account:%s nick:%s type:ellispis %s\n", - $context->{id} . "-url", $username, - $context->{user}{screen_name}, -"http://twitter.com/$context->{user}{screen_name}/status/$context->{id}"; - } $reply = "reply"; } elsif ($@) { print $fh "type:debug request to get context failed: $@"; @@ -749,14 +865,12 @@ sub do_updates { next if $t->{user}{screen_name} eq $username and not Irssi::settings_get_bool("show_own_tweets"); + if ( $t->{truncated} and ref($obj) ne 'Net::Identica' ) { + $text .= " -- http://twitter.com/$t->{user}{screen_name}" + . "/status/$t->{id}"; + } printf $fh "id:%d account:%s nick:%s type:%s %s\n", $t->{id}, $username, $t->{user}{screen_name}, $reply, $text; - if ( $t->{truncated} ) { - printf $fh "id:%s account:%s nick:%s type:ellispis %s\n", - $t->{id} . "-url", $username, - $t->{user}{screen_name}, - "http://twitter.com/$t->{user}{screen_name}/status/$t->{id}"; - } } print scalar localtime, " - Polling for replies" if &debug; @@ -776,14 +890,12 @@ sub do_updates { my $text = decode_entities( $t->{text} ); $text = &hilight($text); - printf $fh "id:%d account:%s nick:%s type:tweet %s\n", - $t->{id}, $username, $t->{user}{screen_name}, $text; if ( $t->{truncated} ) { - printf $fh "id:%s account:%s nick:%s type:ellispis %s\n", - $t->{id} . "-url", $username, - $t->{user}{screen_name}, - "http://twitter.com/$t->{user}{screen_name}/status/$t->{id}"; + $text .= " -- http://twitter.com/$t->{user}{screen_name}" + . "/status/$t->{id}"; } + printf $fh "id:%d account:%s nick:%s type:tweet %s\n", + $t->{id}, $username, $t->{user}{screen_name}, $text; } print scalar localtime, " - Polling for DMs" if &debug; @@ -892,8 +1004,17 @@ sub monitor_child { } my $account = ""; - if ( $meta{account} ne $user ) { - $account = "$meta{account}: "; + if ( lc $meta{account} ne lc "$user\@$defservice" ) { + $meta{account} =~ s/\@(\w+)$//; + my $service = $1; + if ( + lc $service eq + lc Irssi::settings_get_str("twirssi_default_service") ) + { + $account = "$meta{account}: "; + } else { + $account = "$meta{account}\@$service: "; + } } my $marker = ""; @@ -903,15 +1024,18 @@ sub monitor_child { and $meta{id} ) { $marker = ( $id_map{__indexes}{ $meta{nick} } + 1 ) % 100; - $id_map{ lc $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; + $id_map{__tweets}{ lc $meta{nick} }[$marker] = $_; + $marker = ":$marker"; } my $hilight_color = $irssi_to_mirc_colors{ Irssi::settings_get_str("hilight_color") }; - if ( ( $_ =~ /\@$meta{account}\W/i ) - && Irssi::settings_get_bool("twirssi_hilights") ) + my $nick = + '@' . substr( $meta{account}, 0, index( $meta{account}, "@" ) ); + if ( $_ =~ /\Q$nick\E(?:\W|$)/i + and Irssi::settings_get_bool("twirssi_hilights") ) { $meta{nick} = "\cC$hilight_color$meta{nick}\cO"; $hilight = MSGLEVEL_HILIGHT; @@ -923,9 +1047,6 @@ sub monitor_child { ( MSGLEVEL_PUBLIC | $hilight ), $meta{type}, $account, $meta{nick}, $marker, $_ ]; - } elsif ( $meta{type} eq 'ellispis' ) { - push @lines, - [ MSGLEVEL_PUBLIC, "tweet", $account, $meta{nick}, "", $_ ]; } elsif ( $meta{type} eq 'search' ) { push @lines, [ @@ -1114,12 +1235,14 @@ sub too_long { sub valid_username { my $username = shift; + $username = &normalize_username($username); + unless ( exists $twits{$username} ) { ¬ice("Unknown username $username"); - return 0; + return undef; } - return 1; + return $username; } sub logged_in { @@ -1136,7 +1259,7 @@ sub sig_complete { my ( $complist, $window, $word, $linestart, $want_space ) = @_; if ( - $linestart =~ /^\/twitter_reply(?:_as)?\s*$/ + $linestart =~ /^\/(?:retweet|twitter_reply)(?:_as)?\s*$/ or ( Irssi::settings_get_bool("twirssi_use_reply_aliases") and $linestart =~ /^\/reply(?:_as)?\s*$/ ) ) @@ -1238,6 +1361,32 @@ sub shorten { return $data; } +sub normalize_username { + my $user = shift; + + my ( $username, $service ) = split /\@/, $user, 2; + if ($service) { + $service = ucfirst lc $service; + } else { + $service = + ucfirst lc Irssi::settings_get_str("twirssi_default_service"); + unless ( exists $twits{"$username\@$service"} ) { + $service = undef; + foreach my $t ( sort keys %twits ) { + next unless $t =~ /^\Q$username\E\@(Twitter|Identica)/; + $service = $1; + last; + } + + unless ($service) { + ¬ice("Can't find a logged in user '$user'"); + } + } + } + + return "$username\@$service"; +} + Irssi::signal_add( "send text", "event_send_text" ); Irssi::theme_register( @@ -1251,14 +1400,17 @@ Irssi::theme_register( ); Irssi::settings_add_int( "twirssi", "twitter_poll_interval", 300 ); -Irssi::settings_add_str( "twirssi", "twitter_window", "twitter" ); -Irssi::settings_add_str( "twirssi", "bitlbee_server", "bitlbee" ); -Irssi::settings_add_str( "twirssi", "short_url_provider", "TinyURL" ); -Irssi::settings_add_str( "twirssi", "short_url_args", undef ); -Irssi::settings_add_str( "twirssi", "twitter_usernames", undef ); -Irssi::settings_add_str( "twirssi", "twitter_passwords", undef ); -Irssi::settings_add_str( "twirssi", "twirssi_nick_color", "%B" ); -Irssi::settings_add_str( "twirssi", "twirssi_topic_color", "%r" ); +Irssi::settings_add_str( "twirssi", "twitter_window", "twitter" ); +Irssi::settings_add_str( "twirssi", "bitlbee_server", "bitlbee" ); +Irssi::settings_add_str( "twirssi", "short_url_provider", "TinyURL" ); +Irssi::settings_add_str( "twirssi", "short_url_args", undef ); +Irssi::settings_add_str( "twirssi", "twitter_usernames", undef ); +Irssi::settings_add_str( "twirssi", "twitter_passwords", undef ); +Irssi::settings_add_str( "twirssi", "twirssi_default_service", "Twitter" ); +Irssi::settings_add_str( "twirssi", "twirssi_nick_color", "%B" ); +Irssi::settings_add_str( "twirssi", "twirssi_topic_color", "%r" ); +Irssi::settings_add_str( "twirssi", "twirssi_retweet_format", + 'RT $n: "$t" ${-- $c$}' ); Irssi::settings_add_str( "twirssi", "twirssi_location", ".irssi/scripts/twirssi.pl" ); Irssi::settings_add_str( "twirssi", "twirssi_replies_store", @@ -1295,6 +1447,8 @@ if ($window) { Irssi::command_bind( "dm_as", "cmd_direct_as" ); Irssi::command_bind( "tweet", "cmd_tweet" ); Irssi::command_bind( "tweet_as", "cmd_tweet_as" ); + Irssi::command_bind( "retweet", "cmd_retweet" ); + Irssi::command_bind( "retweet_as", "cmd_retweet_as" ); Irssi::command_bind( "twitter_reply", "cmd_reply" ); Irssi::command_bind( "twitter_reply_as", "cmd_reply_as" ); Irssi::command_bind( "twitter_login", "cmd_login" ); @@ -1304,6 +1458,7 @@ if ($window) { Irssi::command_bind( "twitter_unsubscribe", "cmd_del_search" ); Irssi::command_bind( "twitter_list_subscriptions", "cmd_list_search" ); Irssi::command_bind( "twirssi_upgrade", "cmd_upgrade" ); + Irssi::command_bind( "twitter_updates", "get_updates" ); if ( Irssi::settings_get_bool("twirssi_use_reply_aliases") ) { Irssi::command_bind( "reply", "cmd_reply" ); Irssi::command_bind( "reply_as", "cmd_reply_as" ); @@ -1312,7 +1467,8 @@ if ($window) { "twirssi_dump", sub { print "twits: ", join ", ", - map { "u: $_->{username}" } values %twits; + map { "u: $_->{username}\@" . ref($_) } values %twits; + print "selected: $user\@$defservice"; print "friends: ", join ", ", sort keys %friends; print "nicks: ", join ", ", sort keys %nicks; print "searches: ", Dumper \%{ $id_map{__searches} }; @@ -1350,7 +1506,14 @@ if ($window) { sub { ¬ice("Stopped following $_[0]"); delete $nicks{ $_[0] }; } ) ); - Irssi::command_bind( "twitter_updates", "get_updates" ); + Irssi::command_bind( + "twitter_device_updates", + &gen_cmd( + "/twitter_device_updates none|im|sms", + "update_delivery_device", + sub { ¬ice("Device updated to $_[0]"); } + ) + ); Irssi::signal_add_last( 'complete word' => \&sig_complete ); ¬ice(" %Y<%C(%B^%C)%N TWIRSSI v%R$VERSION%N (r$REV)");