aerro 0.3.0

Cross-service gRPC error framework for Rust.
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

//! `#[derive(aerro::AerroHandler)]` adapter test.

#![cfg(feature = "macro")]

use aerro::{Handler, ServiceFailure, StatusIntoResultExt};

#[derive(Debug, aerro::Aerro)]
pub enum CreateUser {
    #[aerro(
        category = Business,
        code = AlreadyExists,
        error = "email already taken: {email}"
    )]
    EmailTaken { email: String },
}

#[derive(aerro::AerroHandler)]
#[aerro(service = "create-user", rpc = "create", exposure = Public, max_frames = 8)]
struct CreateUserHandler;

impl Handler for CreateUserHandler {
    type Request = String;
    type Response = String;
    type Error = CreateUser;

    async fn handle(&self, req: String) -> Result<String, CreateUser> {
        if req == "alice@x" {
            Err(CreateUser::EmailTaken { email: req })
        } else {
            Ok(format!("ok:{req}"))
        }
    }
}

#[tokio::test]
async fn handler_ok_passes_through() {
    let v = CreateUserHandler.call_tonic("bob".into()).await.unwrap();
    assert_eq!(v, "ok:bob");
}

#[tokio::test]
async fn handler_error_becomes_status_with_envelope() {
    let st = CreateUserHandler
        .call_tonic("alice@x".into())
        .await
        .unwrap_err();
    assert_eq!(st.code(), tonic::Code::AlreadyExists);
    // At Public exposure, frames are dropped but the typed envelope still ships.
    let sf: ServiceFailure<CreateUser> = st.into_aerro::<CreateUser>().unwrap();
    match sf.into_inner() {
        CreateUser::EmailTaken { email } => assert_eq!(email, "alice@x"),
    }
}