#include "ResponseElement.h"
#include "uscxml/plugins/invoker/http/HTTPServletInvoker.h"
#include <glog/logging.h>

#ifdef BUILD_AS_PLUGINS
#include <Pluma/Connector.hpp>
#endif

namespace uscxml {

#ifdef BUILD_AS_PLUGINS
PLUMA_CONNECTOR
bool connect(pluma::Host& host) {
	host.add( new ResponseElementProvider() );
	return true;
}
#endif

boost::shared_ptr<ExecutableContentImpl> ResponseElement::create(Interpreter* interpreter) {
	boost::shared_ptr<ResponseElement> invoker = boost::shared_ptr<ResponseElement>(new ResponseElement());
	invoker->_interpreter = interpreter;
	return invoker;
}

void ResponseElement::enterElement(const Arabica::DOM::Node<std::string>& node) {
	if (!HAS_ATTR(node, "request") && !HAS_ATTR(node, "requestexpr")) {
		LOG(ERROR) << "Response element requires request or requestexpr";
		return;
	}
	if (HAS_ATTR(node, "requestexpr") && !_interpreter->getDataModel()) {
		LOG(ERROR) << "Response element with requestexpr requires datamodel";
		return;
	}
	if (HAS_ATTR(node, "close")) {

	}

	std::string requestId = (HAS_ATTR(node, "request") ? ATTR(node, "request") : _interpreter->getDataModel().evalAsString(ATTR(node, "requestexpr")));

	HTTPServletInvoker* servlet = _interpreter->getHTTPServlet();
	tthread::lock_guard<tthread::recursive_mutex> lock(servlet->getMutex());

	if (servlet->getRequests().find(requestId) == servlet->getRequests().end()) {
		LOG(ERROR) << "No matching HTTP request for response element";
		return;
	}

	std::string statusStr = (HAS_ATTR(node, "status") ? ATTR(node, "status") : "200");
	if (!isNumeric(statusStr.c_str(), 10)) {
		LOG(ERROR) << "Response element with non-numeric status " << statusStr;
		return;
	}
	int status = strTo<int>(statusStr);

	HTTPServer::Request httpReq = servlet->getRequests()[requestId];

	HTTPServer::Reply httpReply(httpReq);
	httpReply.status = status;

	HTTPServer::reply(httpReply);
	servlet->getRequests().erase(requestId);
}

void ResponseElement::exitElement(const Arabica::DOM::Node<std::string>& node) {

}

}