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

use async_trait::async_trait;
use anyhow::Result;
use crate::p2p::router::P2PMessageHandler;
use crate::p2p::context::PeerContext;
use crate::generated::io_haveno_protobuffer::network_envelope::Message as EnvMsg;


pub struct AddDataMessageHandler;

#[async_trait]
impl P2PMessageHandler for AddDataMessageHandler {
    async fn handle(&self,ctx: PeerContext) -> Result<()> {
        if let Some(EnvMsg::AddDataMessage(msg)) = ctx.envelope.message {
            println!("📥 [AddDataMessageHandler] Received AddDataMessage: {:#?}", msg);

            // 🔁 Optional: I don't think this message needs a response just remove from persisted storage

        } else {
            println!("⚠️ [AddDataMessageHandler] Unexpected message type.");
        }

        Ok(())
    }
}