HandlerProvider.hpp

#pragma once
 
#include "data/AmendmentCenterInterface.hpp"
#include "data/BackendInterface.hpp"
#include "etl/ETLServiceInterface.hpp"
#include "etl/LoadBalancerInterface.hpp"
#include "feed/SubscriptionManagerInterface.hpp"
#include "rpc/common/AnyHandler.hpp"
#include "rpc/common/HandlerProvider.hpp"
#include "rpc/common/Types.hpp"
#include "util/log/Logger.hpp"
 
#include <memory>
#include <optional>
#include <string>
#include <unordered_map>
#include <unordered_set>
 
namespace rpc {
class Counters;
}  // namespace rpc
 
namespace rpc::impl {
 
class ProductionHandlerProvider final : public HandlerProvider {
    struct Handler {
        AnyHandler handler;
        bool isClioOnly = false;
    };
 
    std::unordered_map<std::string, Handler> handlerMap_;
 
public:
    ProductionHandlerProvider(
        util::config::ClioConfigDefinition const& config,
        std::shared_ptr<BackendInterface> const& backend,
        std::shared_ptr<feed::SubscriptionManagerInterface> const& subscriptionManager,
        std::shared_ptr<etl::LoadBalancerInterface> const& balancer,
        std::shared_ptr<etl::ETLServiceInterface const> const& etl,
        std::shared_ptr<data::AmendmentCenterInterface const> const& amendmentCenter,
        Counters const& counters
    );
 
    bool
    contains(std::string const& command) const override;
 
    std::optional<AnyHandler>
    getHandler(std::string const& command) const override;
 
    bool
    isClioOnly(std::string const& command) const override;
 
    std::unordered_set<std::string>
    handlerNames() const;
};
 
}  // namespace rpc::impl