saorsa-core 0.20.0

Saorsa - Core P2P networking library with DHT, QUIC transport, and post-quantum cryptography
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

//! Network Integration Layer for DHT v2
//!
//! Bridges DHT operations with saorsa-core transport infrastructure, providing
//! efficient protocol handling, connection management, and network optimization.

use crate::PeerId;
use crate::dht::core_engine::{DhtKey, NodeInfo};
use serde::{Deserialize, Serialize};
use std::time::Duration;

/// DHT protocol messages (peer phonebook only — no data storage)
#[derive(Debug, Clone, Serialize, Deserialize)]
pub enum DhtMessage {
    // Node Discovery
    FindNode { target: DhtKey, count: usize },

    // Network Management
    Ping { timestamp: u64 },
    Join { node_info: NodeInfo },
    Leave { node_id: PeerId },
}

/// DHT protocol responses
#[derive(Debug, Clone, Serialize, Deserialize)]
pub enum DhtResponse {
    // Discovery Responses
    FindNodeReply {
        nodes: Vec<NodeInfo>,
        distances: Vec<u32>,
    },

    // Management Responses
    Pong {
        timestamp: u64,
    },
    JoinAck {
        routing_info: RoutingInfo,
        neighbors: Vec<NodeInfo>,
    },
    LeaveAck {
        confirmed: bool,
    },

    // Error Responses
    Error {
        code: ErrorCode,
        message: String,
        retry_after: Option<Duration>,
    },
}

/// Error codes for DHT operations
#[derive(Debug, Clone, Copy, Serialize, Deserialize)]
pub enum ErrorCode {
    Timeout,
    ConnectionFailed,
    InvalidMessage,
    NodeNotFound,
    Overloaded,
    InternalError,
}

/// Routing information for new nodes
#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct RoutingInfo {
    pub bootstrap_nodes: Vec<NodeInfo>,
    pub network_size: usize,
    pub protocol_version: u32,
}