ObjectsAdapter.hpp

#pragma once
 
#include "data/Types.hpp"
#include "migration/cassandra/CassandraMigrationBackend.hpp"
#include "migration/cassandra/impl/FullTableScannerAdapterBase.hpp"
 
#include <boost/asio/spawn.hpp>
#include <xrpl/basics/base_uint.h>
#include <xrpl/protocol/STLedgerEntry.h>
#include <xrpl/protocol/STObject.h>
 
#include <cstdint>
#include <functional>
#include <memory>
#include <optional>
#include <tuple>
#include <utility>
 
namespace migration::cassandra::impl {

struct TableObjectsDesc {
    using Row = std::tuple<ripple::uint256, std::uint32_t, data::Blob>;
    static constexpr char const* kPARTITION_KEY = "key";
    static constexpr char const* kTABLE_NAME = "objects";
};

class ObjectsAdapter : public impl::FullTableScannerAdapterBase<TableObjectsDesc> {
public:
    using OnStateRead = std::function<void(std::uint32_t, std::optional<ripple::SLE>)>;

    explicit ObjectsAdapter(
        std::shared_ptr<CassandraMigrationBackend> backend,
        OnStateRead onStateRead
    )
        : FullTableScannerAdapterBase<TableObjectsDesc>(backend)
        , onStateRead_{std::move(onStateRead)}
    {
    }

    void
    onRowRead(TableObjectsDesc::Row const& row) override;
 
private:
    OnStateRead onStateRead_;
};
 
}  // namespace migration::cassandra::impl