#!/usr/bin/env node

if (process.argv.length != 4) {
	console.log("Usage: ./tour_worker.js <num_turns> <logs_dir>");
	console.log("Runs a game with each of the seeds given on stdin with the specified number of turns.");
	console.log("Game logs will be written to hopefully uniquely named files in the pre-existing directory <logs_dir>.");
	console.log("Writes results to stdout, in the format 'seed result', where <result> is the game result.");
	console.log("Quits on EOF on stdin.");
	process.exit(1);
}

const fs = require("fs");
const child_process = require("child_process");

const num_turns = +process.argv[2];
const logs_dir = process.argv[3];

let buffer = "";
process.stdin.on("data", function(data) {
	buffer += data;
	let idx = buffer.indexOf("\n");
	while (idx != -1) {
		const line = buffer.slice(0, idx);
		buffer = buffer.slice(idx + 1);
		idx = buffer.indexOf("\n");

		handle_line(line);
	}
});

function handle_line(seed) {
	const logfile = logs_dir + "/" + seed + "-" + new Date().getTime() + ".txt";
	const file = fs.openSync(logfile, "w");

	const proc = child_process.spawn(
		"node",
		["run_game.js", seed, num_turns + ""],
		{stdio: ["inherit", file, "inherit"]}
	);
	fs.closeSync(file);

	proc.on("exit", function(code, signal) {
		if (code !== 0) {
			console.log(seed + " crash");
		} else {
			let result = fs.readFileSync(logfile).toString().trim().split("\n");
			result = result[result.length - 1];

			console.log(seed + " " + result);
		}
	});
}