ARCHIVE/xahaud
3
0
Fork 0
mirror of https://github.com/Xahau/xahaud.git synced 2026-07-23 15:10:10 +00:00
Code Issues Packages Projects Releases Wiki Activity

test(ledger): cover consensus entropy replay

Browse Source
This commit is contained in:
Nicholas Dudfield
2026-07-16 19:29:43 +07:00
parent 1be657098f
commit a6bcde3044
1 changed files with 70 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

71
src/test/app/LedgerReplay_test.cpp
View File

@@ -30,6 +30,8 @@
#include <xrpld/overlay/PeerSet.h>
#include <xrpld/overlay/detail/PeerImp.h>
#include <xrpl/basics/Slice.h>
#include <xrpl/protocol/Feature.h>
#include <xrpl/protocol/Serializer.h>
#include <chrono>
#include <thread>
@@ -40,7 +42,7 @@ namespace test {
struct LedgerReplay_test : public beast::unit_test::suite
{
void
run() override
testReplay()
{
testcase("Replay ledger");
@@ -73,6 +75,73 @@ struct LedgerReplay_test : public beast::unit_test::suite
BEAST_EXPECT(replayed->info().hash == lastClosed->info().hash);
}
void
testConsensusEntropyReplay()
{
testcase("Replay ledger with consensus entropy");
using namespace jtx;
auto const alice = Account("alice");
auto const bob = Account("bob");
Env env = [&] {
auto c = jtx::envconfig();
auto& sectionNode = c->section(ConfigSection::nodeDatabase());
sectionNode.set("type", "memory");
c->overwrite(SECTION_RELATIONAL_DB, "backend", "sqlite");
return jtx::Env(
*this,
std::move(c),
supported_amendments() | featureConsensusEntropy,
nullptr);
}();
env.fund(XRP(100000), alice, bob);
env.close();
LedgerMaster& ledgerMaster = env.app().getLedgerMaster();
auto const lastClosed = ledgerMaster.getClosedLedger();
auto const lastClosedParent =
ledgerMaster.getLedgerByHash(lastClosed->info().parentHash);
LedgerReplay const replayData(lastClosedParent, lastClosed);
auto const& orderedTxns = replayData.orderedTxns();
BEAST_EXPECT(orderedTxns.size() > 1);
if (orderedTxns.empty())
return;
auto const& [index, entropyTx] = *orderedTxns.begin();
BEAST_EXPECT(index == 0);
BEAST_EXPECT(entropyTx->getTxnType() == ttCONSENSUS_ENTROPY);
auto const persisted =
lastClosed->txRead(entropyTx->getTransactionID());
BEAST_EXPECT(persisted.first);
BEAST_EXPECT(
persisted.second &&
persisted.second->getFieldU32(sfTransactionIndex) == index);
if (persisted.first)
{
Serializer persistedBytes;
persisted.first->add(persistedBytes);
Serializer replayBytes;
entropyTx->add(replayBytes);
BEAST_EXPECT(replayBytes.peekData() == persistedBytes.peekData());
}
auto const replayed =
buildLedger(replayData, tapNONE, env.app(), env.journal);
BEAST_EXPECT(replayed->info().hash == lastClosed->info().hash);
}
void
run() override
{
testReplay();
testConsensusEntropyReplay();
}
};
enum class InboundLedgersBehavior {