1 | var sys = require('sys'),
|
2 | twitter = require('twitter');
|
3 |
|
4 | var count = 0,
|
5 | lastc = 0;
|
6 |
|
7 | function tweet(data) {
|
8 | count++;
|
9 | if ( typeof data === 'string' )
|
10 | sys.puts(data);
|
11 | else if ( data.text && data.user && data.user.screen_name )
|
12 | sys.puts('"' + data.text + '" -- ' + data.user.screen_name);
|
13 | else if ( data.message )
|
14 | sys.puts('ERROR: ' + sys.inspect(data));
|
15 | else
|
16 | sys.puts(sys.inspect(data));
|
17 | }
|
18 |
|
19 | function memrep() {
|
20 | var rep = process.memoryUsage();
|
21 | rep.tweets = count - lastc;
|
22 | lastc = count;
|
23 | console.log(JSON.stringify(rep));
|
24 |
|
25 | setTimeout(memrep, 60000);
|
26 | }
|
27 |
|
28 | var twit = new twitter({
|
29 | consumer_key: 'STATE YOUR NAME',
|
30 | consumer_secret: 'STATE YOUR NAME',
|
31 | access_token_key: 'STATE YOUR NAME',
|
32 | access_token_secret: 'STATE YOUR NAME'
|
33 | })
|
34 | .stream('statuses/sample', function(stream) {
|
35 | stream.on('data', tweet);
|
36 |
|
37 | setTimeout(memrep, 15000);
|
38 | })
|