pngs/server.js

58 lines
1.3 KiB
JavaScript
Raw Normal View History

2010-12-04 22:04:58 +01:00
var Connect = require('connect');
var wss = require('websocket-server');
var wsc = require('websocket-client');
2010-12-04 22:04:58 +01:00
var frontend;
/* TODO: url */
var nedap = new wsc.WebSocket('ws://localhost:8080/', 'nedap-kneemFothbedchoadHietEnobKavLub1');
2010-12-04 22:04:58 +01:00
nedap.onopen = function() {
console.log('NEDAP opened');
};
nedap.onclose = function() {
console.log('NEDAP closed');
};
nedap.onerror = function(e) {
console.log('NEDAP error: ' + e.message);
};
nedap.onmessage = function(data) {
try {
var msg = JSON.parse(data);
console.log({ fromNedap: msg });
2010-12-04 22:04:58 +01:00
frontend.send(JSON.stringify({ nedap: msg }));
} catch (e) {
console.error(e.stack);
}
};
var server = Connect.createServer(
Connect.logger(),
Connect.bodyDecoder(),
Connect.staticProvider(__dirname),
Connect.errorHandler({ dumpExceptions: true, showStack: true })
);
wss.createServer({ server: server }).on('connection', function(conn) {
2010-12-04 22:04:58 +01:00
if (conn.protocol === 'quiz') {
frontend = conn;
conn.on('data', function(data) {
var msg = JSON.parse(data);
if (msg.nedap) {
console.log({ toNedap: msg.nedap });
2010-12-04 22:04:58 +01:00
nedap.send(JSON.stringify(msg.nedap));
}
2010-12-04 22:04:58 +01:00
});
var reset = function() {
frontend = null;
};
conn.on('close', reset);
conn.on('error', reset);
} else {
conn.end();
}
});
server.listen(8081);