apollo_storage: impl SerializeConfig for storage reader ServerConfig

Author: nadin-Starkware

crates/apollo_storage/src/storage_reader_server.rs

@@ -1,7 +1,10 @@
+use std::collections::BTreeMap;
 use std::io;
 use std::marker::PhantomData;
 use std::net::SocketAddr;
 
+use apollo_config::dumping::{ser_param, SerializeConfig};
+use apollo_config::{ParamPath, ParamPrivacyInput, SerializedParam};
 use async_trait::async_trait;
 use axum::extract::State;
 use axum::http::StatusCode;
@@ -18,14 +21,13 @@ use crate::{StorageError, StorageReader};
 #[path = "storage_reader_server_test.rs"]
 mod storage_reader_server_test;
 
-// TODO(Nadin): Remove #[allow(dead_code)] once the fields are used in the implementation.
-#[allow(dead_code)]
 /// Configuration for the storage reader server.
+#[derive(Clone, Debug, Serialize, Deserialize, PartialEq)]
 pub struct ServerConfig {
     /// The socket address to bind the server to.
-    socket: SocketAddr,
+    pub socket: SocketAddr,
     /// Whether the server is enabled.
-    enable: bool,
+    pub enable: bool,
 }
 
 impl ServerConfig {
@@ -35,6 +37,34 @@ impl ServerConfig {
     }
 }
 
+impl Default for ServerConfig {
+    fn default() -> Self {
+        Self {
+            socket: "0.0.0.0:8080".parse().expect("Default socket address should be valid"),
+            enable: false,
+        }
+    }
+}
+
+impl SerializeConfig for ServerConfig {
+    fn dump(&self) -> BTreeMap<ParamPath, SerializedParam> {
+        BTreeMap::from_iter([
+            ser_param(
+                "socket",
+                &self.socket.to_string(),
+                "The socket address for the storage reader HTTP server.",
+                ParamPrivacyInput::Public,
+            ),
+            ser_param(
+                "enable",
+                &self.enable,
+                "Whether to enable the storage reader HTTP server.",
+                ParamPrivacyInput::Public,
+            ),
+        ])
+    }
+}
+
 #[async_trait]
 /// Handler trait for processing storage reader requests.
 pub trait StorageReaderServerHandler<Request, Response> {
@@ -157,3 +187,21 @@ impl IntoResponse for StorageServerError {
         (StatusCode::INTERNAL_SERVER_ERROR, error_message).into_response()
     }
 }
+
+pub fn create_storage_reader_server<RequestHandler, Request, Response>(
+    storage_reader: StorageReader,
+    socket: SocketAddr,
+    enable: bool,
+) -> Option<StorageReaderServer<RequestHandler, Request, Response>>
+where
+    RequestHandler: StorageReaderServerHandler<Request, Response>,
+    Request: Serialize + DeserializeOwned + Send + 'static,
+    Response: Serialize + DeserializeOwned + Send + 'static,
+{
+    if enable {
+        let config = ServerConfig::new(socket, enable);
+        Some(StorageReaderServer::new(storage_reader, config))
+    } else {
+        None
+    }
+}