index.js
const dgram = require('dgram');
const express = require('express');
const expressWs = require('express-ws');
const path = require('path');
const config = require('./config.json');
const NodeMgr = require('./class/NodeMgr');
const nodeMgr = new NodeMgr();
const WebClientMgr = require('./class/WebClientMgr');
const webClientMgr = new WebClientMgr();
nodeMgr.on('update', msg => {
webClientMgr.broadcast(nodeMgr);
});
webClientMgr.on('command', (...args) => {
nodeMgr.execute(...args)
});
webClientMgr.on('server_command', (cmd, cb) => {
console.log(`Executing: ${cmd}`);
switch (cmd) {
case 'stop':
cb(undefined, {
'type': 'server_execute',
'content': {
'text': 'Stopping Server',
'node': 'Server'
}
});
process.exit();
break;
case 'clear':
case 'prune':
cb(undefined, {
'type': 'server_execute',
'content': {
'text': `${cmd} ${nodeMgr[cmd]()} Nodes`,
'node': 'Server'
}
});
break;
default:
cb(new Error('unknown command: ' + cmd));
}
});
const app = express();
expressWs(app);
app.use(express.static(path.join(__dirname, 'static')));
app.ws('/ws', (ws, req) => {
webClientMgr.addClient(ws);
});
const expressServer = app.listen(config.express.port, () => {
const address = expressServer.address();
console.log(`Express listening on port ${address.port}`);
});
const server = dgram.createSocket('udp4');
server.on('error', (err) => {
console.log(`server error:\n${err.stack}`);
server.close();
});
server.on('message', (msg, rinfo) => {
try {
nodeMgr.handleData(JSON.parse(msg), rinfo);
} catch (e) {
console.error('Invalid Client Message!', e);
}
});
server.on('listening', () => {
const address = server.address();
console.log(`server listening on port ${address.port}`);
});
server.bind(config.udp.port);