platoo/index.js
2020-05-19 19:14:33 +02:00

3768 lines
148 KiB
JavaScript

//on charge les modules et on initialise les paramètres par défaut
const express = require('express');
var app = express();
const server = require('http').Server(app);//https?
const io = require('socket.io')(server);
const bodyParser = require('body-parser');//changer payant ?
var urlencodedParser = bodyParser.urlencoded({ extended: false, parameterLimit:10 });//changer
const async = require('async');
/*const { Pool } = require('pg');
var connection = new Pool({
user: 'admin',
host: '127.0.0.1',
database: 'platoo',
password: 'm1y2s3q4l5',
port: 5432,
})*/
// notice here I'm requiring my database adapter file
// and not requiring node-postgres directly
const connection = require('./db')
//var sqlinjection = require('sql-injection');//necessaire ?
var pattUrl =/^[0-9A-Za-z_-àéèêîïëù]+$/;
var affTime=/[0-9]{2} [0-9]{4} [0-9]{2}:[0-9]{2}:[0-9]{2}/;
//var HTnoeud =/^(?:[^']|(?:\\'))*(?:(?:[^\\]'(?:[^']|(?:\\'))*){2})*#NOEUDS(?:[^']|(?:\\'))*(?:(?:[^\\]'(?:[^']|(?:\\'))*){2})*$/g
var HTnoeud =/(?<=^([^']|\\')*(('([^']|\\')*){2})*)#NOEUDS(?=([^']|\\')*(('([^']|\\')*){2})*$)/g
/* /^
(?:[^']|(?=\\)')*
(?:
(?:
(?!\\)'
(?:[^']|(?=\\)')*
){2}
)*
#NOEUD
(?:[^']|(?=\\)')*
(?:
(?:
(?!\\)'
(?:[^']|(?=\\)')*
){2}
)*
$/ */
/* /
(?<=^
([^']|\\')*
(
(
'
([^']|\\')*
){2}
)*
)
#NOEUD
(?=
([^']|\\')*
(
(
'
([^']|\\')*
){2}
)*
$)
/g */
//aync
//ejs
//icone
//ent
//socketio
//const pool = new Pool({
/*const connection = new Pool({
user: 'admin',
host: '127.0.0.1',
database: 'platoopg',
password: 'm1y2s3q4l5',
port: 5432,
})*/
var NBNOEUD=1024;
function randomString(length, chars) {
var mask = '';
if (chars.indexOf('a') > -1) mask += 'abcdefghijklmnopqrstuvwxyz';
if (chars.indexOf('A') > -1) mask += 'ABCDEFGHIJKLMNOPQRSTUVWXYZ';
if (chars.indexOf('#') > -1) mask += '0123456789';
if (chars.indexOf('!') > -1) mask += '~`!@#$%^&*()_+-={}[]:";\'<>?,./|\\';
var result = '';
for (var i = length; i > 0; --i) result += mask[Math.floor(Math.random() * mask.length)];
return result;
}
//intersection of two arrys
//stack overflow
function intersect(a, b) {
var t;
if (b.length > a.length) t = b, b = a, a = t; // indexOf to loop over shorter
return a.filter(function (e) {
return b.indexOf(e) > -1;
});
}
//il s'agit d'une nouvelle méthode de socket. les socket ont été remplacé par this
function executeSocket(variables={},needsData=true,errMess='',data={},FUN=function(resIP){}){
//console.log(data)
if(this.nomPlatoo && typeof this.nomPlatoo==='string'){
this.nomPlatoo=this.nomPlatoo.substring(0,50);
if(needsData){
var n=Object.keys(variables).length;
var k = 0;
var valide = (typeof data ==='object');
while((valide)&&(k<n)){
valide = valide && ( (typeof data[Object.keys(variables)[k]]) === typeof variables[Object.keys(variables)[k]]);
if((typeof data[Object.keys(variables)[k]]) === 'string'){
data[Object.keys(variables)[k]].substring(0,parseInt(variables[Object.keys(variables)[k]]));
}
k+=1;
}
}else{
var valide = true;
}
if(valide){
var refresh = function(){
this.emit('refresh');
}
const query = {
text: 'SELECT id_page,noeud_courant,id_jeu_depart FROM platooschem.page WHERE nom_page = $1;',
values: [this.nomPlatoo],
}
connection.query(query,function(err,resIP){
if(err){
console.log('erreur de '+errMess+' : '+err.stack);
}else{
if(resIP.rows.length>0){
//results[0].length>0 & results[1].length>0 & results[2].length>0
FUN(resIP.rows);
}else{
console.log('erreur de '+errMess+' : bad id_page');
}
}
});
}else{
console.log(errMess+'.data incorrect dans executeSocket');
this.emit('refresh');
}
}else {
this.emit('noname');
}
}
function checkValide(variables={},needsData=true,errMess='',data={}){
if(needsData){
var n=Object.keys(variables).length;
var k = 0;
var valide = (typeof data ==='object');
while((valide)&&(k<n)){
valide = valide && ( (typeof data[Object.keys(variables)[k]]) === typeof variables[Object.keys(variables)[k]]);
if((typeof data[Object.keys(variables)[k]]) === 'string'){
data[Object.keys(variables)[k]].substring(0,parseInt(variables[Object.keys(variables)[k]]));
}
k+=1;
}
}else{
var valide = true;
}
return valide
}
/*function NoeudsBDD(resIP,errFun,dataErrFun,queryString,FUN,errMess='Erreur in NoeudsBDD :'){
const query = {
text: 'SELECT noeud_precedent,noeud_suivant FROM save_on_page WHERE id_page = $1;',
values: [resIP[0].id_page],
}
connection.query(query,function(errlinks,reslinks){
if(errlinks){
console.log(errMess+errlinks.stack);
//res.redirect('/accueil');//passer le nom en paramètre?
errFun(dataErrFun);
return false;
}else{
var noeuds=[resIP[0].noeud_courant];
var noeuds_suivants=[];
var noeuds_precedents=[];
for(var i=0; i< reslinks.rows.length;i++){
noeuds_suivants.push(reslinks.rows[i].noeud_suivant)
}
for(var i=0; i< reslinks.rows.length;i++){
noeuds_precedents.push(reslinks.rows[i].noeud_precedent)
}
//if(typeof noeuds_suivants == 'number'){
// noeuds_suivants=[noeuds_suivants];
//}
//if(typeof noeuds_precedents == 'number'){
// noeuds_precedents=[noeuds_precedents];
//}
while((noeuds.indexOf(0)==-1) && (noeuds_suivants.indexOf(noeuds[noeuds.length-1])!=-1)){
noeuds.push(noeuds_precedents[noeuds_suivants.indexOf(noeuds[noeuds.length-1])]);
}
noeuds=noeuds.toString().replace(/,0/,'');
noeuds=noeuds.toString().replace(/^0,/,'');
//queryString.replace(HTnoeud,noeuds);
queryString=queryString.replace(HTnoeud,noeuds);
//console.log(queryString);
connection.query(queryString,FUN);
return true;
}
});
}*/
function queryChainedClient(client,query,callback,data,resTot){
client.query(query,function(err,results){
if(err){
//err.message=err.stack;
callback(err);
}else{
resTot.push(results.rows);
callback(null,data,resTot);
}
});
};
connection.queryChained = function(query,callback,data,resTot){
this.query(query,function(err,results){
if(err){
//err.message=err.stack;
callback(err);
}else{
resTot.push(results.rows);
callback(null,data,resTot);
}
});
};
server.listen(8080);
app.use(express.static(__dirname + '/public'));
//empêche le injection sql
//app.use(sqlinjection);
//on fait les routes avec express
app
.get('/',function(req,res){
res.redirect('/accueil');
})
.get('/accueil/',function(req,res){
/*connection.query('select * from information_schema.tables',function(e,r){
if(e){
console.log(e)
}else{
console.log(r)
}
})*/
connection.query('SELECT nom_jeu FROM platooschem.jeu ORDER BY nom_jeu;',function(err,results){
if(err){
console.log('erreur de connexion : '+err.stack);
var parametresAccueil = {
url_defaut:'',
nomsJeux:[]
};
res.render('accueil.ejs',parametresAccueil);
}else{
nomsJeux=[];
for(var i =0;i<results.rows.length;i++){
nomsJeux.push(results.rows[i].nom_jeu);
}
var parametresAccueil = {
url_defaut:'',
nomsJeux:nomsJeux
};
res.render('accueil.ejs',parametresAccueil);
}
});
})
.post('/accueil/',urlencodedParser,function(req,res){
//on vérifie l'entrée
//on essaie de se connecter à la bdd
//on regarde si le nom du jeux et le nom de la page sont dans la bdd
var valide_url = (req.body.url && typeof req.body.url === 'string' && pattUrl.test(req.body.url.substring(0,50)));
var valide_jeu = req.body.jeu && typeof req.body.jeu ==='string' ;
var valide_hasard = (req.body.hasard && req.body.hasard === 'on') && valide_jeu;
if(valide_url && !valide_hasard){
req.body.url = req.body.url.substring(0,50);
}
if(valide_hasard || valide_url){
async.waterfall([
function(callback){
var jeu_ok = true;
var page_dontexist = true;
if(valide_hasard){
var query ='SELECT nom_page FROM platooschem.page;';
}else{
var query = {
text:'SELECT nom_page FROM platooschem.page WHERE nom_page = $1;',
values:[req.body.url]
};
}
connection.query(query,function(err,results){
if(err){
callback(err);
}else{
if(valide_hasard){
page_dontexist=false;
while(!page_dontexist){
page_dontexist=true;
req.body.url = randomString(20,'aA');
var i = 0;
while((page_dontexist) && i < results.length){
if(req.body.url === results.rows[i].nom_page){
page_dontexist=false;
}
i+=1;
}
}
}else{
if(results.rows.length>0){
page_dontexist=false;
}
}
}
callback(null,jeu_ok,page_dontexist);
});
},
function(jeu_ok,page_dontexist,callback){
if(page_dontexist && valide_jeu){
const query = {
text:'SELECT nom_jeu FROM platooschem.jeu WHERE nom_jeu = $1;',
values:[req.body.jeu]
};
connection.query(query,function(err,results){
if(err){
callback(err);
}else{
if(results.rows.length===0){
jeu_ok=false;
}
callback(null,jeu_ok,page_dontexist);
}
});
}else if(!page_dontexist){
res.redirect('/p/'+req.body.url);
callback(false);
}else{
//texte à afficher sur la page: jeu pas valide
//res.redirect('/accueil');
callback({stack:'jeu non valide'});
}
},
function(jeu_ok,page_dontexist,callback){
//si ok:
if(jeu_ok){
//on crée une page
async.waterfall([
function(callback2){
var id_page=0;
var id_jeu=0;
connection.query('SELECT MAX(id_page)+1 AS id FROM platooschem.page;',function(err,results){
if(err){
//console.log('ERROR :'+err.stack);//ATT
//err.message=err.stack
callback2(err);
}else{
if(results.rows.length===0){
id_page=1;
}else{
id_page=results.rows[0].id||1;//si null->id=1
}
callback2(null,id_page,id_jeu);
}
});
},
function(id_page,id_jeu,callback2){
const query = {
text:'SELECT id_jeu AS id FROM platooschem.jeu WHERE nom_jeu = $1;',
values:[req.body.jeu]
};
connection.query(query,function(err,results){
if(err){
//console.log('ERROR :'+err.stack);//ATT
//err.message=err.stack
callback2(err);
}else{
id_jeu=results.rows[0].id;
callback2(null,id_page,id_jeu);
}
});
},
//On démarre une transaction, pour que tout soit ajouté d'un coup ou annulé ensemble
function(id_page,id_jeu,callback2){
//https://node-postgres.com/features/transactions
connection.connect((err, client, done) => {
//gere l'erreur et le rollback
const shouldAbort = err => {
if (err) {
console.error('Error in transaction', err.stack)
client.query('ROLLBACK', err => {
// release the client back to the pool
done();
if (err) {
console.error('Error rolling back client', err.stack)
callback2(err);
}
})
}
return !!err
}
//les instructions: on démarre l transaction
client.query('BEGIN', err => {
if (shouldAbort(err)) return
//un waterfall pour faire toutes les requêtes
async.waterfall([
function(callback3){
const query={
text:'INSERT INTO platooschem.page (id_page,nom_page,id_jeu_depart,nombre_trashs,creating_date,noeud_courant) SELECT $1,$2,id_jeu,nombre_trashs,CURRENT_TIMESTAMP,1 FROM platooschem.jeu WHERE id_jeu = $3; ',
values:[id_page,req.body.url,id_jeu]
};
client.query(query,function(err,results){
if(err){
callback3(err);
}else{
//resTot.push(results);
resTot=[results.rows];
data={id_page:id_page,id_jeu:id_jeu};
callback3(null,data,resTot);
}
});
},
function(data,resTot,callback3){
const query={
text:'INSERT INTO platooschem.joueur_on_page (id_page,id_joueur,label_joueur,action_clic_onboard,action_scroll_onboard,clickable_board,click_board_create_type,click_board_move_type,click_board_move_bac) SELECT $1,'+'id_joueur,label_joueur,action_clic_onboard,action_scroll_onboard,clickable_board,click_board_create_type,click_board_move_type,click_board_move_bac FROM platooschem.joueur_on_jeu WHERE id_jeu = $2; ',
values:[data.id_page,data.id_jeu]
};
queryChainedClient(client,query,callback3,data,resTot);
},
function(data,resTot,callback3){
const query={
text:'INSERT INTO platooschem.save_on_page (id_page,noeud_precedent,noeud_suivant,date,type_action,auteur,couleur,id_joueur) SELECT $1,0,1,CURRENT_TIMESTAMP,\'create\',NULL,NULL,1;',
values:[data.id_page]
};
queryChainedClient(client,query,callback3,data,resTot);
},
function(data,resTot,callback3){
const query={
text:'INSERT INTO platooschem.box_on_page (id_page,diese_box_on_page,num_box_on_page,id_pion,noeud_start) SELECT $1,diese_box_on_jeu,num_box_on_jeu,id_pion,1 FROM platooschem.box_on_jeu WHERE id_jeu = $2; ',
values:[data.id_page,data.id_jeu]
};
queryChainedClient(client,query,callback3,data,resTot);
},
function(data,resTot,callback3){
const query={
text:'INSERT INTO platooschem.stop_box_on_page (id_page,num_box_on_page,noeud_stop) SELECT $1,num_box_on_jeu,0 FROM platooschem.box_on_jeu WHERE id_jeu = $2; ',
values:[data.id_page,data.id_jeu]
};
queryChainedClient(client,query,callback3,data,resTot);
},
function(data,resTot,callback3){
const query={
text:'INSERT INTO platooschem.bac_on_page (id_page,diese_bac_on_page,num_bac_on_page,label_bac,noeud_start) SELECT $1,diese_bac_on_jeu,num_bac_on_jeu,label_bac,1 FROM platooschem.bac_on_jeu WHERE id_jeu = $2; ',
values:[data.id_page,data.id_jeu]
};
queryChainedClient(client,query,callback3,data,resTot);
},
function(data,resTot,callback3){
const query={
text:'INSERT INTO platooschem.stop_bac_on_page (id_page,num_bac_on_page,noeud_stop) SELECT $1,num_bac_on_jeu,0 FROM platooschem.bac_on_jeu WHERE id_jeu = $2; ',
values:[data.id_page,data.id_jeu]
};
queryChainedClient(client,query,callback3,data,resTot);
},
function(data,resTot,callback3){
const query={
text:'INSERT INTO platooschem.board_on_page (id_page,diese_board_on_page,num_board_on_page,id_board,noeud_start) SELECT $1,diese_board_on_jeu,num_board_on_jeu,id_board,1 FROM platooschem.board_on_jeu WHERE id_jeu = $2; ',
values:[data.id_page,data.id_jeu]
};
queryChainedClient(client,query,callback3,data,resTot);
},
function(data,resTot,callback3){
const query={
text:'INSERT INTO platooschem.stop_board_on_page (id_page,num_board_on_page,noeud_stop) SELECT $1,num_board_on_jeu,0 FROM platooschem.board_on_jeu WHERE id_jeu = $2; ',
values:[data.id_page,data.id_jeu]
};
queryChainedClient(client,query,callback3,data,resTot);
},
function(data,resTot,callback3){
const query={
text:'INSERT INTO platooschem.pion_on_bac_on_page (id_page,diese_bac_on_page,id_pion,nombre_pions,diese_pion_on_bac_on_page,num_pion_on_bac_on_page,noeud_start) SELECT $1,'+'diese_bac_on_jeu,id_pion,nombre_pions,diese_pion_on_bac_on_jeu,num_pion_on_bac_on_jeu,1 FROM platooschem.pion_on_bac_on_jeu WHERE id_jeu = $2; ',
values:[data.id_page,data.id_jeu]
};
queryChainedClient(client,query,callback3,data,resTot);
},
function(data,resTot,callback3){
const query={
text:'INSERT INTO platooschem.stop_pion_on_bac_on_page (id_page,diese_bac_on_page,num_pion_on_bac_on_page,noeud_stop) SELECT $1,diese_bac_on_jeu,num_pion_on_bac_on_jeu,0 FROM platooschem.pion_on_bac_on_jeu WHERE id_jeu = $2; ',
values:[data.id_page,data.id_jeu]
};
queryChainedClient(client,query,callback3,data,resTot);
},
function(data,resTot,callback3){
const query={
text:'INSERT INTO platooschem.pion_on_board_on_page (id_page,diese_board_on_page,id_pion,position_x,position_y,taille,diese_pion_on_board_on_page,num_pion_on_board_on_page,noeud_start) SELECT $1,'+'diese_board_on_jeu,id_pion,position_x,position_y,taille,diese_pion_on_board_on_jeu,num_pion_on_board_on_jeu,1 FROM platooschem.pion_on_board_on_jeu WHERE id_jeu = $2; ',
values:[data.id_page,data.id_jeu]
};
queryChainedClient(client,query,callback3,data,resTot);
},
function(data,resTot,callback3){
const query={
text:'INSERT INTO platooschem.stop_pion_on_board_on_page (id_page,diese_board_on_page,num_pion_on_board_on_page,noeud_stop) SELECT $1,'+'diese_board_on_jeu,num_pion_on_board_on_jeu,0 FROM platooschem.pion_on_board_on_jeu WHERE id_jeu = $2; ',
values:[data.id_page,data.id_jeu]
};
queryChainedClient(client,query,callback3,data,resTot);
},
function(data,resTot,callback3){
const query={
text:'INSERT INTO platooschem.carac_pions_page (id_page,id_pion,change_pion,diese_bac_on_page,taille) SELECT $1,'+'id_pion,change_pion,diese_bac_on_jeu,taille FROM platooschem.carac_pions_jeu WHERE id_jeu = $2; ',
values:[data.id_page,data.id_jeu]
};
queryChainedClient(client,query,callback3,data,resTot);
},
function(data,resTot,callback3){
const query={
text:'INSERT INTO platooschem.carac_pions_joueur_on_page (id_page,id_joueur,id_pion,change_pion,diese_bac_on_page,taille) SELECT $1,id_joueur,id_pion,change_pion,diese_bac_on_jeu,taille FROM platooschem.carac_pions_joueur_on_jeu WHERE id_jeu = $2;',
values:[data.id_page,data.id_jeu]
};
client.query(query,function(err,results){
if(err){
callback3(err);
}else{
//resTot.push(results.rows);
resTot.push(results.rows);
callback3(null,resTot);
}
});
}
],function(err){
if(shouldAbort(err)){
return false;
}else{
client.query('COMMIT', err => {
if (err) {
console.error('Error committing transaction', err.stack);
callback2(err);
}else{
res.redirect('/p/'+req.body.url);
callback2(null);
}
done();
});
}
});
});
});
}
],
function(err) {
if(err){
console.log('erreur dans la création de la page : ' + err.stack);
//res.redirect('/accueil');
callback(err);
}else{
callback(null);
}
}
);
}else{
//texte à afficher sur la page : jeu n'existe pas
//res.redirect('/accueil');
callback({stack:'le jeu n existe pas'});
}
}
],
function(err) {
if(err){
console.log('erreur lors de la demande de connection: ' + err.stack);
res.redirect('/accueil');
}
}
);
}else{
res.redirect('/accueil');
//message : pas bon formulaire (nom url ou check)
}
})
.get('/p/:pageid/',function(req,res){
//vérifier id -> necesaire ? remplacer " " par _ ?
if(!pattUrl.test(req.params.pageid)){
res.writeHead(403,{'Content-Type': 'text/plain'});
res.write('Forbidden characters in URL');
res.end();
}else{
connection.connect((err, client, done) => {
//gere l'erreur et le rollback
const shouldAbort = err => {
if (err) {
client.query('ROLLBACK', err => {
if (err) {
console.log('erreur de suppression de la page : '+err.stack);
}
// release the client back to the pool
done();
})
}
return !!err
}
async.waterfall([
function(callback){
client.query('BEGIN',function(err){
if(err){
callback(err);
}else{
callback(null);
}
});
},
function(callback){
const query={
text:'SELECT id_page,noeud_courant FROM platooschem.page WHERE nom_page =$1;',
values:[req.params.pageid]
};
client.query(query,function(err,results_1){
if(err){
//console.log('erreur sql :'+err.stack);
res.redirect('/accueil');//passer le nom en paramètre?
callback(err);
}else{
if(results_1.rows.length>1){
//console.log('plusieurs pages');
res.redirect('/accueil');//supprimer les pages ?
callback('plusieurs pages');
}else if(results_1.rows.length==0){
res.redirect('/accueil');//passer le nom en paramètre?
callback('page absente');
}else{
//renvoyer la page à partir de la bdd
//NoeudsBDD(results,errFun=function(res){res.redirect('/accueil')},dataErrFun=res,
var id_page = results_1.rows[0].id_page;
callback(null,id_page);
}
}
});
},
function(id_page,callback){
const query={
text:'SELECT nombre_trashs,noeud_courant,creating_date FROM platooschem.page WHERE id_page =$1; ',
values:[id_page]
};
client.query(query,function(err,results){
if(err){
callback(err);
}else{
//resTot.push(results.rows);
results_2=[results.rows];
callback(null,id_page,results_2);
}
});
},
function(id_page,results_2,callback){
const query={
text:'SELECT fa.label_fonction AS action_clic_onboard, '+
'fb.label_fonction AS action_scroll_onboard, '+
'fc.label_fonction AS clickable_board, '+
'pa.nom_pion AS click_board_create_type, '+
'pb.nom_pion AS click_board_move_type, '+
'click_board_move_bac FROM platooschem.joueur_on_page '+
'JOIN platooschem.bdd_fonctions fa ON action_clic_onboard = fa.id_fonction '+
'JOIN platooschem.bdd_fonctions fb ON action_scroll_onboard = fb.id_fonction '+
'JOIN platooschem.bdd_fonctions fc ON clickable_board = fc.id_fonction '+
'JOIN platooschem.pion pa ON click_board_create_type = pa.id_pion '+
'JOIN platooschem.pion pb ON click_board_move_type = pb.id_pion '+
'WHERE id_joueur = 1 AND id_page =$1; ',
values:[id_page]
};
queryChainedClient(client,query,callback,id_page,results_2);
},
function(id_page,results_2,callback){
const query={
text:'SELECT pa.nom_pion AS id_pion, pb.nom_pion AS change_pion, pa.svg_pion AS svg_pion, '+
'c.diese_bac_on_page,c.taille FROM platooschem.carac_pions_joueur_on_page c '+
'JOIN platooschem.pion pa ON c.id_pion = pa.id_pion '+
'JOIN platooschem.pion pb ON c.change_pion = pb.id_pion '+
'WHERE c.id_joueur = 1 AND c.id_page =$1; ',
values:[id_page]
};
queryChainedClient(client,query,callback,id_page,results_2);
},
function(id_page,results_2,callback){
const query={
text:'SELECT p.svg_pion,p.nom_pion,b.diese_box_on_page,p.directed,b.num_box_on_page,b.noeud_start,s.nstop noeud_stop FROM platooschem.box_on_page b'+
' JOIN platooschem.pion p ON b.id_pion = p.id_pion'+
' JOIN (SELECT ARRAY_AGG(noeud_stop) nstop,MAX(num_box_on_page) num,MAX(id_page) id FROM platooschem.stop_box_on_page WHERE id_page =$1 GROUP BY num_box_on_page) AS s'+
' ON b.id_page=s.id AND b.num_box_on_page=s.num'+
' WHERE b.id_page =$1 ORDER BY b.diese_box_on_page; ',
values:[id_page]
};
queryChainedClient(client,query,callback,id_page,results_2);
},
function(id_page,results_2,callback){
const query={
text:'SELECT diese_bac_on_page,num_bac_on_page,label_bac,noeud_start,s.nstop noeud_stop FROM platooschem.bac_on_page'+
' JOIN (SELECT ARRAY_AGG(noeud_stop) nstop,MAX(num_bac_on_page) num,MAX(id_page) id FROM platooschem.stop_bac_on_page WHERE id_page =$1 GROUP BY num_bac_on_page) AS s'+
' ON id_page=s.id AND num_bac_on_page=s.num'+
' WHERE id_page =$1 ORDER BY diese_bac_on_page;',
values:[id_page]
};
queryChainedClient(client,query,callback,id_page,results_2);
},
function(id_page,results_2,callback){
const query={
text:'SELECT pp.diese_bac_on_page,p.svg_pion,p.nom_pion,pp.nombre_pions,pp.diese_pion_on_bac_on_page,p.directed,pp.num_pion_on_bac_on_page,pp.noeud_start,s.nstop noeud_stop FROM platooschem.pion_on_bac_on_page pp'+
' JOIN platooschem.pion p ON pp.id_pion = p.id_pion'+
' JOIN (SELECT ARRAY_AGG(noeud_stop) nstop,MAX(num_pion_on_bac_on_page) num,MAX(diese_bac_on_page) diese,MAX(id_page) id FROM platooschem.stop_pion_on_bac_on_page WHERE id_page =$1 GROUP BY num_pion_on_bac_on_page) AS s'+
' ON pp.id_page=s.id AND pp.num_pion_on_bac_on_page=s.num AND pp.diese_bac_on_page=s.diese'+
' WHERE pp.id_page = $1 ORDER BY pp.num_pion_on_bac_on_page; ',
values:[id_page]
};
queryChainedClient(client,query,callback,id_page,results_2);
},
function(id_page,results_2,callback){
const query={
text:'SELECT bp.num_board_on_page,bp.diese_board_on_page,b.svg_board,b.nom_board,bp.noeud_start,s.nstop noeud_stop FROM platooschem.board_on_page bp'+
' JOIN platooschem.board b ON bp.id_board = b.id_board'+
' JOIN (SELECT ARRAY_AGG(noeud_stop) nstop,MAX(num_board_on_page) num,MAX(id_page) id FROM platooschem.stop_board_on_page WHERE id_page =$1 GROUP BY num_board_on_page) AS s'+
' ON bp.id_page=s.id AND bp.num_board_on_page=s.num'+
' WHERE bp.id_page = $1 ORDER BY diese_board_on_page; ',
values:[id_page]
};
queryChainedClient(client,query,callback,id_page,results_2);
},
function(id_page,results_2,callback){
const query={
text:'SELECT pp.diese_board_on_page,pp.diese_pion_on_board_on_page,pp.num_pion_on_board_on_page,p.nom_pion,p.svg_pion,pp.position_x,pp.position_y,pp.taille,p.directed,pp.noeud_start,s.nstop noeud_stop FROM platooschem.pion_on_board_on_page pp'+
' JOIN platooschem.pion p ON pp.id_pion = p.id_pion'+
' JOIN (SELECT ARRAY_AGG(noeud_stop) nstop,MAX(num_pion_on_board_on_page) num,MAX(diese_board_on_page) diese,MAX(id_page) id FROM platooschem.stop_pion_on_board_on_page WHERE id_page = $1 GROUP BY num_pion_on_board_on_page) AS s'+
' ON pp.id_page=s.id AND pp.num_pion_on_board_on_page=s.num AND pp.diese_board_on_page=s.diese'+
' WHERE pp.id_page =$1 ORDER BY num_pion_on_board_on_page;',
values:[id_page]
};
queryChainedClient(client,query,callback,id_page,results_2);
},
function(id_page,results_2,callback){
const query={
text:'SELECT id_joueur,label_joueur FROM platooschem.joueur_on_jeu j JOIN platooschem.page p ON j.id_jeu=p.id_jeu_depart WHERE id_page =$1 ORDER BY label_joueur; ',
values:[id_page]
};
queryChainedClient(client,query,callback,id_page,results_2);
},
function(id_page,results_2,callback){
const query={
text:'SELECT DISTINCT id_board,nom_board FROM platooschem.board ORDER BY nom_board; ',
values:[]
};
queryChainedClient(client,query,callback,id_page,results_2);
},
function(id_page,results_2,callback){
const query={
text:'SELECT DISTINCT id_pion,nom_pion FROM platooschem.pion ORDER BY nom_pion; ',
values:[]
};
queryChainedClient(client,query,callback,id_page,results_2);
},
function(id_page,results_2,callback){
const query={
text:'SELECT time,message,auteur,couleur,id_message FROM platooschem.chat_on_page WHERE id_page = $1 ORDER BY time DESC; ',
values:[id_page]
};
queryChainedClient(client,query,callback,id_page,results_2);
},
function(id_page,results_2,callback){
const query={
text:'SELECT j.wiki AS wiki FROM platooschem.page p JOIN platooschem.jeu j ON p.id_jeu_depart=j.id_jeu;',
values:[]
};
queryChainedClient(client,query,callback,id_page,results_2);
},
function(id_page,results_2,callback){
const query={
text:'SELECT s.noeud_precedent, s.noeud_suivant, s.date, s.auteur, s.couleur, j.label_joueur FROM platooschem.save_on_page s JOIN platooschem.page p ON s.id_page=p.id_page JOIN platooschem.joueur_on_jeu j ON s.id_joueur = j.id_joueur AND p.id_jeu_depart=j.id_jeu WHERE s.id_page =$1;',
values:[id_page]
};
client.query(query,function(err,results){
if(err){
err.message=err.stack;
callback(err);
}else{
results_2.push(results.rows);
callback(null,results_2);
}
});
},
function(results_2,callback){
client.query('COMMIT',function(err,results){
if(err){
err.message=err.stack;
callback(err);
}else{
callback(null,results_2);
}
});
}
],
function(err,results_2){
if(shouldAbort(err)){
console.log('Erreur de chargement de la page depuis la BDD : '+err.stack);
res.redirect('/accueil');//passer le nom en paramètre?
}else{
done();
var noeuds=[results_2[0][0].noeud_courant];
var noeuds_suivants=[];
var noeuds_precedents=[];
for(var i=0; i< results_2[13].length;i++){
noeuds_suivants.push(results_2[13][i].noeud_suivant)
noeuds_precedents.push(results_2[13][i].noeud_precedent)
}
var new_noeud=0;
while((noeuds.indexOf(0)==-1) && (noeuds_suivants.indexOf(noeuds[noeuds.length-1])!=-1)){
new_noeud=noeuds_precedents[noeuds_suivants.indexOf(noeuds[noeuds.length-1])];
noeuds.push(new_noeud);
}
if(noeuds[noeuds.length-1]==0){
noeuds.pop();
}
var params ={
objBoxes : [],
objBoards : [],
objBacs : [],
NTrashs : 0,
action_clic_onboardStr : '',
action_scroll_onboardStr : '',
clickable_boardStr : '',
click_board_create_type : 0,
click_board_move_type : 0,
click_board_move_bac : '',
tabPionListe : [],
tabPionChange : [],
tabPionMove : [],
tabPionTaille : [],
tabPionSvg : [],
nomPlatoo : req.params.pageid,
Joueurs : [],
Boxes :[],
Boards : [],
Chat : [],
Save : [],
wiki:''//,
// maxDiesePion : 0,
// maxDieseBoard : 0,
// maxDieseBac : 0,
// maxDieseGroupe : 0,
// maxDieseBox : 0
}
params.NTrashs = results_2[0][0].nombre_trashs;
params.noeud_courant = results_2[0][0].noeud_courant;
params.action_clic_onboardStr = results_2[1][0].action_clic_onboard;
params.action_scroll_onboardStr = results_2[1][0].action_scroll_onboard;
params.clickable_boardStr = results_2[1][0].clickable_board;
params.click_board_create_type = results_2[1][0].click_board_create_type;
if(params.click_board_create_type === null){
params.click_board_create_type=-1;
}
params.click_board_move_type = results_2[1][0].click_board_move_type;
if(params.click_board_move_type === null){
params.click_board_move_type=-1;
}
params.click_board_move_bac = results_2[1][0].click_board_move_bac;
if(params.click_board_move_bac === null){
params.click_board_move_bac=-1;
}
params.tabPionListe = [];
params.tabPionChange = [];
params.tabPionMove = [];
params.tabPionTaille = [];
params.tabPionSvg = [];
for(var i = 0; i < results_2[2].length; i++){
params.tabPionListe.push(results_2[2][i].id_pion);
if(results_2[2][i].change_pion === null){
results_2[2][i].change_pion=-1;
}
params.tabPionChange.push(results_2[2][i].change_pion);
if(results_2[2][i].diese_bac_on_page === null){
results_2[2][i].diese_bac_on_page=-1;
}
params.tabPionMove.push(results_2[2][i].diese_bac_on_page);
params.tabPionTaille.push(results_2[2][i].taille);
params.tabPionSvg.push(results_2[2][i].svg_pion);
}
params.objBoxes = [];
var display ='';
for(var i = 0; i<results_2[3].length;i++){
/*var noeuds_stop = results_2[3][i].noeud_stop.split(',').map(function (x) {
return parseInt(x, 10);
});*/
var noeuds_stop = results_2[3][i].noeud_stop
//if( (noeuds.indexOf(results_2[3][i].noeud_start)!= -1) && (noeuds.indexOf(results_2[3][i].noeud_stop)==-1)) {
if( (noeuds.indexOf(results_2[3][i].noeud_start)!= -1) && (intersect(noeuds,noeuds_stop).length===0) ){
display='actif';
}else{
display='inactif';
}
params.objBoxes.push({
nom : results_2[3][i].nom_pion,
svg : results_2[3][i].svg_pion,
diese : results_2[3][i].diese_box_on_page,
num : results_2[3][i].num_box_on_page,
directed : results_2[3][i].directed,
noeud_start : results_2[3][i].noeud_start,
noeud_stop : results_2[3][i].noeud_stop,
display : display
});
// if(results_2[3][i].diese_box_on_page>params.maxDieseBox){
// params.maxDieseBox = results_2[3][i].diese_box_on_page;
// }
}
params.objBacs = [];
var i=0;
var c=0;
while(i<results_2[4].length){
var diese=results_2[4][i].diese_bac_on_page;
params.objBacs.push({
bacs :[],
groupes : [],
diese : results_2[4][i].diese_bac_on_page
});
while(i<results_2[4].length && diese===results_2[4][i].diese_bac_on_page){
/*var noeuds_stop = results_2[4][i].noeud_stop.split(',').map(function (x) {
return parseInt(x, 10);
});*/
var noeuds_stop = results_2[4][i].noeud_stop
if( (noeuds.indexOf(results_2[4][i].noeud_start)!= -1) && (intersect(noeuds,noeuds_stop).length===0) ){
display='actif';
}else{
display='inactif';
}
params.objBacs[c].bacs.push({
label : results_2[4][i].label_bac,
num : results_2[4][i].num_bac_on_page,
noeud_start : results_2[4][i].noeud_start,
noeud_stop : results_2[4][i].noeud_stop,
display : display
});
i=i+1
}
c=c+1;
}
var j = 0;
for(var i = 0;i<results_2[5].length;i++){
var n=0;
var cont=true;
while(params.objBacs[j].diese != results_2[5][i].diese_bac_on_page || cont){
j++;
if(j>=params.objBacs.length){
n++;
j = 0;
if(n==2){
cont=false;
}
}
}
/*var noeuds_stop = results_2[5][i].noeud_stop.split(',').map(function (x) {
return parseInt(x, 10);
});*/
var noeuds_stop = results_2[5][i].noeud_stop;
if( (noeuds.indexOf(results_2[5][i].noeud_start)!= -1) && (intersect(noeuds,noeuds_stop).length===0) ){
display='actif';
}else{
display='inactif';
}
params.objBacs[j].groupes.push({
nom : results_2[5][i].nom_pion,
svg : results_2[5][i].svg_pion,
N : results_2[5][i].nombre_pions,
diese : results_2[5][i].diese_pion_on_bac_on_page,
num : results_2[5][i].num_pion_on_bac_on_page,
directed : results_2[5][i].directed,
noeud_start : results_2[5][i].noeud_start,
noeud_stop : results_2[5][i].noeud_stop,
display : display
});
// if(results_2[5][i].diese_pion_on_bac_on_page>params.maxDieseGroupe){
// params.maxDieseGroupe = results_2[5][i].diese_pion_on_bac_on_page;
// }
}
params.objBoards = [];
var i=0;
var c=0;
while(i<results_2[6].length){
var diese=results_2[6][i].diese_board_on_page;
params.objBoards.push({
boards :[],
pions : [],
diese : results_2[6][i].diese_board_on_page
});
while(i<results_2[6].length && diese===results_2[6][i].diese_board_on_page){
/*var noeuds_stop = results_2[6][i].noeud_stop.split(',').map(function (x) {
return parseInt(x, 10);
});*/
var noeuds_stop = results_2[6][i].noeud_stop;
if( (noeuds.indexOf(results_2[6][i].noeud_start)!= -1) && (intersect(noeuds,noeuds_stop).length===0) ){
display='actif';
}else{
display='inactif';
}
params.objBoards[c].boards.push({
svg : results_2[6][i].svg_board,
nom : results_2[6][i].nom_board,
num : results_2[6][i].num_board_on_page,
noeud_start : results_2[6][i].noeud_start,
noeud_stop : results_2[6][i].noeud_stop,
display : display
});
i=i+1
}
c=c+1;
}
var j = 0;
for(var i = 0;i<results_2[7].length;i++){
var n=0;
var cont=true;
while(params.objBoards[j].diese != results_2[7][i].diese_board_on_page || cont){
j++;
if(j>=params.objBoards.length){
n++;
j = 0;
if(n==2){
cont=false;
}
}
}
/*var noeuds_stop = results_2[7][i].noeud_stop.split(',').map(function (x) {
return parseInt(x, 10);
});*/
var noeuds_stop = results_2[7][i].noeud_stop;
if( (noeuds.indexOf(results_2[7][i].noeud_start)!= -1) && (intersect(noeuds,noeuds_stop).length===0) ){
display='actif';
}else{
display='inactif';
}
params.objBoards[j].pions.push({
nom : results_2[7][i].nom_pion,
svg : results_2[7][i].svg_pion,
x : results_2[7][i].position_x,
y : results_2[7][i].position_y,
height: results_2[7][i].taille,
diese : results_2[7][i].diese_pion_on_board_on_page,
num : results_2[7][i].num_pion_on_board_on_page,
directed : results_2[7][i].directed,
noeud_start : results_2[7][i].noeud_start,
noeud_stop : results_2[7][i].noeud_stop,
display : display
});
}
for(var i=0;i<results_2[8].length;i++){
params.Joueurs.push({
id : results_2[8][i].id_joueur,
nom : results_2[8][i].label_joueur
});
}
for(var i=0;i<results_2[9].length;i++){
params.Boards.push({
id : results_2[9][i].id_board,
nom : results_2[9][i].nom_board
});
}
for(var i=0;i<results_2[10].length;i++){
params.Boxes.push({
id : results_2[10][i].id_pion,
nom : results_2[10][i].nom_pion
});
}
for(var i=0;i<results_2[11].length;i++){
params.Chat.push({
id : results_2[11][i].id_message,
auteur : results_2[11][i].auteur,
message : results_2[11][i].message,
couleur : results_2[11][i].couleur,
time : affTime.exec(results_2[11][i].time)
});
}
params.wiki = results_2[12][0].wiki;
params.Save = [{
noeud_precedent : 0,
noeud_suivant : 1,
date : results_2[0][0].creating_date,
auteur : "",
couleur : "black",
label_joueur : "",
x:0,
y:0
}];
var noeuds_sui=[1];
var noeuds_pre=[0];
var y=[0];
var epaisseur=[1];
//on a déjà fait le premier noeud
for(var i = 1; i<results_2[13].length;i++){
y_pre_ind=params.Save[noeuds_sui.indexOf(results_2[13][i].noeud_precedent)].y;
epais=epaisseur[noeuds_sui.indexOf(results_2[13][i].noeud_precedent)];
//Save.y au debut indique l'indice dans le vecteur y
if(noeuds_pre.indexOf(results_2[13][i].noeud_precedent)===-1){
//il n'y a pas de nouveau embranchement
new_y_ind=y_pre_ind;
}else{
//nouvel embranchement
//la valeur du nouveau y
new_y = y[y_pre_ind] + epais;
//on corrige le vecteur y
for(var j=0;j<y.length;j++){
if(y[j]>=new_y){
y[j]=y[j]+1;
}
}
//on ajoute le nouveau y
y.push(new_y)
//nouvel indice
new_y_ind=y.length-1;
//on corrige l'epaisseur
var noe = results_2[13][i].noeud_precedent;
while(noe>0){
epaisseur[noeuds_sui.indexOf(noe)]+=1;
noe=params.Save[noeuds_sui.indexOf(noe)].noeud_precedent;
}
epais=1;
}
params.Save.push({
noeud_precedent : results_2[13][i].noeud_precedent,
noeud_suivant : results_2[13][i].noeud_suivant,
date : results_2[13][i].date,
auteur : results_2[13][i].auteur,
couleur : results_2[13][i].couleur,
label_joueur : results_2[13][i].label_joueur,
x:params.Save[noeuds_sui.indexOf(results_2[13][i].noeud_precedent)].x+1,
y:new_y_ind,
ypre:y_pre_ind,
xpre:params.Save[noeuds_sui.indexOf(results_2[13][i].noeud_precedent)].x
});
noeuds_sui.push(results_2[13][i].noeud_suivant);
noeuds_pre.push(results_2[13][i].noeud_precedent);
epaisseur.push(epais);
}
params.SaveYmax=Math.max(...y);
//on cherche xmax et on remplace les indices de y par les vraies valeurs
xmax=0;
for(var i = 0; i<params.Save.length ;i++){
if(params.Save[i].x>xmax){
xmax=params.Save[i].x
}
params.Save[i].y = y[params.Save[i].y]
params.Save[i].ypre = y[params.Save[i].ypre]
}
params.SaveXmax=xmax;
res.render('platoo.ejs',params);
}
});
});
}
})
.use(function(req, res, next){
res.writeHead(404,{'Content-Type': 'text/plain'});
res.write('Page not found');
res.end();
});
//gérer les autres erreurs que 404
//faire une page 404
//on lance le WebSocket
io.on('connection',function(socket){
//on ajoute la méthode executeSocket
socket.executeSocket=executeSocket;
//socket.runModifJeu=runModifJeu;
//socket.runModifJeuWrap=runModifJeuWrap;
socket.on('newplatoo',function(nomPlatoo){
//securiser nomPlatoo
if(typeof nomPlatoo==='string' && pattUrl.test(nomPlatoo)){
nomPlatoo = nomPlatoo.substring(0,50);
if(socket.nomPlatoo){
socket.leave(socket.nomPlatoo);
}
socket.nomPlatoo=nomPlatoo;
socket.join(nomPlatoo);
}else{
console.log("nomPlatoo incorrect");
socket.emit('refresh');
}
});
//supprime la page
//ok
socket.on('delete',function(){
socket.executeSocket(variables={},needsData=false,errMess='delete',data={},FUN=function(resIP){
connection.connect((err, client, done) => {
//gere l'erreur et le rollback
const shouldAbort = err => {
if (err) {
console.error('erreur de suppression de la page', err.stack);
client.query('ROLLBACK', err => {
if (err) {
console.log('erreur de suppression de la page : '+err.stack);
}
socket.emit('refresh');
// release the client back to the pool
done();
})
}
return !!err
}
//les instructions: on démarre l transaction
client.query('BEGIN', err => {
if (shouldAbort(err)) return
//un waterfall pour faire toutes les requêtes
async.waterfall([
function(callback){
const query={
text:'DELETE FROM platooschem.stop_pion_on_bac_on_page WHERE id_page = $1 ; ',
values:[resIP[0].id_page]
};
client.query(query,function(err,results){
if(err){
callback(err);
}else{
//resTot.push(results);
resTot=[results.rows];
id_page=resIP[0].id_page;
callback(null,id_page,resTot);
}
});
},
function(id_page,resTot,callback){
const query={
text:'DELETE FROM platooschem.stop_pion_on_board_on_page WHERE id_page = $1 ; ',
values:[id_page]
};
queryChainedClient(client,query,callback,id_page,resTot);
},
function(id_page,resTot,callback){
const query={
text:'DELETE FROM platooschem.pion_on_bac_on_page WHERE id_page = $1 ; ',
values:[id_page]
};
queryChainedClient(client,query,callback,id_page,resTot);
},
function(id_page,resTot,callback){
const query={
text:'DELETE FROM platooschem.carac_pions_joueur_on_page WHERE id_page = $1 ; ',
values:[id_page]
};
queryChainedClient(client,query,callback,id_page,resTot);
},
function(id_page,resTot,callback){
const query={
text:'DELETE FROM platooschem.pion_on_board_on_page WHERE id_page = $1 ; ',
values:[id_page]
};
queryChainedClient(client,query,callback,id_page,resTot);
},
function(id_page,resTot,callback){
const query={
text:'DELETE FROM platooschem.carac_pions_page WHERE id_page = $1 ; ',
values:[id_page]
};
queryChainedClient(client,query,callback,id_page,resTot);
},
function(id_page,resTot,callback){
const query={
text:'DELETE FROM platooschem.stop_bac_on_page WHERE id_page = $1 ; ',
values:[id_page]
};
queryChainedClient(client,query,callback,id_page,resTot);
},
function(id_page,resTot,callback){
const query={
text:'DELETE FROM platooschem.bac_on_page WHERE id_page = $1 ; ',
values:[id_page]
};
queryChainedClient(client,query,callback,id_page,resTot);
},
function(id_page,resTot,callback){
const query={
text:'DELETE FROM platooschem.stop_box_on_page WHERE id_page = $1 ; ',
values:[id_page]
};
queryChainedClient(client,query,callback,id_page,resTot);
},
function(id_page,resTot,callback){
const query={
text:'DELETE FROM platooschem.box_on_page WHERE id_page = $1 ; ',
values:[id_page]
};
queryChainedClient(client,query,callback,id_page,resTot);
},
function(id_page,resTot,callback){
const query={
text:'DELETE FROM platooschem.stop_board_on_page WHERE id_page = $1 ; ',
values:[id_page]
};
queryChainedClient(client,query,callback,id_page,resTot);
},
function(id_page,resTot,callback){
const query={
text:'DELETE FROM platooschem.board_on_page WHERE id_page = $1 ; ',
values:[id_page]
};
queryChainedClient(client,query,callback,id_page,resTot);
},
function(id_page,resTot,callback){
const query={
text:'DELETE FROM platooschem.chat_on_page WHERE id_page = $1 ; ',
values:[id_page]
};
queryChainedClient(client,query,callback,id_page,resTot);
},
function(id_page,resTot,callback){
const query={
text:'DELETE FROM platooschem.save_on_page WHERE id_page = $1 ; ',
values:[id_page]
};
queryChainedClient(client,query,callback,id_page,resTot);
},
function(id_page,resTot,callback){
const query={
text:'DELETE FROM platooschem.joueur_on_page WHERE id_page = $1 ; ',
values:[id_page]
};
queryChainedClient(client,query,callback,id_page,resTot);
},
function(id_page,resTot,callback){
const query={
text:'DELETE FROM platooschem.page WHERE id_page = $1 ; ',
values:[id_page]
};
client.query(query,function(err,results){
if(err){
callback(err);
}else{
//resTot.push(results.rows);
resTot.push(results.rows);
id_page=id_page;
callback(null,resTot);
}
});
}
],function(err,resTot){
if(shouldAbort(err)){
//socket.emit('refresh');
}else{
client.query('COMMIT', err => {
if (err) {
console.log('erreur de suppression de la page : '+err.stack);
socket.emit('refresh');
}else{
socket.broadcast.to(socket.nomPlatoo).emit('refresh');
socket.emit('refresh');
}
done();
});
}
});
});
});
});
});
//remise à zéro de la page
//ok
socket.on('raz',function(){
socket.executeSocket(variables={},needsData=false,errMess='RAZ',data={},FUN=function(resIP){
connection.connect((err, client, done) => {
//gere l'erreur et le rollback
const shouldAbort = err => {
if (err) {
console.error('erreur de remise à zéro ', err.stack)
client.query('ROLLBACK', err => {
if (err) {
console.log('erreur de remise à zéro : '+err.stack);
//socket.emit('refresh');
}
socket.emit('refresh');
// release the client back to the pool
done();
})
}
return !!err
}
//les instructions: on démarre l transaction
client.query('BEGIN', err => {
if (shouldAbort(err)) return
//un waterfall pour faire toutes les requêtes
async.waterfall([
function(callback){
const query={
text:'DELETE FROM platooschem.stop_pion_on_bac_on_page WHERE id_page = $1 ; ',
values:[resIP[0].id_page]
};
client.query(query,function(err,results){
if(err){
callback(err);
}else{
//resTot.push(results.rows);
resTot=[results.rows];
data={id_page:resIP[0].id_page,id_jeu_depart:resIP[0].id_jeu_depart}
callback(null,data,resTot);
}
});
},
function(data,resTot,callback){
const query={
text:'DELETE FROM platooschem.pion_on_bac_on_page WHERE id_page = $1 ; ',
values:[data.id_page]
};
queryChainedClient(client,query,callback,data,resTot);
},
function(data,resTot,callback){
const query={
text:'DELETE FROM platooschem.stop_pion_on_board_on_page WHERE id_page = $1 ; ',
values:[data.id_page]
};
queryChainedClient(client,query,callback,data,resTot);
},
function(data,resTot,callback){
const query={
text:'DELETE FROM platooschem.pion_on_board_on_page WHERE id_page = $1 ; ',
values:[data.id_page]
};
queryChainedClient(client,query,callback,data,resTot);
},
function(data,resTot,callback){
const query={
text:'DELETE FROM platooschem.carac_pions_joueur_on_page WHERE id_page = $1 ; ',
values:[data.id_page]
};
queryChainedClient(client,query,callback,data,resTot);
},
function(data,resTot,callback){
const query={
text:'DELETE FROM platooschem.carac_pions_page WHERE id_page = $1 ; ',
values:[data.id_page]
};
queryChainedClient(client,query,callback,data,resTot);
},
function(data,resTot,callback){
const query={
text:'DELETE FROM platooschem.stop_bac_on_page WHERE id_page = $1 ; ',
values:[data.id_page]
};
queryChainedClient(client,query,callback,data,resTot);
},
function(data,resTot,callback){
const query={
text:'DELETE FROM platooschem.bac_on_page WHERE id_page = $1 ; ',
values:[data.id_page]
};
queryChainedClient(client,query,callback,data,resTot);
},
function(data,resTot,callback){
const query={
text:'DELETE FROM platooschem.stop_box_on_page WHERE id_page = $1 ; ',
values:[data.id_page]
};
queryChainedClient(client,query,callback,data,resTot);
},
function(data,resTot,callback){
const query={
text:'DELETE FROM platooschem.box_on_page WHERE id_page = $1 ; ',
values:[data.id_page]
};
queryChainedClient(client,query,callback,data,resTot);
},
function(data,resTot,callback){
const query={
text:'DELETE FROM platooschem.stop_board_on_page WHERE id_page = $1 ; ',
values:[data.id_page]
};
queryChainedClient(client,query,callback,data,resTot);
},
function(data,resTot,callback){
const query={
text:'DELETE FROM platooschem.board_on_page WHERE id_page = $1 ; ',
values:[data.id_page]
};
queryChainedClient(client,query,callback,data,resTot);
},
function(data,resTot,callback){
const query={
text:'DELETE FROM platooschem.chat_on_page WHERE id_page = $1 ; ',
values:[data.id_page]
};
queryChainedClient(client,query,callback,data,resTot);
},
function(data,resTot,callback){
const query={
text:'DELETE FROM platooschem.save_on_page WHERE id_page = $1 ; ',
values:[data.id_page]
};
queryChainedClient(client,query,callback,data,resTot);
},
function(data,resTot,callback){
const query={
text:'DELETE FROM platooschem.joueur_on_page WHERE id_page = $1 ; ',
values:[data.id_page]
};
queryChainedClient(client,query,callback,data,resTot);
},
function(data,resTot,callback){
const query={
text:'INSERT INTO platooschem.joueur_on_page (id_page,id_joueur,label_joueur,action_clic_onboard,action_scroll_onboard,clickable_board,click_board_create_type,click_board_move_type,click_board_move_bac) SELECT $1,id_joueur,label_joueur,action_clic_onboard,action_scroll_onboard,clickable_board,click_board_create_type,click_board_move_type,click_board_move_bac FROM platooschem.joueur_on_jeu WHERE id_jeu = $2; ',
values:[data.id_page,data.id_jeu_depart]
};
queryChainedClient(client,query,callback,data,resTot);
},
function(data,resTot,callback){
const query={
text:'INSERT INTO platooschem.save_on_page (id_page,noeud_precedent,noeud_suivant,date,type_action,auteur,couleur,id_joueur) SELECT $1,0,1,CURRENT_TIMESTAMP,\'create\',NULL,NULL,1;',
values:[data.id_page]
};
queryChainedClient(client,query,callback,data,resTot);
},
function(data,resTot,callback){
const query={
text:'INSERT INTO platooschem.box_on_page (id_page,diese_box_on_page,num_box_on_page,id_pion,noeud_start) SELECT $1,'+'diese_box_on_jeu,num_box_on_jeu,id_pion,1 FROM platooschem.box_on_jeu WHERE id_jeu = $2; ',
values:[data.id_page,data.id_jeu_depart]
};
queryChainedClient(client,query,callback,data,resTot);
},
function(data,resTot,callback){
const query={
text:'INSERT INTO platooschem.stop_box_on_page (id_page,num_box_on_page,noeud_stop) SELECT $1,num_box_on_jeu,0 FROM platooschem.box_on_jeu WHERE id_jeu = $2; ',
values:[data.id_page,data.id_jeu_depart]
};
queryChainedClient(client,query,callback,data,resTot);
},
function(data,resTot,callback){
const query={
text:'INSERT INTO platooschem.bac_on_page (id_page,diese_bac_on_page,num_bac_on_page,label_bac,noeud_start) SELECT $1,'+'diese_bac_on_jeu,num_bac_on_jeu,label_bac,1 FROM platooschem.bac_on_jeu WHERE id_jeu = $2; ',
values:[data.id_page,data.id_jeu_depart]
};
queryChainedClient(client,query,callback,data,resTot);
},
function(data,resTot,callback){
const query={
text:'INSERT INTO platooschem.stop_bac_on_page (id_page,num_bac_on_page,noeud_stop) SELECT $1,num_bac_on_jeu,0 FROM platooschem.bac_on_jeu WHERE id_jeu = $2; ',
values:[data.id_page,data.id_jeu_depart]
};
queryChainedClient(client,query,callback,data,resTot);
},
function(data,resTot,callback){
const query={
text:'INSERT INTO platooschem.board_on_page (id_page,diese_board_on_page,num_board_on_page,id_board,noeud_start) SELECT $1,diese_board_on_jeu,num_board_on_jeu,id_board,1 FROM platooschem.board_on_jeu WHERE id_jeu = $2; ',
values:[data.id_page,data.id_jeu_depart]
};
queryChainedClient(client,query,callback,data,resTot);
},
function(data,resTot,callback){
const query={
text:'INSERT INTO platooschem.stop_board_on_page (id_page,num_board_on_page,noeud_stop) SELECT $1,num_board_on_jeu,0 FROM platooschem.board_on_jeu WHERE id_jeu = $2; ',
values:[data.id_page,data.id_jeu_depart]
};
queryChainedClient(client,query,callback,data,resTot);
},
function(data,resTot,callback){
const query={
text:'INSERT INTO platooschem.pion_on_bac_on_page (id_page,diese_bac_on_page,id_pion,nombre_pions,diese_pion_on_bac_on_page,num_pion_on_bac_on_page,noeud_start) SELECT $1,'+'diese_bac_on_jeu,id_pion,nombre_pions,diese_pion_on_bac_on_jeu,num_pion_on_bac_on_jeu,1 FROM platooschem.pion_on_bac_on_jeu WHERE id_jeu = $2; ',
values:[data.id_page,data.id_jeu_depart]
};
queryChainedClient(client,query,callback,data,resTot);
},
function(data,resTot,callback){
const query={
text:'INSERT INTO platooschem.stop_pion_on_bac_on_page (id_page,diese_bac_on_page,num_pion_on_bac_on_page,noeud_stop) SELECT $1,diese_bac_on_jeu,num_pion_on_bac_on_jeu,0 FROM platooschem.pion_on_bac_on_jeu WHERE id_jeu = $2; ',
values:[data.id_page,data.id_jeu_depart]
};
queryChainedClient(client,query,callback,data,resTot);
},
function(data,resTot,callback){
const query={
text:'INSERT INTO platooschem.pion_on_board_on_page (id_page,diese_board_on_page,id_pion,position_x,position_y,taille,diese_pion_on_board_on_page,num_pion_on_board_on_page,noeud_start) SELECT $1,'+'diese_board_on_jeu,id_pion,position_x,position_y,taille,diese_pion_on_board_on_jeu,num_pion_on_board_on_jeu,1 FROM platooschem.pion_on_board_on_jeu WHERE id_jeu = $2; ',
values:[data.id_page,data.id_jeu_depart]
};
queryChainedClient(client,query,callback,data,resTot);
},
function(data,resTot,callback){
const query={
text:'INSERT INTO platooschem.stop_pion_on_board_on_page (id_page,diese_board_on_page,num_pion_on_board_on_page,noeud_stop) SELECT $1,diese_board_on_jeu,num_pion_on_board_on_jeu,0 FROM platooschem.pion_on_board_on_jeu WHERE id_jeu = $2; ',
values:[data.id_page,data.id_jeu_depart]
};
queryChainedClient(client,query,callback,data,resTot);
},
function(data,resTot,callback){
const query={
text:'INSERT INTO platooschem.carac_pions_page (id_page,id_pion,change_pion,diese_bac_on_page,taille) SELECT $1,id_pion,change_pion,diese_bac_on_jeu,taille FROM platooschem.carac_pions_jeu WHERE id_jeu = $2; ',
values:[data.id_page,data.id_jeu_depart]
};
queryChainedClient(client,query,callback,data,resTot);
},
function(data,resTot,callback){
const query={
text:'INSERT INTO platooschem.carac_pions_joueur_on_page (id_page,id_joueur,id_pion,change_pion,diese_bac_on_page,taille) SELECT $1,id_joueur,id_pion,change_pion,diese_bac_on_jeu,taille FROM platooschem.carac_pions_joueur_on_jeu WHERE id_jeu = $2;',
values:[data.id_page,data.id_jeu_depart]
};
queryChainedClient(client,query,callback,data,resTot);
},
function(id_page,resTot,callback){
const query={
text:'UPDATE platooschem.page SET noeud_courant=1 WHERE id_page = $1; ',
values:[data.id_page]
};
client.query(query,function(err,results){
if(err){
callback(err);
}else{
//resTot.push(results.rows);
resTot.push(results.rows);
id_page=id_page;
callback(null,resTot);
}
});
}
],function(err,resTot){
if(shouldAbort(err)){
//socket.emit('refresh');
}else{
client.query('COMMIT', err => {
if (err) {
console.log('erreur de remise à zéro : '+err.stack);
socket.emit('refresh');
}else{
socket.broadcast.to(socket.nomPlatoo).emit('refresh');
socket.emit('refresh');
}
done();
});
}
});
});
});
});
});
//ok
socket.on('getAction',function(data){
socket.executeSocket(variables={id_joueur:1},needsData=true,errMess='getAction',data=data,FUN=function(resIP){
var query ={
text: 'SELECT fa.label_fonction AS action_clic_onboard, fb.label_fonction AS action_scroll_onboard, fc.label_fonction AS clickable_board, '+
'pa.nom_pion AS click_board_create_type, pb.nom_pion AS click_board_move_type, j.click_board_move_bac '+
'FROM platooschem.joueur_on_page j JOIN platooschem.pion pa ON j.click_board_create_type=pa.id_pion JOIN platooschem.pion pb ON j.click_board_move_type=pb.id_pion '+
'JOIN platooschem.bdd_fonctions fa ON j.action_clic_onboard = fa.id_fonction JOIN platooschem.bdd_fonctions fb ON j.action_scroll_onboard = fb.id_fonction JOIN platooschem.bdd_fonctions fc ON j.clickable_board = fc.id_fonction '+
'WHERE id_page = $1 AND id_joueur = $2; ',
values:[resIP[0].id_page,data.id_joueur]
}
connection.query(query,function(err,res2){
if(err){
console.log('erreur de getAction : '+err.stack);
socket.emit('refresh');
}else{
var action_clic_onboard =res2.rows[0].action_clic_onboard;
var action_scroll_onboard =res2.rows[0].action_scroll_onboard;
var clickable_board =res2.rows[0].clickable_board;
var click_board_create_type =res2.rows[0].click_board_create_type;
var click_board_move_type =res2.rows[0].click_board_move_type;
var click_board_move_bac =res2.rows[0].click_board_move_bac;
socket.emit('setAction',{
action_clic_onboard:action_clic_onboard,
action_scroll_onboard:action_scroll_onboard,
clickable_board:clickable_board,
click_board_create_type:click_board_create_type,
click_board_move_type:click_board_move_type,
click_board_move_bac:click_board_move_bac
});
}
});
});
});
//ok
socket.on('chatNew',function(data){
socket.executeSocket(variables={message:'200',
auteur:'20',
couleur:'20'},
needsData=true,errMess='chat_new',data=data,FUN=function(resIP){
connection.connect((err, client, done) => {
//gere l'erreur et le rollback
const shouldAbort = err => {
if (err) {
console.log('erreur de chatNew : '+err.stack);
socket.emit('refresh');
client.query('ROLLBACK', err => {
if (err) {
console.log('erreur de chatNew : '+err.stack);
}
// release the client back to the pool
done();
})
}
return !!err
}
//les instructions: on démarre l transaction
client.query('BEGIN', err => {
if (shouldAbort(err)) return
//un waterfall pour faire toutes les requêtes
async.waterfall([
function(callback){
const query={
text:'INSERT INTO platooschem.chat_on_page (id_page,id_message,auteur,message,couleur,time) '+
'SELECT $1,CASE WHEN MAX(id_message) IS NULL THEN 1 ELSE MAX(id_message)+1 END,'+
'$2,$3,$4,CURRENT_TIMESTAMP FROM platooschem.chat_on_page WHERE id_page = $5; ',
values:[resIP[0].id_page,data.auteur,data.message,data.couleur,resIP[0].id_page]
};
client.query(query,function(err,results){
if(err){
callback(err);
}else{
//resTot.push(results.rows);
res2=[results.rows];
data={
auteur:data.auteur,
couleur:data.couleur,
message:data.message,
id_page:resIP[0].id_page
}
callback(null,data,res2);
}
});
},
function(id_page,res2,callback){
const query={
text:'SELECT id_message,time FROM platooschem.chat_on_page WHERE id_page = $1 ORDER BY id_message DESC LIMIT 1 ; ',
values:[data.id_page]
};
queryChainedClient(client,query,callback,data,res2);
},
function(id_page,res2,callback){
const query={
text:'DELETE FROM platooschem.chat_on_page WHERE id_page = $1 AND time <'+
'(SELECT c.time FROM (SELECT time FROM platooschem.chat_on_page WHERE id_page = $2 ORDER BY time DESC LIMIT 1 OFFSET 19 ) AS c) ; ',
values:[data.id_page,data.id_page]
};
client.query(query,function(err,results){
if(err){
callback(err);
}else{
res2.push(results.rows);
//resTot=[results.rows];
callback(null,res2);
}
});
},
function(res2,callback){
client.query('COMMIT',function(err){
if(shouldAbort(err)) return
callback(null,res2);
});
}
],function(err,res2){
if(shouldAbort(err)){
//console.log('erreur cat on page');
//socket.emit('refresh');
}else if(res2[1].length>0){
var time = affTime.exec(res2[1][0].time);
socket.emit('chatNew',{
message:data.message,
id:res2[1][0].id_message,
auteur:data.auteur,
couleur:data.couleur,
time:time
});
socket.broadcast.to(socket.nomPlatoo).emit('chatNew',{
message:data.message,
id:res2[1][0].id_message,
auteur:data.auteur,
couleur:data.couleur,
time:time
});
done();
}else{
console.log('erreur cat on page');
socket.emit('refresh');
done();
}
});
});
});
});
});
//ok
socket.on('getTabPion',function(data){
socket.executeSocket(variables={id_joueur:1},needsData=true,errMess='getTabPion',data=data,FUN=function(resIP){
const query={
text:'SELECT pa.nom_pion AS id_pion,pa.svg_pion AS svg_pion,pb.nom_pion AS change_pion,diese_bac_on_page,c.taille'+
' AS taille FROM platooschem.carac_pions_joueur_on_page c JOIN platooschem.pion pa ON c.id_pion=pa.id_pion JOIN platooschem.pion pb ON c.change_pion=pb.id_pion WHERE id_page = $1'+
' AND id_joueur = $2;',
values:[resIP[0].id_page,data.id_joueur]
}
connection.query(query,
function(err,res2){
if(err){
console.log('erreur de getTabPion : '+err.stack);
socket.emit('refresh');
}else{
var tabPionListe =[];
var tabPionChange =[];
var tabPionMove =[];
var tabPionTaille=[];
var tabPionSvg=[];
for(var i=0;i<res2.rows.length;i++){
tabPionListe.push(res2.rows[i].id_pion);
tabPionChange.push(res2.rows[i].change_pion);
tabPionMove.push(res2.rows[i].diese_bac_on_page);
tabPionTaille.push(res2.rows[i].taille);
tabPionSvg.push(res2.rows[i].svg_pion);
}
socket.emit('setTabPion',{tabPionListe:tabPionListe, tabPionChange:tabPionChange,tabPionMove:tabPionMove,tabPionTaille:tabPionTaille,tabPionSvg:tabPionSvg});
}
}
);
});
});
//ok
socket.on('add_trash',function(){
socket.executeSocket(variables={},needsData=false,errMess='add_trash',data={},FUN=function(resIP){
const query = {
text:'UPDATE platooschem.page SET nombre_trashs = (nombre_trashs + 1) WHERE id_page = $1 ;',
values:[resIP[0].id_page]
}
connection.query(query,function(err){
if(err){
console.log('erreur de add_trash : '+err.stack);
socket.emit('refresh');
}else{
socket.broadcast.to(socket.nomPlatoo).emit('add_trash');
}
});
});
});
//ok
socket.on('remove_trash',function(){
socket.executeSocket(variables={},needsData=false,errMess='remove_trash',data={},FUN=function(resIP){
const query = {
text:'UPDATE platooschem.page SET nombre_trashs = GREATEST(nombre_trashs -1,0) WHERE id_page = $1 ; ',
values:[resIP[0].id_page]
}
connection.query(query,function(err){
if(err){
console.log('erreur de remove_trash : '+err.stack);
socket.emit('refresh');
}else{
socket.broadcast.to(socket.nomPlatoo).emit('removeElement',{id:'trash',noeud:null});
socket.emit('removeElement',{id:'trash',noeud:null});
}
});
});
});
//ok
socket.on('changeNoeud',function(data){
socket.executeSocket(variables={noeud:1},needsData=true,errMess='changeNoeud',data=data,FUN=function(resIP){
const query ={
text:'SELECT noeud_suivant FROM platooschem.save_on_page WHERE noeud_suivant = $1 AND id_page = $2 ;',
values:[data.noeud,resIP[0].id_page]
}
connection.query(query,
function(err,res1){
if(err){
console.log('erreur de changeNoeud1 : '+err.stack);
socket.emit('refresh');
}else if(resIP.length===0){
console.log('bad noeud de changeNoeud : '+err.stack);
socket.emit('refresh');
}else{
const query ={
text:'UPDATE platooschem.page SET noeud_courant = $1 WHERE id_page = $2 ;',
values:[data.noeud,resIP[0].id_page]
}
connection.query(query,
function(err2,res2){
if(err2){
console.log('erreur de changeNoeud2 : '+err2.stack);
socket.emit('refresh');
}else{
socket.broadcast.to(socket.nomPlatoo).emit('changeNoeud',{noeud:data.noeud});
socket.emit('changeNoeud',{noeud:data.noeud});
}
}
);
}
}
);
});
});
socket.on('ModifJeu',function(dataTot){
socket.executeSocket(variables={auteur:'20',
couleur:'20',
id_joueur:1,
noeud_courant:1},needsData=true,errMess='ModifJeu',data=dataTot,FUN=function(resIP){
//on vérifie le noeud courant
//console.log(dataTot);
//console.log(dataTot.noeud_courant);
//console.log(resIP[0].noeud_courant);
if(dataTot.noeud_courant !== resIP[0].noeud_courant){
//si ça n'est pas le même: il y a un decalage, on ne fait rien
console.log('mauvais noeud');
socket.emit('refresh');
}else{
connection.connect((err, client, done) => {
//gere l'erreur et le rollback
const shouldAbort = err => {
if (err) {
console.log('erreur de ModifJeu1 : '+err.stack);
client.query('ROLLBACK', err => {
if (err) {
console.log('erreur de ModifJeu2 : '+err.stack);
}else{
//console.log('rollbackok');
}
socket.emit('refresh');
// release the client back to the pool
done();
})
}
return !!err
}
//un waterfall pour faire toutes les requêtes
var Array_waterfall = [
function(callback){
//les instructions: on démarre l transaction
client.query('BEGIN',function(err,results){
if(err){
callback(err);
}else{
callback(null);
}
});
},
function(callback){
const query={
text:'SELECT noeud_precedent,noeud_suivant FROM platooschem.save_on_page WHERE id_page = $1;',
values:[resIP[0].id_page]
};
client.query(query,function(err,results){
if(err){
callback(err);
}else{
//resTot.push(results.rows);
resNoeuds=[results.rows];
data={
auteur:dataTot.auteur,
couleur:dataTot.couleur,
message:dataTot.message,
noeud_courant:dataTot.noeud_courant,
id_joueur:dataTot.id_joueur,
id_page:resIP[0].id_page
}
callback(null,data,resNoeuds);
}
});
},
function(data,resNoeuds,callback){
const query={
text:'INSERT INTO platooschem.save_on_page (id_page,noeud_precedent,noeud_suivant,date,type_action,auteur,couleur,id_joueur) SELECT '+
'$1,$2,CASE WHEN MAX(noeud_suivant) IS NULL THEN 1 ELSE MAX(noeud_suivant)+1 END,CURRENT_TIMESTAMP,\'add_groupe\',$3,'+
'$4,$5 FROM platooschem.save_on_page WHERE id_page=$1;',
values:[data.id_page,data.noeud_courant,data.auteur,data.couleur,data.id_joueur]
};
queryChainedClient(client,query,callback,data,resNoeuds);
},
function(data,resNoeuds,callback){
const query={
text:'UPDATE platooschem.page AS p SET noeud_courant = s.new_noeud'+
' FROM (SELECT MAX(id_page) id_p,MAX(noeud_suivant) new_noeud FROM platooschem.save_on_page GROUP BY id_page) AS s '+
' WHERE p.id_page=s.id_p AND p.id_page = $1;',
values:[data.id_page]
};
queryChainedClient(client,query,callback,data,resNoeuds);
},
function(data,resNoeuds,callback){
const query={
text:'SELECT noeud_courant AS new_noeud,CURRENT_TIMESTAMP AS date FROM platooschem.page WHERE id_page=$1;',
values:[data.id_page]
};
client.query(query,function(err,results){
if(err){
callback(err);
}else{
resNoeuds.push(results.rows);
callback(null,resNoeuds);
}
});
},
function(resNoeuds,callback){
emit_broad.push({text:'newNoeud',data:{noeud:resNoeuds[3][0].new_noeud,save:{
noeud_precedent : resIP[0].noeud_courant,
noeud_suivant : resNoeuds[3][0].new_noeud,
date : resNoeuds[3][0].date,
auteur : resIP[0].auteur,
couleur : resIP[0].couleur,
label_joueur : resIP[0].label_joueur,
x:-1,
y:-1,
xpre:-1,
ypre:-1
}}});
emit.push({text:'newNoeud',data:{noeud:resNoeuds[3][0].new_noeud,save:{
noeud_precedent : resIP[0].noeud_courant,
noeud_suivant : resNoeuds[3][0].new_noeud,
date : resNoeuds[3][0].date,
auteur : resIP[0].auteur,
couleur : resIP[0].couleur,
label_joueur : resIP[0].label_joueur,
x:-1,
y:-1,
xpre:-1,
ypre:-1
}}});
//on calcule les noeuds à ajouter
var noeuds=[resIP[0].noeud_courant];
var noeuds_suivants=[];
var noeuds_precedents=[];
for(var i=0; i< resNoeuds[0].length;i++){
noeuds_suivants.push(resNoeuds[0][i].noeud_suivant)
}
for(var i=0; i< resNoeuds[0].length;i++){
noeuds_precedents.push(resNoeuds[0][i].noeud_precedent)
}
while((noeuds.indexOf(0)==-1) && (noeuds_suivants.indexOf(noeuds[noeuds.length-1])!=-1)){
noeuds.push(noeuds_precedents[noeuds_suivants.indexOf(noeuds[noeuds.length-1])]);
}
//noeuds=noeuds.toString().replace(/,0/,'');
//noeuds=noeuds.toString().replace(/^0,/,'');
const index = noeuds.indexOf(0);
if (index > -1) {
noeuds.splice(index, 1);
}
/*noeudsObj = {
noeuds:noeuds,
toPostgres:function(value){
return noeuds.toString()
}
};*/
resNoeuds.push(noeuds);
callback(null,resNoeuds);
}];
//on parcours les différentes requetes qui sont englobées dans le mouvement
var Abort = false;
var emit = [];
var emit_broad = [];
var requetes_tot= [];
var nb_requete = 0;
for(var i=0;i<dataTot.requetes.length;i++){
var requete=dataTot.requetes[i];
requetes_tot.push(requete);
//action erase-------------------------------------------------------------------------
if(requete.action ==='erase'){//ok
if(!checkValide(variables={},needsData=false,errMess='erase',data=requete.data)){
console.log(errMess+'.data incorrect dans erase');
Abort=true;
}else{
//un waterfall pour faire toutes les requêtes
Array_waterfall=Array_waterfall.concat([
function(resNoeuds,callback){
const query={
text:'INSERT INTO platooschem.stop_pion_on_bac_on_page (id_page,diese_bac_on_page,num_pion_on_bac_on_page,noeud_stop)'+
' SELECT id_page,diese_bac_on_page,num_pion_on_bac_on_page,$1 FROM platooschem.pion_on_bac_on_page p'+
' LEFT JOIN (SELECT COUNT(noeud_stop) nbstop,MAX(id_page) id, MAX(num_pion_on_bac_on_page) num, MAX(diese_bac_on_page) diese FROM platooschem.stop_pion_on_bac_on_page'+
' WHERE id_page = $2 AND ARRAY[noeud_stop] <@ $3 GROUP BY id_page,diese_bac_on_page,num_pion_on_bac_on_page) AS g'+
' ON p.id_page=g.id AND p.num_pion_on_bac_on_page = g.num AND p.diese_bac_on_page=g.diese'+
' WHERE id_page = $2 AND ARRAY[noeud_start] <@ $3 AND ( COALESCE(g.nbstop,0)=0 OR g.nbstop=0) ;',
values:[resNoeuds[3][0].new_noeud,resIP[0].id_page,resNoeuds[4]]
};
client.query(query,function(err,results){
if(err){
callback(err);
}else{
//resTot.push(results.rows);
resTot=[results.rows];
callback(null,resNoeuds,resTot);
}
});
},
function(resNoeuds,resTot,callback){
const query={
text:'INSERT INTO platooschem.stop_pion_on_board_on_page (id_page,diese_board_on_page,num_pion_on_board_on_page,noeud_stop)'+
' SELECT id_page,diese_board_on_page,num_pion_on_board_on_page,$1 FROM platooschem.pion_on_board_on_page p'+
' LEFT JOIN (SELECT COUNT(noeud_stop) nbstop,MAX(id_page) id, MAX(num_pion_on_board_on_page) num, MAX(diese_board_on_page) diese FROM platooschem.stop_pion_on_board_on_page'+
' WHERE id_page = $2 AND ARRAY[noeud_stop] <@ $3 GROUP BY id_page,diese_board_on_page,num_pion_on_board_on_page) AS g'+
' ON p.id_page=g.id AND p.num_pion_on_board_on_page = g.num AND p.diese_board_on_page=g.diese'+
' WHERE id_page = $2 AND ARRAY[noeud_start] <@ $3 AND ( COALESCE(g.nbstop,0)=0 OR g.nbstop=0) ;',
values:[resNoeuds[3][0].new_noeud,resIP[0].id_page,resNoeuds[4]]
};
client.query(query,function(err,results){
if(err){
callback(err);
}else{
//resTot.push(results.rows);
resTot.push(results.rows);
callback(null,resNoeuds,resTot);
}
});
},
function(resNoeuds,resTot,callback){
emit.push({text:'erase',data:{noeud:resNoeuds[3][0].new_noeud}});
emit_broad.push({text:'erase',data:{noeud:resNoeuds[3][0].new_noeud}});
nb_requete +=1;
callback(null,resNoeuds);
}
]);
}
//action add_bac--------------------------------------------------------------
}else if(requete.action ==='add_bac'){//ok
if(!checkValide(variables={label:'20'},needsData=true,errMess='erase',data=requete.data)){
console.log(errMess+'.data incorrect dans add_bac');
Abort = true;
}else{
//un waterfall pour faire toutes les requêtes
Array_waterfall=Array_waterfall.concat([
function(resNoeuds,callback){
const query={
text:'INSERT INTO platooschem.bac_on_page (id_page,diese_bac_on_page,num_bac_on_page,label_bac,noeud_start) SELECT $1'+
', CASE WHEN MAX(diese_bac_on_page) IS NULL THEN 1 ELSE MAX(diese_bac_on_page)+1 END, '+
'CASE WHEN MAX(num_bac_on_page) IS NULL THEN 0 ELSE MAX(num_bac_on_page)+1 END,'+
'$2,$3 FROM platooschem.bac_on_page WHERE id_page = $1 ;',
values:[resIP[0].id_page,requetes_tot[nb_requete].data.label,resNoeuds[3][0].new_noeud],
};
client.query(query,function(err,results){
if(err){
callback(err);
}else{
//resTot.push(results.rows);
resTot=[results.rows];
callback(null,resNoeuds,resTot);
}
});
},
function(resNoeuds,resTot,callback){
const query={
text:'INSERT INTO platooschem.stop_bac_on_page (id_page,num_bac_on_page,noeud_stop) SELECT $1'+
' ,MAX(num_bac_on_page),0 FROM platooschem.bac_on_page WHERE id_page = $1 GROUP BY id_page;',
values:[resIP[0].id_page]
};
queryChainedClient(client,query,callback,resNoeuds,resTot);
},
function(resNoeuds,resTot,callback){
const query={
text:'SELECT MAX(diese_bac_on_page) diese,MAX(num_bac_on_page) num FROM platooschem.bac_on_page WHERE id_page = $1 GROUP BY id_page;',
values:[resIP[0].id_page]
};
client.query(query,function(err,results){
if(err){
callback(err);
}else{
//resTot.push(results.rows);
resTot.push(results.rows);
callback(null,resNoeuds,resTot);
}
});
},
function(resNoeuds,resTot,callback){
emit.push({text:'add_bac',data:{diese:resTot[2][0].diese,label:requetes_tot[nb_requete].data.label,num:resTot[2][0].num,noeud:resNoeuds[3][0].new_noeud}});
emit_broad.push({text:'add_bac',data:{diese:resTot[2][0].diese,label:requetes_tot[nb_requete].data.label,num:resTot[2][0].num,noeud:resNoeuds[3][0].new_noeud}});
nb_requete +=1;
callback(null,resNoeuds);
}
]);
}
//action add_box--------------------------------------------------------------
}else if(requete.action ==='add_box'){//ok
if(!checkValide(variables={nom:'45'},needsData=true,errMess='add_box',data=requete.data)){
console.log(errMess+'.data incorrect dans add_box');
Abort = true;
}else{
Array_waterfall=Array_waterfall.concat([
function(resNoeuds,callback){
const query = {
text:'SELECT id_pion,taille,svg_pion FROM platooschem.pion WHERE nom_pion = $1; ',
values:[requetes_tot[nb_requete].data.nom]
}
client.query(query,function(err,results){
if(err){
callback(err);
}else{
//resTot.push(results.rows);
resPion=[results.rows];
callback(null,resNoeuds,resPion);
}
});
},
function(resNoeuds,resPion,callback){
const query = {
text:'SELECT id_pion FROM platooschem.carac_pions_page c JOIN platooschem.page p ON c.id_page = p.id_page WHERE p.id_page = $1;',
values:[resIP[0].id_page]
}
client.query(query,function(err,results){
if(err){
callback(err);
}else{
if(resPion[0].length!=1 ){
//mauvais diese
console.log(resPion);
callback({stack:'mauvais diese add_box'});
//return false;
}else{
resPion.push(results.rows);
callback(null,resNoeuds,resPion);
}
}
});
},
function(resNoeuds,resPion,callback){
//test pour savoir si on doit ajouter des caractéristiques de pion à la page
var test = false;
var j = 0;
while(!test && (j<resPion[1].length)){
if(resPion[1][j].id_pion === resPion[0][0].id_pion){
test = true;
}
j++;
}
//si test est true, alors il y a un commun entre ceux sur la carac_pion_page et le nouveau
test = !test;
//maintenant, test = true indique qu'on doit rajouter la caractéristique
if(!test){
var N = 2;
}else{
var N=4;
}
var r={
resPion:resPion,
resNoeuds:resNoeuds,
test:test,
N:N
}
const query={
text:'INSERT INTO platooschem.box_on_page (id_page,id_pion,diese_box_on_page,num_box_on_page,noeud_start) SELECT $1'+
',$2, new_diese, new_num, $3 FROM platooschem.box_on_page b JOIN (SELECT '+
'CASE WHEN MAX(diese_box_on_page) IS NULL THEN 1 ELSE MAX(diese_box_on_page)+1 END new_diese,'+
'CASE WHEN MAX(num_box_on_page) IS NULL THEN 1 ELSE MAX(num_box_on_page)+1 END new_num,MAX(id_page) id_pageb'+
' FROM platooschem.box_on_page GROUP BY id_page) AS bb ON b.id_page=bb.id_pageb'+
' WHERE id_page = $1 LIMIT 1; ',
values:[resIP[0].id_page,r.resPion[0][0].id_pion,r.resNoeuds[3][0].new_noeud],
};
client.query(query,function(err,results){
if(err){
callback(err);
}else{
//resTot.push(results.rows);
resTot=[results.rows];
callback(null,r,resTot);
}
});
},
function(r,resTot,callback){
const query={
text:'INSERT INTO platooschem.stop_box_on_page (id_page,num_box_on_page,noeud_stop) SELECT $1'+
' ,MAX(num_box_on_page),0 FROM platooschem.box_on_page WHERE id_page = $1 GROUP BY id_page;',
values:[resIP[0].id_page]
};
queryChainedClient(client,query,callback,r,resTot);
},
function(r,resTot,callback){
if(r.test){
const query={
text:'INSERT INTO platooschem.carac_pions_page (id_page,id_pion,change_pion,diese_bac_on_page,taille) SELECT $1,$2,$2,1,$3 ; ',
values:[resIP[0].id_page,r.resPion[0][0].id_pion,r.resPion[0][0].taille]
};
client.query(query,function(err,results){
if(err){
callback(err);
}else{
//resTot.push(results.rows);
resTot.push(results.rows);
callback(null,r,resTot);
}
});
}else{
callback(null,r,resTot);
}
},
function(r,resTot,callback){
if(r.test){
const query={
text:'INSERT INTO platooschem.carac_pions_joueur_on_page (id_joueur,id_page,id_pion,change_pion,diese_bac_on_page,taille) SELECT id_joueur,'+
'$1,$2,$2,1,$3 FROM platooschem.carac_pions_joueur_on_page WHERE id_page = $1 LIMIT 1; ',
values:[resIP[0].id_page,r.resPion[0][0].id_pion,r.resPion[0][0].taille]
};
client.query(query,function(err,results){
if(err){
callback(err);
}else{
//resTot.push(results.rows);
resTot.push(results.rows);
callback(null,r,resTot);
}
});
}else{
callback(null,r,resTot);
}
},
function(r,resTot,callback){
const query={
text:'SELECT MAX(diese_box_on_page) diese,MAX(num_box_on_page) num FROM platooschem.box_on_page WHERE id_page = $1; ',
values:[resIP[0].id_page]
};
client.query(query,function(err,results){
if(err){
callback(err);
}else{
//resTot.push(results.rows);
resTot.push(results.rows);
callback(null,r,resTot);
}
});
},
function(r,resTot,callback){
if(r.test){
emit.push({text:'getTabPion',data:null});
emit_broad.push({text:'getTabPion',data:null});
}
emit.push({text:'add_box',data:{nom:requetes_tot[nb_requete].data.nom,diese:resTot[r.N][0].diese,svg:r.resPion[0][0].svg_pion,num:resTot[r.N][0].num,noeud:r.resNoeuds[3][0].new_noeud}});
emit_broad.push({text:'add_box',data:{nom:requetes_tot[nb_requete].data.nom,diese:resTot[r.N][0].diese,svg:r.resPion[0][0].svg_pion,num:resTot[r.N][0].num,noeud:r.resNoeuds[3][0].new_noeud}});
nb_requete +=1;
callback(null,r.resNoeuds);
}
]);
}
//action add_board--------------------------------------------------------------
}else if(requete.action ==='add_board'){//ok
if(!checkValide(variables={nom:'45'},needsData=true,errMess='add_board',data=requete.data)){
console.log(errMess+'.data incorrect dans add_board');
Abort = true;
}else{
Array_waterfall=Array_waterfall.concat([
function(resNoeuds,callback){
const query={
text:'SELECT id_board,svg_board FROM platooschem.board WHERE nom_board = $1;',
values:[requetes_tot[nb_requete].data.nom]
};
client.query(query,
function(err2,resPion){
if(err2){
console.log('erreur de add_board : '+err2.stack);
callback(err2);
//return false;
}else{
//verif que le pion et la board existent
if(resPion.rows.length!=1 ){
//mauvais diese
console.log('erreur de add_board: mauvais pion');
callback({stack:'erreur de add_board: mauvais pion'});
//return false;
}else{
var r = {
resPion:resPion.rows,
resNoeuds,resNoeuds
}
callback(null,r);
}
}
}
);
},
function(r,callback){
const query={
text:'INSERT INTO platooschem.board_on_page (id_page,diese_board_on_page,num_board_on_page,id_board,noeud_start) SELECT '+
'$1, new_diese, new_num, $2,$3'+
' FROM platooschem.page b LEFT JOIN (SELECT '+
'CASE WHEN MAX(diese_board_on_page) IS NULL THEN 1 ELSE MAX(diese_board_on_page)+1 END new_diese, '+
'CASE WHEN MAX(num_board_on_page) IS NULL THEN 1 ELSE MAX(num_board_on_page)+1 END new_num,MAX(id_page) id_pageb'+
' FROM platooschem.board_on_page GROUP BY id_page) AS bb ON b.id_page=bb.id_pageb'+
' WHERE id_page = $1 LIMIT 1; ',
values:[resIP[0].id_page,r.resPion[0].id_board,r.resNoeuds[3][0].new_noeud],
};
client.query(query,function(err,results){
if(err){
callback(err);
}else{
//resTot.push(results.rows);
resTot=[results.rows];
callback(null,r,resTot);
}
});
},
function(r,resTot,callback){
const query={
text:'INSERT INTO platooschem.stop_board_on_page (id_page,num_board_on_page,noeud_stop) SELECT $1'+
' ,MAX(num_board_on_page),0 FROM platooschem.board_on_page WHERE id_page = $1 GROUP BY id_page;',
values:[resIP[0].id_page]
};
queryChainedClient(client,query,callback,r,resTot);
},
function(r,resTot,callback){
const query={
text:' SELECT MAX(diese_board_on_page) diese,MAX(num_board_on_page) num FROM platooschem.board_on_page WHERE id_page = $1 GROUP BY id_page;',
values:[resIP[0].id_page]
};
client.query(query,function(err,results){
if(err){
callback(err);
}else{
//resTot.push(results.rows);
resTot.push(results.rows);
callback(null,r,resTot);
}
});
},
function(r,resTot,callback){
emit.push({text:'add_board',data:{nom:requetes_tot[nb_requete].data.nom,diese:resTot[2][0].diese,svg:r.resPion[0].svg_board,num:resTot[2][0].num,noeud:r.resNoeuds[3][0].new_noeud}});
emit_broad.push({text:'add_board',data:{nom:requetes_tot[nb_requete].data.nom,diese:resTot[2][0].diese,svg:r.resPion[0].svg_board,num:resTot[2][0].num,noeud:r.resNoeuds[3][0].new_noeud}});
nb_requete +=1;
callback(null,r.resNoeuds)
}
]);
}
//action removeElement--------------------------------------------------------------
}else if(requete.action ==='removeElement'){//
if(!checkValide(variables={id:'45'},needsData=true,errMess='removeElement',data=requete.data)){
console.log(errMess+'.data incorrect dans removeElement');
Abort = true;
}else{
var classe = /^[a-z]+/.exec(requete.data.id).toString();
var id = parseInt(/[0-9]+$/.exec(requete.data.id),10);
if(isNaN(id) && classe !='trash'){
console.log('mauvais diese1');
}else if(classe==='board'){//ok
Array_waterfall=Array_waterfall.concat([
function(resNoeuds,callback){
const query={
text:' SELECT id_page,num_board_on_page,$1 FROM platooschem.board_on_page p'+
' LEFT JOIN (SELECT COUNT(noeud_stop) nbstop,MAX(id_page) id, MAX(num_board_on_page) num FROM platooschem.stop_board_on_page'+
' WHERE id_page = $2 AND ARRAY[noeud_stop] <@ $3 GROUP BY id_page,num_board_on_page) AS g'+
' ON p.id_page=g.id AND p.num_board_on_page = g.num'+
' WHERE id_page = $2 AND diese_board_on_page = $4 AND ARRAY[noeud_start] <@ $3 AND ( COALESCE(g.nbstop,0)=0 OR g.nbstop=0) ;',
values:[resIP[0].noeud_courant,resIP[0].id_page,resNoeuds[4],id]
}
client.query(query,
function(err,res2){
if(err){
console.log('erreur remove board: '+err.stack);
callback(err);
}else if(res2.rows.length!=1){
//console.log('bad id remove board');
callback({stack:'bad id remove board'});
}else{
callback(null,resNoeuds);
}
}
);
},
function(resNoeuds,callback){
const query={
text:'INSERT INTO platooschem.stop_pion_on_board_on_page (id_page,diese_board_on_page,num_pion_on_board_on_page,noeud_stop)'+
' SELECT id_page,diese_board_on_page,num_pion_on_board_on_page,$1 FROM platooschem.pion_on_board_on_page p'+
' LEFT JOIN (SELECT COUNT(noeud_stop) nbstop,MAX(id_page) id, MAX(num_pion_on_board_on_page) num, MAX(diese_board_on_page) diese FROM platooschem.stop_pion_on_board_on_page'+
' WHERE id_page = $2 AND diese_board_on_page = $3 AND ARRAY[noeud_stop] <@ $4 GROUP BY id_page,diese_board_on_page,num_pion_on_board_on_page) AS g'+
' ON p.id_page=g.id AND p.num_pion_on_board_on_page = g.num AND p.diese_board_on_page=g.diese'+
' WHERE id_page = $2 AND diese_board_on_page = $3 AND ARRAY[noeud_start] <@ $4 AND ( COALESCE(g.nbstop,0)=0 OR g.nbstop=0) ;',
values:[resNoeuds[3][0].new_noeud,resIP[0].id_page,id,resNoeuds[4]],
};
client.query(query,function(err,results){
if(err){
callback(err);
}else{
//resTot.push(results.rows);
resTot=[results.rows];
callback(null,resNoeuds,resTot);
}
});
},
function(resNoeuds,resTot,callback){
const query={
text:'INSERT INTO platooschem.stop_board_on_page (id_page,num_board_on_page,noeud_stop)'+
' SELECT id_page,num_board_on_page,$1 FROM platooschem.board_on_page p'+
' LEFT JOIN (SELECT COUNT(noeud_stop) nbstop,MAX(id_page) id, MAX(num_board_on_page) num FROM platooschem.stop_board_on_page'+
' WHERE id_page = $2 AND ARRAY[noeud_stop] <@ $3 GROUP BY id_page,num_board_on_page) AS g'+
' ON p.id_page=g.id AND p.num_board_on_page = g.num'+
' WHERE id_page = $2 AND diese_board_on_page = $4 AND ARRAY[noeud_start] <@ $3 AND ( COALESCE(g.nbstop,0)=0 OR g.nbstop=0) ;',
values:[resNoeuds[3][0].new_noeud,resIP[0].id_page,resNoeuds[4],id]
};
client.query(query,function(err,results){
if(err){
callback(err);
}else{
//resTot.push(results.rows);
resTot.push(results.rows);
callback(null,resNoeuds,resTot);
}
});
},
function(resNoeuds,resTot,callback){
emit.push({text:'removeElement',data:{id:classe+'-'+id,noeud:resNoeuds[3][0].new_noeud}});
emit_broad .push({text:'removeElement',data:{id:classe+'-'+id,noeud:resNoeuds[3][0].new_noeud}});
nb_requete +=1;
callback(null,resNoeuds);
}
]);
}else if(classe==='bac'){//ok
Array_waterfall=Array_waterfall.concat([
function(resNoeuds,callback){
const query={
text:' SELECT num_bac_on_page FROM platooschem.bac_on_page p'+
' LEFT JOIN (SELECT COUNT(noeud_stop) nbstop,MAX(id_page) id, MAX(num_bac_on_page) num FROM platooschem.stop_bac_on_page'+
' WHERE id_page = $1 AND ARRAY[noeud_stop] <@ $2 GROUP BY id_page,num_bac_on_page) AS g'+
' ON p.id_page=g.id AND p.num_bac_on_page = g.num'+
' WHERE id_page = $1 AND diese_bac_on_page = $3 AND ARRAY[noeud_start] <@ $2 AND ( COALESCE(g.nbstop,0)=0 OR g.nbstop=0) ;',
values:[resIP[0].id_page,resNoeuds[4],id]
}
client.query(query,
function(err,res2){
if(err){
console.log('erreur remove bac: '+err.stack);
callback(err)
}else if(res2.rows.length!=1){
//console.log('bad id remove bac');
callback({stack:'bad id remove bac'});
}else{
callback(null,resNoeuds);
}
}
);
},
function(resNoeuds,callback){
const query={
text:'UPDATE platooschem.joueur_on_page SET click_board_move_bac = null WHERE id_page = $1 AND click_board_move_bac = $2 ; ',
values:[resIP[0].id_page,id]
};
client.query(query,function(err,results){
if(err){
callback(err);
}else{
//resTot.push(results.rows);
resTot=[results.rows];
callback(null,resNoeuds,resTot);
}
});
},
function(resNoeuds,resTot,callback){
const query={
text:'UPDATE platooschem.carac_pions_page SET diese_bac_on_page = null WHERE id_page = $1 AND diese_bac_on_page = $2 ; ',
values:[resIP[0].id_page,id]
};
queryChainedClient(client,query,callback,resNoeuds,resTot);
},
function(resNoeuds,resTot,callback){
const query={
text:'UPDATE platooschem.carac_pions_joueur_on_page SET diese_bac_on_page = null WHERE id_page = $1 AND diese_bac_on_page = $2 ; ',
values:[resIP[0].id_page,id]
};
queryChainedClient(client,query,callback,resNoeuds,resTot);
},
function(resNoeuds,resTot,callback){
const query={
text:'INSERT INTO platooschem.stop_pion_on_bac_on_page (id_page,diese_bac_on_page,num_pion_on_bac_on_page,noeud_stop)'+
' SELECT id_page,diese_bac_on_page,num_pion_on_bac_on_page,$1 FROM platooschem.pion_on_bac_on_page p'+
' LEFT JOIN (SELECT COUNT(noeud_stop) nbstop,MAX(id_page) id, MAX(num_pion_on_bac_on_page) num, MAX(diese_bac_on_page) diese FROM platooschem.stop_pion_on_bac_on_page'+
' WHERE id_page = $2 AND diese_bac_on_page = $3 AND ARRAY[noeud_stop] <@ $4 GROUP BY id_page,diese_bac_on_page,num_pion_on_bac_on_page) AS g'+
' ON p.id_page=g.id AND p.num_pion_on_bac_on_page = g.num AND p.diese_bac_on_page=g.diese'+
' WHERE id_page = $2 AND diese_bac_on_page = $3 AND ARRAY[noeud_start] <@ $4 AND ( COALESCE(g.nbstop,0)=0 OR g.nbstop=0) ;',
values:[resNoeuds[3][0].new_noeud,resIP[0].id_page,id,resNoeuds[4]]
};
queryChainedClient(client,query,callback,resNoeuds,resTot);
},
function(resNoeuds,resTot,callback){
const query={
text:'INSERT INTO platooschem.stop_bac_on_page (id_page,num_bac_on_page,noeud_stop)'+
' SELECT id_page,num_bac_on_page,$1 FROM platooschem.bac_on_page p'+
' LEFT JOIN (SELECT COUNT(noeud_stop) nbstop,MAX(id_page) id, MAX(num_bac_on_page) num FROM platooschem.stop_bac_on_page'+
' WHERE id_page = $2 AND ARRAY[noeud_stop] <@ $3 GROUP BY id_page,num_bac_on_page) AS g'+
' ON p.id_page=g.id AND p.num_bac_on_page = g.num'+
' WHERE id_page = $2 AND diese_bac_on_page = $4 AND ARRAY[noeud_start] <@ $3 AND ( COALESCE(g.nbstop,0)=0 OR g.nbstop=0) ;',
values:[resNoeuds[3][0].new_noeud,resIP[0].id_page,resNoeuds[4],id]
};
client.query(query,function(err,results){
if(err){
callback(err);
}else{
//resTot.push(results.rows);
resTot.push(results.rows);
callback(null,resNoeuds,resTot);
}
});
},
function(resNoeuds,resTot,callback){
emit.push({text:'removeElement',data:{id:classe+'-'+id,noeud:resNoeuds[3][0].new_noeud}});
emit_broad.push({text:'removeElement',data:{id:classe+'-'+id,noeud:resNoeuds[3][0].new_noeud}});
nb_requete +=1;
callback(null,resNoeuds);
}
]);
}else if(classe==='box'){//ok
Array_waterfall=Array_waterfall.concat([
function(resNoeuds,callback){
const query={
text:' SELECT num_box_on_page,$1 FROM platooschem.box_on_page p'+
' LEFT JOIN (SELECT COUNT(noeud_stop) nbstop,MAX(id_page) id, MAX(num_box_on_page) num FROM platooschem.stop_box_on_page'+
' WHERE id_page = $2 AND ARRAY[noeud_stop] <@ $3 GROUP BY id_page,num_box_on_page) AS g'+
' ON p.id_page=g.id AND p.num_box_on_page = g.num'+
' WHERE id_page = $2 AND diese_box_on_page = $4 AND ARRAY[noeud_start] <@ $3 AND ( COALESCE(g.nbstop,0)=0 OR g.nbstop=0) ;',
values:[resIP[0].noeud_courant,resIP[0].id_page,resNoeuds[4],id]
}
client.query(query,
function(err,res2){
if(err){
//console.log('erreur remove box: '+err.stack);
scallback(err);
}else if(res2.rows.length!=1){
//console.log('bad id remove box');
//socket.emit('refresh');
callback({stack:'bad id remove box'});
}else{
callback(null,resNoeuds);
}
}
);
},
function(resNoeuds,callback){
const query={
text:'INSERT INTO platooschem.stop_box_on_page (id_page,num_box_on_page,noeud_stop)'+
' SELECT id_page,num_box_on_page,$1 FROM platooschem.box_on_page p'+
' LEFT JOIN (SELECT COUNT(noeud_stop) nbstop,MAX(id_page) id, MAX(num_box_on_page) num FROM platooschem.stop_box_on_page'+
' WHERE id_page = $2 AND ARRAY[noeud_stop] <@ $3 GROUP BY id_page,num_box_on_page) AS g'+
' ON p.id_page=g.id AND p.num_box_on_page = g.num'+
' WHERE id_page = $2 AND diese_box_on_page = $4 AND ARRAY[noeud_start] <@ $3 AND ( COALESCE(g.nbstop,0)=0 OR g.nbstop=0) ;',
values:[resNoeuds[3][0].new_noeud,resIP[0].id_page,resNoeuds[4],id]
}
client.query(query,
function(err){
if(err){
console.log('erreure de remove : '+err.stack);
//socket.emit('refresh');
callback(err);
//return false;
}else{
emit.push({text:'removeElement',data:{id:classe+'-'+id,noeud:resNoeuds[3][0].new_noeud}});
emit_broad.push({text:'removeElement',data:{id:classe+'-'+id,noeud:resNoeuds[3][0].new_noeud}});
nb_requete +=1;
callback(null,resNoeuds);
}
}
);
}
]);
}else if(classe==='pion'){//ok
Array_waterfall=Array_waterfall.concat([
function(resNoeuds,callback){
const query={
text:' SELECT num_pion_on_board_on_page FROM platooschem.pion_on_board_on_page p'+
' LEFT JOIN (SELECT COUNT(noeud_stop) nbstop,MAX(id_page) id, MAX(num_pion_on_board_on_page) num, MAX(diese_board_on_page) diese FROM platooschem.stop_pion_on_board_on_page'+
' WHERE id_page = $1 AND ARRAY[noeud_stop] <@ $2 GROUP BY id_page,diese_board_on_page,num_pion_on_board_on_page) AS g'+
' ON p.id_page=g.id AND p.num_pion_on_board_on_page = g.num AND p.diese_board_on_page=g.diese'+
' WHERE id_page = $1 AND num_pion_on_board_on_page = $3 AND ARRAY[noeud_start] <@ $2 AND ( COALESCE(g.nbstop,0)=0 OR g.nbstop=0) ;',
values:[resIP[0].id_page,resNoeuds[4],id]
}
client.query(query,
function(err,res2){
if(err){
//console.log('erreur remove pion: '+err.stack);
//socket.emit('refresh');
callback(err);
}else if(res2.rows.length!=1){
//console.log('bad id remove pion');
callback({stack:'bad id remove pion'});
//socket.emit('refresh');
}else{
callback(null,resNoeuds);
}
}
);
},
function(resNoeuds,callback){
const query={
text:'INSERT INTO platooschem.stop_pion_on_board_on_page (id_page,diese_board_on_page,num_pion_on_board_on_page,noeud_stop)'+
' SELECT id_page,diese_board_on_page,num_pion_on_board_on_page,$1 FROM platooschem.pion_on_board_on_page p'+
' LEFT JOIN (SELECT COUNT(noeud_stop) nbstop,MAX(id_page) id, MAX(num_pion_on_board_on_page) num, MAX(diese_board_on_page) diese FROM platooschem.stop_pion_on_board_on_page'+
' WHERE id_page = $2 AND ARRAY[noeud_stop] <@ $3 GROUP BY id_page,diese_board_on_page,num_pion_on_board_on_page) AS g'+
' ON p.id_page=g.id AND p.num_pion_on_board_on_page = g.num AND p.diese_board_on_page=g.diese'+
' WHERE id_page = $2 AND num_pion_on_board_on_page = $4 AND ARRAY[noeud_start] <@ $3 AND ( COALESCE(g.nbstop,0)=0 OR g.nbstop=0) ;',
values:[resNoeuds[3][0].new_noeud,resIP[0].id_page,resNoeuds[4],id]
}
client.query(query,
function(err,res2){
if(err){
console.log('erreure de remove : '+err.stack);
//socket.emit('refresh');
callback(err);
}else{
//console.log(res2)
emit.push({text:'removeElement',data:{id:classe+'-'+id,noeud:resNoeuds[3][0].new_noeud}});
emit_broad.push({text:'removeElement',data:{id:classe+'-'+id,noeud:resNoeuds[3][0].new_noeud}});
nb_requete +=1;
callback(null,resNoeuds);
}
}
);
}
]);
}else if(classe==='groupe'){//ok
Array_waterfall=Array_waterfall.concat([
function(resNoeuds,callback){
const query={
text:'SELECT num_pion_on_bac_on_page FROM platooschem.pion_on_bac_on_page p'+
' LEFT JOIN (SELECT COUNT(noeud_stop) nbstop,MAX(id_page) id, MAX(num_pion_on_bac_on_page) num, MAX(diese_bac_on_page) diese FROM platooschem.stop_pion_on_bac_on_page'+
' WHERE id_page = $1 AND ARRAY[noeud_stop] <@ $2 GROUP BY id_page,diese_bac_on_page,num_pion_on_bac_on_page) AS g'+
' ON p.id_page=g.id AND p.num_pion_on_bac_on_page = g.num AND p.diese_bac_on_page=g.diese'+
' WHERE id_page = $1 AND num_pion_on_bac_on_page = $3 AND ARRAY[noeud_start] <@ $2 AND ( COALESCE(g.nbstop,0)=0 OR g.nbstop=0) ;',
values:[resIP[0].id_page,resNoeuds[4],id]
}
client.query(query,
function(err,res2){
if(err){
//console.log('erreur remove groupe: '+err.stack);
//socket.emit('refresh');
callback(err);
}else if(res2.rows.length!=1){
//console.log('bad id remove groupe');
//socket.emit('refresh');
callback({stack:'bad id remove groupe'});
}else{
callback(null,resNoeuds);
}
}
);
},
function(resNoeuds,callback){
const query={
text:'INSERT INTO platooschem.stop_pion_on_bac_on_page (id_page,diese_bac_on_page,num_pion_on_bac_on_page,noeud_stop)'+
' SELECT id_page,diese_bac_on_page,num_pion_on_bac_on_page,$1 FROM platooschem.pion_on_bac_on_page p'+
' LEFT JOIN (SELECT COUNT(noeud_stop) nbstop,MAX(id_page) id, MAX(num_pion_on_bac_on_page) num, MAX(diese_bac_on_page) diese FROM platooschem.stop_pion_on_bac_on_page'+
' WHERE id_page = $2 AND ARRAY[noeud_stop] <@ $3 GROUP BY id_page,diese_bac_on_page,num_pion_on_bac_on_page) AS g'+
' ON p.id_page=g.id AND p.num_pion_on_bac_on_page = g.num AND p.diese_bac_on_page=g.diese'+
' WHERE id_page = $2 AND num_pion_on_bac_on_page = $4 AND ARRAY[noeud_start] <@ $3 AND ( COALESCE(g.nbstop,0)=0 OR g.nbstop=0) ;',
values:[resNoeuds[3][0].new_noeud,resIP[0].id_page,resNoeuds[4],id]
}
client.query(query,
function(err){
if(err){
//console.log('erreure de remove : '+err.stack);
//socket.emit('refresh');
callback(err);
//return false;
}else{
emit.push({text:'removeElement',data:{id:classe+'-'+id,noeud:resNoeuds[3][0].new_noeud}});
emit_broad.push({text:'removeElement',data:{id:classe+'-'+id,noeud:resNoeuds[3][0].new_noeud}});
nb_requete +=1;
callback(null,resNoeuds);
//return true;
}
}
);
}
]);
}else{
console.log('erreur de remove : mauvaise classe');
Abort=true;
//return false;
}
}
//action changePionOnboard--------------------------------------------------------------
}else if(requete.action ==='changePionOnboard'){//ok
if(!checkValide(variables={
diese:1,
type:'45',
top:1,
left:1,
height:1,
board:1},needsData=true,errMess='changePionOnboard',data=requete.data)){
console.log(requete.data);
console.log(errMess+'.data incorrect dans changePionOnboard');
Abort = true
}else{
Array_waterfall=Array_waterfall.concat([
function(resNoeuds,callback){
const query = {
text:'SELECT num_pion_on_board_on_page,diese_board_on_page FROM platooschem.pion_on_board_on_page p'+
' LEFT JOIN (SELECT COUNT(noeud_stop) nbstop,MAX(id_page) id, MAX(num_pion_on_board_on_page) num, MAX(diese_board_on_page) diese FROM platooschem.stop_pion_on_board_on_page'+
' WHERE id_page = $1 AND ARRAY[noeud_stop] <@ $2 GROUP BY id_page,diese_board_on_page,num_pion_on_board_on_page) AS g'+
' ON p.id_page=g.id AND p.num_pion_on_board_on_page = g.num AND p.diese_board_on_page=g.diese'+
' WHERE id_page = $1 AND diese_pion_on_board_on_page = $3'+
' AND ARRAY[noeud_start] <@ $2 AND ( COALESCE(g.nbstop,0)=0 OR g.nbstop=0) ;',
values:[resIP[0].id_page,resNoeuds[4],requetes_tot[nb_requete].data.diese]
}
//console.log(noeuds)
client.query(query,function(err,results){
if(err){
callback(err);
}else{
//resTot.push(results.rows);
results2=[results.rows];
callback(null,resNoeuds,results2);
}
});
},
function(resNoeuds,results2,callback){
const query = {
text:'SELECT id_pion,taille,svg_pion,directed FROM platooschem.pion WHERE nom_pion = $1;',
values:[requetes_tot[nb_requete].data.type]
}
queryChainedClient(client,query,callback,resNoeuds,results2);
},
function(resNoeuds,results2,callback){
const query = {
text:'SELECT c.id_pion FROM platooschem.carac_pions_page c JOIN platooschem.pion p ON c.id_pion = p.id_pion WHERE p.nom_pion = $1 AND c.id_page = $2; ',
values:[requetes_tot[nb_requete].data.type,resIP[0].id_page]
}
queryChainedClient(client,query,callback,resNoeuds,results2);
},
function(resNoeuds,results2,callback){
const query = {
text:'SELECT num_board_on_page FROM platooschem.board_on_page b'+
' LEFT JOIN (SELECT COUNT(noeud_stop) nbstop,MAX(id_page) id, MAX(num_board_on_page) num FROM platooschem.stop_board_on_page'+
' WHERE id_page = $1 AND ARRAY[noeud_stop] <@ $2 GROUP BY id_page,num_board_on_page) AS g'+
' ON b.id_page=g.id AND b.num_board_on_page = g.num'+
' WHERE b.id_page = $1 AND diese_board_on_page=$3'+
' AND ARRAY[b.noeud_start] <@ $2 AND ( COALESCE(g.nbstop,0)=0 OR g.nbstop=0) ;',
values:[resIP[0].id_page,resNoeuds[4],requetes_tot[nb_requete].data.board]
}
client.query(query,function(err,results){
results2.push(results.rows);
if(err){
callback(err);
}else if(results2[0].length!=1 || results2[3].length!=1){
//mauvais diese
callback({stack:'mauvais diese changePionOnBoard'});
}else if(results2[1].length!=1){
//pas le bon pion
callback({stack:'mauvais pion changePionOnBoard'});
}else{
var r = {
resNoeuds:resNoeuds,
results2:results2
};
callback(null,r);
}
});
},
function(r,callback){
//test pour savoir si on doit ajouter des caractéristiques de pion à la page
r.test = results2[1].length!=1;
const query={
text:'INSERT INTO platooschem.pion_on_board_on_page (id_page,diese_pion_on_board_on_page,num_pion_on_board_on_page,id_pion,diese_board_on_page,position_x,position_y,taille,noeud_start) '+
' SELECT $1,$2, pp.new_num,$3,$4,$5,$6,$7, new_noeud '+
' FROM platooschem.page p LEFT JOIN '+
'(SELECT MAX(id_page) id_pageb,MAX(noeud_suivant) new_noeud FROM platooschem.save_on_page GROUP BY id_page) AS s ON p.id_page=s.id_pageb'+
' LEFT JOIN (SELECT MAX(num_pion_on_board_on_page)+1 new_num, MAX(id_page) id_pagec FROM platooschem.pion_on_board_on_page GROUP BY id_page) AS pp ON p.id_page=pp.id_pagec'+
' WHERE id_page = $1 LIMIT 1; ',
values:[resIP[0].id_page,requetes_tot[nb_requete].data.diese,r.results2[1][0].id_pion,requetes_tot[nb_requete].data.board,requetes_tot[nb_requete].data.left,requetes_tot[nb_requete].data.top,requetes_tot[nb_requete].data.height]
};
client.query(query,function(err,results){
if(err){
callback(err);
}else{
//resTot.push(results.rows);
result3=[results.rows];
callback(null,r,result3);
}
});
},
function(r,result3,callback){
const query={
text:'INSERT INTO platooschem.stop_pion_on_board_on_page (id_page,diese_board_on_page,num_pion_on_board_on_page,noeud_stop)'+
' SELECT $1,$2,$3,$4; ',
values:[resIP[0].id_page,r.results2[0][0].diese_board_on_page,r.results2[0][0].num_pion_on_board_on_page,r.resNoeuds[3][0].new_noeud],
};
queryChainedClient(client,query,callback,r,result3);
},
function(r,result3,callback){
const query = {
text:' SELECT MAX(num_pion_on_board_on_page) num FROM platooschem.pion_on_board_on_page WHERE id_page = $1 GROUP BY id_page;',
values:[resIP[0].id_page]
}
queryChainedClient(client,query,callback,r,result3);
},
function(r,result3,callback){
const query = {
text:'INSERT INTO platooschem.stop_pion_on_board_on_page (id_page,diese_board_on_page,num_pion_on_board_on_page,noeud_stop) SELECT '+
'$1,$2 ,MAX(num_pion_on_board_on_page),0 FROM platooschem.pion_on_board_on_page WHERE id_page = $1 GROUP BY id_page;',
values:[resIP[0].id_page,requetes_tot[nb_requete].data.board]
}
queryChainedClient(client,query,callback,r,result3);
},
function(r,result3,callback){
if(r.test){
const query={
text:'INSERT INTO platooschem.carac_pions_page (id_page,id_pion,change_pion,diese_bac_on_page,taille) SELECT ($1,$2,$2,1,$3) ; ',
values:[resIP[0].id_page,r.results2[1][0].id_pion,r.results2[1][0].taille]
};
client.query(query,function(err,results){
if(err){
callback(err);
}else{
//resTot.push(results.rows);
result3.push(results.rows);
callback(null,r,result3);
}
});
}else{
callback(null,r,result3);
}
},
function(r,result3,callback){
if(r.test){
const query={
text:'INSERT INTO platooschem.carac_pions_joueur_on_page (id_joueur,id_page,id_pion,change_pion,diese_bac_on_page,taille) SELECT id_joueur,$1,$2,$2,1,$3 FROM platooschem.carac_pions_joueur_on_page WHERE id_page = $1 LIMIT 1; ',
values:[resIP[0].id_page,results2[1][0].id_pion,results2[1][0].taille]
};
client.query(query,function(err,results){
if(err){
callback(err);
}else{
//resTot.push(results.rows);
result3.push(results.rows);
callback(null,r,result3);
}
});
}else{
callback(null,r,result3);
}
},
function(r,result3,callback){
if(r.test){
emit.push({text:'getTabPion',data:null});
emit_broad.push({text:'getTabPion',data:null});
}
emit.push({text:'removeElement',data:{id:'pion-'+r.results2[0][0].num_pion_on_board_on_page,noeud:r.resNoeuds[3][0].new_noeud}});
emit_broad.push({text:'removeElement',data:{id:'pion-'+r.results2[0][0].num_pion_on_board_on_page,noeud:r.resNoeuds[3][0].new_noeud}});
requetes_tot[nb_requete].data.svg = r.results2[1][0].svg_pion;
requetes_tot[nb_requete].data.directed = r.results2[1][0].directed;
requetes_tot[nb_requete].data.num =result3[2][0].num;
requetes_tot[nb_requete].data.noeud =r.resNoeuds[3][0].new_noeud;
emit.push({text:'createPionOnboard',data:requetes_tot[nb_requete].data});
emit_broad.push({text:'createPionOnboard',data:requetes_tot[nb_requete].data});
nb_requete +=1;
callback(null,r.resNoeuds);
}
]);
}
//action modifyGroup--------------------------------------------------------------
}else if(requete.action ==='modifyGroup'){//ok
if(!checkValide(variables={
diese:1,
n:1,
bac:1,
type:''},
needsData=true,errMess='modifyGroup',data=requete.data)){
console.log(errMess+'.data incorrect dans modifyGroup');
Abort = true
}else{
Array_waterfall=Array_waterfall.concat([
function(resNoeuds,callback){
const query = {
text:'SELECT num_pion_on_bac_on_page FROM platooschem.pion_on_bac_on_page p'+
' LEFT JOIN (SELECT COUNT(noeud_stop) nbstop,MAX(id_page) id, MAX(num_pion_on_bac_on_page) num, MAX(diese_bac_on_page) diese FROM platooschem.stop_pion_on_bac_on_page'+
' WHERE id_page = $1 AND ARRAY[noeud_stop] <@ $2 GROUP BY id_page,diese_bac_on_page,num_pion_on_bac_on_page) AS g'+
' ON p.id_page=g.id AND p.num_pion_on_bac_on_page = g.num AND p.diese_bac_on_page=g.diese'+
' WHERE id_page = $1 AND diese_pion_on_bac_on_page = $3'+
' AND ARRAY[noeud_start] <@ $2 AND ( COALESCE(g.nbstop,0)=0 OR g.nbstop=0) ;',
values:[resIP[0].id_page,resNoeuds[4],requetes_tot[nb_requete].data.diese]
}
client.query(query,function(err,results){
if(err){
callback(err);
}else{
//resTot.push(results.rows);
results2=[results.rows];
callback(null,resNoeuds,results2);
}
});
},
function(resNoeuds,results2,callback){
const query = {
text:'SELECT id_pion,taille,svg_pion,directed FROM platooschem.pion WHERE nom_pion = $1;',
values:[requetes_tot[nb_requete].data.type]
}
queryChainedClient(client,query,callback,resNoeuds,results2);
},
function(resNoeuds,results2,callback){
const query = {
text:'SELECT c.id_pion FROM platooschem.carac_pions_page c JOIN platooschem.pion p ON c.id_pion = p.id_pion WHERE p.nom_pion = $1 AND c.id_page = $2; ',
values:[requetes_tot[nb_requete].data.type,resIP[0].id_page]
}
queryChainedClient(client,query,callback,resNoeuds,results2);
},
function(resNoeuds,results2,callback){
const query = {
text:'SELECT num_bac_on_page FROM platooschem.bac_on_page b'+
' LEFT JOIN (SELECT COUNT(noeud_stop) nbstop,MAX(id_page) id, MAX(num_bac_on_page) num FROM platooschem.stop_bac_on_page'+
' WHERE id_page = $1 AND ARRAY[noeud_stop] <@ $2 GROUP BY id_page,num_bac_on_page) AS g'+
' ON b.id_page=g.id AND b.num_bac_on_page = g.num'+
' WHERE b.id_page = $1 AND diese_bac_on_page=$3'+
' AND ARRAY[b.noeud_start] <@ $2 AND ( COALESCE(g.nbstop,0)=0 OR g.nbstop=0) ;',
values:[resIP[0].id_page,resNoeuds[4],requetes_tot[nb_requete].data.bac]
}
client.query(query,function(err,results){
results2.push(results.rows);
if(err){
callback(err);
//verif que le pion et la board existent
}else if(results2[0].length!=1 || results2[3].length!=1){
callback({stack:'mauvais diese2'});
}else if(results2[1].length!=1){
//pas le bon pion
callback({stack:'pion incorrect'});
}else{
r={
resNoeuds:resNoeuds,
results2:results2
};
callback(null,r);
}
});
},
function(r,callback){
const query={
text:'INSERT INTO platooschem.stop_pion_on_bac_on_page (id_page,diese_bac_on_page,num_pion_on_bac_on_page,noeud_stop)'+
' SELECT $1,$2,$3,$4; ',
values:[resIP[0].id_page,requetes_tot[nb_requete].data.bac,r.results2[0][0].num_pion_on_bac_on_page,r.resNoeuds[3][0].new_noeud],
};
client.query(query,function(err,results){
if(err){
callback(err);
}else{
//resTot.push(results.rows);
result3=[results.rows];
callback(null,r,result3);
}
});
},
function(r,result3,callback){
const query={
text:'INSERT INTO platooschem.pion_on_bac_on_page (id_page,diese_bac_on_page,id_pion,nombre_pions,diese_pion_on_bac_on_page,num_pion_on_bac_on_page,noeud_start) SELECT '+
'$1,$2,$3,$4,$5, new_num, new_noeud FROM platooschem.page p'+
' LEFT JOIN (SELECT MAX(id_page) id_pagea,MAX(num_pion_on_bac_on_page)+1 new_num FROM platooschem.pion_on_bac_on_page GROUP BY id_page) AS n '+
'ON p.id_page=n.id_pagea '+
'LEFT JOIN (SELECT MAX(id_page) id_pageb,MAX(noeud_suivant) new_noeud FROM platooschem.save_on_page GROUP BY id_page) AS s '+
'ON n.id_pagea=s.id_pageb WHERE id_pagea=$1 LIMIT 1;',
values:[resIP[0].id_page,requetes_tot[nb_requete].data.bac,r.results2[1][0].id_pion,requetes_tot[nb_requete].data.n,requetes_tot[nb_requete].data.diese]
};
queryChainedClient(client,query,callback,r,result3);
},
function(r,result3,callback){
const query = {
text:'INSERT INTO platooschem.stop_pion_on_bac_on_page (id_page,diese_bac_on_page,num_pion_on_bac_on_page,noeud_stop) SELECT '+
'$1,$2 ,MAX(num_pion_on_bac_on_page),0 FROM platooschem.pion_on_bac_on_page WHERE id_page = $1 GROUP BY id_page;',
values:[resIP[0].id_page,requetes_tot[nb_requete].data.bac]
}
queryChainedClient(client,query,callback,r,result3);
},
function(r,result3,callback){
const query={
text:' SELECT MAX(num_pion_on_bac_on_page) num FROM platooschem.pion_on_bac_on_page WHERE id_page = $1 GROUP BY id_page;',
values:[resIP[0].id_page]
};
client.query(query,function(err,results){
if(err){
callback(err);
}else{
//resTot.push(results.rows);
result3.push(results.rows);
callback(null,r,result3);
}
});
},function(r,result3,callback){
emit.push({text:'removeElement',data:{id:'groupe-'+r.results2[0][0].num_pion_on_bac_on_page,noeud:r.resNoeuds[3][0].new_noeud}});
emit_broad.push({text:'removeElement',data:{id:'groupe-'+r.results2[0][0].num_pion_on_bac_on_page,noeud:r.resNoeuds[3][0].new_noeud}});
requetes_tot[nb_requete].data.svg = r.results2[1][0].svg_pion;
requetes_tot[nb_requete].data.directed = r.results2[1][0].directed;
requetes_tot[nb_requete].data.num =result3[3][0].num;
requetes_tot[nb_requete].data.noeud =r.resNoeuds[3][0].new_noeud;
emit.push({text:'createGroupeOnbac',data:requetes_tot[nb_requete].data});
emit_broad.push({text:'createGroupeOnbac',data:requetes_tot[nb_requete].data});
nb_requete +=1;
callback(null,r.resNoeuds);
}
]);
}
//action createPionOnboard--------------------------------------------------------------
}else if(requete.action ==='createPionOnboard'){//ok
if(!checkValide(variables={
type:'45',
top:1,
left:1,
height:1,
board:1},needsData=true,errMess='createPionOnboard',data=requete.data)){
console.log(errMess+'.data incorrect dans createPionOnboard');
Abort = true
//return false;
}else{
Array_waterfall=Array_waterfall.concat([
function(resNoeuds,callback){
const query = {
text:'SELECT id_pion,taille,svg_pion,directed FROM platooschem.pion WHERE nom_pion = $1;',
values:[requetes_tot[nb_requete].data.type]
}
client.query(query,function(err,results){
if(err){
callback(err);
}else{
results2=[results.rows];
callback(null,resNoeuds,results2);
}
});
},
function(resNoeuds,results2,callback){
const query = {
text:'SELECT c.id_pion FROM platooschem.carac_pions_page c JOIN platooschem.pion p ON c.id_pion=p.id_pion WHERE p.nom_pion = $1 AND c.id_page = $2; ',
values:[requetes_tot[nb_requete].data.type,resIP[0].id_page]
}
queryChainedClient(client,query,callback,resNoeuds,results2);
},
function(resNoeuds,results2,callback){
const query = {
text:'SELECT num_board_on_page FROM platooschem.board_on_page b'+
' LEFT JOIN (SELECT COUNT(noeud_stop) nbstop,MAX(id_page) id, MAX(num_board_on_page) num FROM platooschem.stop_board_on_page'+
' WHERE id_page = $1 AND ARRAY[noeud_stop] <@ $2 GROUP BY id_page,num_board_on_page) AS g'+
' ON b.id_page=g.id AND b.num_board_on_page = g.num'+
' WHERE b.id_page = $1 AND diese_board_on_page=$3'+
' AND ARRAY[b.noeud_start] <@ $2 AND ( COALESCE(g.nbstop,0)=0 OR g.nbstop=0) ;',
values:[resIP[0].id_page,resNoeuds[4],requetes_tot[nb_requete].data.board]
}
client.query(query,function(err,results){
results2.push(results.rows);
if(err){
callback(err);
}else if(results2[2].length!=1){
//verif que le pion et la board existent
//mauvais diese
callback({stack:'mauvais diese createPionOnBoard'});
}else if(results2[0].length!=1){
//pas le bon pion
callback({stack:'mauvais pion createPionOnBoard'});
}else{
var r={
results2:results2,
resNoeuds:resNoeuds
}
callback(null,r);
}
});
},
function(r,callback){
//test pour savoir si on doit ajouter des caractéristiques de pion à la page
r.test = r.results2[1].length!=1;
const query={
text:'INSERT INTO platooschem.pion_on_board_on_page (id_page,diese_pion_on_board_on_page,num_pion_on_board_on_page,id_pion,diese_board_on_page,position_x,position_y,taille,noeud_start) '+
' SELECT $1,CASE WHEN pp.new_diese IS NULL THEN 1 ELSE new_diese END, '+
' CASE WHEN pp.new_num IS NULL THEN 0 ELSE new_num END,$2,$3, $4,$5 , $6,$7 FROM platooschem.page p'+
' LEFT JOIN (SELECT MAX(num_pion_on_board_on_page)+1 new_num, MAX(diese_pion_on_board_on_page)+1 new_diese, MAX(id_page) id_pagec FROM platooschem.pion_on_board_on_page GROUP BY id_page) AS pp ON p.id_page=pp.id_pagec'+
' WHERE id_page = $1 LIMIT 1;',
values:[resIP[0].id_page,r.results2[0][0].id_pion,requetes_tot[nb_requete].data.board,requetes_tot[nb_requete].data.left,requetes_tot[nb_requete].data.top,requetes_tot[nb_requete].data.height,r.resNoeuds[3][0].new_noeud],
};
client.query(query,function(err,results){
if(err){
callback(err);
}else{
//resTot.push(results.rows);
result3=[results.rows];
callback(null,r,result3);
}
});
},
function(r,result3,callback){
const query={
text:'INSERT INTO platooschem.stop_pion_on_board_on_page (id_page,diese_board_on_page,num_pion_on_board_on_page,noeud_stop) SELECT '+
'$1,$2 ,MAX(num_pion_on_board_on_page),0 FROM platooschem.pion_on_board_on_page WHERE id_page = $1 GROUP BY id_page;',
values:[resIP[0].id_page,requetes_tot[nb_requete].data.board]
};
queryChainedClient(client,query,callback,r,result3);
},
function(r,result3,callback){
const query = {
text:' SELECT MAX(diese_pion_on_board_on_page) diese,MAX(num_pion_on_board_on_page) num FROM platooschem.pion_on_board_on_page WHERE id_page = $1 GROUP BY id_page;',
values:[resIP[0].id_page]
}
queryChainedClient(client,query,callback,r,result3);
},
function(r,result3,callback){
if(r.test){
const query={
text:'INSERT INTO platooschem.carac_pions_page (id_page,id_pion,change_pion,diese_bac_on_page,taille) SELECT ($1,$2,$2,1,$3) ; ',
values:[resIP[0].id_page,r.results2[1][0].id_pion,r.results2[1][0].taille]
};
client.query(query,function(err,results){
if(err){
callback(err);
}else{
//resTot.push(results.rows);
result3.push(results.rows);
callback(null,result3);
}
});
}else{
callback(null,r,result3);
}
},
function(r,result3,callback){
if(r.test){
const query={
text:'INSERT INTO platooschem.carac_pions_joueur_on_page (id_joueur,id_page,id_pion,change_pion,diese_bac_on_page,taille) SELECT id_joueur,$1,$2,$2,1,$3 FROM platooschem.carac_pions_joueur_on_page WHERE id_page = $1 LIMIT 1; ',
values:[resIP[0].id_page,r.results2[1][0].id_pion,r.results2[1][0].taille]
};
client.query(query,function(err,results){
if(err){
callback(err);
}else{
//resTot.push(results.rows);
result3.push(results.rows);
callback(null,result3);
}
});
}else{
callback(null,r,result3);
}
},
function(r,result3,callback){
if(r.test){
emit.push({text:'getTabPion',data:null});
emit_broad.push({text:'getTabPion',data:null});
}
requetes_tot[nb_requete].data.diese = result3[2][0].diese;
requetes_tot[nb_requete].data.svg = r.results2[0][0].svg_pion;
requetes_tot[nb_requete].data.directed = r.results2[0][0].directed;
requetes_tot[nb_requete].data.num =result3[2][0].num;
requetes_tot[nb_requete].data.noeud =r.resNoeuds[3][0].new_noeud;
emit.push({text:'createPionOnboard',data:requetes_tot[nb_requete].data});
emit_broad.push({text:'createPionOnboard',data:requetes_tot[nb_requete].data});
nb_requete +=1;
callback(null,r.resNoeuds)
}
]);
}
//action createGroupeOnbac--------------------------------------------------------------
}else if(requete.action ==='createGroupeOnbac'){//ok
if(!checkValide(variables={
type:'45',
n:1,
bac:1},needsData=false,errMess='createGroupeOnbac',data=requete.data)){
console.log(errMess+'.data incorrect dans createGroupeOnbac');
Abort=true;
}else{
Array_waterfall=Array_waterfall.concat([
function(resNoeuds,callback){
const query = {
text:'SELECT id_pion,taille,svg_pion FROM platooschem.pion WHERE nom_pion = $1;',
values:[requetes_tot[nb_requete].data.type]
}
client.query(query,function(err,results){
if(err){
callback(err);
}else{
//resTot.push(results.rows);
results2=[results.rows];
callback(null,resNoeuds,results2);
}
});
},
function(resNoeuds,results2,callback){
const query = {
text:'SELECT c.id_pion FROM platooschem.carac_pions_page c JOIN platooschem.pion p ON c.id_pion=p.id_pion WHERE p.nom_pion = $1 AND c.id_page = $2; ',
values:[requetes_tot[nb_requete].data.type,resIP[0].id_page]
}
queryChainedClient(client,query,callback,resNoeuds,results2);
},
function(resNoeuds,results2,callback){
const query = {
text:'SELECT num_bac_on_page FROM platooschem.bac_on_page b'+
' LEFT JOIN (SELECT COUNT(noeud_stop) nbstop,MAX(id_page) id, MAX(num_bac_on_page) num FROM platooschem.stop_bac_on_page'+
' WHERE id_page = $1 AND ARRAY[noeud_stop] <@ $2 GROUP BY id_page,num_bac_on_page) AS g'+
' ON b.id_page=g.id AND b.num_bac_on_page = g.num'+
' WHERE b.id_page = $1 AND diese_bac_on_page=$3'+
' AND ARRAY[b.noeud_start] <@ $2 AND ( COALESCE(g.nbstop,0)=0 OR g.nbstop=0) ;',
values:[resIP[0].id_page,resNoeuds[4],requetes_tot[nb_requete].data.bac]
}
client.query(query,function(err,results){
results2.push(results.rows);
if(err){
callback(err);
}else if(results2[0].length!=1 || results2[2].length!=1){
//mauvais diese
callback({stack:'mauvais diese createGroupeOnbac'});
}else if(results2[1].length!=1){
//pas le bon pion
callback({stack:'mauvais pion createGroupeOnbac'});
}else{
var r ={
resNoeuds:resNoeuds,
results2,results2
}
callback(null,r);
}
});
},
function(r,callback){
//test pour savoir si on doit ajouter des caractéristiques de pion à la page
r.test = r.results2[1].length!=1;
const query={
text:'INSERT INTO platooschem.pion_on_bac_on_page (id_page,diese_pion_on_bac_on_page,num_pion_on_bac_on_page,id_pion,diese_bac_on_page,nombre_pions,noeud_start) '+
' SELECT $1'+
', CASE WHEN new_diese IS NULL THEN 1 ELSE new_diese END,'+
' CASE WHEN new_num IS NULL THEN 0 ELSE new_num END, '+
'$2,$3, $4, new_noeud '+
' FROM platooschem.page p LEFT JOIN '+
'(SELECT MAX(id_page) id_pageb,MAX(noeud_suivant) new_noeud FROM platooschem.save_on_page GROUP BY id_page) AS s ON p.id_page=s.id_pageb'+
' LEFT JOIN (SELECT MAX(num_pion_on_bac_on_page)+1 new_num, MAX(diese_pion_on_bac_on_page)+1 new_diese, MAX(id_page) id_pagec FROM platooschem.pion_on_bac_on_page GROUP BY id_page) AS pp ON p.id_page=pp.id_pagec'+
' WHERE id_page = $1 LIMIT 1;',
values:[resIP[0].id_page,r.results2[0][0].id_pion,requetes_tot[nb_requete].data.bac,requetes_tot[nb_requete].data.n],
};
client.query(query,function(err,results){
if(err){
callback(err);
}else{
//resTot.push(results.rows);
result3=[results.rows];
callback(null,r,result3);
}
});
},
function(r,result3,callback){
const query={
text:'INSERT INTO platooschem.stop_pion_on_bac_on_page (id_page,diese_bac_on_page,num_pion_on_bac_on_page,noeud_stop) SELECT '+
'$1,$2 ,MAX(num_pion_on_bac_on_page),0 FROM platooschem.pion_on_bac_on_page WHERE id_page = $1 GROUP BY id_page;',
values:[resIP[0].id_page,requetes_tot[nb_requete].data.bac]
};
queryChainedClient(client,query,callback,r,result3);
},
function(r,result3,callback){
const query = {
text:' SELECT MAX(diese_pion_on_bac_on_page) diese,MAX(num_pion_on_bac_on_page) num FROM platooschem.pion_on_bac_on_page WHERE id_page = $1 GROUP BY id_page; ',
values:[resIP[0].id_page]
}
queryChainedClient(client,query,callback,r,result3);
},
function(r,result3,callback){
if(r.test){
const query={
text:'INSERT INTO platooschem.carac_pions_page (id_page,id_pion,change_pion,diese_bac_on_page,taille) SELECT ($1,$2,$2,1,$3) ; ',
values:[resIP[0].id_page,r.results2[1][0].id_pion,r.results2[1][0].taille]
};
client.query(query,function(err,results){
if(err){
callback(err);
}else{
//resTot.push(results.rows);
result3.push(results.rows);
callback(null,r,result3);
}
});
}else{
callback(null,r,result3);
}
},
function(r,result3,callback){
if(r.test){
const query={
text:'INSERT INTO platooschem.carac_pions_joueur_on_page (id_joueur,id_page,id_pion,change_pion,diese_bac_on_page,taille) SELECT id_joueur,$1,$2,$2,1,$3 FROM platooschem.carac_pions_joueur_on_page WHERE id_page = $1 LIMIT 1; ',
values:[resIP[0].id_page,r.results2[1][0].id_pion,r.results2[1][0].taille]
};
client.query(query,function(err,results){
if(err){
callback(err);
}else{
//resTot.push(results.rows);
result3.push(results.rows);
callback(null,r,result3);
}
});
}else{
callback(null,r,result3);
}
},function(r,result3,callback){
if(r.test){
emit.push({text:'getTabPion',data:null});
emit_broad.push({text:'getTabPion',data:null});
}
requetes_tot[nb_requete].data.diese = result3[2][0].diese;
requetes_tot[nb_requete].data.svg=r.results2[0][0].svg_pion;
requetes_tot[nb_requete].data.num = result3[2][0].num;
requetes_tot[nb_requete].data.noeud = r.resNoeuds[3][0].new_noeud;
emit.push({text:'createGroupeOnbac',data:requetes_tot[nb_requete].data});
emit_broad.push({text:'createGroupeOnbac',data:requetes_tot[nb_requete].data});
nb_requete +=1;
callback(null,r.resNoeuds);
}
]);
}
//action changeLabelBac--------------------------------------------------------------
}else if(requete.action ==='changeLabelBac'){//
if(!checkValide(variables={diese:1,label:'20'},needsData=true,errMess='changeLabelBac',data=requete.data)){
console.log(errMess+'.data incorrect dans changeLabelBac');
Abort = true;
}else{
Array_waterfall=Array_waterfall.concat([
function(resNoeuds,callback){
const query={
text:'SELECT num_bac_on_page FROM platooschem.bac_on_page b'+
' LEFT JOIN (SELECT COUNT(noeud_stop) nbstop,MAX(id_page) id, MAX(num_bac_on_page) num FROM platooschem.stop_bac_on_page'+
' WHERE id_page = $1 AND ARRAY[noeud_stop] <@ $2 GROUP BY id_page,num_bac_on_page) AS g'+
' ON b.id_page=g.id AND b.num_bac_on_page = g.num'+
' WHERE b.id_page = $1 AND diese_bac_on_page=$3'+
' AND ARRAY[b.noeud_start] <@ $2 AND ( COALESCE(g.nbstop,0)=0 OR g.nbstop=0) ;',
values:[resIP[0].id_page,resNoeuds[4],requetes_tot[nb_requete].data.diese]
};
client.query(query,
function(err2,results2){
if(err2){
console.log('erreur de changeLabelBac : '+err2.stack);
callback(err2);
//return false;
}else{
//verif que le bac existe
if(results2.rows.length!=1){
//console.log('mauvais diese3');
//socket.emit('refresh');
//return false;
callback({stak:'mauvais diese3'});
}else{
r={
resNoeuds:resNoeuds,
results2:results2.rows
};
callback(null,r);
}
}
}
);
},
function(r,callback){
const query={
text:'INSERT INTO platooschem.stop_bac_on_page (id_page,num_bac_on_page,noeud_stop)'+
' SELECT $1,$2,$3;',
values:[resIP[0].id_page,r.results2[0].num_bac_on_page,r.resNoeuds[3][0].new_noeud],
};
client.query(query,function(err,results){
if(err){
callback(err);
}else{
//resTot.push(results.rows);
resTot=[results.rows];
callback(null,r,resTot);
}
});
},
function(r,resTot,callback){
const query={
text:'INSERT INTO platooschem.bac_on_page (id_page,diese_bac_on_page,num_bac_on_page,label_bac,noeud_start) '+
' SELECT $1,$2, new_num, $3, new_noeud FROM platooschem.page p LEFT JOIN '+
'(SELECT MAX(id_page) id_pageb,MAX(noeud_suivant) new_noeud FROM platooschem.save_on_page GROUP BY id_page) AS s ON p.id_page=s.id_pageb'+
' LEFT JOIN (SELECT MAX(num_bac_on_page)+1 new_num,MAX(id_page) id_pagec FROM platooschem.bac_on_page GROUP BY id_page) AS b ON p.id_page=b.id_pagec'+
' WHERE id_page = $1 LIMIT 1;',
values:[resIP[0].id_page,requetes_tot[nb_requete].data.diese,requetes_tot[nb_requete].data.label]
};
queryChainedClient(client,query,callback,r,resTot);
},
function(r,resTot,callback){
const query={
text:'INSERT INTO platooschem.stop_bac_on_page (id_page,num_bac_on_page,noeud_stop) SELECT '+
'$1,MAX(num_bac_on_page),0 FROM platooschem.bac_on_page WHERE id_page = $1 GROUP BY id_page;',
values:[resIP[0].id_page]
};
queryChainedClient(client,query,callback,r,resTot);
},
function(r,resTot,callback){
const query={
text:'SELECT MAX(num_bac_on_page) num FROM platooschem.bac_on_page WHERE id_page = $1 GROUP BY id_page; ',
values:[resIP[0].id_page]
};
client.query(query,function(err,results){
if(err){
callback(err);
}else{
//resTot.push(results.rows);
resTot.push(results.rows);
callback(null,r,resTot);
}
});
},
function(r,resTot,callback){
requetes_tot[nb_requete].data.num=resTot[3][0].num;
requetes_tot[nb_requete].data.oldnum=r.results2[0].num_bac_on_page;
//requetes_tot[nb_requete].data.noeud=resIP[0].noeud_courant;
requetes_tot[nb_requete].data.noeud=resNoeuds[3][0].new_noeud;
emit.push({text:'changeLabelBac',data:requetes_tot[nb_requete].data});
emit_broad.push({text:'changeLabelBac',data:requetes_tot[nb_requete].data});
nb_requete +=1;
callback(null,r.resNoeuds);
}
]);
}
}
}
if(shouldAbort(Abort)){
return
}else{
async.waterfall(Array_waterfall,
function(err,result){
if(shouldAbort(err)){
return
}else{
client.query('COMMIT',function(err){
if(shouldAbort(err)) return
for(var i=0; i<emit.length;i++){
if(emit[i].data===null){
socket.emit(emit[i].text);
}else{
socket.emit(emit[i].text,emit[i].data);
}
}
for(var i=0; i<emit_broad.length;i++){
if(emit_broad[i].data===null){
socket.emit(emit_broad[i].text);
}else{
socket.broadcast.to(socket.nomPlatoo).emit(emit_broad[i].text,emit_broad[i].data);
}
}
done();
});
}
}
);
}
});
}
});
});
});
//http://stackoverflow.com/questions/19035373/how-do-i-redirect-in-expressjs-while-passing-some-context
//http://stackoverflow.com/questions/5710358/how-to-retrieve-post-query-parameters
//http://naholyr.fr/2011/06/bonnes-pratiques-asynchrone-javascript-nodejs/
//promises