-
Notifications
You must be signed in to change notification settings - Fork 0
/
publisher.js
43 lines (32 loc) · 1.19 KB
/
publisher.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
var sys = require("sys");
var http = require("http");
var redg = require("./lib/redis-node-client/lib/redis-client").createClient();
// http://search.twitter.com/search.json?q=
// http://search.twitter.com/search.json?q=%s&since_id=%s
var twitter_search = http.createClient(80, "search.twitter.com");
var since_id=0;
var timeo=10000;
function searcht() {
var request="";
if (since_id == 0 ){
request = twitter_search.request("GET", "/search.json?q=bit.ly+filter:links&rpp=1", {"host": "search.twitter.com"});
} else {
request = twitter_search.request("GET", "/search.json?q=bit.ly+filter:links&rpp=1&since_id="+since_id, {"host": "search.twitter.com"});
}
request.end();
request.on ('response', function (response) {
var body="";
response.on("data", function (chunk) {
body=body+chunk;
});
response.on("end", function() {
res = JSON.parse(body);
since_id = res["max_id"];
if (res["results"].length > 0) {
redg.publish("PUBSUB:COMET", res["results"][0]["text"], function(){});
}
});
});
setTimeout(searcht, timeo);
};
setTimeout(searcht, 2000);