atcheck/atcheck-websocket/server.js

46 lines
1.3 KiB
JavaScript

const WebSocket = require('ws');
var http = require('http');
var websocket_port = 8888;
const wss = new WebSocket.Server({port: websocket_port});
console.log("Websocket server running on port " + websocket_port);
var lookup = [];
wss.on('connection', function connection(ws) {
lookup[ws.protocol] = ws;
});
var server = http.createServer(function (request, response) {
response.writeHead(200, {"Content-Type": "text\plain"});
request.setEncoding('utf8');
if (request.method === "POST") {
var body = '';
request.on('data', function (chunk) {
body += chunk;
});
request.on('end', function () {
body = JSON.parse(body);
console.log(body);
console.log(lookup);
var send_array = {
"type": "data",
"id": body.student_index,
"name": body.student_name,
"surname": body.student_surname,
"classes_code": body.classes_code
};
lookup[body.classes_code].send(JSON.stringify(send_array));
});
}
else {
response.end("Undefined request .");
}
});
var http_port = 8889;
server.listen(http_port);
console.log("HTTP server running on port " + http_port);