haveno 0.1.5

Haveno - secure P2P trading software with Monero integration
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

mod listener;
pub mod router;
pub mod handlers;
pub mod onion_identity;
mod context;

use anyhow::Result;
use std::sync::Arc;
use crate::p2p::router::P2PMessageRouter;
use crate::p2p::listener::P2PListener;
use crate::p2p::handlers::add_data;

/// Initialize and run the P2P layer.
pub async fn setup() -> Result<()> {
    let router = Arc::new(P2PMessageRouter::new());
    let listener = P2PListener::new(3333);

    // ✅ Register handlers
    router.register("AddDataMessage", add_data::AddDataMessageHandler).await;

    // 🚀 Start listener in a background task
    tokio::spawn({
        let router = router.clone();
        async move {
            if let Err(e) = listener.start(router).await {
                eprintln!("🔥 P2P Listener error: {e}");
            }
        }
    });

    Ok(())

}