LedgerDiff.cpp

#include <xrpld/rpc/Context.h>
#include <xrpld/rpc/GRPCHandlers.h>
#include <xrpld/rpc/detail/RPCLedgerHelpers.h>
 
#include <xrpl/beast/utility/instrumentation.h>
#include <xrpl/ledger/Ledger.h>
#include <xrpl/shamap/SHAMap.h>
 
#include <grpcpp/support/status.h>
#include <org/xrpl/rpc/v1/get_ledger_diff.pb.h>
 
#include <limits>
#include <memory>
#include <utility>
 
namespace xrpl {
std::pair<org::xrpl::rpc::v1::GetLedgerDiffResponse, grpc::Status>
doLedgerDiffGrpc(rpc::GRPCContext<org::xrpl::rpc::v1::GetLedgerDiffRequest>& context)
{
    org::xrpl::rpc::v1::GetLedgerDiffRequest const& request = context.params;
    org::xrpl::rpc::v1::GetLedgerDiffResponse response;
    grpc::Status const status = grpc::Status::OK;
 
    std::shared_ptr<ReadView const> baseLedgerRv;
    std::shared_ptr<ReadView const> desiredLedgerRv;
 
    if (rpc::ledgerFromSpecifier(baseLedgerRv, request.base_ledger(), context))
    {
        grpc::Status const errorStatus{grpc::StatusCode::NOT_FOUND, "base ledger not found"};
        return {response, errorStatus};
    }
 
    if (rpc::ledgerFromSpecifier(desiredLedgerRv, request.desired_ledger(), context))
    {
        grpc::Status const errorStatus{grpc::StatusCode::NOT_FOUND, "desired ledger not found"};
        return {response, errorStatus};
    }
 
    std::shared_ptr<Ledger const> const baseLedger =
        std::dynamic_pointer_cast<Ledger const>(baseLedgerRv);
    if (!baseLedger)
    {
        grpc::Status const errorStatus{grpc::StatusCode::NOT_FOUND, "base ledger not validated"};
        return {response, errorStatus};
    }
 
    std::shared_ptr<Ledger const> const desiredLedger =
        std::dynamic_pointer_cast<Ledger const>(desiredLedgerRv);
    if (!desiredLedger)
    {
        grpc::Status const errorStatus{grpc::StatusCode::NOT_FOUND, "desired ledger not validated"};
        return {response, errorStatus};
    }
 
    SHAMap::Delta differences;
 
    int const maxDifferences = std::numeric_limits<int>::max();
 
    bool const res =
        baseLedger->stateMap().compare(desiredLedger->stateMap(), differences, maxDifferences);
    if (!res)
    {
        grpc::Status const errorStatus{
            grpc::StatusCode::RESOURCE_EXHAUSTED, "too many differences between specified ledgers"};
        return {response, errorStatus};
    }
 
    for (auto& [k, v] : differences)
    {
        auto diff = response.mutable_ledger_objects()->add_objects();
        auto inBase = v.first;
        auto inDesired = v.second;
 
        // key does not exist in desired
        if (!inDesired)
        {
            diff->set_key(k.data(), k.size());
        }
        else
        {
            XRPL_ASSERT(inDesired->size() > 0, "xrpl::doLedgerDiffGrpc : non-empty desired");
            diff->set_key(k.data(), k.size());
            if (request.include_blobs())
            {
                diff->set_data(inDesired->data(), inDesired->size());
            }
        }
    }
    return {response, status};
}
 
}  // namespace xrpl