#include "TransactionTransfer.h"

const std::string TransactionTransfer::mInvalidIndexMessage("invalid index");

TransactionTransfer::KontoTableEntry::KontoTableEntry(User* user, google::protobuf::int64 amount, bool negativeAmount/* = false*/)
{
	if (!user) return;

	composeAmountCellString(amount, negativeAmount);

	kontoNameCell = "<td>";
	kontoNameCell += user->getFirstName();
	kontoNameCell += "&nbsp;";
	kontoNameCell += user->getLastName();
	kontoNameCell += "&nbsp;&lt;";
	kontoNameCell += user->getEmail();
	kontoNameCell += "&gt;</td>";
}

TransactionTransfer::KontoTableEntry::KontoTableEntry(const std::string& pubkeyHex, google::protobuf::int64 amount, bool negativeAmount/* = false*/)
{
	composeAmountCellString(amount, negativeAmount);
	kontoNameCell = "<td class=\"small\">0x" + pubkeyHex + "</td>";
}

void TransactionTransfer::KontoTableEntry::composeAmountCellString(google::protobuf::int64 amount, bool negativeAmount)
{
	if (negativeAmount) {
		amountCell = "<td class =\"grd-alert-color\">-";
	}
	else {
		amountCell = "<td class=\"grd-success-color\">";
	}
	amountCell += amountToString(amount);
	amountCell += " GDD</td>";
}

// ********************************************************************************************************************************

TransactionTransfer::TransactionTransfer(const std::string& memo, const model::messages::gradido::Transfer& protoTransfer)
	: TransactionBase(memo), mProtoTransfer(protoTransfer)
{

}

TransactionTransfer::~TransactionTransfer()
{
	mKontoTable.clear();
}

int TransactionTransfer::prepare()
{
	lock();
	const static char functionName[] = { "TransactionTransfer::prepare" };
	if (mProtoTransfer.senderamounts_size() == 0) {
		addError(new Error(functionName, "hasn't sender amount(s)"));
		unlock();
		return -1;
	}
	if (mProtoTransfer.receiveramounts_size() == 0) {
		addError(new Error(functionName, "hasn't receiver amount(s)"));
		unlock();
		return -2;
	}
	mKontoTable.reserve(mProtoTransfer.senderamounts_size() + mProtoTransfer.receiveramounts_size());

	//auto receiverAmount = mProtoTransfer.receiveramount();
	//auto senderAmount
	int senderSum = 0;
	int receiverSum = 0;

	char pubkeyHexTemp[65];

	for (int i = 0; i < mProtoTransfer.senderamounts_size(); i++) {
		auto senderAmount = mProtoTransfer.senderamounts(i);
		auto pubkey = senderAmount.ed25519_sender_pubkey();
		senderSum += senderAmount.amount();
		if (pubkey.size() != 32) {
			addError(new ParamError(functionName, "invalid public key for sender ", i));
			unlock();
			return -3;
		}
		User user((const unsigned char*)pubkey.data());
		if (user.getUserState() == USER_EMPTY) {
			sodium_bin2hex(pubkeyHexTemp, 65, (const unsigned char*)pubkey.data(), pubkey.size());
			mKontoTable.push_back(KontoTableEntry(pubkeyHexTemp, senderAmount.amount(), true));
		}
		else {
			mKontoTable.push_back(KontoTableEntry(&user, senderAmount.amount(), true));
		}
	}
	for (int i = 0; i < mProtoTransfer.receiveramounts_size(); i++) {
		auto receiverAmount = mProtoTransfer.receiveramounts(i);
		auto pubkey = receiverAmount.ed25519_receiver_pubkey();
		receiverSum += receiverAmount.amount();
		if (receiverAmount.ed25519_receiver_pubkey().size() != 32) {
			addError(new ParamError(functionName, "invalid public key for receiver ", i));
			unlock();
			return -4;
		}
		User user((const unsigned char*)pubkey.data());
		if (user.getUserState() == USER_EMPTY) {
			sodium_bin2hex(pubkeyHexTemp, 65, (const unsigned char*)pubkey.data(), pubkey.size());
			mKontoTable.push_back(KontoTableEntry(pubkeyHexTemp, receiverAmount.amount(), false));
		}
		else {
			mKontoTable.push_back(KontoTableEntry(&user, receiverAmount.amount(), false));
		}
	}
	if (senderSum != receiverSum) {
		addError(new Error(functionName, "sender amounts sum != receiver amounts sum"));
		unlock();
		return -5;
	}


	/*
	mReceiverUser = new User(receiverPublic.data());
	getErrors(mReceiverUser);
	if (mReceiverUser->getUserState() == USER_EMPTY) {
		sodium_bin2hex(mReceiverPublicHex, 65, (const unsigned char*)receiverPublic.data(), receiverPublic.size());
		delete mReceiverUser;
		mReceiverUser = nullptr;
	}
	else {
		memcpy(mReceiverPublicHex, mReceiverUser->getPublicKeyHex().data(), 64);
	}
	//*/

	unlock();
	return 0;
}

const std::string& TransactionTransfer::getKontoNameCell(int index)
{
	
	lock();
	if (index >= mKontoTable.size()) {
		unlock();
		return mInvalidIndexMessage;
	}
	unlock();

	return mKontoTable[index].kontoNameCell;
}
const std::string& TransactionTransfer::getAmountCell(int index)
{
	lock();
	if (index >= mKontoTable.size()) {
		unlock();
		return mInvalidIndexMessage;
	}
	unlock();

	return mKontoTable[index].amountCell;
}