* 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  02111-1301  USA

 */

#pragma once

#include <boost/program_options.hpp>

#include <boost/foreach.hpp>

#include <boost/format.hpp>

#include <boost/algorithm/string.hpp>

#include <boost/assign.hpp>

#include <boost/bind.hpp>

#include <boost/signal.hpp>

#define CONFIG_STRING(PTR, KEY) (*PTR)[KEY].as<std::string>()

#define CONFIG_INT(PTR, KEY) (*PTR)[KEY].as<int>()

#define CONFIG_BOOL(PTR, KEY) (*PTR)[KEY].as<bool>()

#define CONFIG_LIST(PTR, KEY) (*PTR)[KEY].as<std::list<std::string> >()

#define CONFIG_VECTOR(PTR, KEY) (*PTR)[KEY].as<std::vector<std::string> >()

namespace Transport {

/// Represents variable:value pairs.

typedef boost::program_options::variables_map Variables;

/// Represents config file.

/// It's used to load config file and allows others parts of libtransport to be configured

/// properly. Config files are text files which use "ini" format. Variables are divided into multiple

/// sections. Every class is configurable with some variables which change its behavior. Check particular

/// class documentation to get a list of all relevant variables for that class.

class Config {

	public:

		/// Constructor.

		Config() {}

		/// Destructor

		virtual ~Config() {}

		/// Loads data from config file.

		/// You can pass your extra options which will be recognized by

		/// the parser using opts parameter.

		/// \param configfile path to config file

		/// \param opts extra options which will be recognized by a parser

		bool load(const std::string &configfile, boost::program_options::options_description &opts, const std::string &jid = "");

		bool load(std::istream &ifs, boost::program_options::options_description &opts, const std::string &jid = "");

		bool load(std::istream &ifs);

		/// Loads data from config file.

		/// This function loads only config variables needed by libtransport.

		/// \see load(const std::string &, boost::program_options::options_description &)

		/// \param configfile path to config file

		bool load(const std::string &configfile, const std::string &jid = "");

		bool reload();

		/// Returns value of variable defined by key.

		/// For variables in sections you can use "section.variable" key format.

		/// \param key config variable name

		const boost::program_options::variable_value &operator[] (const std::string &key) {

			return m_variables[key];

		}

		/// Returns path to config file from which data were loaded.

		const std::string &getConfigFile() { return m_file; }

		const std::map<std::string, std::string> &getUnregistered() {

			return m_unregistered;

		}

		/// This signal is emitted when config is loaded/reloaded.

		boost::signal<void ()> onConfigReloaded;

	private:

		Variables m_variables;

		std::map<std::string, std::string> m_unregistered;

		std::string m_file;

};

			std::cerr << "Config directory " << CONFIG_STRING(config, "service.config_directory") << " does not exist\n";

			exit(6);

		}

		if (!is_directory(p)) {

			std::cerr << "Config directory " << CONFIG_STRING(config, "service.config_directory") << " does not exist\n";

			exit(7);

		}

		std::string spectrum2_binary = searchForBinary("spectrum2");

		if (spectrum2_binary.empty()) {

			std::cerr << "spectrum2 binary not found in PATH\n";

			exit(8);

		}

		directory_iterator end_itr;

		for (directory_iterator itr(p); itr != end_itr; ++itr) {

			if (is_regular(itr->path()) && extension(itr->path()) == ".cfg") {

				Config cfg;

				if (cfg.load(itr->path().string()) == false) {

					std::cerr << "Can't load config file " << itr->path().string() << ". Skipping...\n";

					continue;

				}

				vhosts.push_back(CONFIG_STRING(&cfg, "service.jid"));

				BOOST_FOREACH(std::string &vhost, vhosts) {

					Config vhostCfg;

					if (vhostCfg.load(itr->path().string(), vhost) == false) {

						std::cerr << "Can't load config file " << itr->path().string() << ". Skipping...\n";

						continue;

					}

					int pid = isRunning(CONFIG_STRING(&vhostCfg, "service.pidfile"));

					if (pid == 0) {

						std::cout << "Starting " << itr->path() << ": OK\n";

						exec_(spectrum2_binary, itr->path().string(), vhost);

					}

					else {

						std::cout << "Starting " << itr->path() << ": Already started (PID=" << pid << ")\n";

					}

				}

			}

		}

	}

	catch (const filesystem_error& ex) {

		std::cerr << "boost filesystem error\n";

		exit(5);

}

static void stop_all_instances(ManagerConfig *config) {

	path p(CONFIG_STRING(config, "service.config_directory"));

	try {

		if (!exists(p)) {

			std::cerr << "Config directory " << CONFIG_STRING(config, "service.config_directory") << " does not exist\n";

			exit(6);

		}

		if (!is_directory(p)) {

			std::cerr << "Config directory " << CONFIG_STRING(config, "service.config_directory") << " does not exist\n";

			exit(7);

		}

		directory_iterator end_itr;

		for (directory_iterator itr(p); itr != end_itr; ++itr) {

			if (is_regular(itr->path()) && extension(itr->path()) == ".cfg") {

				Config cfg;

				if (cfg.load(itr->path().string()) == false) {

					std::cerr << "Can't load config file " << itr->path().string() << ". Skipping...\n";

				}

				vhosts.push_back(CONFIG_STRING(&cfg, "service.jid"));

				BOOST_FOREACH(std::string &vhost, vhosts) {

					Config vhostCfg;

					if (vhostCfg.load(itr->path().string(), vhost) == false) {

						std::cerr << "Can't load config file " << itr->path().string() << ". Skipping...\n";

						continue;

					}

					int pid = isRunning(CONFIG_STRING(&vhostCfg, "service.pidfile"));

					if (pid) {

						std::cout << "Stopping " << itr->path() << ": OK\n";

						kill(pid, SIGTERM);

					}

					else {

						std::cout << "Stopping " << itr->path() << ": Not running\n";

					}

				}

			}

		}

	}

	catch (const filesystem_error& ex) {

		std::cerr << "boost filesystem error\n";

		exit(5);