traque/traque.js

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

Les messages à transmettre par le client :
- geoLoc(position)
- changeColor(color)
- setName(id)
Les messages à transmettre par le serveur :
- moving(id, position)
- changeColor(id, color)
- setName(id, name)
*/

// 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 == "/")
        filename = "static/conscrit.html";

    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 socket = equipes[q.query.id];
        var position = [q.query.lat, q.query.lon];
        socket.position = position;
        if(socket.shown)
            for(i in equipes)
                equipes[i].emit('moving', {"id": socket.id, "position": position});
        else {
            socket.emit('moving', {"id": socket.id, "position": position});
            for(i in admins)
                admins[i].emit('moving', {"id": socket.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);

console.log("Setup handlers");
io.sockets.on('connection', function(socket){
    console.log("connection !");
//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 !");