iroh-http-core 0.2.1

Iroh QUIC endpoint, HTTP/1.1 over hyper, fetch/serve with FFI-friendly types
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

//! Transport-level events emitted by the endpoint.

use serde::Serialize;

fn now_ms() -> u64 {
    std::time::SystemTime::now()
        .duration_since(std::time::UNIX_EPOCH)
        .unwrap_or_default()
        .as_millis() as u64
}

/// A transport-level event emitted by the endpoint.
///
/// Serialised with serde for the FFI boundary.  Adapters forward these as
/// `CustomEvent('transport', { detail })` on the JS `IrohNode` instance.
#[derive(Debug, Clone, Serialize)]
#[serde(tag = "type", rename_all = "camelCase")]
pub enum TransportEvent {
    #[serde(rename = "pool:hit")]
    PoolHit {
        #[serde(rename = "peerId")]
        peer_id: String,
        timestamp: u64,
    },
    #[serde(rename = "pool:miss")]
    PoolMiss {
        #[serde(rename = "peerId")]
        peer_id: String,
        timestamp: u64,
    },
    #[serde(rename = "pool:evict")]
    PoolEvict {
        #[serde(rename = "peerId")]
        peer_id: String,
        timestamp: u64,
    },
    #[serde(rename = "path:change")]
    PathChange {
        #[serde(rename = "peerId")]
        peer_id: String,
        addr: String,
        relay: bool,
        timestamp: u64,
    },
    #[serde(rename = "handle:sweep")]
    HandleSweep { evicted: u64, timestamp: u64 },
}

impl TransportEvent {
    pub fn pool_hit(peer_id: impl Into<String>) -> Self {
        Self::PoolHit {
            peer_id: peer_id.into(),
            timestamp: now_ms(),
        }
    }
    pub fn pool_miss(peer_id: impl Into<String>) -> Self {
        Self::PoolMiss {
            peer_id: peer_id.into(),
            timestamp: now_ms(),
        }
    }
    pub fn pool_evict(peer_id: impl Into<String>) -> Self {
        Self::PoolEvict {
            peer_id: peer_id.into(),
            timestamp: now_ms(),
        }
    }
    pub fn path_change(peer_id: impl Into<String>, addr: impl Into<String>, relay: bool) -> Self {
        Self::PathChange {
            peer_id: peer_id.into(),
            addr: addr.into(),
            relay,
            timestamp: now_ms(),
        }
    }
    pub fn handle_sweep(evicted: u64) -> Self {
        Self::HandleSweep {
            evicted,
            timestamp: now_ms(),
        }
    }
}