Unsubscribe.hpp

#pragma once
 
#include "feed/SubscriptionManagerInterface.hpp"
#include "feed/Types.hpp"
#include "rpc/common/Types.hpp"
 
#include <rpcspec/HandlerFor.hpp>
#include <rpcspec/handlers/unsubscribe/Types.hpp>
#include <xrpl/protocol/AccountID.h>
 
#include <expected>
#include <memory>
#include <vector>
 
namespace rpc {

 
class UnsubscribeHandler : public rpc::spec::HandlerFor<rpc::spec::handlers::unsubscribe::Input> {
    std::shared_ptr<feed::SubscriptionManagerInterface> subscriptions_;
 
public:
    using OrderBook = rpc::spec::handlers::unsubscribe::OrderBook;

    using StreamType = rpc::spec::handlers::unsubscribe::StreamType;
 
    using Output = VoidOutput;
    using Result = HandlerReturnType<Output>;

    UnsubscribeHandler(std::shared_ptr<feed::SubscriptionManagerInterface> const& subscriptions);

    [[nodiscard]] Result
    process(Input const& input, Context const& ctx) const;
 
private:
    void
    unsubscribeFromStreams(
        std::vector<StreamType> const& streams,
        feed::SubscriberSharedPtr const& session
    ) const;
 
    void
    unsubscribeFromAccounts(
        std::vector<xrpl::AccountID> const& accounts,
        feed::SubscriberSharedPtr const& session
    ) const;
 
    void
    unsubscribeFromProposedAccounts(
        std::vector<xrpl::AccountID> const& accountsProposed,
        feed::SubscriberSharedPtr const& session
    ) const;
 
    void
    unsubscribeFromBooks(
        std::vector<OrderBook> const& books,
        feed::SubscriberSharedPtr const& session
    ) const;
};
 
}  // namespace rpc