NetworkValidatedLedgers.hpp

#pragma once
 
#include "etl/NetworkValidatedLedgersInterface.hpp"
 
#include <boost/signals2/connection.hpp>
#include <boost/signals2/signal.hpp>
#include <boost/signals2/variadic_signal.hpp>
 
#include <condition_variable>
#include <cstdint>
#include <memory>
#include <mutex>
#include <optional>
 
namespace etl {

class NetworkValidatedLedgers : public NetworkValidatedLedgersInterface {
    std::optional<uint32_t> latest_;  // currently known latest sequence validated by network
 
    mutable std::mutex mtx_;
    std::condition_variable cv_;
 
    SignalType notificationChannel_;
 
public:
    static std::shared_ptr<NetworkValidatedLedgers>
    makeValidatedLedgers();

    void
    push(uint32_t idx) final;

    std::optional<uint32_t>
    getMostRecent() final;

    bool
    waitUntilValidatedByNetwork(uint32_t sequence, std::optional<uint32_t> maxWaitMs = {}) final;
 
    boost::signals2::scoped_connection
    subscribe(SignalType::slot_type const& subscriber) override;
};
 
}  // namespace etl