-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathserver.js
76 lines (61 loc) · 2.19 KB
/
server.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
70
71
72
73
74
75
76
var express = require('express')
var logger = require('morgan')
var compression = require('compression')
var methodOverride = require('method-override')
var bodyParser = require('body-parser')
var uaparser = require('ua-parser')
var redis = require('redis')
var maxmind = require('maxmind')
var cityLookup = maxmind.open('/usr/src/geoip/GeoLite2-City.mmdb')
var helmet = require('helmet')
var app = express()
app.use(helmet())
app.use(helmet.hidePoweredBy())
app.set('port', process.env.PORT || process.argv[2] || 6000)
app.use(compression())
app.use(logger('dev'))
app.use(bodyParser.json())
app.use(bodyParser.urlencoded({ extended: false }))
var client = redis.createClient(6379, 'redis')
var TimeSeries = require('./TimeSeries')
var timeSeries = new TimeSeries.TimeSeries(client, 'tracker')
app.use(methodOverride('_method'))
var router = express.Router()
router.get('/', function (req, res, next) {
console.log('used get/')
process.nextTick(function () {
// tracking operations
var qu = req && req.query
var token = qu && qu.token
var ip = req && req.headers['x-real-ip'] || req.headers['X-Real-IP'] || req.connection.remoteAddress
var ua = req && uaparser.parse(req.headers['user-agent'])
console.log('date: ' + Date.now())
console.log('query: ' + JSON.stringify(qu))
console.log('token: ' + token)
console.log('ip: ' + ip)
console.log('browser: ' + ua.ua.toString())
console.log('OS: ' + ua.os.toString())
console.log('device: ' + ua.device.toString())
var city = cityLookup.get(ip)
console.log('city: ' + JSON.stringify(city))
timeSeries.insert(Date.now() / 1000 | 0, ip)
timeSeries.insert(Date.now() / 1000 | 0, ua.device.toString())
})
return res.status(204).send()
})
app.use(router)
app.get('*', function (req, res, next) {
var err = new Error()
err.status = 404
next(err)
})
app.use(function (err, req, res, next) {
if (err.status !== 404) {
return next()
}
return res.status(404).send('Ressource not found')
})
app.listen(app.get('port'), function () {
console.log('Express server listening on port ' + app.get('port'))
})
module.exports = app