wakuwaku 0.2.2

Async backend utilities for RabbitMQ, SQLx, Redis, and pooled resources
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
70
71
72
73
74
75
76
77
78

/// Unified error type used across crate modules.
#[derive(Debug, thiserror::Error)]
pub enum Error {
    #[error("{0}")]
    /// Serialize Error by kanau
    SerializeError(#[from] kanau::message::SerializeError),

    #[error("{0}")]
    /// Deserialize Error
    DeserializeError(#[from] kanau::message::DeserializeError),

    #[cfg(feature = "amqprs")]
    /// AMQP Error
    #[error("{0}")]
    AmqpError(#[from] amqprs::error::Error),

    #[cfg(feature = "redis")]
    /// Redis Error
    #[error("{0}")]
    RedisError(#[from] redis::RedisError),

    #[cfg(feature = "sqlx")]
    #[error("{0}")]
    /// Database Error
    DatabaseError(#[from] sqlx::Error),

    #[error("{0}")]
    /// Error occurred in business logic. This kind of business error can not be solved by retrying.
    BusinessPanic(anyhow::Error),

    #[error("{0}")]
    /// IO Error occurred in business logic. This kind of error can be solved by just retrying.
    Io(anyhow::Error),

    #[error("Permission is not enough")]
    /// Trying to do some operation that requires higher permission
    PermissionsDenied,

    #[error("Invalid input")]
    /// Input payload or arguments are invalid.
    InvalidInput,

    #[error("Trying to access a resource that does not exist")]
    /// Requested resource does not exist.
    NotFound,
}

#[cfg(feature = "tonic")]
impl From<&Error> for tonic::Status {
    fn from(value: &Error) -> Self {
        match value {
            #[cfg(feature = "amqprs")]
            Error::AmqpError(_) => tonic::Status::internal("Internal server error"),

            #[cfg(feature = "redis")]
            Error::RedisError(_) => tonic::Status::internal("Internal server error"),

            #[cfg(feature = "sqlx")]
            Error::DatabaseError(_) => tonic::Status::internal("Database error"),

            Error::Io(_) => tonic::Status::internal("Internal server error"),
            Error::SerializeError(_) | Error::DeserializeError(_) => {
                tonic::Status::invalid_argument(value.to_string())
            }
            Error::BusinessPanic(_) => tonic::Status::internal("Internal server error"),
            Error::PermissionsDenied => tonic::Status::permission_denied("Permission denied"),
            Error::InvalidInput => tonic::Status::invalid_argument("Invalid input"),
            Error::NotFound => tonic::Status::not_found("Not found"),
        }
    }
}

#[cfg(feature = "tonic")]
impl From<Error> for tonic::Status {
    fn from(value: Error) -> Self {
        (&value).into()
    }
}