// Eris - The WorldForge client entity library
// Copyright (C) 2011 Alistair Riddoch
//
// This program is free software; you can redistribute it and/or modify
// it under the terms of the GNU General Public License as published by
// the Free Software Foundation; either version 2 of the License, or
// (at your option) any later version.
// 
// This program is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
// GNU General Public License for more details.
// 
// You should have received a copy of the GNU General Public License
// along with this program; if not, write to the Free Software Foundation,
// Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA

#include <Eris/Connection.h>
#include <Eris/Log.h>
#include <Eris/EventService.h>

#include <sigc++/adaptors/bind.h>

#include <iostream>

#include <cstdlib>
#include <unistd.h>

#include <getopt.h>

int connection_count = 0;
bool done = false;

static void usage(const char* prgname) {
	std::cout << "usage: " << prgname << " [-p port ] [-nv] host [port]"
			  << std::endl;
}

static void onConnected(Eris::Connection* c) {
	std::cout << "connected to server" << std::endl;
	if (--connection_count == 0) {
		done = true;
	}
}

static void onConnectionFail(const std::string& errMsg) {
	std::cout << "failed to connect to server: " << errMsg << std::endl;
	if (--connection_count == 0) {
		done = true;
	}
}

int main(int argc, char** argv) {
	bool option_verbose = false;
	bool option_nonblock = false;
	int option_port = 6767;

	while (1) {
		int c = getopt(argc, argv, "np:v");
		if (c == -1) {
			break;
		} else if (c == '?') {
			usage(argv[0]);
			return 1;
		} else if (c == 'v') {
			option_verbose = true;
		} else if (c == 'n') {
			option_nonblock = true;
		} else if (c == 'p') {
			option_port = strtol(optarg, 0, 10);
		}
	}

	if (option_verbose && option_nonblock) {
		std::cerr << "Connecting non blocking"
				  << std::endl;
	}

	int arg_left = argc - optind;

	if (arg_left < 1) {
		usage(argv[0]);
		return 1;
	}

	boost::asio::io_context io_service;
	Eris::EventService event_service(io_service);

	for (int i = optind; i < argc; ++i) {
		Eris::Connection* c = new Eris::Connection(io_service, event_service,
												   "test",
												   argv[i],
												   option_port);

		c->Connected.connect(sigc::bind(sigc::ptr_fun(onConnected), c));
		c->Failure.connect(sigc::ptr_fun(onConnectionFail));

		std::cout << "Calling connect" << std::endl;
		c->connect();
		++connection_count;
	}

	while (!done) {
		std::cout << "Calling poll" << std::endl;
//        Eris::PollDefault::poll(100);
		std::cout << "Called poll" << std::endl;
	}

	return 0;
}
