#include <iostream>
#include <cstdlib>
#include "referee.h"
#include "params.h"


Referee::Referee(const string_view execname, const vector<string> &players)
		: proc(execname) {

	proc.run();

	if (referee_verbose) {
		cout << "REF(" << proc.getPid() << ") starting for:";
		for (const string &p : players) cout << " " << p;
		cout << endl;
	}
	
	proc.writeLine(to_string(players.size()));
	for (const string &p : players) {
		proc.writeLine(p);
	}
}

Referee::~Referee() {
	if (referee_verbose) {
		cout << "REF(" << proc.getPid() << ") stopping" << endl;
	}
	proc.wait();
	proc.terminate();
}

bool Referee::moveValid(int player, const string_view line) {
	string s = to_string(player) + " ";
	s.append(line);

	if (referee_verbose) {
		cout << "REF(" << proc.getPid() << ") write <" << s << ">" << endl;
	}

	proc.writeLine(s);

	optional<string> response = proc.readLine();
	if (response) {
		if (referee_verbose) {
			cout << "REF(" << proc.getPid() << ") read <" << *response << ">" << endl;
		}

		if (*response == "valid end") {
			isEnd = true;
			readScores();
			return true;
		} else if (*response == "valid") {
			return true;
		} else {
			return false;
		}
	} else {
		if (referee_verbose) {
			cout << "REF(" << proc.getPid() << ") EOF!" << endl;
		}
		return false;
	}
}

bool Referee::gameEnded() {
	return isEnd;
}

void Referee::readScores() {
	optional<string> line = proc.readLine();
	if (!line) {
		cerr << "Referee stopped before providing scores" << endl;
		exit(1);
	}

	if (referee_verbose) {
		cout << "REF(" << proc.getPid() << ") readScores <" << *line << ">" << endl;
	}

	size_t cursor = 0;
	while (cursor < line->size()) {
		size_t idx = line->find(' ', cursor);
		if (idx == string::npos) idx = line->size();
		scores.push_back(stoi(line->substr(cursor, idx - cursor)));
		cursor = idx + 1;
	}
}

optional<vector<int>> Referee::getScores() {
	if (isEnd) return scores;
	else return nullopt;
}

void Referee::terminate() {
	proc.terminate();
}