Changeset 8618438

Timestamp:

Nov 28, 2008, 12:29:38 PM (15 years ago)

Author:

Nelson Elhage <nelhage@mit.edu>

Branches:

master, release-1.10, release-1.7, release-1.8, release-1.9

Children:

affa874

Parents:

104f7d9

Message:

Implement receiving messages

Location:

lib/BarnOwl

Files:

• Message/Twitter.pm (added)
• Module/Twitter.pm (modified) (3 diffs)

lib/BarnOwl/Module/Twitter.pm

@@ -19 +19 @@
 use BarnOwl;
 use BarnOwl::Hooks;
+use BarnOwl::Message::Twitter;
+use HTML::Entities;
 
 my $twitter;
@@ -102 +104 @@
 }
 
+my $last_poll = 0;
+my $last_id   = undef;
+unless(defined($last_id)) {
+    $last_id = $twitter->friends_timeline({count => 1})->[0]{id};
+}
+
+sub poll_messages {
+    return unless ( time - $last_poll ) >= 45;
+    $last_poll = time;
+    my $timeline = $twitter->friends_timeline( { since_id => $last_id } );
+    unless(defined($timeline)) {
+        BarnOwl::error("Twitter returned error ... rate-limited?");
+        # Sleep for 15 minutes
+        $last_poll = time + 60*15;
+        return;
+    };
+    if ( scalar @$timeline ) {
+        for my $tweet ( reverse @$timeline ) {
+            if ( $tweet->{id} <= $last_id ) {
+                next;
+            }
+            my $msg = BarnOwl::Message->new(
+                type      => 'Twitter',
+                sender    => $tweet->{user}{screen_name},
+                recipient => $cfg->{user} || $user,
+                direction => 'in',
+                source    => decode_entities($tweet->{source}),
+                location  => decode_entities($tweet->{user}{location}),
+                body      => decode_entities($tweet->{text})
+               );
+            BarnOwl::queue_message($msg);
+        }
+        $last_id = $timeline->[0]{id};
+    } else {
+        # BarnOwl::message("No new tweets...");
+    }
+}
+
 sub twitter {
     my $msg = shift;
@@ -128 +168 @@
 eval {
     $BarnOwl::Hooks::receiveMessage->add("BarnOwl::Module::Twitter::handle_message");
+    $BarnOwl::Hooks::mainLoop->add("BarnOwl::Module::Twitter::poll_messages");
 };
 if($@) {
     $BarnOwl::Hooks::receiveMessage->add(\&handle_message);
+    $BarnOwl::Hooks::mainLoop->add(\&poll_messages);
 }
 
+BarnOwl::command(qw(filter twitter type ^twitter$));
+
 1;