#include "JsonTransaction.h"
#include "Poco/URI.h"
#include "Poco/Dynamic/Struct.h"

#include "../SingletonManager/SessionManager.h"
#include "../ServerConfig.h"

Poco::JSON::Object* JsonTransaction::handle(Poco::Dynamic::Var params)
{
	Poco::JSON::Object* result = new Poco::JSON::Object;
	int session_id = 0;
	
	// if is json object
	if (params.type() == typeid(Poco::JSON::Object::Ptr)) {
		Poco::JSON::Object::Ptr paramJsonObject = params.extract<Poco::JSON::Object::Ptr>();

		try {
			/// Throws a RangeException if the value does not fit
			/// into the result variable.
			/// Throws a NotImplementedException if conversion is
			/// not available for the given type.
			/// Throws InvalidAccessException if Var is empty.
			paramJsonObject->get("session_id").convert(session_id);
			auto sm = SessionManager::getInstance();
			if (session_id != 0) {
				auto session = sm->getSession(session_id);
				if (!session) {
					result->set("state", "error");
					result->set("msg", "session not found");
					return result;
				}

				int balance = 0;
				
				if (!paramJsonObject->isNull("balance")) {
					paramJsonObject->get("balance").convert(balance);
					if (balance) {
						auto nu = session->getNewUser();
						if (!nu.isNull()) {
							nu->setBalance(balance);
						}
					}
				}

				std::string transactionBase64String;
				Poco::Dynamic::Var transaction_base64 = paramJsonObject->get("transaction_base64");
				int alreadyEnlisted = 0;
				bool auto_sign = false;
				auto auto_sign_json = paramJsonObject->get("auto_sign");
				if (!auto_sign_json.isEmpty()) {
					auto_sign_json.convert(auto_sign);
				}
				
				if (transaction_base64.isString()) {
					paramJsonObject->get("transaction_base64").convert(transactionBase64String);

					if (!session->startProcessingTransaction(transactionBase64String, auto_sign)) {
						if (auto_sign) {
							auto errorJson = session->getErrorsArray();
							result->set("state", "error");
							result->set("msg", "error processing transaction");
							result->set("details", errorJson);
							return result;
						}
						auto lastError = session->getLastError();
						if (lastError) delete lastError;
						result->set("state", "error");
						result->set("msg", "already enlisted");
						return result;
					}

				} else {
					Poco::DynamicStruct ds = *paramJsonObject;
					int alreadyEnlisted = 0;

					for (int i = 0; i < ds["transaction_base64"].size(); i++) {
						ds["transaction_base64"][i].convert(transactionBase64String);
						if (!session->startProcessingTransaction(transactionBase64String, auto_sign)) {
							auto lastError = session->getLastError();
							if (lastError) delete lastError;
							alreadyEnlisted++;
						}
					}
					
					if (alreadyEnlisted > 0) {
						result->set("state", "warning");
						result->set("msg", std::to_string(alreadyEnlisted) + " already enlisted");
						return result;
					}
				}

				

				result->set("state", "success");
				return result;
			}

		}
		catch (Poco::Exception& ex) {
			printf("[JsonTransaction::handle] try to use params as jsonObject: %s\n", ex.displayText().data());
			result->set("state", "error");
			result->set("msg", "json exception");
			result->set("details", ex.displayText());
			return result;
		}
	}
	else if (params.isVector()) {
		const Poco::URI::QueryParameters queryParams = params.extract<Poco::URI::QueryParameters>();
		auto transactionIT = queryParams.begin();
		for (auto it = queryParams.begin(); it != queryParams.end(); it++) {
			if (it->first == "session_id") {
				session_id = stoi(it->second);
				//break;
			}
			else if (it->first == "transaction_base64") {
				transactionIT = it;
			}
		}
		if (session_id) {
			auto sm = SessionManager::getInstance();
			auto session = sm->getSession(session_id);
			if (!session) {
				result->set("state", "error");
				result->set("msg", "session not found");
				return result;
			}
			if (!session->startProcessingTransaction(transactionIT->second)) {
				auto lastError = session->getLastError();
				if (lastError) delete lastError;
				result->set("state", "error");
				result->set("msg", "already enlisted");
				return result;
			}
			result->set("state", "success");
			return result;
		}
		else {
			result->set("state", "error");
			result->set("msg", "session id not set");
			return result;
		}
	}
	else if (params.isStruct()) {
		result->set("state", "error");
		result->set("msg", "struct not implemented yet");
	}
	else if (params.isArray()) {
		result->set("state", "error");
		result->set("msg", "array not implemented yet");
	}
	else if (params.isList()) {
		result->set("state", "error");
		result->set("msg", "list not implemented yet");
	}
	else if (params.isString()) {
		result->set("state", "error");
		result->set("msg", "string not implemented yet");
	}
	else if (params.isDeque()) {
		result->set("state", "error");
		result->set("meg", "deque not implemented yet");
	}
	else {

		result->set("state", "error");
		result->set("msg", "format not implemented");
		result->set("details", std::string(params.type().name()));
	}

	return result;
}