ma_core/
outbox.rs

1//! Transport-agnostic send handle to a remote ma service.
2//!
3//! An `Outbox` wraps the transport details and exposes only
4//! `send()` + `close()`. Created via [`crate::iroh::IrohEndpoint::outbox`].
5//!
6//! `send()` takes a [`Message`], validates it,
7//! serializes to CBOR, and transmits. Malformed or expired messages
8//! are rejected before anything hits the wire.
9//!
10//! Requires the `iroh` feature.
11//!
12//! ```ignore
13//! let mut outbox = ep.outbox("did:ma:456", "ma/presence/0.0.1").await?;
14//! outbox.send(&message).await?;
15//! outbox.close();
16//! ```
17
18use crate::error::Result;
19use crate::iroh::channel::Channel;
20use did_ma::Message;
21
22/// A transport-agnostic write handle to a remote service.
23///
24/// The caller doesn't need to know the underlying transport.
25#[derive(Debug)]
26pub struct Outbox {
27    inner: OutboxTransport,
28    did: String,
29    protocol: String,
30}
31
32#[derive(Debug)]
33enum OutboxTransport {
34    Channel(Channel),
35}
36
37impl Outbox {
38    /// Create an outbox backed by a channel.
39    pub(crate) fn from_channel(channel: Channel, did: String, protocol: String) -> Self {
40        Self {
41            inner: OutboxTransport::Channel(channel),
42            did,
43            protocol,
44        }
45    }
46
47    /// Send a ma message to the remote service.
48    ///
49    /// Validates the message headers, serializes to CBOR, and transmits.
50    pub async fn send(&mut self, message: &Message) -> Result<()> {
51        message.headers().validate()?;
52        let cbor = message.to_cbor()?;
53        match &mut self.inner {
54            OutboxTransport::Channel(channel) => channel.send(&cbor).await,
55        }
56    }
57
58    /// The DID this outbox delivers to.
59    pub fn did(&self) -> &str {
60        &self.did
61    }
62
63    /// The protocol this outbox is connected to.
64    pub fn protocol(&self) -> &str {
65        &self.protocol
66    }
67
68    /// Close the outbox gracefully.
69    pub fn close(self) {
70        match self.inner {
71            OutboxTransport::Channel(channel) => channel.close(),
72        }
73    }
74}
ma_core/outbox.rs

ma_core/
outbox.rs
