openlimits-messaging 0.1.0

The messaging system of OpenLimits.
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

use cross_test::prelude::*;
use openlimits_messaging::prelude::*;

cross_test_configure!();

pub struct CustomRequester;

#[derive(Debug, PartialEq)]
pub struct CustomRequest {
    valid: bool
}

#[derive(Debug, PartialEq)]
pub struct CustomResponse {
    content: String
}

#[async_trait]
impl Requester for CustomRequester {
    type Request = CustomRequest;
    type Response = CustomResponse;
    type Error = String;
    async fn request(&mut self, request: &Self::Request) -> Result<Self::Response, Self::Error> {
        if request.valid {
            Ok(CustomResponse {
                content: "Valid request.".into()
            })
        } else {
            Err("Invalid request.".into())
        }
    }
}

#[cross_test]
async fn requester() {
    let mut requester = CustomRequester;
    assert_eq!(requester.request(&CustomRequest { valid: true  }).await, Ok(CustomResponse { content: "Valid request.".into() }));
    assert_eq!(requester.request(&CustomRequest { valid: false }).await, Err("Invalid request.".into()));
}