276 lines
8.1 KiB
JavaScript
276 lines
8.1 KiB
JavaScript
/* struct equipe
|
|
{
|
|
"id" : string,
|
|
"pos" : [lat : float, long : float],
|
|
"state" : {
|
|
"shown" : bool,
|
|
"tracker" : bool,
|
|
"npc" : bool
|
|
}
|
|
}
|
|
|
|
Les messages à transmettre par le client :
|
|
- position, HTTP "/log?id=%ID&lat=%LAT&lon=%LON"
|
|
- code(code)
|
|
- (vieux) changeState (state)
|
|
Les messages à transmettre par le serveur :
|
|
- moving(id, color, position)
|
|
- (vieux) newState(state)
|
|
*/
|
|
|
|
// require = include
|
|
var http = require('https');//require('http');
|
|
var url = require('url');
|
|
var fs = require('fs');
|
|
var config = require('./config.js');
|
|
|
|
// Textes d'interaction avec les conscrits
|
|
var PWD_TRACKED = "tracked";
|
|
var PWD_TRACKER = "tracker";
|
|
var PWD_INVISIBLE = "invisible";
|
|
var MSG_BAD = "Code Incorrect";
|
|
var MSG_TRACKED = "Vous êtes maintenant traqué.e.s !"
|
|
var MSG_TRACKER = "Vous pouvez maintenant traquer !";
|
|
var MSG_INVISIBLE = "Les autres équipes ne peuvent plus vous voir !";
|
|
var invisible_delay = 10000;// 3*60*1000;
|
|
|
|
var equipes = {};
|
|
var invisi = {};
|
|
|
|
console.log("Setup http server");
|
|
|
|
const option = {
|
|
key: fs.readFileSync(config.key),
|
|
cert: fs.readFileSync(config.cert)
|
|
};
|
|
|
|
// The server
|
|
var server = http.createServer(option, function(req, res){
|
|
var q = url.parse(req.url, true);
|
|
var filename = "static" + q.pathname;
|
|
if(q.pathname.includes(".."))
|
|
filename = "static/dotdot.html";
|
|
|
|
if(q.pathname.startsWith("/tracking/")){
|
|
id = q.pathname.substring("/tracking/".length);
|
|
var end_path = ["conscrit.html", "vieux.html", "invalid.html"][config.validator(id)];
|
|
filename = "static/tracking/" + end_path;
|
|
return fs.readFile(filename, 'utf8', function(err, data){
|
|
if(err)
|
|
throw new Error("where " + end_path + " is !?");
|
|
|
|
res.writeHead(200, {'Content-Type': 'text/html'});
|
|
res.write(data.replaceAll("%ID", id));
|
|
return res.end();
|
|
});
|
|
}
|
|
|
|
if(q.pathname == "/log"){
|
|
//position logging
|
|
console.log("team " + q.query.id + " moved to (" + q.query.lat + "," + q.query.lon + ")");
|
|
|
|
if(!(q.query.id in equipes))
|
|
equipes[q.query.id] = default_team(q.query.id);
|
|
equipes[q.query.id].pos = [q.query.lat, q.query.lon];
|
|
emit_update(q.query.id);
|
|
|
|
//return empty page
|
|
res.writeHead(200, {'Content-Type': 'text/html'});
|
|
return res.end();
|
|
}
|
|
fs.readFile(filename, function(err, data) {
|
|
if (err) {
|
|
console.log("404: ", q.pathname, filename);
|
|
res.writeHead(404, {'Content-Type': 'text/html'});
|
|
return res.end("404 Not Found");
|
|
}
|
|
res.writeHead(200, {'Content-Type': 'text/html'});
|
|
res.write(data);
|
|
return res.end();
|
|
});
|
|
});
|
|
|
|
console.log("Setup io server");
|
|
const { Server } = require("socket.io");
|
|
var io = new Server(server);
|
|
|
|
/////////////////
|
|
// Tracking room
|
|
//
|
|
// Everyone in this room is located
|
|
// sub-rooms :
|
|
// * "npc" room for non-player
|
|
// * "%ID" room of a team
|
|
//
|
|
// To join :
|
|
// auth = {
|
|
// type = "conscrit" | "vieux",
|
|
// id = "%ID"
|
|
// }
|
|
// "conscrit" are classical player, "vieux" are npcs (they can become tracker when needed)
|
|
var tracking = io.to("Tracking");
|
|
|
|
/////////////////
|
|
// Admin room
|
|
//
|
|
// Room for admins
|
|
// To join :
|
|
// auth = {
|
|
// type = "Admin"
|
|
// }
|
|
var admin = io.to("Admin");
|
|
|
|
// visible color of a team
|
|
function color(team){
|
|
if(!team.state.shown) return 2;
|
|
if(team.state.tracker) return 1;
|
|
if(team.state.npc != 0) return 2 + team.state.npc;
|
|
return 0;
|
|
}
|
|
|
|
// apparent information of a team, for other only
|
|
function apparent_info(equipe){
|
|
if(equipe.state.shown){
|
|
return {"id": equipe.id, "color": color(equipe), "position": equipe.pos};
|
|
} else {
|
|
return {"id": equipe.id, "color": color(equipe), "position": [0,0]};
|
|
}
|
|
}
|
|
|
|
function emit_update(team_id) {
|
|
var equipe = equipes[team_id];
|
|
tracking.except(team_id).emit('moving', apparent_info(equipe));
|
|
// the team and the admins always have the real informations
|
|
admin.to(team_id).emit('moving', {"id": team_id, "color": color(equipe), "position": equipe.pos});
|
|
}
|
|
|
|
// produces a team object populated with default values
|
|
function default_team(team_id) {
|
|
var equipe = {};
|
|
var state = {};
|
|
state.shown = true;
|
|
state.tracker = false;
|
|
state.npc = 0;
|
|
equipe.state = state;
|
|
equipe.pos = [0,0];
|
|
equipe.id = team_id;
|
|
return equipe;
|
|
}
|
|
|
|
// connect a socket to the room corresponding to its team and send it infos
|
|
function team_join(team, socket){
|
|
socket.join(team.id);
|
|
var state = team.state;
|
|
if(state.npc != 0) socket.join("npc");
|
|
socket.emit('moving', {"id": team.id, "color": color(team), "position": team.pos});
|
|
for(other_id in equipes)
|
|
if(other_id != team.id)
|
|
socket.emit('moving', apparent_info(equipes[other_id]));
|
|
}
|
|
|
|
console.log("Setup handlers");
|
|
io.on('connection', function(socket){
|
|
if(socket.handshake.auth.type == "conscrit" ||
|
|
socket.handshake.auth.type == "vieux") {
|
|
var id = socket.handshake.auth.id;
|
|
console.log("connection of " + id + " !");
|
|
|
|
socket.join("Tracking");
|
|
if(!(id in equipes))
|
|
equipes[id] = default_team(id);
|
|
var equipe = equipes[id]
|
|
team_join(equipe, socket);
|
|
|
|
socket.on("code", function(d){
|
|
var code = d.code;
|
|
if(code == PWD_TRACKER){
|
|
equipe.state.tracker = true;
|
|
io.to(id).emit('popup', {"content": MSG_TRACKER});
|
|
emit_update(id);
|
|
} else if((code in invisi) && invisi[code]){
|
|
invisi[code] = false;
|
|
equipe.state.shown = false;
|
|
io.to(id).emit('popup', {"content": MSG_INVISIBLE});
|
|
emit_update(id);
|
|
setTimeout(function(eq){
|
|
eq.state.shown = true;
|
|
emit_update(eq.id);
|
|
}, invisible_delay, equipe);
|
|
} else {
|
|
socket.emit('popup', {"content": MSG_BAD});
|
|
return;
|
|
}
|
|
});
|
|
}
|
|
|
|
if(socket.handshake.auth.type == "vieux"){
|
|
var id = socket.handshake.auth.id;
|
|
var equipe = equipes[id]
|
|
|
|
socket.on('changeState', function(d){
|
|
equipe.state = d;
|
|
io.to(id).emit('newState', d);
|
|
emit_update(id);
|
|
});
|
|
|
|
socket.emit('newState', equipe.state);
|
|
}
|
|
|
|
if(socket.handshake.auth.type == "Admin"){
|
|
socket.join("Admin");
|
|
|
|
socket.on('newCode', function(d){
|
|
invisi[d.code] = true;
|
|
});
|
|
|
|
socket.on('popup', function(d){
|
|
tracking.emit('popup', {"content": d.content});
|
|
});
|
|
|
|
socket.on('newTracker', function(d){
|
|
io.emit('newTracker', d);
|
|
});
|
|
|
|
for(i in equipes){
|
|
var equipe = equipes[i];
|
|
socket.emit('moving', {"id": equipe.id, "color": color(equipe), "position": equipe.pos});
|
|
}
|
|
}
|
|
|
|
|
|
//ici essentiellement tout est a refaire
|
|
// socket.on('message', function(d){
|
|
// d.content = d.content.toLowerCase();
|
|
// if(d.content == PWD_TRACKED){
|
|
// d.color = 0;
|
|
// socket.emit('popup', {"content": MSG_TRACKED});
|
|
// } else if(d.content == PWD_TRACKER){
|
|
// d.color = 1;
|
|
// socket.emit('popup', {"content": MSG_TRACKER});
|
|
// } else if(d.content == PWD_INVISIBLE){
|
|
// d.color = -1;
|
|
// socket.emit('popup', {"content": MSG_INVISIBLE});
|
|
// } else
|
|
// socket.color = d.color - 0;
|
|
// if(d.color == -1)
|
|
// socket.shown = false;
|
|
// else{
|
|
// if(!socket.shown)
|
|
// for(i in equipes)
|
|
// equipes[i].emit('moving', {"id": socket.id, "position": socket.position});
|
|
// socket.shown = true;
|
|
// }
|
|
// for(i in equipes)
|
|
// equipes[i].emit('changeColor', {"id": socket.id, "color": d.color});
|
|
// });
|
|
// socket.on("disconnect", function(_){
|
|
// console.log(socket.id + " disconnect");
|
|
// socket.shown = false;
|
|
// for(i in equipes)
|
|
// equipes[i].emit('remove', {"id": socket.id});
|
|
// });
|
|
});
|
|
|
|
console.log("Launch server");
|
|
server.listen(config.port, "::");
|
|
console.log("Running !");
|