summaryrefslogtreecommitdiff
path: root/deps/npm/node_modules/JSONStream/node_modules/jsonparse/examples/twitterfeed.js
diff options
context:
space:
mode:
Diffstat (limited to 'deps/npm/node_modules/JSONStream/node_modules/jsonparse/examples/twitterfeed.js')
-rw-r--r--deps/npm/node_modules/JSONStream/node_modules/jsonparse/examples/twitterfeed.js30
1 files changed, 30 insertions, 0 deletions
diff --git a/deps/npm/node_modules/JSONStream/node_modules/jsonparse/examples/twitterfeed.js b/deps/npm/node_modules/JSONStream/node_modules/jsonparse/examples/twitterfeed.js
new file mode 100644
index 0000000000..10210d470b
--- /dev/null
+++ b/deps/npm/node_modules/JSONStream/node_modules/jsonparse/examples/twitterfeed.js
@@ -0,0 +1,30 @@
+var Parser = require('../jsonparse');
+var Http = require('http');
+require('./colors');
+var p = new Parser();
+var cred = require('./credentials');
+var client = Http.createClient(80, "stream.twitter.com");
+var request = client.request("GET", "/1/statuses/sample.json", {
+ "Host": "stream.twitter.com",
+ "Authorization": (new Buffer(cred.username + ":" + cred.password)).toString("base64")
+});
+request.on('response', function (response) {
+ console.log(response.statusCode);
+ console.dir(response.headers);
+ response.on('data', function (chunk) {
+ p.write(chunk);
+ });
+ response.on('end', function () {
+ console.log("END");
+ });
+});
+request.end();
+var text = "", name = "";
+p.onValue = function (value) {
+ if (this.stack.length === 1 && this.key === 'text') { text = value; }
+ if (this.stack.length === 2 && this.key === 'name' && this.stack[1].key === 'user') { name = value; }
+ if (this.stack.length === 0) {
+ console.log(text.blue + " - " + name.yellow);
+ text = name = "";
+ }
+};