#include "core.h"
#include "exceptions.h"
#include <Ice/Initialize.h>
#include <boost/filesystem/convenience.hpp>

namespace IceSpider {
	const boost::filesystem::path Core::defaultConfig("config/ice.properties");

	static
	bool
	operator/=(const PathElements & pathparts, const IRouteHandler * r)
	{
		auto rpi = r->parts.begin();
		for (auto ppi = pathparts.begin(); ppi != pathparts.end(); ++ppi, ++rpi) {
			if (!(*rpi)->matches(*ppi)) return false;
		}
		return true;
	}

	Core::Core(int argc, char ** argv)
	{
		Ice::InitializationData id;
		id.properties = Ice::createProperties(argc, argv);
		if (boost::filesystem::exists(defaultConfig)) {
			id.properties->load(defaultConfig.string());
		}
		communicator = Ice::initialize(id);

		// Initialize routes
		for (const auto & rp : AdHoc::PluginManager::getDefault()->getAll<RouteHandlerFactory>()) {
			auto r = rp->implementation()->create(this);
			if (routes.size() <= r->pathElementCount()) {
				routes.resize(r->pathElementCount() + 1);
			}
			auto & lroutes = routes[r->pathElementCount()];
			lroutes.push_back(r);
		}
	}

	Core::~Core()
	{
		if (communicator) communicator->destroy();
		for (auto l : routes) {
			for (auto r : l) {
				delete r;
			}
		}
	}

	void
	Core::process(IHttpRequest * request) const
	{
		try {
			findRoute(request)->execute(request);
		}
		catch (const HttpException & he) {
			request->response(he.code, he.message);
		}
		catch (const std::exception & e) {
			request->response(500, e.what());
		}
		catch (...) {
			request->response(500, "Unknown internal server error");
		}
	}

	const IRouteHandler *
	Core::findRoute(const IHttpRequest * request) const
	{
		const auto & pathparts = request->getRequestPath();
		const auto method = request->getRequestMethod();
		if (pathparts.size() >= routes.size()) {
			throw Http404_NotFound();
		}
		const auto & routeSet = routes[pathparts.size()];
		bool match = false;
		for (const auto & r : routeSet) {
			if (pathparts /= r) {
				if (r->method == method) {
					return r;
				}
				match = true;
			}
		}
		if (!match) {
			throw Http404_NotFound();
		}
		throw Http405_MethodNotAllowed();
	}

	Ice::ObjectPrx
	Core::getProxy(const char * type) const
	{
		char * buf = __cxxabiv1::__cxa_demangle(type, NULL, NULL, NULL);
		auto i = communicator->propertyToProxy(buf);
		free(buf);
		return i;
	}
}