1

var http = require('http');

     2

var EventEmitter = require('events').EventEmitter;

     3

     4

function loadTwitterListPage(owner, slug, cursor, users, callback) {

     5

    // Rate limited to 150 / hour, beware!

     6

   var request = http.get({host: 'api.twitter.com', path:'/1/lists/members.json?slug=' + slug + '&owner_screen_name=' + owner + '&skip_status=1&cursor=' + cursor}, function (response) {

     7

       response.setEncoding('utf8');

     8

       var twitterDataJSON = "", twitterData;

     9

       response.on('data', function (chunk) {

    10

	   twitterDataJSON = twitterDataJSON + chunk;

    11

       });

    12

       response.on('end', function () {

    13

	   console.log(response.statusCode + JSON.stringify(response.headers));

    14

	   twitterData = JSON.parse(twitterDataJSON);

    15

	   users = users.concat(twitterData.users);

    16

	   if (twitterData.next_cursor) {

    17

	       loadTwitterListPage(owner, slug, twitterData.next_cursor, users, callback);

    18

	   } else {

    19

	       callback(users);

    20

	   }

    21

       });

    22

   });

    23

}

    24

    25

exports.listTwitterIds = function(list_owner, list_slug, callback) {

    26

    loadTwitterListPage(

    29

	    -1,

    30

	[], 

    31

	function (users) {

    32

	    var twitterIds = [];

    33

	    console.log(users);

    34

	    for (u in users) {

    35

		twitterIds.push(users[u].id);

    36

	    }

    37

	    callback(twitterIds);

    38

    39

	});

    40

};

    41

    42

exports.listenToTweets = function(twitter_ids, twitter_auth)  {

    43

    var emitter = new EventEmitter();

    44

    var stream = http.request(

    45

	{host: 'stream.twitter.com', path:'/1/statuses/filter.json', 'method': 'POST'}, 

    46

	function (res) {

    47

	    res.setEncoding('utf8');

    48

	    var incompleteChunk = "";

    49

	    res.on(

    50

		'data',

    51

		function (chunk) {

    52

		    incompleteChunk += chunk;

    53

		    incompleteChunk = incompleteChunk.trim();

    54

		    if (incompleteChunk) {

    55

			try {

    56

			    var tweet = JSON.parse(incompleteChunk);

    57

			    emitter.emit("tweet", tweet);

    58

			    incompleteChunk = "";

    59

			} catch (err) {

    60

			    console.log(err);

    61

			}

    62

		    }

    63

		});

    64

	    res.on(

    65

		'end',

    66

		function () {

    67

		    console.log("Twitter stream terminated with error " + res.statusCode);

    68

		});

    69

	}

    70

    );

    71

    stream.setHeader("Content-Type", "application/x-www-form-urlencoded");

    72

    stream.setHeader("Authorization", 'Basic ' + new Buffer(options.twitter_auth.name + ':' + options.twitter_auth.password).toString('base64'));

    73

    stream.write("follow=" + twitter_ids.join(","));

    74

    stream.end();

    75

};