decdn-client 0.1.0

The deCDN client SDK: fetch content-addressed blobs from deCDN nodes, pay per megabyte from a USDC payment pool, and verify every byte as it arrives
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
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87

use super::{ProgressClock, SCRIPT_GIVE_UP, StopPolicy};
use std::sync::Arc;
use tokio::time::{Duration, Instant};

#[test]
fn a_terminal_waits_forever_and_a_script_gives_up_after_ten_minutes() {
    let clock = Arc::new(ProgressClock::new());
    assert_eq!(
        StopPolicy::new(true, None, Arc::clone(&clock)).give_up_after,
        None
    );
    assert_eq!(
        StopPolicy::new(false, None, Arc::clone(&clock)).give_up_after,
        Some(SCRIPT_GIVE_UP)
    );
    let custom = Some(Duration::from_secs(30));
    assert_eq!(
        StopPolicy::new(true, custom, Arc::clone(&clock)).give_up_after,
        custom
    );
    assert_eq!(StopPolicy::new(false, custom, clock).give_up_after, custom);
}

#[tokio::test(start_paused = true)]
async fn it_expires_after_the_limit_with_no_progress() {
    let clock = Arc::new(ProgressClock::new());
    let policy = StopPolicy::new(false, Some(Duration::from_mins(1)), clock);
    let start = Instant::now();
    let gave_up = policy.expired().await;
    assert_eq!(Instant::now() - start, Duration::from_mins(1));
    assert_eq!(gave_up.idle, Duration::from_mins(1));
}

#[tokio::test(start_paused = true)]
async fn progress_pushes_the_deadline_out() {
    let clock = Arc::new(ProgressClock::new());
    let policy = StopPolicy::new(false, Some(Duration::from_mins(1)), Arc::clone(&clock));
    let start = Instant::now();
    let ticker = async {
        tokio::time::sleep(Duration::from_secs(50)).await;
        clock.tick();
    };
    let ((), gave_up) = tokio::join!(ticker, policy.expired());
    assert_eq!(Instant::now() - start, Duration::from_secs(110));
    assert_eq!(gave_up.idle, Duration::from_mins(1));
}

#[tokio::test(start_paused = true)]
async fn a_hold_stops_the_clock_and_its_drop_restarts_the_limit() {
    let clock = Arc::new(ProgressClock::new());
    let policy = StopPolicy::new(false, Some(Duration::from_mins(1)), Arc::clone(&clock));
    let start = Instant::now();
    let holder = async {
        let hold = clock.hold();
        tokio::time::sleep(Duration::from_mins(5)).await;
        drop(hold);
    };
    let ((), gave_up) = tokio::join!(holder, policy.expired());
    assert_eq!(Instant::now() - start, Duration::from_mins(6));
    assert_eq!(gave_up.idle, Duration::from_mins(1));
}

#[test]
fn the_message_names_the_idle_time_and_the_remedy() {
    let gave_up = super::GaveUp {
        idle: Duration::from_mins(10),
    };
    assert_eq!(gave_up.to_string(), "no progress for 10m; rerun to resume");
    let short = super::GaveUp {
        idle: Duration::from_secs(45),
    };
    assert_eq!(short.to_string(), "no progress for 45s; rerun to resume");
}

/// A limit that is not a whole number of minutes prints in seconds, so
/// 90 s never reads as "1m".
#[test]
fn a_limit_between_whole_minutes_prints_in_seconds() {
    let odd = super::GaveUp {
        idle: Duration::from_secs(90),
    };
    assert_eq!(odd.to_string(), "no progress for 90s; rerun to resume");
    let whole = super::GaveUp {
        idle: Duration::from_mins(2),
    };
    assert_eq!(whole.to_string(), "no progress for 2m; rerun to resume");
}