v0.3.7-pre.003

crates/ksp-app-backfill-desk/src/bootstrap.rs

@@ -1,7 +1,7 @@
 // file: crates/ksp-app-backfill-desk/src/bootstrap.rs
-// version: 1
+// version: 2
 
-//! Config and Logging bootstrap for the Backfill Desk scaffold.
+//! Config composite and Logging bootstrap for Backfill Desk.
 
 /// Crate-internal Logging startup state shared by the application state.
 pub(crate) struct LoggingStartup {
@@ -43,7 +43,48 @@ pub(crate) fn config_management(arguments: &[std::ffi::OsString]) -> ksp_core_li
     return std::result::Result::Ok(ksp_config_lib::ConfigManagement::new(engine));
 }
 
-/// Initializes Logging from the standard managed Config document, with the common Desk fallback policy.
+/// Loads the concrete Backfill Desk Config composite using its registered logical `file_id` and autonomous default profile.
+pub(crate) fn load_backfill_desk_composite(management: &ksp_config_lib::ConfigManagement) -> ksp_core_lib::Result<ksp_config_lib::ResolvedConfigComposite> {
+    let file_id = ksp_config_lib::ConfigFileId::new(ksp_config_lib::FILE_ID_COMPOSITE_KSP_APP_BACKFILL_DESK);
+    let file_id = match file_id {
+        std::result::Result::Ok(value) => value,
+        std::result::Result::Err(error) => return std::result::Result::Err(error),
+    };
+    return management.engine().load_resolved_composite(&file_id, std::option::Option::None);
+}
+
+/// Returns one required standard profile from the Backfill Desk composite after validating the referenced logical `file_id`.
+pub(crate) fn required_composite_component_profile(
+    composite: &ksp_config_lib::ResolvedConfigComposite,
+    component_id: &str,
+    expected_file_id: &str,
+) -> ksp_core_lib::Result<ksp_config_lib::ResolvedConfigProfile> {
+    let component = composite.component(component_id);
+    let component = match component {
+        std::option::Option::Some(value) => value,
+        std::option::Option::None => {
+            return std::result::Result::Err(
+                ksp_core_lib::Error::new(crate::ERROR_CODE_CONFIG_COMPOSITE_INVALID, "Backfill Desk composite is missing a required component")
+                    .with_context("composite_file_id", composite.file_id().as_str())
+                    .with_context("composite_profile_id", composite.profile_id())
+                    .with_context("component_id", component_id),
+            );
+        },
+    };
+    if component.resolved().file_id().as_str() != expected_file_id {
+        return std::result::Result::Err(
+            ksp_core_lib::Error::new(crate::ERROR_CODE_CONFIG_COMPOSITE_INVALID, "Backfill Desk composite component references an unexpected Config document")
+                .with_context("composite_file_id", composite.file_id().as_str())
+                .with_context("composite_profile_id", composite.profile_id())
+                .with_context("component_id", component_id)
+                .with_context("expected_file_id", expected_file_id)
+                .with_context("actual_file_id", component.resolved().file_id().as_str()),
+        );
+    }
+    return std::result::Result::Ok(component.resolved().clone());
+}
+
+/// Initializes Logging from the Backfill Desk composite, with a trace-level development fallback.
 pub(crate) fn initialize_logging(
     management: &ksp_config_lib::ConfigManagement,
     runtime_identity: &ksp_logging_lib::LoggingRuntimeIdentity,
@@ -58,7 +99,7 @@ pub(crate) fn initialize_logging(
                         target: crate::TRACING_TARGET,
                         domain = crate::TRACING_DOMAIN_BOOTSTRAP,
                         active_profile = active_profile_id.as_str(),
-                        "initialized Backfill Desk logging from managed configuration"
+                        "initialized Backfill Desk logging from composite-managed configuration"
                     );
                     std::result::Result::Ok(LoggingStartup {
                         guard,
@@ -78,7 +119,7 @@ pub(crate) fn initialize_logging(
 
 fn fallback_logging_settings() -> ksp_logging_lib::LoggingSettings {
     return ksp_logging_lib::LoggingSettings::new(
-        ksp_logging_lib::LogFilterLevel::Info,
+        ksp_logging_lib::LogFilterLevel::Trace,
         ksp_logging_lib::SpanEvents::Off,
         std::option::Option::Some(ksp_logging_lib::ConsoleSettings::stderr()),
         std::vec::Vec::new(),
@@ -91,7 +132,26 @@ fn resolve_logging_startup(management: &ksp_config_lib::ConfigManagement) -> Log
         std::result::Result::Ok(value) => value,
         std::result::Result::Err(error) => return fallback_startup_plan(error),
     };
-    let resolved = management.engine().load_resolved_logging_config(std::option::Option::None, &environment);
+    let composite = crate::load_backfill_desk_composite(management);
+    let composite = match composite {
+        std::result::Result::Ok(value) => value,
+        std::result::Result::Err(error) => return fallback_startup_plan(error),
+    };
+    let logging_profile = crate::required_composite_component_profile(&composite, crate::COMPOSITE_COMPONENT_ID_LOGGING, ksp_config_lib::FILE_ID_STD_LOGGING);
+    let logging_profile = match logging_profile {
+        std::result::Result::Ok(value) => value,
+        std::result::Result::Err(error) => return fallback_startup_plan(error),
+    };
+    let transport_profile =
+        crate::required_composite_component_profile(&composite, crate::COMPOSITE_COMPONENT_ID_TRANSPORT, ksp_config_lib::FILE_ID_STD_TRANSPORT);
+    if let std::result::Result::Err(error) = transport_profile {
+        return fallback_startup_plan(error);
+    }
+    let store_profile = crate::required_composite_component_profile(&composite, crate::COMPOSITE_COMPONENT_ID_STORE, ksp_config_lib::FILE_ID_STD_STORE);
+    if let std::result::Result::Err(error) = store_profile {
+        return fallback_startup_plan(error);
+    }
+    let resolved = management.engine().resolve_logging_config_profile(&logging_profile, &environment);
     let resolved = match resolved {
         std::result::Result::Ok(value) => value,
         std::result::Result::Err(error) => return fallback_startup_plan(error),
@@ -135,7 +195,7 @@ fn initialize_planned_fallback_logging(
         domain = crate::TRACING_DOMAIN_BOOTSTRAP,
         error_domain = diagnostic.domain.as_str(),
         error_code = diagnostic.code.as_str(),
-        "managed Logging configuration is unavailable; using transient in-memory fallback"
+        "managed Logging configuration is unavailable; using transient trace-level development fallback"
     );
     return std::result::Result::Ok(LoggingStartup {
         guard,
@@ -144,3 +204,12 @@ fn initialize_planned_fallback_logging(
         startup_diagnostic: std::option::Option::Some(diagnostic),
     });
 }
+
+#[cfg(test)]
+mod tests {
+    #[test]
+    fn development_fallback_keeps_trace_level_enabled() {
+        let settings = super::fallback_logging_settings();
+        assert_eq!(settings.default_filter(), ksp_logging_lib::LogFilterLevel::Trace);
+    }
+}