ARCHIVE/clio
1
0
Fork 0
mirror of https://github.com/XRPLF/clio.git synced 2025-11-27 23:25:53 +00:00
Code Issues Packages Projects Releases Wiki Activity

handle validated as ledger_index

Browse Source
This commit is contained in:
CJ Cobb
2021-06-23 16:52:45 +00:00
parent 0d2aef18b5
commit 2e00c0edcb
2 changed files with 9 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
src/handlers/RPCHelpers.cpp
View File

@@ -1,5 +1,5 @@
#include <handlers/RPCHelpers.h>
#include <backend/BackendInterface.h> #include <backend/BackendInterface.h>
#include <handlers/RPCHelpers.h>
std::optional<ripple::AccountID> std::optional<ripple::AccountID>
accountFromStringStrict(std::string const& account) accountFromStringStrict(std::string const& account)
@@ -60,11 +60,8 @@ deserializeTxPlusMeta(
{ {
auto [tx, meta] = deserializeTxPlusMeta(blobs); auto [tx, meta] = deserializeTxPlusMeta(blobs);
std::shared_ptr<ripple::TxMeta> m = std::shared_ptr<ripple::TxMeta> m =
std::make_shared<ripple::TxMeta>( std::make_shared<ripple::TxMeta>(tx->getTransactionID(), seq, *meta);
tx->getTransactionID(),
seq,
*meta);
return {tx, m}; return {tx, m};
} }
@@ -85,9 +82,8 @@ toJson(ripple::STBase const& obj)
boost::json::value boost::json::value
getJson(Json::Value const& value) getJson(Json::Value const& value)
{ {
boost::json::value boostValue = boost::json::value boostValue = boost::json::parse(value.toStyledString());
boost::json::parse(value.toStyledString());
return boostValue; return boostValue;
} }
@@ -147,7 +143,8 @@ ledgerSequenceFromRequest(
boost::json::object const& request, boost::json::object const& request,
BackendInterface const& backend) BackendInterface const& backend)
{ {
if (not request.contains("ledger_index")) if (!request.contains("ledger_index") ||
request.at("ledger_index").is_string())
{ {
return backend.fetchLatestLedgerSequence(); return backend.fetchLatestLedgerSequence();
} }

4
test.py
View File

@@ -681,7 +681,7 @@ import pathlib
numCalls = 0 numCalls = 0
async def ledgers(ip, port, minLedger, maxLedger, transactions, expand, maxCalls): async def ledgers(ip, port, minLedger, maxLedger, transactions, expand, maxCalls):
global numCalls global numCalls
address = 'wss://' + str(ip) + ':' + str(port) address = 'ws://' + str(ip) + ':' + str(port)
random.seed() random.seed()
ledger = 0 ledger = 0
ssl_context = ssl.SSLContext(ssl.PROTOCOL_TLS_CLIENT) ssl_context = ssl.SSLContext(ssl.PROTOCOL_TLS_CLIENT)
@@ -690,7 +690,7 @@ async def ledgers(ip, port, minLedger, maxLedger, transactions, expand, maxCalls
ssl_context.check_hostname = False ssl_context.check_hostname = False
ssl_context.verify_mode = ssl.CERT_NONE ssl_context.verify_mode = ssl.CERT_NONE
try: try:
async with websockets.connect(address,max_size=1000000000,ssl=ssl_context) as ws: async with websockets.connect(address,max_size=1000000000) as ws:
global numCalls global numCalls
for i in range(0, maxCalls): for i in range(0, maxCalls):