Exposing ServerConfig options

CHANGELOG.adoc

@@ -15,6 +15,10 @@
 
 https://github.com/oxidecomputer/dropshot/compare/v0.10.0\...HEAD[Full list of commits]
 
+=== Breaking Changes
+
+* https://github.com/oxidecomputer/dropshot/pull/959[#959] expands the settings available via `ConfigDropshot`. This adds two new fields `page_max_nitems` and `page_default_nitems` that will need to be added wherever a `ConfigDropshot` struct is manually constructed.
+
 == 0.10.0 (released 2024-02-06)
 
 https://github.com/oxidecomputer/dropshot/compare/v0.9.0\...v0.10.0[Full list of commits]

dropshot/src/config.rs

@@ -4,6 +4,7 @@
 use serde::Deserialize;
 use serde::Serialize;
 use std::net::SocketAddr;
+use std::num::NonZeroU32;
 use std::path::PathBuf;
 
 /// Raw [`rustls::ServerConfig`] TLS configuration for use with
@@ -49,6 +50,10 @@ pub struct ConfigDropshot {
     pub bind_address: SocketAddr,
     /// maximum allowed size of a request body, defaults to 1024
     pub request_body_max_bytes: usize,
+    /// maximum size of any page of results
+    pub page_max_nitems: NonZeroU32,
+    /// default size for a page of results
+    pub page_default_nitems: NonZeroU32,
     /// Default behavior for HTTP handler functions with respect to clients
     /// disconnecting early.
     pub default_handler_task_mode: HandlerTaskMode,
@@ -106,6 +111,8 @@ impl Default for ConfigDropshot {
         ConfigDropshot {
             bind_address: "127.0.0.1:0".parse().unwrap(),
             request_body_max_bytes: 1024,
+            page_max_nitems: NonZeroU32::new(10000).unwrap(),
+            page_default_nitems: NonZeroU32::new(100).unwrap(),
             default_handler_task_mode: HandlerTaskMode::Detached,
         }
     }

dropshot/src/lib.rs

@@ -49,7 +49,7 @@
 //! use dropshot::ConfigLoggingLevel;
 //! use dropshot::HandlerTaskMode;
 //! use dropshot::HttpServerStarter;
-//! use std::sync::Arc;
+//! use std::{num::NonZeroU32, sync::Arc};
 //!
 //! #[tokio::main]
 //! async fn main() -> Result<(), String> {
@@ -71,6 +71,8 @@
 //!             &ConfigDropshot {
 //!                 bind_address: "127.0.0.1:0".parse().unwrap(),
 //!                 request_body_max_bytes: 1024,
+//!                 page_max_nitems: NonZeroU32::new(10000).unwrap(),
+//!                 page_default_nitems: NonZeroU32::new(100).unwrap(),
 //!                 default_handler_task_mode: HandlerTaskMode::Detached,
 //!             },
 //!             api,

dropshot/src/server.rs

@@ -31,7 +31,6 @@ use std::convert::TryFrom;
 use std::future::Future;
 use std::mem;
 use std::net::SocketAddr;
-use std::num::NonZeroU32;
 use std::panic;
 use std::pin::Pin;
 use std::sync::Arc;
@@ -63,7 +62,7 @@ pub struct DropshotState<C: ServerContext> {
     /// caller-specific state
     pub private: C,
     /// static server configuration parameters
-    pub config: ServerConfig,
+    pub config: ConfigDropshot,
     /// request router
     pub router: HttpRouter<C>,
     /// server-wide log handle
@@ -83,21 +82,6 @@ impl<C: ServerContext> DropshotState<C> {
     }
 }
 
-/// Stores static configuration associated with the server
-/// TODO-cleanup merge with ConfigDropshot
-#[derive(Debug)]
-pub struct ServerConfig {
-    /// maximum allowed size of a request body
-    pub request_body_max_bytes: usize,
-    /// maximum size of any page of results
-    pub page_max_nitems: NonZeroU32,
-    /// default size for a page of results
-    pub page_default_nitems: NonZeroU32,
-    /// Default behavior for HTTP handler functions with respect to clients
-    /// disconnecting early.
-    pub default_handler_task_mode: HandlerTaskMode,
-}
-
 pub struct HttpServerStarter<C: ServerContext> {
     app_state: Arc<DropshotState<C>>,
     local_addr: SocketAddr,
@@ -122,21 +106,12 @@ impl<C: ServerContext> HttpServerStarter<C> {
         log: &Logger,
         tls: Option<ConfigTls>,
     ) -> Result<HttpServerStarter<C>, GenericError> {
-        let server_config = ServerConfig {
-            // We start aggressively to ensure test coverage.
-            request_body_max_bytes: config.request_body_max_bytes,
-            page_max_nitems: NonZeroU32::new(10000).unwrap(),
-            page_default_nitems: NonZeroU32::new(100).unwrap(),
-            default_handler_task_mode: config.default_handler_task_mode,
-        };
-
         let handler_waitgroup = WaitGroup::new();
         let starter = match &tls {
             Some(tls) => {
                 let (starter, app_state, local_addr) =
                     InnerHttpsServerStarter::new(
-                        config,
-                        server_config,
+                        config.clone(),
                         api,
                         private,
                         log,
@@ -153,8 +128,7 @@ impl<C: ServerContext> HttpServerStarter<C> {
             None => {
                 let (starter, app_state, local_addr) =
                     InnerHttpServerStarter::new(
-                        config,
-                        server_config,
+                        config.clone(),
                         api,
                         private,
                         log,
@@ -274,8 +248,7 @@ impl<C: ServerContext> InnerHttpServerStarter<C> {
     /// of `HttpServerStarter` (and await the result) to actually start the
     /// server.
     fn new(
-        config: &ConfigDropshot,
-        server_config: ServerConfig,
+        config: ConfigDropshot,
         api: ApiDescription<C>,
         private: C,
         log: &Logger,
@@ -286,7 +259,7 @@ impl<C: ServerContext> InnerHttpServerStarter<C> {
 
         let app_state = Arc::new(DropshotState {
             private,
-            config: server_config,
+            config,
             router: api.into_router(),
             log: log.new(o!("local_addr" => local_addr)),
             local_addr,
@@ -559,8 +532,7 @@ impl<C: ServerContext> InnerHttpsServerStarter<C> {
     }
 
     fn new(
-        config: &ConfigDropshot,
-        server_config: ServerConfig,
+        config: ConfigDropshot,
         api: ApiDescription<C>,
         private: C,
         log: &Logger,
@@ -587,7 +559,7 @@ impl<C: ServerContext> InnerHttpsServerStarter<C> {
 
         let app_state = Arc::new(DropshotState {
             private,
-            config: server_config,
+            config,
             router: api.into_router(),
             log: logger,
             local_addr,

dropshot/src/test_util.rs

@@ -480,7 +480,7 @@ impl<Context: ServerContext> TestContext<Context> {
     pub fn new(
         api: ApiDescription<Context>,
         private: Context,
-        config_dropshot: &ConfigDropshot,
+        config_dropshot: ConfigDropshot,
         log_context: Option<LogContext>,
         log: Logger,
     ) -> TestContext<Context> {

dropshot/src/websocket.rs

@@ -296,10 +296,10 @@ impl JsonSchema for WebsocketUpgrade {
 mod tests {
     use crate::config::HandlerTaskMode;
     use crate::router::HttpRouter;
-    use crate::server::{DropshotState, ServerConfig};
+    use crate::server::DropshotState;
     use crate::{
-        ExclusiveExtractor, HttpError, RequestContext, RequestInfo,
-        WebsocketUpgrade,
+        ConfigDropshot, ExclusiveExtractor, HttpError, RequestContext,
+        RequestInfo, WebsocketUpgrade,
     };
     use debug_ignore::DebugIgnore;
     use http::Request;
@@ -324,12 +324,13 @@ mod tests {
         let rqctx = RequestContext {
             server: Arc::new(DropshotState {
                 private: (),
-                config: ServerConfig {
+                config: ConfigDropshot {
                     request_body_max_bytes: 0,
                     page_max_nitems: NonZeroU32::new(1).unwrap(),
                     page_default_nitems: NonZeroU32::new(1).unwrap(),
                     default_handler_task_mode:
                         HandlerTaskMode::CancelOnDisconnect,
+                    ..Default::default()
                 },
                 router: HttpRouter::new(),
                 log: log.clone(),

dropshot/tests/common/mod.rs

@@ -39,7 +39,7 @@ pub fn test_setup_with_context<Context: ServerContext>(
 
     let logctx = create_log_context(test_name);
     let log = logctx.log.new(o!());
-    TestContext::new(api, ctx, &config_dropshot, Some(logctx), log)
+    TestContext::new(api, ctx, config_dropshot, Some(logctx), log)
 }
 
 pub fn create_log_context(test_name: &str) -> LogContext {

dropshot/tests/test_config.rs

@@ -111,6 +111,7 @@ fn make_config(
         ),
         request_body_max_bytes: 1024,
         default_handler_task_mode,
+        ..Default::default()
     }
 }
 

dropshot/tests/test_tls.rs

@@ -114,6 +114,7 @@ fn make_server(
         bind_address: "127.0.0.1:0".parse().unwrap(),
         request_body_max_bytes: 1024,
         default_handler_task_mode: HandlerTaskMode::CancelOnDisconnect,
+        ..Default::default()
     };
     let config_tls = Some(ConfigTls::AsFile {
         cert_file: cert_file.to_path_buf(),
@@ -426,6 +427,7 @@ async fn test_server_is_https() {
         bind_address: "127.0.0.1:0".parse().unwrap(),
         request_body_max_bytes: 1024,
         default_handler_task_mode: HandlerTaskMode::CancelOnDisconnect,
+        ..Default::default()
     };
     let config_tls = Some(ConfigTls::AsFile {
         cert_file: cert_file.path().to_path_buf(),