const axios         = require('axios');

var gtTabMsg = [];

const DATABASENAME     = "test";
//const DATABASENAME     = "Imported";

const ROOTUSER         = "root";
const ROOTPWD          = "playwithdata";
const ARCADEDBHOST     = "arcadedb-http";
const ARCADEDBPOSTRCP  = 5432;
const ARCADEDBPOSTHTTP = 2480;

async function envoyerLigne(asMsg) {
	if (20<asMsg.length) {
		console.log("envoyerLigne00 asMsg "+asMsg.substring(0,40));
	} else {
		console.log("envoyerLigne00 asMsg "+asMsg);
	}
	if (asMsg=="") {
		console.log("envoyerLigne00a asMsg vide return");
		return;
	}

	// equivalent de BEGIN TRANSACTION 
	let url1  = "http://"+ROOTUSER+":"+ROOTPWD+"@"+ARCADEDBHOST+":"+ARCADEDBPOSTHTTP+"/api/v1/begin/"+DATABASENAME;
	//console.log("envoyerLigne01 url "+url1);
	return axios.post(url1)
	.then((res1) => {
		let data1 = res1.headers;
		//console.log("envoyerLigne02 :"+JSON.stringify(data1));
		let transactionid = data1["arcadedb-session-id"];
		//console.log("envoyerLigne03 transactionid :"+transactionid);

		// equivelent de CREATE VERTEX 
		let payload2 =  { 
			"language" : "sql", 
			"command"  : "create vertex tabMessages set message = :message",
			"params"   : {"message" : asMsg }
		};
		const config2 = {
			headers: {
				"arcadedb-session-id": transactionid
			}
		}
		let url2  = "http://"+ROOTUSER+":"+ROOTPWD+"@"+ARCADEDBHOST+":"+ARCADEDBPOSTHTTP+"/api/v1/command/"+DATABASENAME;
		//console.log("envoyerLigne04 url "+url2);
		//console.log("envoyerLigne05 payload "+JSON.stringify(payload2));
		return axios.post(url2, payload2, config2)
		.then((res2) => {
			let data2 = res2.data;
			
			//console.log("envoyerLigne06 :"+JSON.stringify(data2));

			// equivalent de COMMIT
			const payload3 = {};
			const config3 = {
				headers: {
					"arcadedb-session-id": transactionid
				}
			}
			let url3  = "http://"+ROOTUSER+":"+ROOTPWD+"@"+ARCADEDBHOST+":"+ARCADEDBPOSTHTTP+"/api/v1/commit/"+DATABASENAME;
			//console.log("envoyerLigne07 url "+url3);
			//console.log("envoyerLigne08 config "+JSON.stringify(config3));
			return axios.post(url3, payload3, config3)
			.then((res3) => {
				let data3 = res3.data;
				//console.log("envoyerLigne09 :"+JSON.stringify(data3));
				//console.log("envoyerLigne99");
				return doWait(50);
			})
			.catch ((err) => {
				console.log("envoyerLigne96 erreur "+err)
				return;
			});
		})
		.catch ((err) => {
			console.log("envoyerLigne97 erreur "+err)
			return;
		});
	})
	.catch ((err) => {
		console.log("envoyerLigne98 erreur "+err)
		return;
	});
}
async function setupDatabase (){
	let lbExiste = false;
	{
		// Voir ici https://docs.arcadedb.com/ArcadeDB-manual.pdf 7.2 Http/json protocol
		// equivalent de CREATE DATABASE test
		let url  = "http://"+ROOTUSER+":"+ROOTPWD+"@"+ARCADEDBHOST+":"+ARCADEDBPOSTHTTP+"/api/v1/create/"+DATABASENAME;
		console.log("essaiCreateDatabase03 url "+url);
		try {
			let res  = await axios.post(url);
			let data = res.data;
			
			console.log("essaiCreateDatabase04 :"+JSON.stringify(data));
		} catch (ex) {
			// La base existe deja
			console.log("essaiCreateDatabase04a error "+ex);
			lbExiste = true;
		}
	}
	if (!lbExiste) {
		// equivelent de CREATE TABLE tabmessage
		let payload =  { 
			"language" : "sql", 
			"command"  : "create vertex type tabMessages"
		};
		let url  = "http://"+ROOTUSER+":"+ROOTPWD+"@"+ARCADEDBHOST+":"+ARCADEDBPOSTHTTP+"/api/v1/command/"+DATABASENAME;
		console.log("essaiCreateDatabase05 url     "+url);
		console.log("essaiCreateDatabase05 payload "+JSON.stringify(payload));
		let res  = await axios.post(url, payload);
		let data = res.data;
		
		console.log("essaiCreateDatabase06 :"+JSON.stringify(data));
	}
	if (!lbExiste) {
		// equivelent de CREATE TABLE tabmessage
		let payload =  { 
			"language" : "sql", 
			"command"  : "create property tabMessages.message string"
		};
		let url  = "http://"+ROOTUSER+":"+ROOTPWD+"@"+ARCADEDBHOST+":"+ARCADEDBPOSTHTTP+"/api/v1/command/"+DATABASENAME;
		console.log("essaiCreateDatabase07 url "+url);
		console.log("essaiCreateDatabase07 payload "+JSON.stringify(payload));
		let res  = await axios.post(url, payload);
		let data = res.data;
		
		console.log("essaiCreateDatabase08 :"+JSON.stringify(data));
	}
	if (!lbExiste) {
		// equivelent de CREATE TABLE tabmessage
		let payload =  { 
			"language" : "sql", 
			"command"  : "create index tabMessages_message_idx IF NOT EXISTS ON tabMessages(message) NOTUNIQUE"
		};
		let url  = "http://"+ROOTUSER+":"+ROOTPWD+"@"+ARCADEDBHOST+":"+ARCADEDBPOSTHTTP+"/api/v1/command/"+DATABASENAME;
		console.log("essaiCreateDatabase09 url "+url);
		console.log("essaiCreateDatabase09 payload "+JSON.stringify(payload));
		let res  = await axios.post(url, payload);
		let data = res.data;
		
		console.log("essaiCreateDatabase10 :"+JSON.stringify(data));
	}
	//envoyerLigne("lmjjmmjmlj");
}
function doWait(milleseconds) {
	return new Promise(resolve => setTimeout(resolve, milleseconds))
}
async function doBoucler() {
	var liI = 0;
	while (true) {
		if (0<gtTabMsg.length) {
			console.log(liI+"       doBoucler taille liste "+gtTabMsg.length);
			// Envoi le dernier de la liste
			envoyerLigne(JSON.stringify(gtTabMsg.shift()));
			await doWait(50);
		}
		if (0==gtTabMsg.length) {
			console.log(liI+"       doBoucler avant attente");
			await doWait(100);
		}
		liI++;
	}
}
setupDatabase();
gtTabMsg.push("message1");
gtTabMsg.push("message2");
gtTabMsg.push("message3");
gtTabMsg.push("message4");
gtTabMsg.push("message5");
gtTabMsg.push("message6");
gtTabMsg.push("message7");
doBoucler();