threema 0.2.0

A threema.ch api library, based on o3ma
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

pub mod messages;

use crate::Error;
use crate::Result;
use std::sync::Arc;
use webpki::TrustAnchor;

// from https://github.com/threema-ch/threema-android/blob/997fd7baacf314bb0238cca4912bd4d3d28b6886/app/src/main/java/ch/threema/client/ProtocolStrings.java
const API: &str = "https://apip.threema.ch";
const USER_AGENT: &str = "Threema";

include!(concat!(env!("OUT_DIR"), "/src/ca.rs"));

impl From<serde_json::error::Error> for Error {
    fn from(e: serde_json::error::Error) -> Self {
        Self::ParseError(e.to_string())
    }
}

impl From<ureq::Error> for Error {
    fn from(_e: ureq::Error) -> Self {
        Self::RequestError
    }
}

fn tls_config() -> Arc<rustls::ClientConfig> {
    let mut root_store = rustls::RootCertStore::empty();
    root_store.add_server_trust_anchors(webpki_roots::TLS_SERVER_ROOTS.0.iter().map(|ta| {
        rustls::OwnedTrustAnchor::from_subject_spki_name_constraints(
            ta.subject,
            ta.spki,
            ta.name_constraints,
        )
    }));
    root_store.add_server_trust_anchors(webpki::TlsServerTrustAnchors(&THREEMA_CA).0.iter().map(
        |ta| {
            rustls::OwnedTrustAnchor::from_subject_spki_name_constraints(
                ta.subject,
                ta.spki,
                ta.name_constraints,
            )
        },
    ));
    Arc::new(
        rustls::ClientConfig::builder()
            .with_safe_defaults()
            .with_root_certificates(root_store)
            .with_no_client_auth(),
    )
}

fn agent() -> ureq::Agent {
    ureq::AgentBuilder::new().tls_config(tls_config()).build()
}

pub(crate) fn request<R>(path: &str) -> Result<R>
where
    R: serde::de::DeserializeOwned,
{
    let agent = agent();

    let path = API.to_owned() + path;
    let resp = agent
        .get(&path)
        .set("user-agent", USER_AGENT)
        .set("accept", "application/json")
        .call()?;
    Ok(resp.into_json()?)
}