gazelle_api 0.18.0

use crate::prelude::*;
use std::time::{Duration, SystemTime};

const LIMIT_COUNT: usize = 5;
const LIMIT_DURATION: Duration = Duration::from_secs(10);
const LIMIT_DURATION_SHORT: Duration = Duration::from_millis(250);

#[tokio::test]
async fn test_get_wait_duration_empty() {
    // Arrange
    let limiter = RateLimiter::new(LIMIT_COUNT, LIMIT_DURATION);

    // Act
    let wait = limiter.get_wait_duration().await;
    print_duration("Wait", wait);

    // Assert
    assert!(wait.is_none());
}

#[tokio::test]
async fn test_get_wait_duration_available() {
    // Arrange
    let limiter = RateLimiter::new(LIMIT_COUNT, LIMIT_DURATION);
    let now = SystemTime::now();
    {
        let mut requests = limiter.requests.lock().await;
        for _ in 0..(LIMIT_COUNT - 1) {
            requests.push_back(now);
        }
    }

    // Act
    let wait = limiter.get_wait_duration().await;
    print_duration("Wait", wait);

    // Assert
    assert!(wait.is_none());
}

#[tokio::test]
async fn test_get_wait_duration_full() {
    // Arrange
    let limiter = RateLimiter::new(LIMIT_COUNT, LIMIT_DURATION);
    let now = SystemTime::now();
    {
        let mut requests = limiter.requests.lock().await;
        for _ in 0..LIMIT_COUNT {
            requests.push_back(now);
        }
    }

    // Act
    let wait = limiter.get_wait_duration().await;
    print_duration("Wait", wait);

    // Assert
    assert!(wait.is_some());
    assert!(approximately_equals(
        wait.expect("full queue should require wait"),
        LIMIT_DURATION,
        Duration::from_millis(100)
    ));
}

#[tokio::test]
async fn test_execute_available() {
    // Arrange
    let limiter = RateLimiter::new(LIMIT_COUNT, LIMIT_DURATION);
    let now = SystemTime::now();
    {
        let mut requests = limiter.requests.lock().await;
        for _ in 0..(LIMIT_COUNT - 1) {
            requests.push_back(now);
        }
    }

    // Act
    let now = SystemTime::now();
    let wait = limiter.execute().await;
    let elapsed = now.elapsed().expect("elapsed should not fail");
    print_duration("Wait", wait);
    print_duration("Elapsed", Some(elapsed));

    // Assert
    assert!(wait.is_none());
    assert!(approximately_equals(
        elapsed,
        Duration::from_secs(0),
        Duration::from_millis(50)
    ));
}

#[tokio::test]
async fn test_execute_full() {
    // Arrange
    let limiter = RateLimiter::new(LIMIT_COUNT, LIMIT_DURATION_SHORT);
    let now = SystemTime::now();
    {
        let mut requests = limiter.requests.lock().await;
        for _ in 0..LIMIT_COUNT {
            requests.push_back(now);
        }
    }

    // Act
    let now = SystemTime::now();
    let wait = limiter.execute().await;
    let elapsed = now.elapsed().expect("elapsed should not fail");
    print_duration("Wait", wait);
    print_duration("Elapsed", Some(elapsed));

    // Assert
    assert!(wait.is_some());
    assert!(approximately_equals(
        wait.expect("full queue should require wait"),
        LIMIT_DURATION_SHORT,
        Duration::from_millis(50)
    ));
    assert!(approximately_equals(
        elapsed,
        LIMIT_DURATION_SHORT,
        Duration::from_millis(50)
    ));
}

fn approximately_equals(d1: Duration, d2: Duration, tolerance: Duration) -> bool {
    if d1 > d2 {
        d1.checked_sub(d2)
            .expect("subtraction should not underflow")
            <= tolerance
    } else {
        d2.checked_sub(d1)
            .expect("subtraction should not underflow")
            <= tolerance
    }
}

fn print_duration(name: &str, duration: Option<Duration>) {
    if let Some(duration) = duration {
        println!("{name} duration: {:.3} seconds", duration.as_secs_f64());
    } else {
        println!("{name} duration: None");
    }
}

// Edge case tests

#[tokio::test]
async fn test_constructor_initializes_empty_queue() {
    // Arrange & Act
    let limiter = RateLimiter::new(10, Duration::from_secs(60));

    // Assert
    assert!(limiter.requests.lock().await.is_empty());
    assert_eq!(limiter.rate.num, 10);
    assert_eq!(limiter.rate.per, Duration::from_secs(60));
}

#[tokio::test]
async fn test_remove_stale_clears_old_requests() {
    // Arrange
    let limiter = RateLimiter::new(LIMIT_COUNT, Duration::from_millis(50));
    let now = SystemTime::now();
    // Add requests that are already stale
    let old_time = now - Duration::from_millis(100);
    {
        let mut requests = limiter.requests.lock().await;
        for _ in 0..LIMIT_COUNT {
            requests.push_back(old_time);
        }
        assert_eq!(requests.len(), LIMIT_COUNT);
    }

    // Act - get_wait_duration calls remove_stale internally
    let wait = limiter.get_wait_duration().await;

    // Assert - stale requests should be removed, no wait needed
    assert!(wait.is_none());
    assert!(limiter.requests.lock().await.is_empty());
}

#[tokio::test]
async fn test_partial_stale_removal() {
    // Arrange
    let limiter = RateLimiter::new(LIMIT_COUNT, Duration::from_millis(100));
    let now = SystemTime::now();

    // Add some stale and some fresh requests
    let stale_time = now - Duration::from_millis(200);
    {
        let mut requests = limiter.requests.lock().await;
        for _ in 0..3 {
            requests.push_back(stale_time);
        }
        for _ in 0..2 {
            requests.push_back(now);
        }
        assert_eq!(requests.len(), 5);
    }

    // Act
    let wait = limiter.get_wait_duration().await;

    // Assert - stale removed, only fresh remain, under limit so no wait
    assert!(wait.is_none());
    assert_eq!(limiter.requests.lock().await.len(), 2);
}

#[tokio::test]
async fn test_execute_adds_request_to_queue() {
    // Arrange
    let limiter = RateLimiter::new(LIMIT_COUNT, LIMIT_DURATION);
    assert!(limiter.requests.lock().await.is_empty());

    // Act
    limiter.execute().await;

    // Assert
    assert_eq!(limiter.requests.lock().await.len(), 1);
}

#[tokio::test]
async fn test_multiple_executes_fill_queue() {
    // Arrange
    let limiter = RateLimiter::new(LIMIT_COUNT, LIMIT_DURATION);

    // Act
    for _ in 0..(LIMIT_COUNT - 1) {
        limiter.execute().await;
    }

    // Assert - queue should have LIMIT_COUNT - 1 entries
    assert_eq!(limiter.requests.lock().await.len(), LIMIT_COUNT - 1);

    // Act - one more should not require waiting
    let wait = limiter.execute().await;

    // Assert
    assert!(wait.is_none());
    assert_eq!(limiter.requests.lock().await.len(), LIMIT_COUNT);
}