rrw 0.1.2

A crate to easily build clients for REST-APIs.
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

use rrw::throttle::StupidThrottle;
use rrw::{Error, RestConfigBuilder, RestRequest, StandardRestError};
use rrw_macro::rest;
use serde::{Deserialize, Serialize};

#[derive(Serialize)]
struct LocationQuery {
    query: String,
}

#[derive(Deserialize, Debug, PartialEq, Eq)]
struct Location {
    id: String,
    name: String,
}

#[rest]
impl Bahn {
    async fn location(
        &self,
        location: &LocationQuery,
    ) -> Result<Vec<Location>, Error<StandardRestError>> {
        RestRequest::<&LocationQuery, ()>::get("/locations").query(location)
    }
}

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    env_logger::init();
    // Allow only one request every 10 seconds.
    let config = RestConfigBuilder::new("https://v5.db.transport.rest")
        .throttle(StupidThrottle::new(6.0))
        .build();
    let bahn = Bahn::new(config);
    let berlin = LocationQuery {
        query: "Berlin".to_string(),
    };
    let munich = LocationQuery {
        query: "München".to_string(),
    };

    let results_berlin = bahn.location(&berlin).await?;

    for location in results_berlin {
        println!("{}: {}", location.id, location.name);
    }

    let results_munich = bahn.location(&munich).await?;

    for location in results_munich {
        println!("{}: {}", location.id, location.name);
    }

    Ok(())
}