savon 0.2.0

SOAP async HTTP client generator
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

use crate::gen::{FromElement, ToElements};
use crate::rpser::{Method, Response};
use reqwest::Client;
use std::fmt::Debug;

pub async fn one_way<Input: ToElements>(
    client: &Client,
    base_url: &str,
    ns: &str,
    method: &str,
    input: &Input,
) -> Result<(), crate::Error> {
    let mut v = input.to_elements();
    let mut m = Method::new(method);

    for el in v.drain(..) {
        m = m.with(el);
    }
    let s = m.as_xml(ns);
    trace!("sending: {}", s);

    let response: String = client
        .post(base_url)
        .header("Content-Type", "text/xml")
        .header("MessageType", "Call")
        .body(s)
        .send()
        .await?
        .text()
        .await?;

    trace!("received: {}", response);
    Ok(())
}

pub async fn request_response<Input: ToElements, Output: Debug + FromElement, Error>(
    client: &Client,
    base_url: &str,
    ns: &str,
    method: &str,
    input: &Input,
) -> Result<Result<Output, Error>, crate::Error> {
    let mut v = input.to_elements();
    let mut m = Method::new(method);

    for el in v.drain(..) {
        m = m.with(el);
    }
    let s = m.as_xml(ns);
    trace!("sending: {}", s);

    let response: String = client
        .post(base_url)
        .header("Content-Type", "text/xml")
        .header("MessageType", "Call")
        .body(s)
        .send()
        .await?
        .text()
        .await?;

    trace!("received: {}", response);
    let r = Response::from_xml(&response).unwrap();
    trace!("parsed: {:#?}", r);
    let o = Output::from_element(&r.body);
    trace!("output: {:#?}", o);

    o.map(Ok)
}