foxhunt/testing/load/src/lib.rs

//! Common utilities for load testing Trading Service
//!
//! Shared infrastructure for metrics, client connections, and order generation.

use std::sync::atomic::{AtomicU64, Ordering};
use std::time::Duration;
use tonic::transport::Channel;

// gRPC generated code
pub mod trading {
    tonic::include_proto!("trading");
}

pub use trading::trading_service_client::TradingServiceClient;
pub use trading::{OrderSide, OrderType, SubmitOrderRequest};

/// Safe float division with edge case handling
fn safe_div(numerator: f64, denominator: f64) -> f64 {
    if denominator == 0.0 || !denominator.is_finite() || !numerator.is_finite() {
        0.0
    } else {
        #[allow(clippy::float_arithmetic)]
        let result = numerator / denominator;
        if result.is_finite() {
            result
        } else {
            0.0
        }
    }
}

/// Safe float multiplication with edge case handling
fn safe_mul(a: f64, b: f64) -> f64 {
    if !a.is_finite() || !b.is_finite() {
        0.0
    } else {
        #[allow(clippy::float_arithmetic)]
        let result = a * b;
        if result.is_finite() {
            result
        } else {
            0.0
        }
    }
}

/// Safe float addition with edge case handling
fn safe_add(a: f64, b: f64) -> f64 {
    if !a.is_finite() || !b.is_finite() {
        0.0
    } else {
        #[allow(clippy::float_arithmetic)]
        let result = a + b;
        if result.is_finite() {
            result
        } else {
            0.0
        }
    }
}

/// Performance metrics aggregator
#[derive(Debug)]
pub struct PerformanceMetrics {
    pub latencies_ns: Vec<u64>,
    pub successful_orders: AtomicU64,
    pub failed_orders: AtomicU64,
    pub total_orders: AtomicU64,
    pub test_duration: Duration,
}

impl PerformanceMetrics {
    pub fn new() -> Self {
        Self {
            latencies_ns: Vec::new(),
            successful_orders: AtomicU64::new(0),
            failed_orders: AtomicU64::new(0),
            total_orders: AtomicU64::new(0),
            test_duration: Duration::ZERO,
        }
    }

    pub fn record_success(&self, _latency_ns: u64) {
        self.successful_orders.fetch_add(1, Ordering::Relaxed);
        self.total_orders.fetch_add(1, Ordering::Relaxed);
    }

    pub fn record_failure(&self) {
        self.failed_orders.fetch_add(1, Ordering::Relaxed);
        self.total_orders.fetch_add(1, Ordering::Relaxed);
    }

    pub fn calculate_percentiles(mut latencies: Vec<u64>) -> (u64, u64, u64, u64, u64) {
        if latencies.is_empty() {
            return (0, 0, 0, 0, 0);
        }

        latencies.sort_unstable();
        let len = latencies.len();

        let min = latencies[0];
        let p50 = latencies[len / 2];
        let p95_idx = safe_mul(len as f64, 0.95) as usize;
        let p95 = latencies[p95_idx.min(len - 1)];
        let p99_idx = safe_mul(len as f64, 0.99) as usize;
        let p99 = latencies[p99_idx.min(len - 1)];
        let max = latencies[len - 1];

        (min, p50, p95, p99, max)
    }

    pub fn print_summary(&self, latencies: &[u64]) {
        let successful = self.successful_orders.load(Ordering::Relaxed);
        let failed = self.failed_orders.load(Ordering::Relaxed);
        let total = self.total_orders.load(Ordering::Relaxed);

        let success_rate = if total > 0 {
            safe_mul(safe_div(successful as f64, total as f64), 100.0)
        } else {
            0.0
        };

        let throughput = if self.test_duration.as_secs_f64() > 0.0 {
            safe_div(successful as f64, self.test_duration.as_secs_f64())
        } else {
            0.0
        };

        let (min, p50, p95, p99, max) = Self::calculate_percentiles(latencies.to_vec());

        println!("\n╔═══════════════════════════════════════════════════════════╗");
        println!("║           TRADING SERVICE LOAD TEST RESULTS               ║");
        println!("╠═══════════════════════════════════════════════════════════╣");
        println!(
            "║ Test Duration:       {:.2}s",
            self.test_duration.as_secs_f64()
        );
        println!("║ Total Orders:        {}", total);
        println!(
            "║ Successful Orders:   {} ({:.2}%)",
            successful, success_rate
        );
        println!("║ Failed Orders:       {}", failed);
        println!("║ Throughput:          {:.0} orders/sec", throughput);
        println!("╠═══════════════════════════════════════════════════════════╣");
        println!("║                    LATENCY METRICS                        ║");
        println!("╠═══════════════════════════════════════════════════════════╣");
        println!(
            "║ Min Latency:         {:.2}ms ({:.2}μs)",
            safe_div(min as f64, 1_000_000.0),
            safe_div(min as f64, 1_000.0)
        );
        println!(
            "║ P50 Latency:         {:.2}ms ({:.2}μs)",
            safe_div(p50 as f64, 1_000_000.0),
            safe_div(p50 as f64, 1_000.0)
        );
        println!(
            "║ P95 Latency:         {:.2}ms ({:.2}μs)",
            safe_div(p95 as f64, 1_000_000.0),
            safe_div(p95 as f64, 1_000.0)
        );
        println!(
            "║ P99 Latency:         {:.2}ms ({:.2}μs)",
            safe_div(p99 as f64, 1_000_000.0),
            safe_div(p99 as f64, 1_000.0)
        );
        println!(
            "║ Max Latency:         {:.2}ms ({:.2}μs)",
            safe_div(max as f64, 1_000_000.0),
            safe_div(max as f64, 1_000.0)
        );
        println!("╚═══════════════════════════════════════════════════════════╝");

        // Performance assessment
        println!("\n📊 PERFORMANCE ASSESSMENT:");

        if throughput >= 10_000.0 {
            println!(
                "✅ Throughput target ACHIEVED: {:.0} orders/sec (target: 10K orders/sec)",
                throughput
            );
        } else {
            println!(
                "⚠️  Throughput BELOW target: {:.0} orders/sec (target: 10K orders/sec)",
                throughput
            );
        }

        if p99 < 100_000_000 {
            // 100ms in nanoseconds
            println!(
                "✅ P99 latency GOOD: {:.2}ms (< 100ms)",
                safe_div(p99 as f64, 1_000_000.0)
            );
        } else {
            println!(
                "⚠️  P99 latency HIGH: {:.2}ms (> 100ms)",
                safe_div(p99 as f64, 1_000_000.0)
            );
        }

        if success_rate >= 99.0 {
            println!("✅ Success rate EXCELLENT: {:.2}%", success_rate);
        } else if success_rate >= 95.0 {
            println!("⚠️  Success rate ACCEPTABLE: {:.2}%", success_rate);
        } else {
            println!("❌ Success rate POOR: {:.2}%", success_rate);
        }
    }
}

impl Default for PerformanceMetrics {
    fn default() -> Self {
        Self::new()
    }
}

/// Create a test order request
pub fn create_order_request(index: u64) -> SubmitOrderRequest {
    let symbols = ["BTC/USD", "ETH/USD", "SOL/USD", "AVAX/USD", "MATIC/USD"];
    let symbol = symbols[(index % symbols.len() as u64) as usize].to_string();

    SubmitOrderRequest {
        symbol,
        side: if index % 2 == 0 {
            OrderSide::Buy.into()
        } else {
            OrderSide::Sell.into()
        },
        order_type: OrderType::Limit.into(),
        quantity: safe_add(1.0, safe_mul((index % 10) as f64, 0.1)),
        price: Some(safe_add(50000.0, (index % 1000) as f64)),
        stop_price: None,
        account_id: format!("test_account_{}", index % 10),
        metadata: std::collections::HashMap::new(),
    }
}

/// Connect to Trading Service
pub async fn connect_trading_service(
) -> Result<TradingServiceClient<Channel>, Box<dyn std::error::Error>> {
    let endpoint = "http://localhost:50052";
    println!("🔌 Connecting to Trading Service at {}", endpoint);

    let channel = Channel::from_static("http://localhost:50052")
        .connect_timeout(Duration::from_secs(10))
        .timeout(Duration::from_secs(30))
        .connect()
        .await?;

    let client = TradingServiceClient::new(channel);
    println!("✅ Connected successfully");

    Ok(client)
}