From 1838027849e81b68c5c135803b413fff4c7b4cf2 Mon Sep 17 00:00:00 2001
From: franck cuny <franck@lumberjaph.net>
Date: Thu, 24 Jun 2010 11:22:44 +0200
Subject: small script to insert tweet from the stream api to presque

---
 eg/twitter.pl | 34 ++++++++++++++++++++++++++++++++++
 1 file changed, 34 insertions(+)
 create mode 100644 eg/twitter.pl

diff --git a/eg/twitter.pl b/eg/twitter.pl
new file mode 100644
index 0000000..b074641
--- /dev/null
+++ b/eg/twitter.pl
@@ -0,0 +1,34 @@
+#!/usr/bin/perl
+use strict;
+use Net::Presque;
+use AnyEvent::Twitter::Stream;
+
+my $done = AE::cv;
+
+my($user, $password, $method, %args) = @ARGV;
+
+my $presque = Net::Presque->new(api_base_url => 'http://localhost:5000');
+
+my $streamer = AnyEvent::Twitter::Stream->new(
+    username => $user,
+    password => $password,
+    method   => $method || "sample",
+    %args,
+    on_tweet => sub {
+        my $tweet = shift;
+        $presque->create_job(queue_name => 'twitter_stream', user => $tweet->{user}{screen_name}, text => $tweet->{text});
+    },
+    on_error => sub {
+        my $error = shift;
+        warn "ERROR: $error";
+        $done->send;
+    },
+    on_eof   => sub {
+        $done->send;
+    },
+);
+
+# uncomment to test undef $streamer
+# my $t = AE::timer 1, 0, sub { undef $streamer };
+
+$done->recv;
-- 
cgit 1.4.1