fedimint-core 0.11.0

fedimint-core provides common code used by both client and server.
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
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
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122

use std::sync::atomic::{AtomicU8, Ordering};
use std::time::Duration;

use anyhow::anyhow;
use assert_matches::assert_matches;
use fedimint_core::runtime::Elapsed;
use futures::FutureExt;

use super::{NextOrPending, SafeUrl, backoff_util, retry};
use crate::runtime::timeout;

#[test]
fn test_safe_url() {
    let test_cases = vec![
        (
            "http://1.2.3.4:80/foo",
            "http://1.2.3.4/foo",
            "SafeUrl(http://1.2.3.4/foo)",
            "http://1.2.3.4/foo",
        ),
        (
            "http://1.2.3.4:81/foo",
            "http://1.2.3.4:81/foo",
            "SafeUrl(http://1.2.3.4:81/foo)",
            "http://1.2.3.4:81/foo",
        ),
        (
            "fedimint://1.2.3.4:1000/foo",
            "fedimint://1.2.3.4:1000/foo",
            "SafeUrl(fedimint://1.2.3.4:1000/foo)",
            "fedimint://1.2.3.4:1000/foo",
        ),
        (
            "fedimint://foo:bar@domain.com:1000/foo",
            "fedimint://REDACTEDUSER:REDACTEDPASS@domain.com:1000/foo",
            "SafeUrl(fedimint://REDACTEDUSER:REDACTEDPASS@domain.com:1000/foo)",
            "fedimint://domain.com:1000/foo",
        ),
        (
            "fedimint://foo@1.2.3.4:1000/foo",
            "fedimint://REDACTEDUSER@1.2.3.4:1000/foo",
            "SafeUrl(fedimint://REDACTEDUSER@1.2.3.4:1000/foo)",
            "fedimint://1.2.3.4:1000/foo",
        ),
    ];

    for (url_str, safe_display_expected, safe_debug_expected, without_auth_expected) in test_cases {
        let safe_url = SafeUrl::parse(url_str).unwrap();

        let safe_display = format!("{safe_url}");
        assert_eq!(
            safe_display, safe_display_expected,
            "Display implementation out of spec"
        );

        let safe_debug = format!("{safe_url:?}");
        assert_eq!(
            safe_debug, safe_debug_expected,
            "Debug implementation out of spec"
        );

        let without_auth = safe_url.without_auth().unwrap();
        assert_eq!(
            without_auth.as_str(),
            without_auth_expected,
            "Without auth implementation out of spec"
        );
    }

    // Exercise `From`-trait via `Into`
    let _: SafeUrl = url::Url::parse("http://1.2.3.4:80/foo").unwrap().into();
}

#[tokio::test]
async fn test_next_or_pending() {
    let mut stream = futures::stream::iter(vec![1, 2]);
    assert_eq!(stream.next_or_pending().now_or_never(), Some(1));
    assert_eq!(stream.next_or_pending().now_or_never(), Some(2));
    assert_matches!(
        timeout(Duration::from_millis(100), stream.next_or_pending()).await,
        Err(Elapsed { .. })
    );
}

#[tokio::test]
async fn retry_succeed_with_one_attempt() {
    let counter = AtomicU8::new(0);
    let closure = || async {
        counter.fetch_add(1, Ordering::SeqCst);
        // Always return a success.
        Ok(42)
    };

    let _ = retry(
        "Run once",
        backoff_util::immediate_backoff(Some(2)),
        closure,
    )
    .await;

    // Ensure the closure was only called once, and no backoff was applied.
    assert_eq!(counter.load(Ordering::SeqCst), 1);
}

#[tokio::test]
async fn retry_fail_with_three_attempts() {
    let counter = AtomicU8::new(0);
    let closure = || async {
        counter.fetch_add(1, Ordering::SeqCst);
        // always fail
        Err::<(), anyhow::Error>(anyhow!("42"))
    };

    let _ = retry(
        "Run 3 times",
        backoff_util::immediate_backoff(Some(2)),
        closure,
    )
    .await;

    assert_eq!(counter.load(Ordering::SeqCst), 3);
}