#include <boost/asio.hpp>
#include <iostream>

#include <boost/foreach.hpp>
#include <boost/program_options.hpp>
#include <boost/test/included/unit_test.hpp>

#include "Application.h"
#include "CallRPC.h"
#include "Config.h"
#include "utils.h"
#include "Log.h"

namespace po = boost::program_options;

extern bool AddSystemEntropy();
using namespace std;
using namespace boost::unit_test;

void startServer()
{
	theApp = new Application();
	theApp->run();					// Blocks till we get a stop RPC.
}


bool init_unit_test()
{
	theApp = new Application();

    return true;
}

void printHelp(const po::options_description& desc)
{
	cerr << SYSTEM_NAME "d [options] <command> <params>" << endl;

	cerr << desc << endl;

	cerr << "Commands: " << endl;
	cerr << "     account_domain_set <seed> <paying_account> [<domain>]" << endl;
	cerr << "     account_email_set <seed> <paying_account> [<email_address>]" << endl;
	cerr << "     account_lines <account>|<nickname>|<account_public_key> [<index>]" << endl;
	cerr << "     account_offers <account>|<nickname>|<account_public_key> [<index>]" << endl;
	cerr << "     account_info <account>|<nickname>" << endl;
	cerr << "     account_info <seed>|<pass_phrase>|<key> [<index>]" << endl;
	cerr << "     account_message_set <seed> <paying_account> <pub_key>" << endl;
	cerr << "     account_publish_set <seed> <paying_account> <hash> <size>" << endl;
	cerr << "     account_rate_set <seed> <paying_account> <rate>" << endl;
	cerr << "     account_wallet_set <seed> <paying_account> [<wallet_hash>]" << endl;
	cerr << "     connect <ip> [<port>]" << endl;
	cerr << "     data_delete <key>" << endl;
	cerr << "     data_fetch <key>" << endl;
	cerr << "     data_store <key> <value>" << endl;
	cerr << "     ledger [<id>|current|lastclosed] [full]" << endl;
	cerr << "     logrotate " << endl;
	cerr << "     nickname_info <nickname>" << endl;
	cerr << "     nickname_set <seed> <paying_account> <nickname> [<offer_minimum>] [<authorization>]" << endl;
	cerr << "     offer_create <seed> <paying_account> <taker_pays_amount> <taker_pays_currency> <taker_pays_issuer> <takers_gets_amount> <takers_gets_currency> <takers_gets_issuer> <expires> [passive]" << endl;
	cerr << "     offer_cancel <seed> <paying_account> <sequence>" << endl;
	cerr << "     password_fund <seed> <paying_account> [<account>]" << endl;
	cerr << "     password_set <master_seed> <regular_seed> [<account>]" << endl;
	cerr << "     peers" << endl;
	cerr << "     random" << endl;
	cerr << "     ripple ..." << endl;
	cerr << "     ripple_line_set <seed> <paying_account> <destination_account> <limit_amount> <currency> [<quality_in>] [<quality_out>]" << endl;
	cerr << "     send <seed> <paying_account> <account_id> <amount> [<currency>] [<send_max>] [<send_currency>]" << endl;
	cerr << "     stop" << endl;
	cerr << "     tx <id>" << endl;
	cerr << "     unl_add <domain>|<public> [<comment>]" << endl;
	cerr << "     unl_delete <domain>|<public_key>" << endl;
	cerr << "     unl_list" << endl;
	cerr << "     unl_load" << endl;
	cerr << "     unl_network" << endl;
	cerr << "     unl_reset" << endl;
	cerr << "     validation_create [<seed>|<pass_phrase>|<key>]" << endl;
	cerr << "     validation_seed [<seed>|<pass_phrase>|<key>]" << endl;
	cerr << "     wallet_add <regular_seed> <paying_account> <master_seed> [<initial_funds>] [<account_annotation>]" << endl;
	cerr << "     wallet_accounts <seed>" << endl;
	cerr << "     wallet_claim <master_seed> <regular_seed> [<source_tag>] [<account_annotation>]" << endl;
	cerr << "     wallet_seed [<seed>|<passphrase>|<passkey>]" << endl;
	cerr << "     wallet_propose [<passphrase>]" << endl;
}

int main(int argc, char* argv[])
{
	int					iResult	= 0;
	po::variables_map	vm;										// Map of options.

	//
	// Set up option parsing.
	//
	po::options_description desc("General Options");
	desc.add_options()
		("help,h", "Display this message.")
		("conf", po::value<std::string>(), "Specify the configuration file.")
		("rpc", "Perform rpc command (default).")
		("standalone,a", "Run with no peers.")
		("test,t", "Perform unit tests.")
		("parameters", po::value< vector<string> >(), "Specify comma separated parameters.")
		("quiet,q", "Reduce diagnotics.")
		("verbose,v", "Verbose logging.")
		("load", "Load the current ledger from the local DB.")
		("start", "Start from a fresh Ledger.")
		("net", "Get the initial ledger from the network.")
	;

	po::options_description hidden("Hidden Options");
	hidden.add_options()
		("trace,vvv",		"Trace level logging")
		("debug,vv",		"Debug level logging")
	;

	po::options_description all("All Options");
	all.add(desc).add(hidden);

	// Interpret positional arguments as --parameters.
	po::positional_options_description p;
	p.add("parameters", -1);

	//
	// Prepare to run
	//

	if (!AddSystemEntropy())
	{
		std::cerr << "Unable to add system entropy" << std::endl;
		iResult	= 2;
	}


	if (iResult)
	{
		nothing();
	}
	else
	{
		// Parse options, if no error.
		try {
			po::store(po::command_line_parser(argc, argv)
				.options(all)											// Parse options.
				.positional(p)											// Remainder as --parameters.
				.run(),
				vm);
			po::notify(vm);												// Invoke option notify functions.
		}
		catch (...)
		{
			iResult	= 1;
		}
	}

	if (vm.count("trace"))
		Log::setMinSeverity(lsTRACE, true);
	else if (vm.count("debug"))
		Log::setMinSeverity(lsDEBUG, true);
	else if (vm.count("verbose"))
		Log::setMinSeverity(lsINFO, true);
	else
		Log::setMinSeverity(lsWARNING, true);

	InstanceType::multiThread();

	if (vm.count("test"))
	{
		unit_test_main(init_unit_test, argc, argv);
		return 0;
	}

	if (!iResult)
	{
		theConfig.setup(
			vm.count("conf") ? vm["conf"].as<std::string>() : "",	// Config file.
			!!vm.count("quiet"));									// Quiet flag.

		if (vm.count("standalone"))
		{
			theConfig.RUN_STANDALONE = true;
		}
	}

	if (vm.count("start")) theConfig.START_UP = Config::FRESH;
	else if (vm.count("load")) theConfig.START_UP = Config::LOAD;
	else if (vm.count("net")) theConfig.START_UP = Config::NETWORK;

	if (iResult)
	{
		nothing();
	}
	else if (vm.count("help"))
	{
		iResult	= 1;
	}
	else if (!vm.count("parameters"))
	{
		// No arguments. Run server.
		startServer();
	}
	else
	{
		// Have a RPC command.
		std::vector<std::string> vCmd	= vm["parameters"].as<std::vector<std::string> >();

		iResult	= commandLineRPC(vCmd);
	}

	if (1 == iResult && !vm.count("quiet"))
		printHelp(desc);

	return iResult;
}
// vim:ts=4