76 lines
2.3 KiB
JavaScript
76 lines
2.3 KiB
JavaScript
var path = require('path');
|
|
var app = require('express')();
|
|
var bodyParser = require('body-parser');
|
|
var cors = require('cors');
|
|
var createStore = require('./store');
|
|
|
|
module.exports.run = function(worker) {
|
|
var httpServer = worker.httpServer;
|
|
var scServer = worker.scServer;
|
|
var store;
|
|
|
|
httpServer.on('request', app);
|
|
|
|
app.set('view engine', 'ejs');
|
|
app.set('views', path.resolve(__dirname, '..', 'views'));
|
|
|
|
app.get('/', function(req, res) {
|
|
res.render('index', { port: worker.options.port });
|
|
});
|
|
|
|
app.use(cors({ methods: 'POST' }));
|
|
app.use(bodyParser.json());
|
|
app.use(bodyParser.urlencoded({ extended: false }));
|
|
app.post('/', function(req, res) {
|
|
if (!req.body) return res.status(404).end();
|
|
if (!store) store = createStore(worker.options);
|
|
|
|
switch(req.body.op) {
|
|
case 'get':
|
|
store.get(req.body.id).then(function(r) {
|
|
res.send(r || {});
|
|
});
|
|
break;
|
|
default:
|
|
store.add(req.body).then(function(r) {
|
|
scServer.exchange.publish('log', req.body);
|
|
res.send({ id: r.id, error: r.error });
|
|
});
|
|
}
|
|
});
|
|
|
|
scServer.addMiddleware(scServer.MIDDLEWARE_EMIT, function (req, next) {
|
|
var channel = req.event;
|
|
var data = req.data;
|
|
if (channel.substr(0, 3) === 'sc-' || channel === 'respond' || channel === 'log') {
|
|
scServer.exchange.publish(channel, data);
|
|
} else if (channel === 'log-noid') {
|
|
scServer.exchange.publish('log', { id: req.socket.id, data: data });
|
|
}
|
|
next();
|
|
});
|
|
|
|
scServer.on('connection', function(socket) {
|
|
var channelToWatch, channelToEmit;
|
|
socket.on('login', function (credentials, respond) {
|
|
if (credentials === 'master') {
|
|
channelToWatch = 'respond'; channelToEmit = 'log';
|
|
} else {
|
|
channelToWatch = 'log'; channelToEmit = 'respond';
|
|
}
|
|
worker.exchange.subscribe('sc-' + socket.id).watch(function(msg) {
|
|
socket.emit(channelToWatch, msg);
|
|
});
|
|
respond(null, channelToWatch);
|
|
});
|
|
socket.on('disconnect', function() {
|
|
var channel = worker.exchange.channel('sc-' + socket.id);
|
|
channel.unsubscribe(); channel.destroy();
|
|
scServer.exchange.publish(
|
|
channelToEmit,
|
|
{ id: socket.id, type: 'DISCONNECTED' }
|
|
);
|
|
});
|
|
});
|
|
};
|