Refactor mission input types and update WASM interfaces

- Split `PipelineInput` into `MissionInput` and `PipelineInput` to separate core mission fields from nyx-specific fields.
- Update all references to `PipelineInput` in the codebase to use the new `MissionInput` where appropriate.
- Adjust serialization/deserialization logic to accommodate the new structure.
- Modify tests to reflect changes in input types and ensure compatibility with existing functionality.
- Update comments and documentation to clarify the purpose of the new types and their usage.
- Ensure that all WASM bindings are updated to use the new `MissionInput` type instead of `PipelineInput`.

Author: sakobu

.gitignore

@@ -13,6 +13,9 @@
 
 /reports/
 
+# WASM build output
+rpo-wasm/pkg/
+
 # OS
 .DS_Store
 Thumbs.db

README.md

@@ -27,7 +27,7 @@ rpo-nyx (AGPL-3.0)  <--  rpo-cli (AGPL-3.0)
 
 ```bash
 cargo build                     # build workspace
-cargo test                      # 596 tests across 5 crates (564 + 32 ignored full-physics; 596 total with -- --include-ignored)
+cargo test                      # 597 tests across 5 crates (565 + 32 ignored full-physics; 597 total with -- --include-ignored)
 ```
 
 Run an example mission (CLI):
@@ -226,7 +226,7 @@ The CLI provides batch execution and shell-composable plumbing for scripting. Th
 
 ## Testing
 
-596 tests across 5 crates (361 rpo-core, 131 rpo-nyx, 55 rpo-cli, 36 rpo-wasm, 13 rpo-api). 32 full-physics tests are `#[ignore]` by default (require ANISE kernels, ~50 MB cached download).
+597 tests across 5 crates (361 rpo-core, 132 rpo-nyx, 55 rpo-cli, 36 rpo-wasm, 13 rpo-api). 32 full-physics tests are `#[ignore]` by default (require ANISE kernels, ~50 MB cached download).
 
 ```bash
 cargo test                      # full suite (5 crates)

rpo-api/tests/integration.rs

@@ -358,8 +358,8 @@ async fn extract_drag_different_configs() {
     let msg = json!({
         "type": "extract_drag",
         "request_id": 40,
-        "chief": serde_json::to_value(&input.chief).unwrap(),
-        "deputy": serde_json::to_value(&input.deputy).unwrap(),
+        "chief": serde_json::to_value(&input.base.chief).unwrap(),
+        "deputy": serde_json::to_value(&input.base.deputy).unwrap(),
         "chief_config": serde_json::to_value(chief_config).unwrap(),
         "deputy_config": serde_json::to_value(deputy_config).unwrap()
     });
@@ -414,8 +414,8 @@ async fn validate_mission_roundtrip() {
         "type": "validate",
         "request_id": 20,
         "mission": serde_json::to_value(&output.mission).unwrap(),
-        "chief": serde_json::to_value(&input.chief).unwrap(),
-        "deputy": serde_json::to_value(&input.deputy).unwrap(),
+        "chief": serde_json::to_value(&input.base.chief).unwrap(),
+        "deputy": serde_json::to_value(&input.base.deputy).unwrap(),
         "chief_config": serde_json::to_value(chief_config).unwrap(),
         "deputy_config": serde_json::to_value(deputy_config).unwrap(),
         "samples_per_leg": 2
@@ -474,11 +474,11 @@ async fn mc_ensemble_roundtrip() {
         "type": "run_mc",
         "request_id": 30,
         "mission": serde_json::to_value(&output.mission).unwrap(),
-        "chief": serde_json::to_value(&input.chief).unwrap(),
-        "deputy": serde_json::to_value(&input.deputy).unwrap(),
+        "chief": serde_json::to_value(&input.base.chief).unwrap(),
+        "deputy": serde_json::to_value(&input.base.deputy).unwrap(),
         "chief_config": serde_json::to_value(chief_config).unwrap(),
         "deputy_config": serde_json::to_value(deputy_config).unwrap(),
-        "mission_config": serde_json::to_value(&input.config).unwrap(),
+        "mission_config": serde_json::to_value(&input.base.config).unwrap(),
         "propagator": "j2",
         "monte_carlo": {
             "num_samples": 3,
@@ -577,8 +577,8 @@ async fn cancel_active_validation() {
         "type": "validate",
         "request_id": 50,
         "mission": serde_json::to_value(&output.mission).unwrap(),
-        "chief": serde_json::to_value(&input.chief).unwrap(),
-        "deputy": serde_json::to_value(&input.deputy).unwrap(),
+        "chief": serde_json::to_value(&input.base.chief).unwrap(),
+        "deputy": serde_json::to_value(&input.base.deputy).unwrap(),
         "chief_config": serde_json::to_value(chief_config).unwrap(),
         "deputy_config": serde_json::to_value(deputy_config).unwrap(),
         "samples_per_leg": 2
@@ -648,8 +648,8 @@ async fn cancel_active_drag_no_late_result() {
     let drag_msg = json!({
         "type": "extract_drag",
         "request_id": 77,
-        "chief": serde_json::to_value(&input.chief).unwrap(),
-        "deputy": serde_json::to_value(&input.deputy).unwrap(),
+        "chief": serde_json::to_value(&input.base.chief).unwrap(),
+        "deputy": serde_json::to_value(&input.base.deputy).unwrap(),
         "chief_config": serde_json::to_value(chief_config).unwrap(),
         "deputy_config": serde_json::to_value(deputy_config).unwrap()
     });

rpo-cli/src/commands/common.rs

@@ -60,7 +60,7 @@ pub fn plan_with_physics(
     status!(spinner, "Classification + Lambert transfer...");
     let transfer_input = TransferComputationInput::from(input);
     let mut transfer = compute_transfer(&transfer_input)?;
-    let suggestion = suggest_enrichment(&transfer, input);
+    let suggestion = suggest_enrichment(&transfer, &input.base);
     if let Some(ref s) = suggestion {
         apply_perch_enrichment(&mut transfer, s);
     }
@@ -79,7 +79,7 @@ pub fn plan_with_physics(
     )?;
 
     status!(spinner, "Waypoint targeting...");
-    let wp_mission = plan_waypoints_from_transfer(&transfer, input, &propagator)?;
+    let wp_mission = plan_waypoints_from_transfer(&transfer, &input.base, &propagator)?;
 
     Ok(PlannedMission {
         transfer,

rpo-cli/src/commands/mc.rs

@@ -53,13 +53,13 @@ pub fn run(
     };
 
     // Optional covariance propagation
-    let covariance_report = if let Some(ref nav) = input.navigation_accuracy {
+    let covariance_report = if let Some(ref nav) = input.base.navigation_accuracy {
         status!(plan.spinner, "Running covariance propagation...");
         Some(compute_mission_covariance(
             &plan.wp_mission,
             &plan.transfer.plan.chief_at_arrival,
             nav,
-            input.maneuver_uncertainty.as_ref(),
+            input.base.maneuver_uncertainty.as_ref(),
             &plan.propagator,
         )?)
     } else {
@@ -68,8 +68,8 @@ pub fn run(
 
     // Resolve MC dispersions: derive from top-level nav/maneuver if not explicitly set
     let resolved_mc = mc_config.with_resolved_dispersions(
-        input.navigation_accuracy.as_ref(),
-        input.maneuver_uncertainty.as_ref(),
+        input.base.navigation_accuracy.as_ref(),
+        input.base.maneuver_uncertainty.as_ref(),
     );
 
     // Run Monte Carlo
@@ -84,7 +84,7 @@ pub fn run(
         initial_chief: &plan.transfer.perch_chief,
         initial_deputy: &plan.transfer.perch_deputy,
         config: &resolved_mc,
-        mission_config: &input.config,
+        mission_config: &input.base.config,
         chief_config: &chief_config,
         deputy_config: &deputy_config,
         propagator: &plan.propagator,
@@ -105,12 +105,12 @@ pub fn run(
 
     // Build canonical output with nominal safety context (free-drift, POCA).
     let safety = compute_safety_analysis(
-        &plan.wp_mission, input.config.safety.as_ref(), input.cola.as_ref(), &plan.propagator,
+        &plan.wp_mission, input.base.config.safety.as_ref(), input.base.cola.as_ref(), &plan.propagator,
     );
     let mut result = build_output(
         rpo_core::pipeline::BuildOutputCtx {
             transfer: &plan.transfer,
-            input: &input,
+            input: &input.base,
             propagator: &plan.propagator,
             auto_drag: plan.derived_drag,
             suggestion: plan.suggestion,

rpo-cli/src/commands/mission.rs

@@ -26,7 +26,7 @@ pub fn run(
     match mode {
         OutputMode::Json => output_json(&result, output),
         OutputMode::Summary => {
-            let propagator = to_propagation_model(&input.propagator);
+            let propagator = to_propagation_model(&input.base.propagator);
             let md = markdown_fmt::mission_to_markdown(&result, &input, &propagator, false);
             output_text(&md, output)
         }

rpo-cli/src/commands/safety.rs

@@ -18,7 +18,7 @@ pub fn run(input_path: &Path) -> Result<(), CliError> {
     )?;
     let output = execute_mission(&input)?;
 
-    let safety_config = input.config.safety.unwrap_or_default();
+    let safety_config = input.base.config.safety.unwrap_or_default();
     let result = output.mission.safety.as_ref().map(|s| {
         let assessment = assess_safety(s, &safety_config);
         serde_json::json!({

rpo-cli/src/commands/validate.rs

@@ -48,7 +48,7 @@ pub fn run(
 
     // Compute safety analysis and derive COLA burns for nyx injection.
     let (safety, cola_burns) = compute_validation_burns(
-        &plan.wp_mission, input.config.safety.as_ref(), input.cola.as_ref(), &plan.propagator,
+        &plan.wp_mission, input.base.config.safety.as_ref(), input.base.cola.as_ref(), &plan.propagator,
     )?;
 
     status!(
@@ -63,7 +63,7 @@ pub fn run(
     let cola_input = ColaValidationInput {
         burns: cola_burns,
         analytical_maneuvers: safety.cola.clone().unwrap_or_default(),
-        target_distance_km: input.cola.as_ref().map(|c| c.target_distance_km),
+        target_distance_km: input.base.cola.as_ref().map(|c| c.target_distance_km),
     };
 
     let dynamics = build_full_physics_dynamics(&plan.almanac)?;
@@ -86,7 +86,7 @@ pub fn run(
     let result = rpo_core::pipeline::build_output(
         rpo_core::pipeline::BuildOutputCtx {
             transfer: &plan.transfer,
-            input: &input,
+            input: &input.base,
             propagator: &plan.propagator,
             auto_drag: plan.derived_drag,
             suggestion: plan.suggestion,

rpo-cli/src/output/common.rs

@@ -63,7 +63,7 @@ pub struct OverlayFlags {
 pub fn apply_overlays(input: &mut PipelineInput, flags: &OverlayFlags) {
     // COLA overlay
     if let Some(threshold) = flags.cola_threshold {
-        input.cola = Some(ColaConfig {
+        input.base.cola = Some(ColaConfig {
             target_distance_km: threshold,
             max_dv_km_s: flags.cola_budget.unwrap_or(DEFAULT_COLA_BUDGET_KM_S),
         });
@@ -76,7 +76,7 @@ pub fn apply_overlays(input: &mut PipelineInput, flags: &OverlayFlags) {
         (None, false) => None,
     };
     if let Some(min_separation_km) = separation_km {
-        input.safety_requirements = Some(SafetyRequirements {
+        input.base.safety_requirements = Some(SafetyRequirements {
             min_separation_km,
             alignment: EiAlignment::default(),
         });
@@ -231,7 +231,7 @@ pub fn resolve_drag_and_propagator(
     };
     Ok(resolve_propagator(
         auto_drag_config,
-        to_propagation_model(&input.propagator),
+        to_propagation_model(&input.base.propagator),
     ))
 }
 

rpo-cli/src/output/markdown_fmt/mc.rs

@@ -24,7 +24,7 @@ pub fn mc_to_markdown(
     derived_drag: Option<&DragConfig>,
 ) -> String {
     let mut out = String::with_capacity(8192);
-    let sc = input.config.safety.unwrap_or_default();
+    let sc = input.base.config.safety.unwrap_or_default();
     let stats = &report.statistics;
 
     let mc_vr = determine_mc_verdict(report, &sc);
@@ -561,7 +561,7 @@ mod tests {
     /// Regression test for Task 3 of the CLI report audit.
     ///
     /// The MC renderer previously appended [`insights::cola_analytical_miss_insights`]
-    /// to its insight list whenever both `output.safety.cola` and `input.cola`
+    /// to its insight list whenever both `output.safety.cola` and `input.base.cola`
     /// were set. That warning is narratively wrong in `mc.md`: MC samples
     /// propagate the pre-COLA baseline, so a warning *about* the analytical
     /// COLA solver belongs in the mission renderer, not here. This test asserts
@@ -585,10 +585,10 @@ mod tests {
         // actually needs avoidance.
         output.safety.cola = Some(vec![make_subthreshold_maneuver()]);
 
-        // Ensure `input.cola.target_distance_km` is comfortably above the
+        // Ensure `input.base.cola.target_distance_km` is comfortably above the
         // injected 0.050 km post-avoidance POCA so the insight is unambiguously
         // triggered (pre-fix).
-        input.cola = Some(ColaConfig {
+        input.base.cola = Some(ColaConfig {
             target_distance_km: 0.300,
             max_dv_km_s: 0.010,
         });
@@ -724,7 +724,7 @@ mod tests {
             &std::fs::read_to_string(examples_dir().join("mission.json")).unwrap(),
         )
         .unwrap();
-        input.cola = Some(ColaConfig {
+        input.base.cola = Some(ColaConfig {
             target_distance_km: 0.300,
             max_dv_km_s: 0.010,
         });
@@ -887,7 +887,7 @@ mod tests {
         )
         .unwrap();
         // Strip any COLA config so the renderer doesn't inject unrelated callouts.
-        input.cola = None;
+        input.base.cola = None;
 
         let mut output = execute_mission(&input).unwrap();
         output.safety.cola = None;