data_source_event_handler.hpp

#pragma once
 
#include <boost/asio/any_io_executor.hpp>
 
#include "data_source_status_manager.hpp"
#include "data_source_update_sink.hpp"
 
#include <launchdarkly/config/shared/built/service_endpoints.hpp>
#include <launchdarkly/context.hpp>
#include <launchdarkly/data/evaluation_result.hpp>
#include <launchdarkly/logging/logger.hpp>
 
namespace launchdarkly::client_side::data_sources {
 
class DataSourceEventHandler {
   public:
    enum class MessageStatus {
        kMessageHandled,
        kInvalidMessage,
        kUnhandledVerb
    };
 
    struct PatchData {
        std::string key;
        EvaluationResult flag;
    };
 
    struct DeleteData {
        std::string key;
        uint64_t version;
    };
 
    DataSourceEventHandler(Context const& context,
                           IDataSourceUpdateSink& handler,
                           Logger const& logger,
                           DataSourceStatusManager& status_manager);
 
    MessageStatus HandleMessage(std::string const& type,
                                std::string const& data);
 
   private:
    IDataSourceUpdateSink& handler_;
    Logger const& logger_;
    DataSourceStatusManager& status_manager_;
    Context context_;
};
}  // namespace launchdarkly::client_side::data_sources