#include "ChangeTransactor.h"
#include "Log.h"

SETUP_LOG();

TER ChangeTransactor::doApply()
{
	if (mTxn.getTxnType() == ttFEATURE)
		return applyFeature();

	if (mTxn.getTxnType() == ttFEE)
		return applyFee();

	return temUNKNOWN;
}

TER ChangeTransactor::checkSig()
{
	if (mTxn.getFieldAccount160(sfAccount).isNonZero())
	{
		cLog(lsWARNING) << "Change transaction had bad source account";
		return temBAD_SRC_ACCOUNT;
	}

	if (!mTxn.getSigningPubKey().empty() || !mTxn.getSignature().empty())
	{
		cLog(lsWARNING) << "Change transaction had bad signature";
		return temBAD_SIGNATURE;
	}

	return tesSUCCESS;
}

TER ChangeTransactor::checkSeq()
{
	if ((mTxn.getSequence() != 0) || mTxn.isFieldPresent(sfPreviousTxnID))
	{
		cLog(lsWARNING) << "Change transaction had bad sequence";
		return temBAD_SEQUENCE;
	}
	return tesSUCCESS;
}

TER ChangeTransactor::payFee()
{
	if (mTxn.getTransactionFee() != STAmount())
	{
		cLog(lsWARNING) << "Change transaction with non-zero fee";
		return temBAD_FEE;
	}

	return tesSUCCESS;
}

TER ChangeTransactor::preCheck()
{
	mTxnAccountID	= mTxn.getSourceAccount().getAccountID();
	if (mTxnAccountID.isNonZero())
	{
		cLog(lsWARNING) << "applyTransaction: bad source id";

		return temBAD_SRC_ACCOUNT;
	}

	if (isSetBit(mParams, tapOPEN_LEDGER))
	{
		cLog(lsWARNING) << "Change transaction against open ledger";
		return temINVALID;
	}

	return tesSUCCESS;
}

TER ChangeTransactor::applyFeature()
{
	uint256 feature = mTxn.getFieldH256(sfFeature);

	SLE::pointer featureObject = mEngine->entryCache(ltFEATURES, Ledger::getLedgerFeatureIndex());
	if (!featureObject)
		featureObject = mEngine->entryCreate(ltFEATURES, Ledger::getLedgerFeatureIndex());

	STVector256 features = featureObject->getFieldV256(sfFeatures);
	if (features.hasValue(feature))
		return tefALREADY;
	
	features.addValue(feature);
	featureObject->setFieldV256(sfFeatures, features);
	mEngine->entryModify(featureObject);

	return tesSUCCESS;
}

TER ChangeTransactor::applyFee()
{

	SLE::pointer feeObject = mEngine->entryCache(ltFEE_SETTINGS, Ledger::getLedgerFeeIndex());
	if (!feeObject)
		feeObject = mEngine->entryCreate(ltFEE_SETTINGS, Ledger::getLedgerFeeIndex());

	cLog(lsINFO) << "Previous fee object: " << feeObject->getJson(0);

	feeObject->setFieldU64(sfBaseFee, mTxn.getFieldU64(sfBaseFee));
	feeObject->setFieldU32(sfReferenceFeeUnits, mTxn.getFieldU32(sfReferenceFeeUnits));
	feeObject->setFieldU32(sfReserveBase, mTxn.getFieldU32(sfReserveBase));
	feeObject->setFieldU32(sfReserveIncrement, mTxn.getFieldU32(sfReserveIncrement));

	mEngine->entryModify(feeObject);

	cLog(lsINFO) << "New fee object: " << feeObject->getJson(0);
	cLog(lsWARNING) << "Fees have been changed";
	return tesSUCCESS;
}