mirror of
https://github.com/XRPLF/rippled.git
synced 2025-12-06 17:27:55 +00:00
51db2d2cd7
Process to SQL database and publish from this structure. Include number of transactions in ledger publish info. Publish transactions in applied order.
92 lines
2.4 KiB
C++
92 lines
2.4 KiB
C++
#include "AcceptedLedger.h"
|
|
|
|
#include <boost/foreach.hpp>
|
|
|
|
TaggedCache<uint256, AcceptedLedger> AcceptedLedger::ALCache("AcceptedLedger", 4, 60);
|
|
|
|
ALTransaction::ALTransaction(uint32 seq, SerializerIterator& sit)
|
|
{
|
|
Serializer txnSer(sit.getVL());
|
|
SerializerIterator txnIt(txnSer);
|
|
|
|
mTxn = boost::make_shared<SerializedTransaction>(boost::ref(txnIt));
|
|
mRawMeta= sit.getVL();
|
|
mMeta = boost::make_shared<TransactionMetaSet>(mTxn->getTransactionID(), seq, mRawMeta);
|
|
mAffected = mMeta->getAffectedAccounts();
|
|
mResult = mMeta->getResultTER();
|
|
}
|
|
|
|
ALTransaction::ALTransaction(SerializedTransaction::ref txn, TransactionMetaSet::ref met) :
|
|
mTxn(txn), mMeta(met), mAffected(met->getAffectedAccounts())
|
|
{
|
|
mResult = mMeta->getResultTER();
|
|
}
|
|
|
|
ALTransaction::ALTransaction(SerializedTransaction::ref txn, TER result) :
|
|
mTxn(txn), mResult(result), mAffected(txn->getMentionedAccounts())
|
|
{ ; }
|
|
|
|
std::string ALTransaction::getEscMeta() const
|
|
{
|
|
assert(!mRawMeta.empty());
|
|
return sqlEscape(mRawMeta);
|
|
}
|
|
|
|
Json::Value ALTransaction::getJson(int j) const
|
|
{
|
|
Json::Value ret(Json::objectValue);
|
|
ret["transaction"] = mTxn->getJson(j);
|
|
if (mMeta)
|
|
{
|
|
ret["meta"] = mMeta->getJson(j);
|
|
ret["raw_meta"] = strHex(mRawMeta);
|
|
}
|
|
ret["result"] = transHuman(mResult);
|
|
|
|
if (!mAffected.empty())
|
|
{
|
|
Json::Value affected(Json::arrayValue);
|
|
BOOST_FOREACH(const RippleAddress& ra, mAffected)
|
|
{
|
|
affected.append(ra.humanAccountID());
|
|
}
|
|
ret["affected"] = affected;
|
|
}
|
|
|
|
return ret;
|
|
}
|
|
|
|
AcceptedLedger::AcceptedLedger(Ledger::ref ledger) : mLedger(ledger)
|
|
{
|
|
SHAMap& txSet = *ledger->peekTransactionMap();
|
|
for (SHAMapItem::pointer item = txSet.peekFirstItem(); !!item; item = txSet.peekNextItem(item->getTag()))
|
|
{
|
|
SerializerIterator sit(item->peekSerializer());
|
|
insert(ALTransaction(ledger->getLedgerSeq(), sit));
|
|
}
|
|
}
|
|
|
|
AcceptedLedger::pointer AcceptedLedger::makeAcceptedLedger(Ledger::ref ledger)
|
|
{
|
|
AcceptedLedger::pointer ret = ALCache.fetch(ledger->getHash());
|
|
if (ret)
|
|
return ret;
|
|
ret = AcceptedLedger::pointer(new AcceptedLedger(ledger));
|
|
ALCache.canonicalize(ledger->getHash(), ret);
|
|
return ret;
|
|
}
|
|
|
|
void AcceptedLedger::insert(const ALTransaction& at)
|
|
{
|
|
assert(mMap.find(at.getIndex()) == mMap.end());
|
|
mMap.insert(std::make_pair(at.getIndex(), at));
|
|
}
|
|
|
|
const ALTransaction* AcceptedLedger::getTxn(int i) const
|
|
{
|
|
map_t::const_iterator it = mMap.find(i);
|
|
if (it == mMap.end())
|
|
return NULL;
|
|
return &it->second;
|
|
}
|