apollo_config_manager: add acquiring http server dynamic config

Author: Itay-Tsabary-Starkware

Cargo.lock

@@ -17,6 +17,7 @@ apollo_config.workspace = true
 apollo_config_manager_config.workspace = true
 apollo_config_manager_types.workspace = true
 apollo_consensus_config.workspace = true
+apollo_http_server_config.workspace = true
 apollo_infra.workspace = true
 apollo_mempool_config.workspace = true
 apollo_metrics.workspace = true

crates/apollo_config_manager/Cargo.toml

@@ -2,6 +2,7 @@ use apollo_config_manager_config::config::ConfigManagerConfig;
 use apollo_config_manager_types::communication::{ConfigManagerRequest, ConfigManagerResponse};
 use apollo_config_manager_types::config_manager_types::ConfigManagerResult;
 use apollo_consensus_config::config::ConsensusDynamicConfig;
+use apollo_http_server_config::config::HttpServerDynamicConfig;
 use apollo_infra::component_definitions::{ComponentRequestHandler, ComponentStarter};
 use apollo_mempool_config::config::MempoolDynamicConfig;
 use apollo_node_config::node_config::NodeDynamicConfig;
@@ -38,6 +39,12 @@ impl ConfigManager {
         Ok(self.latest_node_dynamic_config.consensus_dynamic_config.as_ref().unwrap().clone())
     }
 
+    pub(crate) fn get_http_server_dynamic_config(
+        &self,
+    ) -> ConfigManagerResult<HttpServerDynamicConfig> {
+        Ok(self.latest_node_dynamic_config.http_server_dynamic_config.as_ref().unwrap().clone())
+    }
+
     pub(crate) fn get_mempool_dynamic_config(&self) -> ConfigManagerResult<MempoolDynamicConfig> {
         Ok(self.latest_node_dynamic_config.mempool_dynamic_config.as_ref().unwrap().clone())
     }
@@ -54,6 +61,11 @@ impl ComponentRequestHandler<ConfigManagerRequest, ConfigManagerResponse> for Co
                     self.get_consensus_dynamic_config(),
                 )
             }
+            ConfigManagerRequest::GetHttpServerDynamicConfig => {
+                ConfigManagerResponse::GetHttpServerDynamicConfig(
+                    self.get_http_server_dynamic_config(),
+                )
+            }
             ConfigManagerRequest::GetMempoolDynamicConfig => {
                 ConfigManagerResponse::GetMempoolDynamicConfig(self.get_mempool_dynamic_config())
             }

crates/apollo_config_manager/src/config_manager.rs

@@ -11,6 +11,7 @@ workspace = true
 
 [dependencies]
 apollo_consensus_config.workspace = true
+apollo_http_server_config.workspace = true
 apollo_infra.workspace = true
 apollo_mempool_config.workspace = true
 apollo_metrics.workspace = true

crates/apollo_config_manager_types/Cargo.toml

@@ -1,6 +1,7 @@
 use std::sync::Arc;
 
 use apollo_consensus_config::config::ConsensusDynamicConfig;
+use apollo_http_server_config::config::HttpServerDynamicConfig;
 use apollo_infra::component_client::{ClientError, LocalComponentClient, RemoteComponentClient};
 use apollo_infra::component_definitions::{ComponentClient, PrioritizedRequest, RequestWrapper};
 use apollo_infra::{impl_debug_for_infra_requests_and_responses, impl_labeled_request};
@@ -32,6 +33,10 @@ pub trait ConfigManagerClient: Send + Sync {
         &self,
     ) -> ConfigManagerClientResult<ConsensusDynamicConfig>;
 
+    async fn get_http_server_dynamic_config(
+        &self,
+    ) -> ConfigManagerClientResult<HttpServerDynamicConfig>;
+
     async fn get_mempool_dynamic_config(&self) -> ConfigManagerClientResult<MempoolDynamicConfig>;
 
     async fn set_node_dynamic_config(
@@ -48,6 +53,7 @@ pub trait ConfigManagerClient: Send + Sync {
 )]
 pub enum ConfigManagerRequest {
     GetConsensusDynamicConfig,
+    GetHttpServerDynamicConfig,
     GetMempoolDynamicConfig,
     SetNodeDynamicConfig(NodeDynamicConfig),
 }
@@ -65,6 +71,7 @@ generate_permutation_labels! {
 #[derive(Clone, Serialize, Deserialize, AsRefStr)]
 pub enum ConfigManagerResponse {
     GetConsensusDynamicConfig(ConfigManagerResult<ConsensusDynamicConfig>),
+    GetHttpServerDynamicConfig(ConfigManagerResult<HttpServerDynamicConfig>),
     GetMempoolDynamicConfig(ConfigManagerResult<MempoolDynamicConfig>),
     SetNodeDynamicConfig(ConfigManagerResult<()>),
 }
@@ -96,6 +103,19 @@ where
         )
     }
 
+    async fn get_http_server_dynamic_config(
+        &self,
+    ) -> ConfigManagerClientResult<HttpServerDynamicConfig> {
+        let request = ConfigManagerRequest::GetHttpServerDynamicConfig;
+        handle_all_response_variants!(
+            ConfigManagerResponse,
+            GetHttpServerDynamicConfig,
+            ConfigManagerClientError,
+            ConfigManagerError,
+            Direct
+        )
+    }
+
     async fn get_mempool_dynamic_config(&self) -> ConfigManagerClientResult<MempoolDynamicConfig> {
         let request = ConfigManagerRequest::GetMempoolDynamicConfig;
         handle_all_response_variants!(