traque/traque.js

/* struct equipe
{
    "id" : string,
    "pos" : [lat : float, long : float],
    "color" : int,
    "room" : socket.io room,
    "shown" : bool
}

Les messages à transmettre par le client :
- position, HTTP "/log?id=%ID&lat=%LAT&lon=%LON"
- code(code)
Les messages à transmettre par le serveur :
- moving(id, position)
- changeColor(id, color)
*/

// 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 = 3*60*1000;

var equipes = {};
var admins = {};
var invisi = {};

// require = include
var http = require('https');//require('http');
var url = require('url');
var fs = require('fs');
var config = require('./config.js');

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);
    //
    // todo : utiliser ?id pour changer des chose dans la page, ou faire ça en fesant croire
    // qu'il y a plein de fichiers sous le dossier "conscrit", alors que c'est juste une page html;
    // la page conscrit seul renvoyant 404 ou random page erreur "utilise les lien qu'on donne petit conscrit"
    //
    var filename = "static" + q.pathname;
    if(q.pathname.includes(".."))
        filename = "static/dotdot.html";
    
    if(q.pathname.startsWith("/conscrit/")){
        id = q.pathname.substring("/conscrit/".length);
        return fs.readFile("static/conscrit.html", 'utf8', function(err, data){
            if(err)
                throw new Error("where conscrit.html 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 + ")");

        //current impl (to be changed)
        var equipe = equipes[q.query.id];
        var position = [q.query.lat, q.query.lon];
        equipe.pos = position;
        if(equipe.shown)
            for(i in equipes)
                equipes[i].room.emit('moving', {"id": equipe.id, "position": position});
        else {
            equipe.room.emit('moving', {"id": equipe.id, "position": position});
//            for(i in admins)
//                admins[i].emit('moving', {"id": equipe.id, "position": position})
        }


        //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);
var team_nsp = io.of("/");//TODO: separate admin and player

console.log("Setup handlers");
team_nsp.on('connection', function(socket){
    var id = socket.handshake.auth.id;
    console.log("connection of " + id + " !");

    socket.join(id);
    if(!(id in equipes)){
        var equipe = {};
        equipe.shown = true;
        equipe.pos = [0,0];
        equipe.color = 0;
        equipe.id = id;
        equipe.room = team_nsp.to(id);
        equipes[id] = equipe;
    }

    socket.on("code", function(d){ /*TODO*/ });

    for(i in equipes){
        if(!equipes[i].shown)
            continue;
        socket.emit('moving', {"id": i, "position": equipes[i].pos});
        socket.emit('changeColor', {"id": i, "color": equipes[i].color});
    }


//ici essentiellement tout est a refaire
//    socket.id = equipes.length;
//    equipes.push(socket);
//    socket.shown = true;
//    socket.admin = false;
//    socket.color = 0;
//    socket.position = [0,0];
//    socket.on('admin', function(){
//        socket.admin = true;
//        socket.shown = false;
//        admins.push(socket);
//        for(i in equipes)
//            equipes[i].emit('changeColor', {"id": socket.id, "color": -1});
//        socket.on('newTracker', function(d){
//            for(i in equipes)
//                equipes[i].emit('newTracker', d);
//        });
//    });
//    socket.on('changeColor', function(d){
//        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('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 if((d.content in invisi) && invisi[d.content]){
//            invisi[d.content] = false;
//			old_color = socket.color;
//            d.color = -1;
//            socket.emit('popup', {"content": MSG_INVISIBLE});
//		    setTimeout(function(s,c){
//				for(i in equipes){
//					equipes[i].emit('moving', {"id": s.id, "position": s.position});
//	            	equipes[i].emit('changeColor', {"id": s.id, "color": c, "debug": "timeout"});
//				}
//				s.color = c;
//	    	}, invisible_delay, socket, old_color);
//        } else {
//            socket.emit('popup', {"content": MSG_BAD});
//            return;
//        }
//        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('popup', function(d){
//        for(i in equipes)
//            equipes[i].emit('popup', {"content": d.content});
//    });
//    socket.on('setName', function(d){
//        socket.name = d.name;
//        for(i in equipes)
//            equipes[i].emit('setName', {"id": socket.id, "name": d.name});
//    });
//    socket.on('newCode', function(d){
//        invisi[d.code] = true;
//    });
//    socket.on("disconnect", function(_){
//	console.log(socket.id + " disconnect"); 
//	socket.shown = false;
//        for(i in equipes)
//            equipes[i].emit('remove', {"id": socket.id});
//    });
//
//    socket.emit('yourId', {"id": socket.id});
//    for(i in equipes){
//        if(!equipes[i].shown)
//            continue;
//        socket.emit('setName', {"id": i, "name": equipes[i].name});
//        socket.emit('changeColor', {"id": i, "color": equipes[i].color});
//        socket.emit('moving', {"id": i, "position": equipes[i].position});
//    }
});

console.log("Launch server");
server.listen(config.port, "::");
console.log("Running !");