ma-core 0.6.1

DIDComm service library: inboxes, outboxes, DID document publishing, and transport abstraction
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
70
71
72
73
74
75
76
77
78
79

//! DID document resolution traits and implementations.

use async_trait::async_trait;
use did_ma::Document;

/// Trait for resolving a DID to its DID document.
///
/// Ship with `GatewayResolver` for HTTP gateway resolution.
/// Implement this trait for custom resolution strategies.
#[async_trait]
pub trait DidResolver: Send + Sync {
    async fn resolve(&self, did: &str) -> crate::error::Result<Document>;
}

/// Resolves DID documents via an IPFS/IPNS HTTP gateway.
///
/// The gateway must serve DID documents at `/ipns/<key-id>`.
#[cfg(not(target_arch = "wasm32"))]
pub struct GatewayResolver {
    gateway_url: String,
    client: reqwest::Client,
}

#[cfg(not(target_arch = "wasm32"))]
impl GatewayResolver {
    pub fn new(gateway_url: impl Into<String>) -> Self {
        let mut url = gateway_url.into();
        // Ensure trailing slash
        if !url.ends_with('/') {
            url.push('/');
        }
        Self {
            gateway_url: url,
            client: reqwest::Client::builder()
                .timeout(std::time::Duration::from_secs(15))
                .build()
                .expect("failed to build HTTP client"),
        }
    }
}

#[cfg(not(target_arch = "wasm32"))]
#[async_trait]
impl DidResolver for GatewayResolver {
    async fn resolve(&self, did: &str) -> crate::error::Result<Document> {
        let parsed = did_ma::Did::try_from(did).map_err(crate::error::Error::Validation)?;
        let url = format!("{}ipns/{}", self.gateway_url, parsed.ipns);

        let response =
            self.client
                .get(&url)
                .send()
                .await
                .map_err(|e| crate::error::Error::Resolution {
                    did: did.to_string(),
                    detail: e.to_string(),
                })?;

        if !response.status().is_success() {
            return Err(crate::error::Error::Resolution {
                did: did.to_string(),
                detail: format!("gateway returned {}", response.status()),
            });
        }

        let body = response
            .text()
            .await
            .map_err(|e| crate::error::Error::Resolution {
                did: did.to_string(),
                detail: e.to_string(),
            })?;

        Document::unmarshal(&body).map_err(|e| crate::error::Error::Resolution {
            did: did.to_string(),
            detail: e.to_string(),
        })
    }
}