TransactionsAdapter.hpp

#pragma once
 
#include "migration/cassandra/CassandraMigrationBackend.hpp"
#include "migration/cassandra/impl/FullTableScannerAdapterBase.hpp"
 
#include <boost/asio/spawn.hpp>
#include <xrpl/basics/Blob.h>
#include <xrpl/basics/base_uint.h>
#include <xrpl/protocol/STTx.h>
#include <xrpl/protocol/TxMeta.h>
 
#include <cstdint>
#include <functional>
#include <memory>
#include <tuple>
#include <utility>
 
namespace migration::cassandra::impl {

struct TableTransactionsDesc {
    // hash, date, ledger_seq, metadata, transaction
    using Row = std::tuple<xrpl::uint256, std::uint64_t, std::uint32_t, xrpl::Blob, xrpl::Blob>;
    static constexpr char const* kPartitionKey = "hash";
    static constexpr char const* kTableName = "transactions";
};

class TransactionsAdapter : public impl::FullTableScannerAdapterBase<TableTransactionsDesc> {
public:
    using OnTransactionRead = std::function<void(xrpl::STTx, xrpl::TxMeta)>;

    explicit TransactionsAdapter(
        std::shared_ptr<CassandraMigrationBackend> backend,
        OnTransactionRead onTxRead
    )
        : FullTableScannerAdapterBase<TableTransactionsDesc>(backend)
        , onTransactionRead_{std::move(onTxRead)}
    {
    }

    void
    onRowRead(TableTransactionsDesc::Row const& row) override;
 
private:
    OnTransactionRead onTransactionRead_;
};
 
}  // namespace migration::cassandra::impl