connectrpc 0.1.0

Connect RPC implementation 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
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
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97

use serde::{Deserialize, Serialize};

pub trait EncodeMessage: prost::Message + Serialize {}

impl<T> EncodeMessage for T where T: prost::Message + Serialize {}

pub trait DecodeMessage: prost::Message + for<'de> Deserialize<'de> + Default {}

impl<T> DecodeMessage for T where T: prost::Message + for<'de> Deserialize<'de> + Default {}

/// ConnectCode represents categories of errors as codes.
#[derive(Clone, Copy, Debug, PartialEq, Serialize, Deserialize)]
#[serde(rename_all = "snake_case")]
pub enum ConnectCode {
    /// The operation completed successfully.
    Ok,
    /// The operation was cancelled.
    Canceled,
    /// Unknown error.
    Unknown,
    /// Client specified an invalid argument.
    InvalidArgument,
    /// Deadline expired before operation could complete.
    DeadlineExceeded,
    /// Some requested entity was not found.
    NotFound,
    /// The entity is not in the expected format.
    UnsupportedMediaType,
    /// Some entity that we attempted to create already exists.
    AlreadyExists,
    /// The caller does not have permission to execute the specified operation.
    PermissionDenied,
    /// Some resource has been exhausted.
    ResourceExhausted,
    /// The system is not in a state required for the operation's execution.
    FailedPrecondition,
    /// The operation was aborted.
    Aborted,
    /// Operation was attempted past the valid range.
    OutOfRange,
    /// Operation is not implemented or not supported.
    Unimplemented,
    /// Internal error.
    Internal,
    /// The service is currently unavailable.
    Unavailable,
    /// Unrecoverable data loss or corruption.
    DataLoss,
    /// The request does not have valid authentication credentials
    Unauthenticated,
}

// https://connectrpc.com/docs/protocol/#http-to-error-code
impl From<http::StatusCode> for ConnectCode {
    fn from(code: http::StatusCode) -> Self {
        use http::StatusCode;
        match code {
            StatusCode::BAD_REQUEST => Self::Internal,
            StatusCode::UNAUTHORIZED => Self::Unauthenticated,
            StatusCode::FORBIDDEN => Self::PermissionDenied,
            StatusCode::NOT_FOUND => Self::Unimplemented,
            StatusCode::UNSUPPORTED_MEDIA_TYPE => Self::UnsupportedMediaType,
            StatusCode::NOT_IMPLEMENTED => Self::Unimplemented,
            StatusCode::TOO_MANY_REQUESTS
            | StatusCode::BAD_GATEWAY
            | StatusCode::SERVICE_UNAVAILABLE
            | StatusCode::GATEWAY_TIMEOUT => Self::Unavailable,
            _ => Self::Unknown,
        }
    }
}

impl From<ConnectCode> for http::StatusCode {
    fn from(code: ConnectCode) -> Self {
        use ConnectCode::*;
        match code {
            Ok => http::StatusCode::OK,
            Canceled => http::StatusCode::REQUEST_TIMEOUT,
            Unknown => http::StatusCode::INTERNAL_SERVER_ERROR,
            InvalidArgument => http::StatusCode::BAD_REQUEST,
            DeadlineExceeded => http::StatusCode::GATEWAY_TIMEOUT,
            NotFound => http::StatusCode::NOT_FOUND,
            UnsupportedMediaType => http::StatusCode::UNSUPPORTED_MEDIA_TYPE,
            AlreadyExists => http::StatusCode::CONFLICT,
            PermissionDenied => http::StatusCode::FORBIDDEN,
            ResourceExhausted => http::StatusCode::TOO_MANY_REQUESTS,
            FailedPrecondition => http::StatusCode::PRECONDITION_FAILED,
            Aborted => http::StatusCode::CONFLICT,
            OutOfRange => http::StatusCode::BAD_REQUEST,
            Unimplemented => http::StatusCode::NOT_IMPLEMENTED,
            Internal => http::StatusCode::INTERNAL_SERVER_ERROR,
            Unavailable => http::StatusCode::SERVICE_UNAVAILABLE,
            DataLoss => http::StatusCode::INTERNAL_SERVER_ERROR,
            Unauthenticated => http::StatusCode::UNAUTHORIZED,
        }
    }
}