75 lines
1.8 KiB
JavaScript
75 lines
1.8 KiB
JavaScript
import socket from 'socket.io-serveronly'
|
|
import http from 'http'
|
|
import nStatic from 'node-static'
|
|
import * as casparcg from './casparcg/client.mjs'
|
|
|
|
import lowdb from './db.mjs'
|
|
import config from './config.mjs'
|
|
import log from './log.mjs'
|
|
import onConnection from './routerio.mjs'
|
|
|
|
log.info('Server: Opening database db.json')
|
|
|
|
lowdb().then(function(db) {
|
|
const fileServer = new nStatic.Server('./public')
|
|
const server = http.createServer(function (req, res) {
|
|
const child = log.child({})
|
|
|
|
const d1 = new Date().getTime()
|
|
|
|
var done = function () {
|
|
var requestTime = new Date().getTime() - d1
|
|
|
|
let level = 'info'
|
|
if (res.status >= 400) {
|
|
level = 'warn'
|
|
}
|
|
if (res.status >= 500) {
|
|
level = 'error'
|
|
}
|
|
|
|
child[level]({
|
|
duration: requestTime,
|
|
status: res.statusCode,
|
|
}, `<-- ${req.method} ${req.url}`)
|
|
}
|
|
|
|
res.addListener('finish', done);
|
|
res.addListener('close', done);
|
|
|
|
req.addListener('end', function () {
|
|
if (req.url === '/') {
|
|
res.writeHead(302, { Location: '/index.html' })
|
|
return res.end()
|
|
}
|
|
|
|
fileServer.serve(req, res, function (err) {
|
|
if (err) {
|
|
log.error(err);
|
|
|
|
res.writeHead(err.status, err.headers);
|
|
res.end(err.message);
|
|
}
|
|
});
|
|
}).resume()
|
|
})
|
|
|
|
const io = new socket(server)
|
|
io.on('connection', onConnection.bind(this, io, db))
|
|
|
|
casparcg.initialise(log, db, io)
|
|
|
|
server.listen(config.get('server:port'), '0.0.0.0', function(err) {
|
|
if (err) {
|
|
log.fatal(err)
|
|
return process.exit(2)
|
|
}
|
|
log.info(`Server is listening on ${config.get('server:port')}`)
|
|
})
|
|
}, function(e) {
|
|
log.fatal(e, 'Critical error loading database')
|
|
process.exit(1)
|
|
}).catch(function(e) {
|
|
log.fatal(e, 'Critical error starting server')
|
|
process.exit(1)
|
|
})
|