traque/traque.js

/* struct equipe
{
    "id" : string,
    "pos" : [lat : float, long : float],
    "vieux": bool,
    "state" : {
        "invisibilty" : bool,
        "blurred": bool,
        "tracker" : bool,
        "npc" : int
    },
    "codes" : {
        "invisiblity" : int,
        "blurred" : int
    }
}

Les messages à transmettre par le client :
- position, HTTP "/log?id=%ID&lat=%LAT&lon=%LON"
- use(code)
- (vieux) changeState (state)
Les messages à transmettre par le serveur :
- moving(id, color, position)
- setCodes(codes)
- (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
const MSG_BAD = "Code Incorrect";
const MSG_TRACKED = "Vous êtes maintenant traqué.e.s !"
const MSG_TRACKER = "Vous pouvez maintenant traquer !";
const MSG_CODES = {
    blurred: "Votre positions est maintenant brouillée !",
    invisibility: "Les autres équipes ne peuvent plus vous voir !"
};
const bonus_delay = 10000;// 3*60*1000;

var equipes = {};

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);
        gpslog = true;
        if(id.startsWith("nolog/")){
            gpslog = false;
            id = id.substring("nolog/".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).replaceAll("%GPSLOG", gpslog));
            return res.end();
        });
    }

    if(q.pathname == "/log"){
        //position logging
        console.log("team " + q.query.id + " moved to (" + q.query.lat + "," + q.query.lon + ")");

        var id = q.query.id;
        if(id in equipes){
            equipes[id].pos = [q.query.lat, q.query.lon];
            emit_update(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");
    }
    if(filename.endsWith('.js'))
        res.writeHead(200, {'Content-Type': 'text/javascript'});
    else
        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);

io.use(function(socket, next){
    var id = socket.handshake.auth.id;
    var type = socket.handshake.auth.type;

    if(type == "Admin")
        next();
    else{
        var valid = config.validator(id);
        if(valid == 0 && type == "conscrit" ||
           valid == 1 && type == "vieux"){
            if(!(id in equipes)){
                equipes[id] = default_team(id, valid);
                emit_update(id);
            }
            next();
        } else
            next(new Error("invalid"));
    }
});

/////////////////
// 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.invisibility) return 2;
    if(team.state.tracker) return 1;
    if(team.state.npc != 0) return team.state.npc - 0 + 2;
    return 0;
}

// apparent information of a team, for other only
function apparent_info(equipe){
    if(equipe.state.invisibility)
        return {"id": equipe.id, "color": color(equipe), "position": [0,0]};
    if(equipe.state.blurred)
        return {"id": equipe.id, "color": color(equipe),
                "position": [parseFloat(equipe.pos[0])+config.lat_ofs*(Math.random()*2-1),
                            parseFloat(equipe.pos[1])+config.long_ofs*(Math.random()*2-1)]};
    return {"id": equipe.id, "color": color(equipe), "position": equipe.pos};
}

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});
    admin.emit('update', equipe);
}

// produces a team object populated with default values
function default_team(team_id, valid) {
    var state = {};
    state.invisibility = valid != 0;
    state.blurred = false;
    state.tracker = false;
    state.npc = valid;

    var codes = {};
    codes.blurred = 0;
    codes.invisibility = 0;

    var equipe = {};
    equipe.state = state;
    equipe.codes = codes;
    equipe.vieux = valid == 1;
    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") {
        var id = socket.handshake.auth.id;
        var equipe = equipes[id]
        socket.join("Tracking");
        team_join(equipe, socket);

        socket.on("useCode", function(code){
            if(code in equipe.codes && equipe.codes[code] > 0){
                equipe.codes[code] -= 1;
                equipe.state[code] = true;
                io.to(id).emit('popup', {content: MSG_CODES[code]});
                io.to(id).emit('setCodes', equipe.codes);
                emit_update(id);
                setTimeout(function(eq, c){
                    eq.state[c] = false;
                    emit_update(eq.id);
                }, bonus_delay, equipe, code);
            }
        });
    }

    if(socket.handshake.auth.type == "vieux"){
        var id = socket.handshake.auth.id;
        var equipe = equipes[id]
        socket.join("Tracking");
        team_join(equipe, socket);

        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){
            equipes[d.id].codes[d.code] += 1;
            io.to(d.id).emit('setCodes', equipes[d.id].codes);
            admin.emit('update', equipes[d.id]);
        });

        socket.on('popup', function(d){
            tracking.emit('popup', {"content": d.content});
        });

        socket.on('newTracker', function(d){
            io.emit('newTracker', d);
        });

        socket.on('setState', function(d){
            equipes[d.id].state = d.state;
            emit_update(d.id);
            if(equipes[d.id].vieux)
                io.to(d.id).emit('newState', d.state);
        });

        for(i in equipes){
            var equipe = equipes[i];
            socket.emit('moving', {"id": equipe.id, "color": color(equipe), "position": equipe.pos});
            socket.emit('update', equipe);
        }
    }


//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 !");