ForwardingSource.hpp

#pragma once
 
#include "rpc/Errors.hpp"
#include "util/log/Logger.hpp"
#include "util/requests/WsConnection.hpp"
 
#include <boost/asio/spawn.hpp>
#include <boost/json/object.hpp>
 
#include <chrono>
#include <expected>
#include <optional>
#include <string>
#include <string_view>
 
namespace etl::impl {
 
class ForwardingSource {
    util::Logger log_;
    util::requests::WsConnectionBuilder connectionBuilder_;
    std::chrono::steady_clock::duration forwardingTimeout_;
 
    static constexpr std::chrono::seconds kConnectionTimeout{3};
 
public:
    ForwardingSource(
        std::string ip,
        std::string wsPort,
        std::chrono::steady_clock::duration forwardingTimeout,
        std::chrono::steady_clock::duration connTimeout = ForwardingSource::kConnectionTimeout
    );

    [[nodiscard]] std::expected<boost::json::object, rpc::ClioError>
    forwardToRippled(
        boost::json::object const& request,
        std::optional<std::string> const& forwardToRippledClientIp,
        std::string_view xUserValue,
        boost::asio::yield_context yield
    ) const;
};
 
}  // namespace etl::impl