This repository has been archived by the owner on Jul 3, 2019. It is now read-only.
/
webapp.js
69 lines (52 loc) · 1.68 KB
/
webapp.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
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
require("coffee-script");
var sys = require('sys'),
http = require('http'),
ws = require("./utils/ws")
// Command line args
var username = "twitdron1"
var password = "thedrone";
var keyword = "apple";
var Twit = require('twit')
var T = new Twit({
consumer_key: '4kygiZAnk74lz0apFQA'
, consumer_secret: 'UQhTU1MjgT7fTAQprFBl9Z0EVtzYAnLUNYvMugEHRHg'
, access_token: '983003724-8Unflf2U7c3IF3fNID6hvPaOidwwqjmnFk2XDC98'
, access_token_secret: 'Uqh3uOGV9gRRFIoJuCdBgmGR1d2w7Tc9ZzcMlKa1tA'
})
var stream = T.stream('statuses/filter', { track: '@FaceDrone' })
stream.on('tweet', function (tweet) {
console.log(clients.length)
for(var i=0; i<clients.length; i++) {
console.log("Emitting")
clients[i].emit("tweet", tweet.text);
}
})
clients = [];
var io = require('socket.io').listen(9090);
io.sockets.on('connection', function (socket) {
console.log("......................")
clients.push(socket);
});
var express = require('express')
, http = require('http')
, path = require('path');
var app = express();
app.configure(function(){
app.set('port', process.env.PORT || 3000);
app.set('views', __dirname + '/views');
app.set('view engine', 'jade');
app.use(express.favicon());
app.use(express.logger('dev'));
app.use(express.bodyParser());
app.use(express.methodOverride());
app.use(app.router);
app.use(express.static(path.join(__dirname, 'public')));
});
app.configure('development', function(){
app.use(express.errorHandler());
});
app.get('/', require('./routes/index'));
app.get('/what', require('./routes/index'));
http.createServer(app).listen(8080, function(){
console.log("Express server listening on port 8080")
});