/
server.js
112 lines (95 loc) · 2.88 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
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
'use strict';
var utils = require('./utils');
var config = require('./config');
var app = require('./config/express');
var mongoose = require('./config/mongoose');
var passport = require('./config/passport');
var Board = mongoose.model('board', require('./config/schemas/board'));
process.env.INSTANCE_NAME =
process.env.INSTANCE_NAME || process.env.HOSTNAME || 'unknown';
console.log(process.env.INSTANCE_NAME);
// Setup 'jarmo' integration for InfluxDB reporter.
app.use(require('jarmo-express')({
resolve: function(req, res, duration) {
return {
tags: {
version: process.env.VERSION || 'unknown',
hostname: process.env.INSTANCE_NAME,
path: req.route.path,
method: req.method,
// InfluxDB tag values can't be numbers.
status: '' + res.statusCode + ''
},
fields: {
value: duration
},
name: '' + process.env.INSTANCE_NAME + '.response_time'
}
},
host: process.env.JARMO_HOST,
port: process.env.JARMO_PORT
}));
// Use 'passport' authentication.
app.use(passport.initialize());
// Attach 'CORS' middleware to every route.
app.all('*', require('cors')({
exposedHeaders: ['x-access-token']
}));
// Setup API Routes.
app.use('/api', require('./routes/auth'));
app.use('/api', require('./routes/board'));
app.use('/api', require('./routes/version'));
app.use('/api', require('./routes/user'));
/**
* Error handling middleware. All errors passed to 'next' will eventually end
* up here.
*/
app.use(function(err, req, res, next) {
var boom = require('boom');
err = boom.wrap(err, err.status);
if(err.output.statusCode >= 500) {
console.error(err);
}
return res.status(err.output.statusCode).send(err.output.payload);
});
/**
* The Express application.
*/
module.exports.app = app;
/**
* Perform necessary initialization to start the server.
*
* @param {function} onListen Callback invoked when the server starts
* listening to incoming requests.
*/
module.exports.listen = function(onListen) {
var connectWithRetry = function() {
mongoose.connect(config.mongo.url, config.mongo.opts, function (err) {
if(err) {
console.error(err);
console.log("Reconnecting in " + config.mongo.timeout + " ms...");
setTimeout(connectWithRetry, config.mongo.timeout);
}
});
}
mongoose.connection.on('error', function(error) {
console.error('Error during MongoDB runtime! ' + error);
});
mongoose.connection.on('connected', function() {
console.log('Connected to MongoDB!');
});
connectWithRetry();
this.server = app.listen(config.port, onListen || function() {
console.log('server listening at', config.port);
});
}
/**
* Perform necessary teardown to stop the server.
*
* @param {function=} onShutdown Callback invoked after shutting down.
*/
module.exports.shutdown = function(onShutdown) {
return this.server.close(function() {
mongoose.disconnect(onShutdown || function() {});
});
}