LedgerFeed.hpp

#pragma once
 
#include "data/BackendInterface.hpp"
#include "feed/Types.hpp"
#include "feed/impl/SingleFeedBase.hpp"
#include "util/async/AnyExecutionContext.hpp"
 
#include <boost/asio/io_context.hpp>
#include <boost/asio/spawn.hpp>
#include <boost/json/object.hpp>
#include <boost/json/serialize.hpp>
#include <xrpl/protocol/Fees.h>
#include <xrpl/protocol/LedgerHeader.h>
 
#include <cstdint>
#include <memory>
#include <string>
 
namespace feed::impl {

class LedgerFeed : public SingleFeedBase {
public:
    LedgerFeed(util::async::AnyExecutionContext& executionCtx)
        : SingleFeedBase(executionCtx, "ledger")
    {
    }

    boost::json::object
    sub(boost::asio::yield_context yield,
        std::shared_ptr<data::BackendInterface const> const& backend,
        SubscriberSharedPtr const& subscriber,
        uint32_t networkID);

    void
    pub(ripple::LedgerHeader const& lgrInfo,
        ripple::Fees const& fees,
        std::string const& ledgerRange,
        uint32_t txnCount,
        uint32_t networkID);
 
private:
    static boost::json::object
    makeLedgerPubMessage(
        ripple::LedgerHeader const& lgrInfo,
        ripple::Fees const& fees,
        std::string const& ledgerRange,
        uint32_t txnCount,
        uint32_t networkID
    );
};
}  // namespace feed::impl