InboundTransactions.h

#pragma once
 
#include <xrpld/overlay/Peer.h>
 
#include <xrpl/basics/base_uint.h>
#include <xrpl/beast/clock/abstract_clock.h>
#include <xrpl/beast/insight/Collector.h>
#include <xrpl/shamap/SHAMap.h>
 
#include <xrpl.pb.h>
 
#include <chrono>
#include <cstdint>
#include <functional>
#include <memory>
 
namespace xrpl {
 
class Application;

 
class InboundTransactions
{
public:
    using ClockType = beast::AbstractClock<std::chrono::steady_clock>;
 
    InboundTransactions() = default;
    InboundTransactions(InboundTransactions const&) = delete;
    InboundTransactions&
    operator=(InboundTransactions const&) = delete;
 
    virtual ~InboundTransactions() = 0;

    virtual std::shared_ptr<SHAMap>
    getSet(UInt256 const& setHash, bool acquire) = 0;

    virtual void
    gotData(
        UInt256 const& setHash,
        std::shared_ptr<Peer> peer,
        std::shared_ptr<protocol::TMLedgerData> message) = 0;

    virtual void
    giveSet(UInt256 const& setHash, std::shared_ptr<SHAMap> const& set, bool acquired) = 0;

    virtual void
    newRound(std::uint32_t seq) = 0;
 
    virtual void
    stop() = 0;
};
 
std::unique_ptr<InboundTransactions>
makeInboundTransactions(
    Application& app,
    beast::insight::Collector::Ptr const& collector,
    std::function<void(std::shared_ptr<SHAMap> const&, bool)> gotSet);
 
}  // namespace xrpl