BookChangesFeed.hpp

#pragma once
 
#include "data/Types.hpp"
#include "feed/impl/SingleFeedBase.hpp"
#include "rpc/BookChangesHelper.hpp"
#include "util/async/AnyExecutionContext.hpp"
 
#include <boost/asio/io_context.hpp>
#include <boost/json/serialize.hpp>
#include <xrpl/protocol/LedgerHeader.h>
 
#include <vector>
 
namespace feed::impl {

struct BookChangesFeed : public SingleFeedBase {
    BookChangesFeed(util::async::AnyExecutionContext& executionCtx)
        : SingleFeedBase(executionCtx, "book_changes")
    {
    }

    void
    pub(xrpl::LedgerHeader const& lgrInfo,
        std::vector<data::TransactionAndMetadata> const& transactions)
    {
        SingleFeedBase::pub(boost::json::serialize(rpc::computeBookChanges(lgrInfo, transactions)));
    }
};
}  // namespace feed::impl