xahaud/src/Ledger.h

#ifndef __LEDGER__
#define __LEDGER__

#include <map>
#include <list>

#include <boost/shared_ptr.hpp>
#include <boost/enable_shared_from_this.hpp>
#include <boost/date_time/posix_time/posix_time.hpp>

#include "../json/value.h"

#include "Transaction.h"
#include "AccountState.h"
#include "types.h"
#include "BitcoinUtil.h"
#include "SHAMap.h"


enum LedgerStateParms
{
	lepNONE = 0,				// no special flags

	// input flags
	lepCREATE,					// Create if not present

	// output flags
	lepOKAY,					// success
	lepMISSING,					// No node in that slot
	lepWRONGTYPE,				// Node of different type there
	lepCREATED,					// Node was created
	lepERROR,					// error
};

class Ledger : public boost::enable_shared_from_this<Ledger>
{ // The basic Ledger structure, can be opened, closed, or synching
	friend class TransactionEngine;
public:
	typedef boost::shared_ptr<Ledger> pointer;


	enum TransResult
	{
		TR_ERROR	=-1,
		TR_SUCCESS	=0,
		TR_NOTFOUND	=1,
		TR_ALREADY	=2,
		TR_BADTRANS =3,	// the transaction itself is corrupt
		TR_BADACCT	=4,	// one of the accounts is invalid
		TR_INSUFF	=5,	// the sending(apply)/receiving(remove) account is broke
		TR_PASTASEQ	=6,	// account is past this transaction
		TR_PREASEQ	=7,	// account is missing transactions before this
		TR_BADLSEQ	=8,	// ledger too early
		TR_TOOSMALL =9, // amount is less than Tx fee
	};


private:
	uint256 mHash, mParentHash, mTransHash, mAccountHash;
	uint64 mTotCoins;
	uint64 mCloseTime; // when this ledger closes
	uint32 mLedgerSeq;
	uint16 mLedgerInterval;
	bool mClosed, mValidHash, mAccepted, mImmutable;

	SHAMap::pointer mTransactionMap, mAccountStateMap;

	mutable boost::recursive_mutex mLock;

	Ledger(const Ledger&);				// no implementation
	Ledger& operator=(const Ledger&);	// no implementation

protected:

	bool addTransaction(Transaction::pointer);
	bool addTransaction(const uint256& id, const Serializer& txn, uint64_t fee);

	static Ledger::pointer getSQL(const std::string& sqlStatement);

	SerializedLedgerEntry::pointer getASNode(LedgerStateParms& parms, const uint256& nodeID,
	 LedgerEntryType let);

public:
	Ledger(const NewcoinAddress& masterID, uint64 startAmount); // used for the starting bootstrap ledger
	Ledger(const uint256 &parentHash, const uint256 &transHash, const uint256 &accountHash,
		uint64 totCoins, uint64 timeStamp, uint32 ledgerSeq); // used for database ledgers
	Ledger(const std::vector<unsigned char>& rawLedger);
	Ledger(const std::string& rawLedger);
	Ledger(Ledger::pointer previous);	// ledger after this one

	void updateHash();
	void setClosed()	{ mClosed = true; }
	void setAccepted()	{ mAccepted = true; }
	bool isClosed()		{ return mClosed; }
	bool isAccepted()	{ return mAccepted; }

	// ledger signature operations
	void addRaw(Serializer &s);

	uint256 getHash();
	const uint256& getParentHash() const	{ return mParentHash; }
	const uint256& getTransHash() const		{ return mTransHash; }
	const uint256& getAccountHash() const	{ return mAccountHash; }
	uint64 getTotalCoins() const			{ return mTotCoins; }
	uint64 getCloseTimeNC() const			{ return mCloseTime; }
	uint32 getLedgerSeq() const				{ return mLedgerSeq; }
	uint16 getInterval() const				{ return mLedgerInterval; }

	// close time functions
	boost::posix_time::ptime getCloseTime() const;
	void setCloseTime(boost::posix_time::ptime);
	uint64 getNextLedgerClose() const;

	// low level functions
	SHAMap::pointer peekTransactionMap() { return mTransactionMap; }
	SHAMap::pointer peekAccountStateMap() { return mAccountStateMap; }

	// ledger sync functions
	void setAcquiring(void);
	bool isAcquiring(void);
	bool isAcquiringTx(void);
	bool isAcquiringAS(void);

	// Transaction Functions
	bool hasTransaction(const uint256& TransID) const;
	Transaction::pointer getTransaction(const uint256& transID) const;

	Ledger::pointer switchPreviousLedger(Ledger::pointer oldPrevious, Ledger::pointer newPrevious,	int limit);

	// high-level functions
	AccountState::pointer getAccountState(const NewcoinAddress& acctID);
	LedgerStateParms writeBack(LedgerStateParms parms, SerializedLedgerEntry::pointer);
	SerializedLedgerEntry::pointer getAccountRoot(LedgerStateParms& parms, const uint160& accountID);
	SerializedLedgerEntry::pointer getNickname(LedgerStateParms& parms, const std::string& nickname);
	SerializedLedgerEntry::pointer getNickname(LedgerStateParms& parms, const uint256& nickHash);
//	SerializedLedgerEntry::pointer getRippleState(LedgerStateParms parms, const uint160& offeror,
//		const uint160& borrower, const Currency& currency);

	// database functions
	static void saveAcceptedLedger(Ledger::pointer);
	static Ledger::pointer loadByIndex(uint32 ledgerIndex);
	static Ledger::pointer loadByHash(const uint256& ledgerHash);

	// index calculation functions
	static uint256 getAccountRootIndex(const uint160& account);
	static uint256 getAccountRootIndex(const NewcoinAddress& account)
	{ return getAccountRootIndex(account.getAccountID()); }

	static uint256 getRippleIndex(const uint160& account, const uint160& extendTo, const uint160& currency);
	static uint256 getRippleIndex(const uint160& account, const uint160& extendTo)
	{ return getRippleIndex(account, extendTo, uint160()); }
	static uint256 getRippleIndex(const NewcoinAddress& account, const NewcoinAddress& extendTo,
	 const uint160& currency)
	{ return getRippleIndex(account.getAccountID(), extendTo.getAccountID(), currency); }

	bool isCompatible(boost::shared_ptr<Ledger> other);
	bool signLedger(std::vector<unsigned char> &signature, const LocalHanko &hanko);

	void addJson(Json::Value&);

	static bool unitTest();
};

inline LedgerStateParms operator|(const LedgerStateParms& l1, const LedgerStateParms& l2)
{
	return static_cast<LedgerStateParms>(static_cast<int>(l1) | static_cast<int>(l2));
}

inline LedgerStateParms operator&(const LedgerStateParms& l1, const LedgerStateParms& l2)
{
	return static_cast<LedgerStateParms>(static_cast<int>(l1) & static_cast<int>(l2));
}

#endif
// vim:ts=4