Merge pull request StellarCommons#207 from abdulrcrtw/feat/simulation-network-load

feat(devkit/simulation): NetworkLoadConfig, throughput simulator, capacity pressure, fee curve JSON

Author: Tinna23

packages/core/src/alerts/mod.rs

@@ -64,7 +64,7 @@ impl AlertManager {
                 peak_fee: spike.peak_fee,
                 baseline_fee: spike.baseline_fee,
                 spike_ratio: spike.spike_ratio,
-                start_time: spike.start_time.clone(),
+                start_time: spike.start_time,
                 duration_seconds: spike.duration.num_seconds().max(0),
                 network: self.network.clone(),
                 timestamp: Utc::now(),

packages/core/src/api/fees.rs

@@ -513,6 +513,14 @@ mod tests {
                 p10: "100".into(),
                 p20: "100".into(),
                 p30: "120".into(),
+                p40: "130".into(),
+                p50: "150".into(),
+                p60: "200".into(),
+                p70: "250".into(),
+                p80: "300".into(),
+                p90: "500".into(),
+                p95: "800".into(),
+                p99: "1000".into(),
                 p40: "140".into(),
                 p50: "150".into(),
                 p60: "200".into(),
@@ -537,6 +545,17 @@ mod tests {
             p10: "100".into(),
             p20: "100".into(),
             p30: "120".into(),
+            p40: "130".into(),
+            p50: "150".into(),
+            p60: "200".into(),
+            p70: "250".into(),
+            p80: "300".into(),
+            p90: "500".into(),
+            p95: "800".into(),
+            p99: "1000".into(),
+        };
+        let json = serde_json::to_value(&p).unwrap();
+        for field in &["p10", "p20", "p50", "p80", "p90", "p95"] {
             p40: "140".into(),
             p50: "150".into(),
             p60: "200".into(),

packages/core/src/insights/calculator.rs

@@ -42,6 +42,7 @@ impl<T> CircularBuffer<T> {
 
 /// Calculator for rolling averages across multiple time windows
 pub struct RollingAverageCalculator {
+    #[allow(dead_code)]
     config: AverageConfig,
     windows: HashMap<TimeWindow, CircularBuffer<FeeDataPoint>>,
     time_windows: Vec<TimeWindow>,

packages/core/src/insights/detector.rs

@@ -206,7 +206,7 @@ impl CongestionDetector {
 
         // Sort fees by timestamp to process in chronological order
         let mut sorted_fees = fees.to_vec();
-        sorted_fees.sort_by(|a, b| a.timestamp.cmp(&b.timestamp));
+        sorted_fees.sort_by_key(|a| a.timestamp);
 
         let mut current_spike: Option<FeeSpike> = None;
 

packages/core/src/insights/tests.rs

@@ -39,6 +39,7 @@ mod tests {
             )
     }
 
+    #[allow(dead_code)]
     fn time_window_strategy() -> impl Strategy<Value = TimeWindow> {
         (
             prop::collection::vec("[a-z]+", 1..10).prop_map(|words| words.join("_")),

packages/core/src/repository.rs

@@ -496,6 +496,14 @@ mod tests {
                 p10: "100".into(),
                 p20: "100".into(),
                 p30: "120".into(),
+                p40: "130".into(),
+                p50: "150".into(),
+                p60: "200".into(),
+                p70: "250".into(),
+                p80: "300".into(),
+                p90: "500".into(),
+                p95: "800".into(),
+                p99: "1000".into(),
                 p40: "140".into(),
                 p50: "150".into(),
                 p60: "200".into(),

packages/core/src/scheduler.rs

@@ -98,6 +98,7 @@ pub async fn run_fee_polling_with_retry(
 }
 
 /// Execute a single poll cycle with retry and optional persistence.
+#[allow(clippy::too_many_arguments)]
 async fn poll_once(
     horizon_provider: &Arc<dyn FeeDataProvider + Send + Sync>,
     history_store: &Arc<RwLock<FeeHistoryStore>>,

packages/core/src/services/horizon.rs

@@ -264,6 +264,14 @@ mod tests {
             "p10": "100",
             "p20": "100",
             "p30": "120",
+            "p40": "130",
+            "p50": "150",
+            "p60": "200",
+            "p70": "250",
+            "p80": "300",
+            "p90": "500",
+            "p95": "800",
+            "p99": "1000"
             "p40": "140",
             "p50": "150",
             "p60": "200",
@@ -278,6 +286,8 @@ mod tests {
         assert_eq!(fc.max, "5000");
         assert_eq!(fc.avg, "213");
         assert_eq!(fc.p10, "100");
+        assert_eq!(fc.p50, "150");
+        assert_eq!(fc.p80, "300");
         assert_eq!(fc.p20, "100");
         assert_eq!(fc.p30, "120");
         assert_eq!(fc.p40, "140");
@@ -301,6 +311,14 @@ mod tests {
                 "p10": "100",
                 "p20": "100",
                 "p30": "120",
+                "p40": "130",
+                "p50": "150",
+                "p60": "200",
+                "p70": "250",
+                "p80": "300",
+                "p90": "500",
+                "p95": "800",
+                "p99": "1000"
                 "p40": "140",
                 "p50": "150",
                 "p60": "200",

packages/devkit/Cargo.toml

@@ -6,6 +6,7 @@ description = "Developer toolkit for testing and simulating the Stellar fee trac
 
 [dependencies]
 axum = "0.7"
+serde = { version = "1", features = ["derive"] }
 rand = { version = "0.8", features = ["small_rng"] }
 serde_json = "1"
 thiserror = "1"

packages/devkit/src/simulation/fee_model.rs

@@ -97,6 +97,87 @@ impl FeeModel {
 /// Models for simulating Stellar transaction fee behaviour.
 pub struct FeeModel;
 
+/// A fee curve snapshot matching the Horizon `fee_stats` shape (#119).
+#[derive(Debug, Clone, serde::Serialize, serde::Deserialize)]
+pub struct FeeCurve {
+    pub last_ledger: String,
+    pub last_ledger_base_fee: String,
+    pub ledger_capacity_usage: String,
+    pub fee_charged: FeePercentiles,
+    pub max_fee: FeePercentiles,
+}
+
+#[derive(Debug, Clone, serde::Serialize, serde::Deserialize)]
+pub struct FeePercentiles {
+    pub max: String,
+    pub min: String,
+    pub mode: String,
+    pub p10: String,
+    pub p20: String,
+    pub p30: String,
+    pub p40: String,
+    pub p50: String,
+    pub p60: String,
+    pub p70: String,
+    pub p80: String,
+    pub p90: String,
+    pub p95: String,
+    pub p99: String,
+}
+
+impl FeeModel {
+    /// Generate a `FeeCurve` scaled by `pressure` (0.0–1.0) (#122).
+    ///
+    /// At pressure 0 fees stay at `base_fee`; at pressure 1 they reach `max_fee`.
+    pub fn generate(base_fee: u64, max_fee: u64, pressure: f64, ledger_seq: u64) -> FeeCurve {
+        let pressure = pressure.clamp(0.0, 1.0);
+        let fee = |pct: f64| -> String {
+            let scaled = base_fee as f64 + (max_fee - base_fee) as f64 * pressure * pct;
+            (scaled as u64).to_string()
+        };
+
+        FeeCurve {
+            last_ledger: ledger_seq.to_string(),
+            last_ledger_base_fee: base_fee.to_string(),
+            ledger_capacity_usage: format!("{:.2}", pressure),
+            fee_charged: FeePercentiles {
+                min: base_fee.to_string(),
+                max: fee(1.0),
+                mode: fee(0.6),
+                p10: fee(0.1),
+                p20: fee(0.2),
+                p30: fee(0.3),
+                p40: fee(0.4),
+                p50: fee(0.5),
+                p60: fee(0.6),
+                p70: fee(0.7),
+                p80: fee(0.8),
+                p90: fee(0.9),
+                p95: fee(0.95),
+                p99: fee(0.99),
+            },
+            max_fee: FeePercentiles {
+                min: base_fee.to_string(),
+                max: fee(1.0),
+                mode: fee(0.7),
+                p10: fee(0.15),
+                p20: fee(0.25),
+                p30: fee(0.35),
+                p40: fee(0.45),
+                p50: fee(0.55),
+                p60: fee(0.65),
+                p70: fee(0.75),
+                p80: fee(0.85),
+                p90: fee(0.92),
+                p95: fee(0.97),
+                p99: fee(1.0),
+            },
+        }
+    }
+
+    /// Serialise a `FeeCurve` to a JSON string (#119).
+    pub fn to_json(curve: &FeeCurve) -> Result<String, serde_json::Error> {
+        serde_json::to_string(curve)
 impl FeeModel {
     /// Generate fee points for a single config.
     pub fn generate(config: &FeeModelConfig) -> Vec<FeePoint> {