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

Impliments book_offers in postgres

Browse Source
This commit is contained in:
Nathan Nichols
2021-05-10 15:40:03 -05:00
parent 945598d953
commit d7ce14983a
1 changed files with 16 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
reporting/PostgresBackend.cpp
View File

@@ -431,14 +431,11 @@ PostgresBackend::fetchBookOffers(
continue; continue;
} }
auto blob = res.asUnHexedBlob(i, 2);
results.push_back({std::move(book), std::move(key)}); results.push_back({std::move(book), std::move(key)});
} }
return {complete, results}; return {complete, results};
} }
std::vector<Blob> blobs = fetchLedgerObjects(keys, ledgerSequence);
return {true, {}}; return {true, {}};
}; };
@@ -476,6 +473,22 @@ PostgresBackend::fetchBookOffers(
if (upperComplete) if (upperComplete)
return fetchObjects(upperResults, ledgerSequence, limit); return fetchObjects(upperResults, ledgerSequence, limit);
auto lower = (ledgerSequence >> 8) << 8;
auto [lowerComplete, lowerResults] = getBooks(lower);
assert(lowerComplete);
std::vector<bookKeyPair> pairs;
pairs.reserve(upperResults.size() + lowerResults.size());
std::merge(upperResults.begin(), upperResults.end(),
lowerResults.begin(), lowerResults.end(),
std::back_inserter(pairs),
[](bookKeyPair pair1, bookKeyPair pair2) -> bool
{
return pair1.first < pair2.first;
});
return fetchObjects(pairs, ledgerSequence, limit);
} }
std::vector<TransactionAndMetadata> std::vector<TransactionAndMetadata>