modelpipe 0.3.0

Reach an OpenAI-compatible model server from anywhere over p2p — no VPN, no account, no cloud in the path
Documentation 
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
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61

//! Tests for [`super::Grants`] — a credential that admits once.

use std::time::Duration;

use super::*;

const CODE: &str = "483920";
const LONG: Duration = Duration::from_mins(1);

#[test]
fn a_grant_admits_exactly_once() {
    let grants = Grants::new();
    grants.add(CODE.to_owned(), LONG);
    assert!(
        grants.consume(CODE.as_bytes()),
        "the first presentation admits"
    );
    assert!(
        !grants.consume(CODE.as_bytes()),
        "the second finds nothing to consume"
    );
}

#[test]
fn a_grant_that_was_never_used_still_dies_at_its_deadline() {
    let grants = Grants::new();
    grants.add(CODE.to_owned(), Duration::ZERO);
    assert_eq!(grants.count(), 0, "already past its deadline");
    assert!(!grants.consume(CODE.as_bytes()));
}

#[test]
fn a_wrong_value_consumes_nothing() {
    let grants = Grants::new();
    grants.add(CODE.to_owned(), LONG);
    for wrong in ["483921", "48392", "4839200", "", "Bearer 483920"] {
        assert!(
            !grants.consume(wrong.as_bytes()),
            "{wrong:?} must not admit"
        );
    }
    assert_eq!(grants.count(), 1, "and the real one is still waiting");
}

#[test]
fn two_grants_are_two_admissions() {
    let grants = Grants::new();
    grants.add("first".to_owned(), LONG);
    grants.add("second".to_owned(), LONG);
    assert!(grants.consume(b"second"));
    assert!(grants.consume(b"first"));
    assert_eq!(grants.count(), 0);
}

#[test]
fn the_count_reports_only_live_grants() {
    let grants = Grants::new();
    grants.add("live".to_owned(), LONG);
    grants.add("dead".to_owned(), Duration::ZERO);
    assert_eq!(grants.count(), 1);
}