-
Notifications
You must be signed in to change notification settings - Fork 0
/
app.js
152 lines (132 loc) · 4.47 KB
/
app.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
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
const http = require('http').Server;
const path = require('path');
const express = require('express');
const logger = require('morgan');
const cookieParser = require('cookie-parser');
const bodyParser = require('body-parser');
const sassMiddleware = require('node-sass-middleware');
const expressValidator = require('express-validator');
const session = require('express-session');
const passport = require('passport');
const LocalStrategy = require('passport-local').Strategy;
const mongo = require('mongodb');
const mongoose = require('mongoose');
const socketio = require('socket.io');
const cors = require('cors');
const app = express();
app.use(cors());
// Load modules
const FTP = require('./modules/getFTPFiles');
const webSockets = require('./modules/websockets');
const serviceWorker = require('./modules/server-service-worker');
const consumeLiveStream = require('./modules/consume-live-stream');
const index = require('./routes/index');
const auth = require('./routes/auth');
const users = require('./routes/users');
const api = require('./routes/api');
const error = require('./routes/error');
const customerDashboard = require('./routes/customer-dashboard');
const operatorDashboard = require('./routes/operator/dashboard');
const operatorDashboardHistory = require('./routes/operator/dashboard-history');
// Init hourly API calls
const gasCalculation = require('./modules/gas-calculation');
const feedCalculation = require('./modules/feed-calculation');
require('dotenv').config();
// Socket.io connection
const io = socketio();
app.io = io;
// mongoose setup
const dbOld = false; //switch for connecting to the old vs new mongoDb IMPORTANT: also make the switch in the user model!
mongoose.createConnection(dbOld? process.env.DB_URL: process.env.DB_URL_NEW)
// Enable these next lines to check for csv files with sensordata in the ftp folder and load them into MongoDb
//console.log("getFTPfiles");
//FTP.checkForNewLocalFiles('value');
//FTP.checkForNewLocalFiles('status');
// FTP.checkForNewLocalFiles('alarm'); // does not work with current filenames
//Kick off calculations and websockets
const data = {
init() {
if(!dbOld) {consumeLiveStream.init() } //Only connect to the live datastream if working on new db as well
webSockets.init(app, io, dbOld);
gasCalculation.init();
feedCalculation.init();
this.interval();
},
interval() {
let intervalTime = 60000 * 60;
setInterval(gasCalculation.init, intervalTime);
setInterval(feedCalculation.init, intervalTime);
}
};
data.init();
// view engine setup
app.set('views', path.join(__dirname, 'views'));
app.set('view engine', 'ejs');
// uncomment after placing your favicon in /public
// app.use(favicon(path.join(__dirname, 'public', 'favicon.ico')));
app.use(logger('dev'));
app.use(bodyParser.json());
app.use(bodyParser.urlencoded({extended: false}));
app.use(cookieParser());
app.use(express.static(path.join(__dirname, 'public')));
// express session
app.use(session({
secret: 'appelflap',
saveUninitialized: true,
resave: true
}));
// passport init
app.use(passport.initialize());
app.use(passport.session());
// express validator
app.use(expressValidator({
errorFormatter(param, msg, value) {
const namespace = param.split('.');
const root = namespace.shift();
let formParam = root;
while (namespace.length) {
formParam += '[' + namespace.shift() + ']';
}
return {
param: formParam,
msg,
value
};
}
}));
// global vars
app.use((req, res, next) => {
res.locals.user = req.user || null;
next();
});
// error handler
app.use((err, req, res, next) => {
// set locals, only providing error in development
res.locals.message = err.message;
res.locals.error = req.app.get('env') === 'development' ? err : {};
// render the error page
res.status(err.status || 500);
res.render('error');
});
//Tried to move this to websockets but ran into issues with bin/www
io.on('connection', socket => {
console.log('Client Connected');
webSockets.sendInitialData();
});
app.use('/', index);
app.use('/auth', auth);
app.use('/users', users);
app.use('/api', api);
app.use('/operator/dashboard', operatorDashboard);
app.use('/operator/dashboard/history', operatorDashboardHistory);
app.use('/customer/dashboard', customerDashboard);
app.use('*', error);
// Service worker push notifications
serviceWorker(app);
// catch 404 and forward to error handler
app.use((req, res, next) => {
const err = new Error('Not Found');
err.status = 404;
next(err);
});
module.exports = app;