rypsok 0.10.0

Headless meta-search service for AI agents, served over the Model Context Protocol
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41

//! Tests of the per-caller invocation limiters.

use std::sync::Arc;

use rypsok_core::limits::Limits;
use rypsok_core::model::CallerId;

use super::CallerLimiters;

/// REQ-SEC-014 (handoff 020j, NET-13): a panic while the callers' lock is
/// held does not make every later call panic: the limiters of a caller seen
/// before the panic are still found, and a new caller gets its own.
#[test]
fn req_sec_014_poisoned_caller_lock_does_not_stop_the_limiters() {
    let limiters = Arc::new(CallerLimiters::new(&Limits::default()));
    let before = limiters.for_caller(&CallerId::local());

    let shared = Arc::clone(&limiters);
    let outcome = std::thread::spawn(move || {
        let _guard = shared.callers.lock().unwrap();
        panic!("poisoning the lock on purpose");
    })
    .join();
    assert!(outcome.is_err());
    assert!(limiters.callers.is_poisoned());

    let after = limiters.for_caller(&CallerId::local());
    assert!(Arc::ptr_eq(&before, &after));
    let other = limiters.for_caller(&CallerId::new("mimlys"));
    assert!(other.search.admit().is_ok());
}

/// A limiter prints its name and nothing of its state (a mutant that printed
/// nothing was missed).
#[test]
fn req_mcp_010_a_limiter_debug_names_the_type_only() {
    assert_eq!(
        format!("{:?}", super::ToolLimiter::per_minute(5)),
        "ToolLimiter"
    );
}