homestar-runtime 0.3.0

Homestar runtime implementation
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

//! # Error types involving event handling.

use crate::network::swarm::RequestResponseKey;
use anyhow::Result;
use serde::{Deserialize, Serialize};

/// Error type for messages related to [libp2p::request_response].
#[derive(thiserror::Error, Debug, Serialize, Deserialize)]
pub(crate) enum RequestResponseError {
    /// Return a timeout error when attempting to retrieve data keyed by Cid.
    #[error("failed to retrieve data keyed by cid {}, tagged with {:?}, within timeout", .0.cid, .0.capsule_tag.tag())]
    Timeout(RequestResponseKey),
    /// Error when attempting to wrap a Cid into a Ipld capsule.
    #[error("failed to wrap {} into a Ipld capsule, tagged with {:?}", .0.cid, .0.capsule_tag.tag())]
    InvalidCapsule(RequestResponseKey),
    /// Unsupported message request based on the capsule tag.
    #[error("unsupported message request for tag {:?}, with cid {}", .0.capsule_tag.tag(), .0.cid)]
    Unsupported(RequestResponseKey),
}

impl RequestResponseError {
    /// Encode the error into a byte vector via CBOR.
    ///
    /// [CBOR]: serde_ipld_dagcbor
    pub(crate) fn encode(&self) -> Result<Vec<u8>> {
        serde_ipld_dagcbor::to_vec(self).map_err(anyhow::Error::new)
    }

    /// Decode the error from a byte vector via [CBOR].
    ///
    /// [CBOR]: serde_ipld_dagcbor
    pub(crate) fn decode(bytes: &[u8]) -> Result<(Self, usize)> {
        serde_ipld_dagcbor::from_slice(bytes).map_err(anyhow::Error::new)
    }
}